com.facebook.presto.spi

Class ConnectorTableLayout

java.lang.Object

com.facebook.presto.spi.ConnectorTableLayout

public class ConnectorTableLayout
extends Object

Constructor Summary

Constructors

Constructor and Description
ConnectorTableLayout(ConnectorTableLayoutHandle handle)
ConnectorTableLayout(ConnectorTableLayoutHandle handle, Optional<List<ColumnHandle>> columns, TupleDomain<ColumnHandle> predicate, Optional<ConnectorNodePartitioning> nodePartitioning, Optional<Set<ColumnHandle>> streamPartitioningColumns, Optional<DiscretePredicates> discretePredicates, List<LocalProperty<ColumnHandle>> localProperties)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Optional<List<ColumnHandle>>	getColumns() The columns from the original table provided by this layout.
Optional<DiscretePredicates>	getDiscretePredicates() A collection of discrete predicates describing the data in this layout.
ConnectorTableLayoutHandle	getHandle()
List<LocalProperty<ColumnHandle>>	getLocalProperties() Properties describing the layout of the data (grouping/sorting) within each partition
Optional<ConnectorNodePartitioning>	getNodePartitioning() The partitioning of the table across the worker nodes.
TupleDomain<ColumnHandle>	getPredicate() A predicate that describes the universe of data in this layout.
Optional<Set<ColumnHandle>>	getStreamPartitioningColumns() The partitioning for the table streams.
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectorTableLayout

public ConnectorTableLayout(ConnectorTableLayoutHandle handle)

ConnectorTableLayout

public ConnectorTableLayout(ConnectorTableLayoutHandle handle,
                            Optional<List<ColumnHandle>> columns,
                            TupleDomain<ColumnHandle> predicate,
                            Optional<ConnectorNodePartitioning> nodePartitioning,
                            Optional<Set<ColumnHandle>> streamPartitioningColumns,
                            Optional<DiscretePredicates> discretePredicates,
                            List<LocalProperty<ColumnHandle>> localProperties)

Method Detail

getHandle

public ConnectorTableLayoutHandle getHandle()

getColumns

public Optional<List<ColumnHandle>> getColumns()

The columns from the original table provided by this layout. A layout may provide only a subset of columns.

getPredicate

public TupleDomain<ColumnHandle> getPredicate()

A predicate that describes the universe of data in this layout. It may be used by the query engine to infer additional properties and perform further optimizations

getNodePartitioning

public Optional<ConnectorNodePartitioning> getNodePartitioning()

The partitioning of the table across the worker nodes.

If the table is node partitioned, the connector guarantees that each combination of values for the distributed columns will be contained within a single worker.

getStreamPartitioningColumns

public Optional<Set<ColumnHandle>> getStreamPartitioningColumns()

The partitioning for the table streams. If empty, the table layout is partitioned arbitrarily. Otherwise, table steams are partitioned on the given set of columns (or unpartitioned, if the set is empty)

If the table is partitioned, the connector guarantees that each combination of values for the partition columns will be contained within a single split (i.e., partitions cannot straddle multiple splits)

getDiscretePredicates

public Optional<DiscretePredicates> getDiscretePredicates()

A collection of discrete predicates describing the data in this layout. The union of these predicates is expected to be equivalent to the overall predicate returned by getPredicate(). They may be used by the engine for further optimizations.

getLocalProperties

public List<LocalProperty<ColumnHandle>> getLocalProperties()

Properties describing the layout of the data (grouping/sorting) within each partition

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object