Modifier and Type | Method and Description |
---|---|
LocatableInputSplit |
LocatableInputSplitAssigner.getNextInputSplit(String host,
int taskId) |
Constructor and Description |
---|
LocatableInputSplitAssigner(LocatableInputSplit[] splits) |
Constructor and Description |
---|
LocatableInputSplitAssigner(Collection<LocatableInputSplit> splits) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopInputSplit
A wrapper that represents an input split from the Hadoop mapred API as a Flink
InputSplit . |
Modifier and Type | Class and Description |
---|---|
class |
TableInputSplit
This class implements a input splits for HBase.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveTableInputSplit
An wrapper class that wraps info needed for a hadoop input split.
|
Modifier and Type | Class and Description |
---|---|
class |
FileInputSplit
A file input split provides information on a particular part of a file, possibly hosted on a
distributed file system and replicated among several hosts.
|
Modifier and Type | Class and Description |
---|---|
class |
TimestampedFileInputSplit
A
FileInputSplit with TimestampedInputSplit . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.