@Experimental public interface TestEnvironment extends TestResource
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
createExecutionEnvironment()
Create a new
StreamExecutionEnvironment for configuring and executing the Flink job. |
startUp, tearDown
StreamExecutionEnvironment createExecutionEnvironment()
StreamExecutionEnvironment
for configuring and executing the Flink job.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.