Class | Description |
---|---|
HDFSCopyFromLocal |
Utility for copying from local file system to a HDFS
FileSystem . |
HDFSCopyToLocal |
Utility for copying from a HDFS
FileSystem to the local file system. |
StreamingMultipleProgramsTestBase |
Base class for streaming unit tests that run multiple tests and want to reuse the same
Flink cluster.
|
StreamingProgramTestBase | |
TestStreamEnvironment |
A StreamExecutionEnvironment that executes its jobs on a test cluster.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.