| Modifier and Type | Class and Description |
|---|---|
class |
TableInputFormat<T extends Tuple>
Deprecated.
please use
HBaseInputFormat. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
InputFormat<OT,T extends InputSplit>
The base interface for data sources that produces records.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BinaryInputFormat<T>
Base class for all input formats that use blocks of fixed size.
|
class |
DelimitedInputFormat<OT>
Base implementation for input formats that split the input at a delimiter into records.
|
class |
FileInputFormat<OT>
The base class for
RichInputFormats that read from files. |
class |
GenericCsvInputFormat<OT> |
class |
GenericInputFormat<OT>
Generic base class for all Rich inputs that are not based on files.
|
class |
ReplicatingInputFormat<OT,S extends InputSplit>
A ReplicatingInputFormat replicates any
InputFormat to all parallel instances of a
DataSource, i.e., the full input of the replicated InputFormat is completely processed by each
parallel instance of the DataSource. |
class |
RichInputFormat<OT,T extends InputSplit>
An abstract stub implementation for Rich input formats.
|
class |
SerializedInputFormat<T extends IOReadableWritable>
Reads elements by deserializing them with their regular serialization/deserialization
functionality.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HadoopInputFormatCommonBase<T,SPITTYPE extends InputSplit>
A common base for both "mapred" and "mapreduce" Hadoop input formats.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HadoopInputFormat<K,V>
InputFormat implementation allowing to use Hadoop (mapreduce) InputFormats with Flink.
|
class |
HadoopInputFormatBase<K,V,T>
Base class shared between the Java and Scala API of Flink.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionInputFormat<T>
An input format that returns objects from a collection.
|
class |
CsvInputFormat<OUT>
InputFormat that reads csv files.
|
class |
IteratorInputFormat<T>
An input format that returns objects from an iterator.
|
class |
ParallelIteratorInputFormat<T>
An input format that generates data in parallel through a
SplittableIterator. |
class |
PojoCsvInputFormat<OUT>
Input format that reads csv into POJOs.
|
class |
PrimitiveInputFormat<OT>
An input format that reads single field primitive data from a given file.
|
class |
RowCsvInputFormat
Input format that reads csv into
Row. |
class |
TextInputFormat
Input Format that reads text files.
|
class |
TextValueInputFormat
Input format that reads text files.
|
class |
TupleCsvInputFormat<OUT>
Input format that reads csv into tuples.
|
class |
TypeSerializerInputFormat<T>
Reads elements by deserializing them with a given type serializer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JDBCInputFormat
Deprecated.
Please use
JdbcInputFormat. |
| Modifier and Type | Class and Description |
|---|---|
class |
CassandraInputFormat<OUT extends Tuple>
InputFormat to read data from Apache Cassandra and generate $
Tuple. |
class |
CassandraInputFormatBase<OUT>
Base class for
RichInputFormat to read data from Apache Cassandra and generate a custom
Cassandra annotated object. |
class |
CassandraPojoInputFormat<OUT>
InputFormat to read data from Apache Cassandra and generate a custom Cassandra annotated object.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Generator
InputFormat that generates a deterministic DataSet of Tuple2(String, Integer)
String: key, can be repeated.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseInputFormat<T extends Tuple>
InputFormat subclass that wraps the access for HTables. |
class |
HBaseRowDataInputFormat
InputFormat subclass that wraps the access for HTables. |
class |
HBaseRowInputFormat
InputFormat subclass that wraps the access for HTables. |
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcInputFormat
InputFormat to read data from a database and generate Rows.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcRowDataInputFormat
InputFormat for
JdbcDynamicTableSource. |
| Modifier and Type | Class and Description |
|---|---|
class |
HiveTableFileInputFormat
A
FileInputFormat that wraps a HiveTableInputFormat. |
class |
HiveTableInputFormat
The HiveTableInputFormat are inspired by the HCatInputFormat and HadoopInputFormatBase.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileCopyTaskInputFormat
An implementation of an input format that dynamically assigns
FileCopyTask to the mappers
that have finished previously assigned tasks. |
| Modifier and Type | Class and Description |
|---|---|
class |
AvroInputFormat<E>
Provides a
FileInputFormat for Avro records. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCsvInputFormat<T>
Input format that reads csv.
|
static class |
CsvFileSystemFormatFactory.CsvInputFormat
InputFormat that reads csv record into
RowData. |
| Modifier and Type | Class and Description |
|---|---|
static class |
JsonFileSystemFormatFactory.JsonInputFormat
A
JsonFileSystemFormatFactory.JsonInputFormat is responsible to read RowData records from json format
files. |
| Modifier and Type | Class and Description |
|---|---|
static class |
ParquetFileSystemFormatFactory.ParquetInputFormat
An implementation of
ParquetInputFormat to read RowData records from Parquet
files. |
class |
ParquetInputFormat<E>
The base InputFormat class to read from Parquet files.
|
class |
ParquetMapInputFormat
An implementation of
ParquetInputFormat to read Map records from Parquet files. |
class |
ParquetPojoInputFormat<E>
An implementation of
ParquetInputFormat to read POJO records from Parquet files. |
class |
ParquetRowInputFormat
An implementation of
ParquetInputFormat to read Row records from Parquet files. |
| Modifier and Type | Class and Description |
|---|---|
class |
HCatInputFormatBase<T>
A InputFormat to read from HCatalog tables.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HCatInputFormat<T>
A InputFormat to read from HCatalog tables.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
OrcFileSystemFormatFactory.OrcRowDataInputFormat
An implementation of
FileInputFormat to read RowData records from orc files. |
class |
OrcInputFormat<T>
InputFormat to read ORC files.
|
class |
OrcRowInputFormat
InputFormat to read ORC files into
Row. |
| Modifier and Type | Method and Description |
|---|---|
InputSplitSource<?> |
JobVertex.getInputSplitSource() |
| Modifier and Type | Method and Description |
|---|---|
void |
JobVertex.setInputSplitSource(InputSplitSource<?> inputSplitSource) |
| Modifier and Type | Class and Description |
|---|---|
class |
BroadcastStateInputFormat<K,V>
The input format for reading
BroadcastState. |
class |
KeyedStateInputFormat<K,N,OUT>
Input format for reading partitioned state.
|
class |
ListStateInputFormat<OT>
Input format for reading operator list state.
|
class |
UnionStateInputFormat<OT>
Input format for reading operator union state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ValuesInputFormat
Generated ValuesInputFormat.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TransactionRowInputFormat
An bounded input of transactions.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.