Class | Description |
---|---|
StreamingMultipleProgramsTestBase |
Base class for streaming unit tests that run multiple tests and want to reuse the same
Flink cluster.
|
StreamingProgramTestBase |
Base class for unit tests that run a single test.
|
TestStreamEnvironment |
A
StreamExecutionEnvironment that executes its jobs on LocalFlinkMiniCluster . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.