| 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 |
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>
Wrapper for using HadoopInputFormats (mapred-variant) with Flink.
|
class |
HadoopInputFormatBase<K,V,T>
Common base for Java and Scala API for using Hadoop input formats with Flink.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionInputFormat<T>
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
class |
CsvInputFormat<OUT>
InputFormat that reads csv files.
|
class |
IteratorInputFormat<T>
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
class |
ParallelIteratorInputFormat<T>
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
class |
PojoCsvInputFormat<OUT>
Input format that reads csv into POJOs.
|
class |
PrimitiveInputFormat<OT>
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
class |
TextInputFormat
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
class |
TextValueInputFormat
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
class |
TupleCsvInputFormat<OUT>
Input format that reads csv into tuples.
|
class |
TypeSerializerInputFormat<T>
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a
future Flink major version. You can still build your application in DataSet, but you should
move to either the DataStream and/or Table API.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HiveTableInputFormat
The HiveTableInputFormat are inspired by the HCatInputFormat and HadoopInputFormatBase.
|
| 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.
|
class |
RowCsvInputFormat
Input format that reads csv into
Row. |
| 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–2024 The Apache Software Foundation. All rights reserved.