Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
AbstractTableInputFormat.getInputSplitAssigner(TableInputSplit[] inputSplits) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultInputSplitAssigner
This is the default implementation of the
InputSplitAssigner interface. |
class |
LocatableInputSplitAssigner
The locatable input split assigner assigns to each host splits that are local, before assigning
splits that are not local.
|
class |
ReplicatingInputSplitAssigner
Assigns each InputSplit to each requesting parallel instance.
|
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
ReplicatingInputFormat.getInputSplitAssigner(S[] inputSplits) |
InputSplitAssigner |
InputFormat.getInputSplitAssigner(T[] inputSplits)
Gets the type of the input splits that are processed by this input format.
|
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
HadoopInputFormatBase.getInputSplitAssigner(HadoopInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
HadoopInputFormatBase.getInputSplitAssigner(HadoopInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
JDBCInputFormat.getInputSplitAssigner(InputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
CassandraInputFormatBase.getInputSplitAssigner(InputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
Generator.getInputSplitAssigner(GenericInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
InputSplitSource.getInputSplitAssigner(T[] inputSplits)
Returns the assigner for the input splits.
|
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
FileCopyTaskInputFormat.getInputSplitAssigner(FileCopyTaskInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
HCatInputFormatBase.getInputSplitAssigner(HadoopInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
ExecutionJobVertex.getSplitAssigner() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.