Uses of Interface
org.apache.drill.exec.store.schedule.CompleteWork

Packages that use CompleteWork

Package	Description
org.apache.drill.exec.store.iceberg
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.schedule

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

Classes in org.apache.drill.exec.store.iceberg that implement CompleteWork

Modifier and Type	Class and Description
class	IcebergCompleteWork

Methods in org.apache.drill.exec.store.iceberg with parameters of type CompleteWork

Modifier and Type	Method and Description
int	IcebergCompleteWork.compareTo(CompleteWork o)

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

Classes in org.apache.drill.exec.store.kafka that implement CompleteWork

Modifier and Type	Class and Description
static class	KafkaGroupScan.PartitionScanWork

Methods in org.apache.drill.exec.store.kafka with parameters of type CompleteWork

Modifier and Type	Method and Description
int	KafkaGroupScan.PartitionScanWork.compareTo(CompleteWork o)

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

Classes in org.apache.drill.exec.store.parquet that implement CompleteWork

Modifier and Type	Class and Description
class	RowGroupInfo

Methods in org.apache.drill.exec.store.parquet with parameters of type CompleteWork

Modifier and Type	Method and Description
int	RowGroupInfo.compareTo(CompleteWork o)

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

Classes in org.apache.drill.exec.store.schedule with type parameters of type CompleteWork

Modifier and Type	Class and Description
class	AssignmentCreator<T extends CompleteWork> Responsible for assigning a set of work units to the available slices.

Classes in org.apache.drill.exec.store.schedule that implement CompleteWork

Modifier and Type	Class and Description
class	CompleteFileWork

Methods in org.apache.drill.exec.store.schedule with type parameters of type CompleteWork

Modifier and Type	Method and Description
static <T extends CompleteWork> List<EndpointAffinity>	AffinityCreator.getAffinityMap(List<T> work)
static <T extends CompleteWork> org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap<Integer,T>	AssignmentCreator.getMappings(List<CoordinationProtos.DrillbitEndpoint> incomingEndpoints, List<T> units) Assign each unit of work to a minor fragment, given that a list of DrillbitEndpoints, whose index in the list correspond to the minor fragment id for each fragment.

Methods in org.apache.drill.exec.store.schedule with parameters of type CompleteWork

Modifier and Type	Method and Description
int	CompleteFileWork.compareTo(CompleteWork o)