org.apache.flink.statefun.flink.harness

Class Harness

java.lang.Object

org.apache.flink.statefun.flink.harness.Harness

public class Harness
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Harness()

Method Summary

Modifier and Type	Method and Description
void	start()
Harness	withConfiguration(java.lang.String key, java.lang.String value) Set a flink-conf configuration.
<T> Harness	withConsumingEgress(EgressIdentifier<T> identifier, SerializableConsumer<T> consumer)
Harness	withFlinkJobName(java.lang.String flinkJobName) Set the name used in the Flink UI.
<T> Harness	withFlinkSourceFunction(IngressIdentifier<T> identifier, org.apache.flink.streaming.api.functions.source.SourceFunction<T> supplier)
Harness	withGlobalConfiguration(java.lang.String key, java.lang.String value) Sets a global configuration available in the StatefulFunctionModule on configure.
Harness	withKryoMessageSerializer()
Harness	withParallelism(int parallelism) Set the desired parallelism.
<T> Harness	withPrintingEgress(EgressIdentifier<T> identifier)
Harness	withSavepointLocation(java.lang.String savepointLocation) Sets the path to the savepoint location to restore from, when this harness starts.
<T> Harness	withSupplyingIngress(IngressIdentifier<T> identifier, SerializableSupplier<T> supplier)

Methods inherited from class java.lang.Object

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

Constructor Detail

Harness

public Harness()

Method Detail

withSupplyingIngress

public <T> Harness withSupplyingIngress(IngressIdentifier<T> identifier,
                                        SerializableSupplier<T> supplier)

withFlinkSourceFunction

public <T> Harness withFlinkSourceFunction(IngressIdentifier<T> identifier,
                                           org.apache.flink.streaming.api.functions.source.SourceFunction<T> supplier)

withConsumingEgress

public <T> Harness withConsumingEgress(EgressIdentifier<T> identifier,
                                       SerializableConsumer<T> consumer)

withPrintingEgress

public <T> Harness withPrintingEgress(EgressIdentifier<T> identifier)

withKryoMessageSerializer

public Harness withKryoMessageSerializer()

withFlinkJobName

public Harness withFlinkJobName(java.lang.String flinkJobName)

Set the name used in the Flink UI.

withConfiguration

public Harness withConfiguration(java.lang.String key,
                                 java.lang.String value)

Set a flink-conf configuration.

withParallelism

public Harness withParallelism(int parallelism)

Set the desired parallelism.

withGlobalConfiguration

public Harness withGlobalConfiguration(java.lang.String key,
                                       java.lang.String value)

Sets a global configuration available in the StatefulFunctionModule on configure.

withSavepointLocation

public Harness withSavepointLocation(java.lang.String savepointLocation)

Sets the path to the savepoint location to restore from, when this harness starts.

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception