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