Package | Description |
---|---|
org.apache.flink.addons.hbase | |
org.apache.flink.api.common.io | |
org.apache.flink.api.java.hadoop.mapreduce.wrapper | |
org.apache.flink.core.fs |
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.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.