org.apache.flink.runtime.executiongraph

Class ExecutionJobVertex.PredeterminedInputSplitAssigner

java.lang.Object

org.apache.flink.runtime.executiongraph.ExecutionJobVertex.PredeterminedInputSplitAssigner

All Implemented Interfaces:

InputSplitAssigner

Enclosing class:

ExecutionJobVertex

public static class ExecutionJobVertex.PredeterminedInputSplitAssigner
extends Object
implements InputSplitAssigner

Constructor Summary

Constructors

Constructor and Description
PredeterminedInputSplitAssigner(List<LocatableInputSplit>[] inputSplitsPerSubtask)

Method Summary

Modifier and Type	Method and Description
InputSplit	getNextInputSplit(String host, int taskId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PredeterminedInputSplitAssigner

public PredeterminedInputSplitAssigner(List<LocatableInputSplit>[] inputSplitsPerSubtask)

Method Detail

getNextInputSplit

public InputSplit getNextInputSplit(String host,
                                    int taskId)

Specified by:

getNextInputSplit in interface InputSplitAssigner