T
- The type of the input splits created by the source.@Public public interface InputSplitSource<T extends InputSplit> extends Serializable
InputSplit
s that define portions of data to be produced
by InputFormat
s.Modifier and Type | Method and Description |
---|---|
T[] |
createInputSplits(int minNumSplits)
Computes the input splits.
|
InputSplitAssigner |
getInputSplitAssigner(T[] inputSplits)
Returns the assigner for the input splits.
|
T[] createInputSplits(int minNumSplits) throws Exception
minNumSplits
- Number of minimal input splits, as a hint.Exception
- Exceptions when creating the input splits may be forwarded and will cause the
execution to permanently fail.InputSplitAssigner getInputSplitAssigner(T[] inputSplits)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.