com.facebook.presto.spi.connector

Interface ConnectorNodePartitioningProvider

All Known Implementing Classes:

ClassLoaderSafeNodePartitioningProvider

public interface ConnectorNodePartitioningProvider

Method Summary

Modifier and Type	Method and Description
BucketFunction	getBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle, List<Type> partitionChannelTypes, int bucketCount)
Map<Integer,Node>	getBucketToNode(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle)
java.util.function.ToIntFunction<ConnectorSplit>	getSplitBucketFunction(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorPartitioningHandle partitioningHandle)

Method Detail

getBucketToNode

Map<Integer,Node> getBucketToNode(ConnectorTransactionHandle transactionHandle,
                                  ConnectorSession session,
                                  ConnectorPartitioningHandle partitioningHandle)

getSplitBucketFunction

java.util.function.ToIntFunction<ConnectorSplit> getSplitBucketFunction(ConnectorTransactionHandle transactionHandle,
                                                                        ConnectorSession session,
                                                                        ConnectorPartitioningHandle partitioningHandle)

getBucketFunction

BucketFunction getBucketFunction(ConnectorTransactionHandle transactionHandle,
                                 ConnectorSession session,
                                 ConnectorPartitioningHandle partitioningHandle,
                                 List<Type> partitionChannelTypes,
                                 int bucketCount)