Package | Description |
---|---|
org.apache.flink.streaming.api.environment | |
org.apache.flink.streaming.api.functions.source |
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) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.