org.apache.flink.connectors.test.common

Interface TestResource

All Known Subinterfaces:

TestEnvironment

All Known Implementing Classes:

DefaultContainerizedExternalSystem, FlinkContainerTestEnvironment, MiniClusterTestEnvironment, RemoteClusterTestEnvironment

@Experimental
public interface TestResource

Basic abstractions for all resources used in connector testing framework, including TestEnvironment annotated by TestEnv and external system annotated by ExternalSystem.

Lifecycle of test resources will be managed by the framework.

Method Summary

Modifier and Type	Method and Description
void	startUp() Start up the test resource.
void	tearDown() Tear down the test resource.

Method Detail

startUp

void startUp()
      throws Exception

Start up the test resource.

The implementation of this method should be idempotent.

Throws:

Exception - if anything wrong when starting the resource

tearDown

void tearDown()
       throws Exception

Tear down the test resource.

The test resource should be able to tear down even without a startup (could be a no-op).

Throws:

Exception - if anything wrong when tearing the resource down