From 0e85913b6cd70f731076f86af1dccc2807d54e3b Mon Sep 17 00:00:00 2001 From: Ramesh Babu Date: Wed, 8 Jun 2022 17:17:01 +0530 Subject: [PATCH 1/4] return ddresses --- .../src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java | 6 ++++++ 1 file changed, 6 insertions(+) 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..b6d23bd6622c 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 @@ -74,4 +74,10 @@ public long getRetainedSizeInBytes() + estimatedSizeOf(addresses, HostAddress::getRetainedSizeInBytes) + serializedPhoenixInputSplit.getRetainedSizeInBytes(); } + + @Override + public Object getInfo() + { + return getAddresses(); + } } From 7d120023b15049a56b9e5ae27602b049abd3e4b2 Mon Sep 17 00:00:00 2001 From: Ramesh Babu Date: Wed, 8 Jun 2022 17:20:04 +0530 Subject: [PATCH 2/4] return addresses --- .../src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java | 1 + 1 file changed, 1 insertion(+) 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 b6d23bd6622c..d2e02e13f472 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 @@ -78,6 +78,7 @@ public long getRetainedSizeInBytes() @Override public Object getInfo() { + //return the addresses return getAddresses(); } } From 459bed4d4b81bffccdfbcbde4b25936e09a1c9c8 Mon Sep 17 00:00:00 2001 From: Ramesh Babu Date: Wed, 8 Jun 2022 20:50:37 +0530 Subject: [PATCH 3/4] return the addresses map --- .../main/java/io/trino/plugin/phoenix/PhoenixSplit.java | 7 +++++-- .../main/java/io/trino/plugin/phoenix5/PhoenixSplit.java | 9 +++++++++ 2 files changed, 14 insertions(+), 2 deletions(-) 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 d2e02e13f472..ad6ae0e5c5f3 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; @@ -78,7 +79,9 @@ public long getRetainedSizeInBytes() @Override public Object getInfo() { - //return the addresses - return getAddresses(); + 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(); + } } From f56ee445c45a9fec3abc80134193992806caa6c1 Mon Sep 17 00:00:00 2001 From: Ramesh Babu Date: Thu, 9 Jun 2022 11:55:09 +0530 Subject: [PATCH 4/4] Fix the style check --- .../src/main/java/io/trino/plugin/phoenix/PhoenixSplit.java | 1 - 1 file changed, 1 deletion(-) 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 ad6ae0e5c5f3..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 @@ -83,5 +83,4 @@ public Object getInfo() .put("addresses", addresses) .buildOrThrow(); } - }