public class Harness
extends java.lang.Object
Constructor and Description |
---|
Harness() |
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() |
<T> Harness |
withPrintingEgress(EgressIdentifier<T> identifier) |
<T> Harness |
withSupplyingIngress(IngressIdentifier<T> identifier,
SerializableSupplier<T> supplier) |
public <T> Harness withSupplyingIngress(IngressIdentifier<T> identifier, SerializableSupplier<T> supplier)
public <T> Harness withFlinkSourceFunction(IngressIdentifier<T> identifier, org.apache.flink.streaming.api.functions.source.SourceFunction<T> supplier)
public <T> Harness withConsumingEgress(EgressIdentifier<T> identifier, SerializableConsumer<T> consumer)
public <T> Harness withPrintingEgress(EgressIdentifier<T> identifier)
public Harness withKryoMessageSerializer()
public Harness withFlinkJobName(java.lang.String flinkJobName)
public Harness withConfiguration(java.lang.String key, java.lang.String value)
public Harness withGlobalConfiguration(java.lang.String key, java.lang.String value)
StatefulFunctionModule
on configure.public void start() throws java.lang.Exception
java.lang.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.