Package co.decodable.sdk.pipeline.testing

Class KeyedPipelineTestContext

java.lang.Object

co.decodable.sdk.pipeline.testing.KeyedPipelineTestContext

All Implemented Interfaces:

AutoCloseable

public class KeyedPipelineTestContext
extends Object
implements AutoCloseable

Provides access to keyed 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	KeyedPipelineTestContext.ThrowingConsumer<T>	A Consumer variant which allows for declared checked exception types.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	runJobAsync(KeyedPipelineTestContext.ThrowingConsumer<String[]> jobMainMethod, String... args)	Asynchronously executes the given Flink job main method.
KeyedDecodableStream<String,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

KeyedPipelineTestContext

public KeyedPipelineTestContext(TestEnvironment testEnvironment)

Creates a new testing context, using the given TestEnvironment.

Method Details

stream

public KeyedDecodableStream<String,String> stream(String name)

Returns a stream for the given name.

runJobAsync

public void runJobAsync(KeyedPipelineTestContext.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