Class | Description |
---|---|
MiniClusterExtension |
Starts a Flink
MiniCluster and registers the respective ExecutionEnvironment and
StreamExecutionEnvironment in the correct thread local environment. |
Annotation Type | Description |
---|---|
InjectClusterClient |
Annotate a test method parameter with this annotation to inject the
ClusterClient or the
RestClusterClient instance. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.