Package org.apache.drill.exec.physical.base

Interface HasAffinity

All Superinterfaces:

GraphValue<PhysicalOperator>, Iterable<PhysicalOperator>, PhysicalOperator

All Known Subinterfaces:

DbGroupScan, FileGroupScan, GroupScan, IndexGroupScan, Store

All Known Implementing Classes:

AbstractDbGroupScan, AbstractFileGroupScan, AbstractGroupScan, AbstractGroupScanWithMetadata, AbstractParquetGroupScan, AbstractStore, DeltaGroupScan, DirectGroupScan, DrillGroupScan, DruidGroupScan, EasyGroupScan, EnumerableGroupScan, GoogleSheetsGroupScan, HBaseGroupScan, HiveDrillNativeParquetScan, HiveScan, HttpGroupScan, IcebergGroupScan, InfoSchemaGroupScan, JdbcGroupScan, KafkaGroupScan, KuduGroupScan, MetadataDirectGroupScan, MockGroupScanPOP, MockStorePOP, MongoGroupScan, OpenTSDBGroupScan, ParquetGroupScan, PhoenixGroupScan, SchemalessScan, Screen, SplunkGroupScan, SystemTableScan

public interface HasAffinity
extends PhysicalOperator

Describes a physical operator that has affinity to particular nodes. Used for assignment decisions.

Method Summary

Modifier and Type	Method	Description
DistributionAffinity	getDistributionAffinity()	Get distribution affinity which describes the parallelization strategy of the operator.
List<EndpointAffinity>	getOperatorAffinity()	Get the list of Endpoints with associated affinities that this operator has preference for.

Methods inherited from interface org.apache.drill.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator

accept, getCost, getInitialAllocation, getMaxAllocation, getNewWithChildren, getOperatorId, getOperatorType, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId

Method Details

getOperatorAffinity

List<EndpointAffinity> getOperatorAffinity()

Get the list of Endpoints with associated affinities that this operator has preference for.

Returns:

List of EndpointAffinity objects.

getDistributionAffinity

DistributionAffinity getDistributionAffinity()

Get distribution affinity which describes the parallelization strategy of the operator.