Uses of Class
org.apache.drill.exec.physical.EndpointAffinity

Packages that use EndpointAffinity

Package	Description
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.config
org.apache.drill.exec.planner.fragment
org.apache.drill.exec.store.dfs.easy
org.apache.drill.exec.store.druid
org.apache.drill.exec.store.hbase
org.apache.drill.exec.store.hive
org.apache.drill.exec.store.iceberg
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kudu
org.apache.drill.exec.store.mapr.db
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.mongo	MongoDB storage plugin.
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.schedule
org.apache.drill.exec.store.sys

Uses of EndpointAffinity in org.apache.drill.exec.physical.base

Methods in org.apache.drill.exec.physical.base that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
protected static List<EndpointAffinity>	AbstractExchange.getDefaultAffinityMap(List<CoordinationProtos.DrillbitEndpoint> fragmentEndpoints) Get a default endpoint affinity map where affinity of a Drillbit is proportional to the number of its occurrences in given endpoint list.
List<EndpointAffinity>	HasAffinity.getOperatorAffinity() Get the list of Endpoints with associated affinities that this operator has preference for.
List<EndpointAffinity>	AbstractGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.physical.config

Methods in org.apache.drill.exec.physical.config that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	Screen.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.planner.fragment

Methods in org.apache.drill.exec.planner.fragment that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
Map<CoordinationProtos.DrillbitEndpoint,EndpointAffinity>	ParallelizationInfo.getEndpointAffinityMap()

Method parameters in org.apache.drill.exec.planner.fragment with type arguments of type EndpointAffinity

Modifier and Type	Method and Description
void	ParallelizationInfo.ParallelizationInfoCollector.addEndpointAffinities(List<EndpointAffinity> endpointAffinities)
void	Stats.addEndpointAffinities(List<EndpointAffinity> endpointAffinityList)
static ParallelizationInfo	ParallelizationInfo.create(int minWidth, int maxWidth, List<EndpointAffinity> endpointAffinities)

Uses of EndpointAffinity in org.apache.drill.exec.store.dfs.easy

Methods in org.apache.drill.exec.store.dfs.easy that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	EasyGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.druid

Methods in org.apache.drill.exec.store.druid that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	DruidGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.hbase

Methods in org.apache.drill.exec.store.hbase that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	HBaseGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.hive

Methods in org.apache.drill.exec.store.hive that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	HiveScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.iceberg

Methods in org.apache.drill.exec.store.iceberg that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	IcebergGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.kafka

Methods in org.apache.drill.exec.store.kafka that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	KafkaGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.kudu

Methods in org.apache.drill.exec.store.kudu that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	KuduGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.mapr.db

Methods in org.apache.drill.exec.store.mapr.db that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	MapRDBGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.mock

Methods in org.apache.drill.exec.store.mock that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	MockStorePOP.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.mongo

Methods in org.apache.drill.exec.store.mongo that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	MongoGroupScan.getOperatorAffinity()

Uses of EndpointAffinity in org.apache.drill.exec.store.parquet

Methods in org.apache.drill.exec.store.parquet that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	AbstractParquetGroupScan.getOperatorAffinity() Calculates the affinity each endpoint has for this scan, by adding up the affinity each endpoint has for each rowGroup.

Uses of EndpointAffinity in org.apache.drill.exec.store.schedule

Methods in org.apache.drill.exec.store.schedule that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
static <T extends CompleteWork> List<EndpointAffinity>	AffinityCreator.getAffinityMap(List<T> work)

Uses of EndpointAffinity in org.apache.drill.exec.store.sys

Methods in org.apache.drill.exec.store.sys that return types with arguments of type EndpointAffinity

Modifier and Type	Method and Description
List<EndpointAffinity>	SystemTableScan.getOperatorAffinity() If distributed, the scan needs to happen on every node.