Package org.apache.flink.test.junit5
-
Class Summary Class Description MiniClusterExtension Starts a FlinkMiniClusterand registers theStreamExecutionEnvironmentin the correct thread local environment. -
Annotation Types Summary Annotation Type Description InjectClusterClient Annotate a test method parameter with this annotation to inject theClusterClientor theRestClusterClientinstance.