Interface | Description |
---|---|
ClusterControllable |
Interface for triggering failover in a Flink cluster.
|
TestEnvironment |
Test environment for running Flink jobs.
|
Class | Description |
---|---|
MiniClusterTestEnvironment |
Test environment for running jobs on Flink mini-cluster.
|
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 . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.