Uses of Interface
org.apache.drill.exec.store.schedule.CompleteWork
Packages that use CompleteWork
Package
Description
Kafka storage plugin.
-
Uses of CompleteWork in org.apache.drill.exec.store.iceberg
Classes in org.apache.drill.exec.store.iceberg that implement CompleteWorkMethods in org.apache.drill.exec.store.iceberg with parameters of type CompleteWork -
Uses of CompleteWork in org.apache.drill.exec.store.kafka
Classes in org.apache.drill.exec.store.kafka that implement CompleteWorkMethods in org.apache.drill.exec.store.kafka with parameters of type CompleteWork -
Uses of CompleteWork in org.apache.drill.exec.store.parquet
Classes in org.apache.drill.exec.store.parquet that implement CompleteWorkMethods in org.apache.drill.exec.store.parquet with parameters of type CompleteWork -
Uses of CompleteWork in org.apache.drill.exec.store.schedule
Classes in org.apache.drill.exec.store.schedule with type parameters of type CompleteWorkModifier and TypeClassDescriptionclass
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 CompleteWorkMethods in org.apache.drill.exec.store.schedule with type parameters of type CompleteWorkModifier and TypeMethodDescriptionstatic <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