diff --git a/plugin/trino-phoenix/src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java b/plugin/trino-phoenix/src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java index edf3a6c167ae..b8f1011291db 100644 --- a/plugin/trino-phoenix/src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java +++ b/plugin/trino-phoenix/src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java @@ -16,6 +16,7 @@ import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonProperty; +import com.google.common.collect.ImmutableMap; import io.airlift.slice.SizeOf; import io.trino.plugin.jdbc.JdbcSplit; import io.trino.spi.HostAddress; @@ -74,4 +75,12 @@ public long getRetainedSizeInBytes() + estimatedSizeOf(addresses, HostAddress::getRetainedSizeInBytes) + serializedPhoenixInputSplit.getRetainedSizeInBytes(); } + + @Override + public Object getInfo() + { + return ImmutableMap.builder() + .put("addresses", addresses) + .buildOrThrow(); + } } diff --git a/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixSplit.java b/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixSplit.java index 6ce5ea9c0b4a..6556578b8ea3 100644 --- a/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixSplit.java +++ b/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixSplit.java @@ -16,6 +16,7 @@ import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonProperty; +import com.google.common.collect.ImmutableMap; import io.airlift.slice.SizeOf; import io.trino.plugin.jdbc.JdbcSplit; import io.trino.spi.HostAddress; @@ -74,4 +75,12 @@ public long getRetainedSizeInBytes() + estimatedSizeOf(addresses, HostAddress::getRetainedSizeInBytes) + serializedPhoenixInputSplit.getRetainedSizeInBytes(); } + + @Override + public Object getInfo() + { + return ImmutableMap.builder() + .put("addresses", addresses) + .buildOrThrow(); + } }