Package | Description |
---|---|
org.apache.flink.api.common.io | |
org.apache.flink.streaming.api.environment |
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.
|
class |
GlobFilePathFilter
Class for determining if a particular file should be included or excluded
based on a set of include and exclude glob filters.
|
Modifier and Type | Method and Description |
---|---|
static FilePathFilter |
FilePathFilter.createDefaultFilter()
Returns the default filter, which excludes the following files:
Files starting with "_"
Files starting with "."
Files containing the string "_COPYING_"
|
Modifier and Type | Method and Description |
---|---|
void |
FileInputFormat.setFilesFilter(FilePathFilter filesFilter) |
Modifier and Type | Method and Description |
---|---|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat,
String filePath,
FileProcessingMode watchType,
long interval,
FilePathFilter filter)
Deprecated.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.