Uses of Class
org.apache.flink.statefun.sdk.io.EgressIdentifier

Packages that use EgressIdentifier

Package	Description
org.apache.flink.statefun.e2e.smoke.driver
org.apache.flink.statefun.flink.core
org.apache.flink.statefun.flink.core.functions
org.apache.flink.statefun.flink.core.translation
org.apache.flink.statefun.flink.datastream
org.apache.flink.statefun.flink.harness
org.apache.flink.statefun.flink.harness.io
org.apache.flink.statefun.flink.io.common.json
org.apache.flink.statefun.flink.io.datastream
org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1
org.apache.flink.statefun.sdk
org.apache.flink.statefun.sdk.io
org.apache.flink.statefun.sdk.kafka
org.apache.flink.statefun.sdk.kinesis.egress
org.apache.flink.statefun.testutils.function

Uses of EgressIdentifier in org.apache.flink.statefun.e2e.smoke.driver

Fields in org.apache.flink.statefun.e2e.smoke.driver declared as EgressIdentifier

Modifier and Type	Field and Description
static EgressIdentifier<TypedValue>	Constants.OUT
static EgressIdentifier<TypedValue>	Constants.VERIFICATION_RESULT

Uses of EgressIdentifier in org.apache.flink.statefun.flink.core

Methods in org.apache.flink.statefun.flink.core that return types with arguments of type EgressIdentifier

Modifier and Type	Method and Description
java.util.Map<EgressIdentifier<?>,EgressSpec<?>>	StatefulFunctionsUniverse.egress()

Uses of EgressIdentifier in org.apache.flink.statefun.flink.core.functions

Constructor parameters in org.apache.flink.statefun.flink.core.functions with type arguments of type EgressIdentifier

Constructor and Description
FunctionGroupDispatchFactory(StatefulFunctionsConfig configuration, java.util.Map<EgressIdentifier<?>,org.apache.flink.util.OutputTag<java.lang.Object>> sideOutputs)

Uses of EgressIdentifier in org.apache.flink.statefun.flink.core.translation

Methods in org.apache.flink.statefun.flink.core.translation that return types with arguments of type EgressIdentifier

Modifier and Type	Method and Description
<T extends StatefulFunctionProvider & java.io.Serializable> java.util.Map<EgressIdentifier<?>,org.apache.flink.streaming.api.datastream.DataStream<?>>	EmbeddedTranslator.translate(java.util.List<org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage>> ingresses, java.lang.Iterable<EgressIdentifier<?>> egressesIds, java.util.Map<FunctionType,T> functions)

Method parameters in org.apache.flink.statefun.flink.core.translation with type arguments of type EgressIdentifier

Modifier and Type	Method and Description
<T extends StatefulFunctionProvider & java.io.Serializable> java.util.Map<EgressIdentifier<?>,org.apache.flink.streaming.api.datastream.DataStream<?>>	EmbeddedTranslator.translate(java.util.List<org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage>> ingresses, java.lang.Iterable<EgressIdentifier<?>> egressesIds, java.util.Map<FunctionType,T> functions)

Uses of EgressIdentifier in org.apache.flink.statefun.flink.datastream

Methods in org.apache.flink.statefun.flink.datastream with parameters of type EgressIdentifier

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.datastream.DataStream<T>	StatefulFunctionEgressStreams.getDataStreamForEgressId(EgressIdentifier<T> id) Returns the DataStream that represents a stateful functions egress for an EgressIdentifier.
StatefulFunctionDataStreamBuilder	StatefulFunctionDataStreamBuilder.withEgressId(EgressIdentifier<?> egressId) Registers an EgressIdentifier.

Uses of EgressIdentifier in org.apache.flink.statefun.flink.harness

Methods in org.apache.flink.statefun.flink.harness with parameters of type EgressIdentifier

Modifier and Type	Method and Description
<T> Harness	Harness.withConsumingEgress(EgressIdentifier<T> identifier, SerializableConsumer<T> consumer)
<T> Harness	Harness.withPrintingEgress(EgressIdentifier<T> identifier)

Uses of EgressIdentifier in org.apache.flink.statefun.flink.harness.io

Methods in org.apache.flink.statefun.flink.harness.io that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<T>	ConsumingEgressSpec.id()

Constructors in org.apache.flink.statefun.flink.harness.io with parameters of type EgressIdentifier

Constructor and Description
ConsumingEgressSpec(EgressIdentifier<T> id, SerializableConsumer<T> consumer)

Uses of EgressIdentifier in org.apache.flink.statefun.flink.io.common.json

Methods in org.apache.flink.statefun.flink.io.common.json that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<TypedValue>	EgressIdentifierJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext deserializationContext)

Uses of EgressIdentifier in org.apache.flink.statefun.flink.io.datastream

Methods in org.apache.flink.statefun.flink.io.datastream that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<T>	SinkFunctionSpec.id()

Constructors in org.apache.flink.statefun.flink.io.datastream with parameters of type EgressIdentifier

Constructor and Description
SinkFunctionSpec(EgressIdentifier<T> id, org.apache.flink.streaming.api.functions.sink.SinkFunction<T> delegate)

Uses of EgressIdentifier in org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1

Methods in org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1 that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<TypedValue>	GenericKinesisEgressSpec.id()

Uses of EgressIdentifier in org.apache.flink.statefun.sdk

Methods in org.apache.flink.statefun.sdk with parameters of type EgressIdentifier

Modifier and Type	Method and Description
<T> void	Context.send(EgressIdentifier<T> egress, T message) Sends an output to an egress, identified by the egress' EgressIdentifier.

Uses of EgressIdentifier in org.apache.flink.statefun.sdk.io

Methods in org.apache.flink.statefun.sdk.io that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<T>	EgressSpec.id() Returns the unique identifier of the egress.

Uses of EgressIdentifier in org.apache.flink.statefun.sdk.kafka

Methods in org.apache.flink.statefun.sdk.kafka that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<OutT>	KafkaEgressSpec.id()

Methods in org.apache.flink.statefun.sdk.kafka with parameters of type EgressIdentifier

Modifier and Type	Method and Description
static <OutT> KafkaEgressBuilder<OutT>	KafkaEgressBuilder.forIdentifier(EgressIdentifier<OutT> egressIdentifier)

Uses of EgressIdentifier in org.apache.flink.statefun.sdk.kinesis.egress

Methods in org.apache.flink.statefun.sdk.kinesis.egress that return EgressIdentifier

Modifier and Type	Method and Description
EgressIdentifier<T>	KinesisEgressSpec.id()

Methods in org.apache.flink.statefun.sdk.kinesis.egress with parameters of type EgressIdentifier

Modifier and Type	Method and Description
static <T> KinesisEgressBuilder<T>	KinesisEgressBuilder.forIdentifier(EgressIdentifier<T> id)

Uses of EgressIdentifier in org.apache.flink.statefun.testutils.function

Methods in org.apache.flink.statefun.testutils.function with parameters of type EgressIdentifier

Modifier and Type	Method and Description
<T> java.util.List<T>	FunctionTestHarness.getEgress(EgressIdentifier<T> identifier)