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,
FilePathFilter filter)
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,
TypeInformation<OUT> typeInformation)
Reads the contents of the user-specified
filePath based on the given FileInputFormat . |
Modifier and Type | Class and Description |
---|---|
static class |
FilePathFilter.DefaultFilter
The default file path filtering method and is used
if no other such function is provided.
|
Modifier and Type | Method and Description |
---|---|
static FilePathFilter |
FilePathFilter.createDefaultFilter() |
Constructor and Description |
---|
ContinuousFileMonitoringFunction(FileInputFormat<OUT> format,
String path,
FilePathFilter filter,
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)
Reads the contents of the user-specified path based on the given
FileInputFormat . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.