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 |
---|---|
DataStream<String> |
StreamExecutionEnvironment.readFileStream(String filePath,
long intervalMillis,
FileMonitoringFunction.WatchType watchType)
Creates a data stream that contains the contents of file created while system watches the given path.
|
Modifier and Type | Method and Description |
---|---|
static FileMonitoringFunction.WatchType |
FileMonitoringFunction.WatchType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FileMonitoringFunction.WatchType[] |
FileMonitoringFunction.WatchType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
FileMonitoringFunction(String path,
long interval,
FileMonitoringFunction.WatchType watchType) |
Modifier and Type | Method and Description |
---|---|
DataStream<String> |
StreamExecutionEnvironment.readFileStream(String StreamPath,
long intervalMillis,
FileMonitoringFunction.WatchType watchType)
Creates a DataStream that contains the contents of file created while
system watches the given path.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.