Class | Description |
---|---|
LatencyStats |
The
LatencyStats objects are used to track and report on the behavior of latencies across measurements. |
StreamingProgramTestBase |
Base class for unit tests that run a single test.
|
TestStreamEnvironment |
A
StreamExecutionEnvironment that executes its jobs on LocalFlinkMiniCluster . |
Enum | Description |
---|---|
LatencyStats.Granularity |
Granularity for latency metrics.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.