public static class DefaultInputConsumableDecider.Factory extends Object implements InputConsumableDecider.Factory
DefaultInputConsumableDecider
.Modifier and Type | Field and Description |
---|---|
static InputConsumableDecider.Factory |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
InputConsumableDecider |
createInstance(SchedulingTopology schedulingTopology,
java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever) |
public static final InputConsumableDecider.Factory INSTANCE
public InputConsumableDecider createInstance(SchedulingTopology schedulingTopology, java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)
createInstance
in interface InputConsumableDecider.Factory
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.