diff --git a/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorNodePartitioningProvider.java b/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorNodePartitioningProvider.java index 3747bc65efe7..da4b951bd035 100644 --- a/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorNodePartitioningProvider.java +++ b/core/trino-spi/src/main/java/io/trino/spi/connector/ConnectorNodePartitioningProvider.java @@ -20,9 +20,6 @@ public interface ConnectorNodePartitioningProvider { - // TODO: Use ConnectorPartitionHandle (instead of int) to represent individual buckets. - // Currently, it's mixed. listPartitionHandles used CPartitionHandle whereas the other functions used int. - ConnectorBucketNodeMap getBucketNodeMap(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle); ToIntFunction getSplitBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle);