Uses of Interface
org.apache.drill.exec.store.schedule.CompleteWork
Package
Description
Kafka storage plugin.
-
Uses of CompleteWork in org.apache.drill.exec.store.iceberg
-
Uses of CompleteWork in org.apache.drill.exec.store.kafka
-
Uses of CompleteWork in org.apache.drill.exec.store.parquet
-
Uses of CompleteWork in org.apache.drill.exec.store.schedule
Modifier and TypeClassDescriptionclass
AssignmentCreator<T extends CompleteWork>
Responsible for assigning a set of work units to the available slices.Modifier 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.