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) |
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 |
CassandraInputFormatBase.getInputSplitAssigner(InputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
Generator.getInputSplitAssigner(GenericInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
AbstractTableInputFormat.getInputSplitAssigner(TableInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
AbstractTableInputFormat.getInputSplitAssigner(TableInputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
JdbcInputFormat.getInputSplitAssigner(InputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
JdbcRowDataInputFormat.getInputSplitAssigner(InputSplit[] inputSplits) |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
HiveTableInputFormat.getInputSplitAssigner(HiveTableInputSplit[] 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() |
Modifier and Type | Method and Description |
---|---|
InputSplitAssigner |
KeyedStateInputFormat.getInputSplitAssigner(KeyGroupRangeInputSplit[] inputSplits) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.