Package co.decodable.sdk.pipeline.testing

Class PipelineTestContext

java.lang.Object

co.decodable.sdk.pipeline.testing.PipelineTestContext

All Implemented Interfaces:

AutoCloseable

public class PipelineTestContext
extends Object
implements AutoCloseable

Provides access to Decodable streams during testing as well as the ability to run custom Flink jobs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PipelineTestContext.ThrowingConsumer<T>	A Consumer variant which allows for declared checked exception types.

Constructor Summary

Constructors

Constructor	Description
PipelineTestContext(TestEnvironment testEnvironment)	Creates a new testing context, using the given TestEnvironment.

Method Summary

Modifier and Type	Method	Description
void	close()
void	runJobAsync(PipelineTestContext.ThrowingConsumer<String[]> jobMainMethod, String... args)	Asynchronously executes the given Flink job main method.
DecodableStream<String>	stream(String name)	Returns a stream for the given name.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PipelineTestContext

public PipelineTestContext(TestEnvironment testEnvironment)

Creates a new testing context, using the given TestEnvironment.

Method Details

stream

public DecodableStream<String> stream(String name)

Returns a stream for the given name.

runJobAsync

public void runJobAsync(PipelineTestContext.ThrowingConsumer<String[]> jobMainMethod,
 String... args)
                 throws Exception

Asynchronously executes the given Flink job main method.

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception