Class and Description |
---|
ClusterControllable
Interface for triggering failover in a Flink cluster.
|
TestEnvironment
Test environment for running Flink jobs.
|
TestEnvironment.Endpoint
Endpoint with address and port of the test environment.
|
TestEnvironmentSettings
Options for configuring
StreamExecutionEnvironment created by TestEnvironment . |
TestEnvironmentSettings.Builder
Builder class for
TestEnvironmentSettings . |
Class and Description |
---|
ClusterControllable
Interface for triggering failover in a Flink cluster.
|
TestEnvironment
Test environment for running Flink jobs.
|
Class and Description |
---|
TestEnvironment.Endpoint
Endpoint with address and port of the test environment.
|
Class and Description |
---|
ClusterControllable
Interface for triggering failover in a Flink cluster.
|
TestEnvironment
Test environment for running Flink jobs.
|
TestEnvironment.Endpoint
Endpoint with address and port of the test environment.
|
TestEnvironmentSettings
Options for configuring
StreamExecutionEnvironment created by TestEnvironment . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.