diff --git a/src/main/java/org/ebyhr/trino/storage/StorageSplit.java b/src/main/java/org/ebyhr/trino/storage/StorageSplit.java index 74d2a55..969bf81 100644 --- a/src/main/java/org/ebyhr/trino/storage/StorageSplit.java +++ b/src/main/java/org/ebyhr/trino/storage/StorageSplit.java @@ -15,10 +15,12 @@ import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonProperty; +import com.google.common.collect.ImmutableMap; import io.trino.spi.HostAddress; import io.trino.spi.connector.ConnectorSplit; import java.util.List; +import java.util.Map; import static java.util.Objects.requireNonNull; @@ -75,9 +77,13 @@ public List getAddresses() } @Override - public Object getInfo() + public Map getSplitInfo() { - return this; + return ImmutableMap.builder() + .put("mode", mode.name()) + .put("schemaName", schemaName) + .put("tableName", tableName) + .buildOrThrow(); } public enum Mode