Modifier and Type | Class and Description |
---|---|
class |
TableInputSplit
This class implements a input splits for HBase.
|
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 mapreduce API as
a Flink
InputSplit . |
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
An extended
FileInputSplit that also includes information about:
The modification time of the file this split belongs to.
When checkpointing, the state of the split at the moment of the checkpoint.
This class is used by the ContinuousFileMonitoringFunction and the
ContinuousFileReaderOperator to perform continuous file processing. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.