Package | Description |
---|---|
org.apache.flink.streaming.api.environment | |
org.apache.flink.streaming.api.functions.source | |
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
<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 . |
Modifier and Type | Method and Description |
---|---|
static FileProcessingMode |
FileProcessingMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FileProcessingMode[] |
FileProcessingMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
ContinuousFileMonitoringFunction(FileInputFormat<OUT> format,
FileProcessingMode watchType,
int readerParallelism,
long interval) |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamExecutionEnvironment.readFile(FileInputFormat<T> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval,
FilePathFilter filter,
TypeInformation<T> evidence$6)
Deprecated.
Use
FileInputFormat#setFilesFilter(FilePathFilter) to set a filter and
StreamExecutionEnvironment#readFile(FileInputFormat, String, FileProcessingMode, long) |
<T> DataStream<T> |
StreamExecutionEnvironment.readFile(FileInputFormat<T> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval,
TypeInformation<T> evidence$7)
Reads the contents of the user-specified path based on the given
FileInputFormat . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.