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 |
GenericCsvInputFormat<OT> |
class |
SerializedInputFormat<T extends IOReadableWritable>
Reads elements by deserializing them with their regular serialization/deserialization
functionality.
|
Modifier and Type | Method and Description |
---|---|
<X> DataSource<X> |
ExecutionEnvironment.readFile(FileInputFormat<X> inputFormat,
String filePath) |
Modifier and Type | Class and Description |
---|---|
class |
CsvInputFormat<OUT>
InputFormat that reads csv files.
|
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 |
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.
|
Constructor and Description |
---|
InputFormatBasedReader(Path path,
FileInputFormat<T> inputFormat) |
Constructor and Description |
---|
Factory(SerializableSupplierWithException<FileInputFormat<T>,IOException> inputFormatFactory) |
Modifier and Type | Method and Description |
---|---|
static <T> CompactReader.Factory<T> |
FileInputFormatCompactReader.factory(FileInputFormat<T> format) |
Modifier and Type | Class and Description |
---|---|
class |
HiveTableFileInputFormat
A
FileInputFormat that wraps a HiveTableInputFormat . |
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 | Method and Description |
---|---|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat,
String filePath)
Reads the contents of the user-specified
filePath based on the given FileInputFormat . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval)
Reads the contents of the user-specified
filePath based on the given FileInputFormat . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval,
FilePathFilter filter)
Deprecated.
|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval,
TypeInformation<OUT> typeInformation)
Reads the contents of the user-specified
filePath based on the given FileInputFormat . |
Constructor and Description |
---|
ContinuousFileMonitoringFunction(FileInputFormat<OUT> format,
FileProcessingMode watchType,
int readerParallelism,
long interval) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.