Package | Description |
---|---|
org.apache.flink.statefun.flink.harness | |
org.apache.flink.statefun.flink.harness.io |
Modifier and Type | Method and Description |
---|---|
<T> Harness |
Harness.withSupplyingIngress(IngressIdentifier<T> identifier,
SerializableSupplier<T> supplier) |
Constructor and Description |
---|
SupplyingIngressSpec(IngressIdentifier<T> id,
SerializableSupplier<T> supplier,
long productionDelayInMilliseconds) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.