Uses of Class
org.apache.flink.types.Either

Packages that use Either

Package	Description
org.apache.flink.api.common.typeinfo
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.cep
org.apache.flink.runtime.blob
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.io.network.partition
org.apache.flink.types

Uses of Either in org.apache.flink.api.common.typeinfo

Methods in org.apache.flink.api.common.typeinfo that return types with arguments of type Either

Modifier and Type	Method and Description
static <L,R> TypeInformation<Either<L,R>>	Types.EITHER(TypeInformation<L> leftType, TypeInformation<R> rightType) Returns type information for Flink's Either type.

Uses of Either in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils that return types with arguments of type Either

Modifier and Type	Method and Description
TypeSerializer<Either<L,R>>	EitherTypeInfo.createSerializer(ExecutionConfig config)
TypeInformation<Either<L,R>>	EitherTypeInfoFactory.createTypeInfo(Type t, Map<String,TypeInformation<?>> genericParameters)
Class<Either<L,R>>	EitherTypeInfo.getTypeClass()

Uses of Either in org.apache.flink.api.java.typeutils.runtime

Methods in org.apache.flink.api.java.typeutils.runtime that return Either

Modifier and Type	Method and Description
Either<L,R>	EitherSerializer.copy(Either<L,R> from)
Either<L,R>	EitherSerializer.copy(Either<L,R> from, Either<L,R> reuse)
Either<L,R>	EitherSerializer.createInstance()
Either<L,R>	EitherSerializer.deserialize(DataInputView source)
Either<L,R>	EitherSerializer.deserialize(Either<L,R> reuse, DataInputView source)

Methods in org.apache.flink.api.java.typeutils.runtime that return types with arguments of type Either

Modifier and Type	Method and Description
TypeSerializer<Either<L,R>>	EitherSerializer.duplicate()
TypeSerializerSchemaCompatibility<Either<L,R>>	EitherSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer) Deprecated.
TypeSerializerSchemaCompatibility<Either<L,R>>	EitherSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer) Deprecated.

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type Either

Modifier and Type	Method and Description
Either<L,R>	EitherSerializer.copy(Either<L,R> from)
Either<L,R>	EitherSerializer.copy(Either<L,R> from, Either<L,R> reuse)
Either<L,R>	EitherSerializer.copy(Either<L,R> from, Either<L,R> reuse)
Either<L,R>	EitherSerializer.deserialize(Either<L,R> reuse, DataInputView source)
void	EitherSerializer.serialize(Either<L,R> record, DataOutputView target)

Method parameters in org.apache.flink.api.java.typeutils.runtime with type arguments of type Either

Modifier and Type	Method and Description
TypeSerializerSchemaCompatibility<Either<L,R>>	EitherSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer) Deprecated.
TypeSerializerSchemaCompatibility<Either<L,R>>	EitherSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer) Deprecated.

Uses of Either in org.apache.flink.cep

Methods in org.apache.flink.cep that return Either

Modifier and Type	Method and Description
Either<L,R>	PatternStream.CoMapTimeout.map1(R value)
Either<L,R>	PatternStream.CoMapTimeout.map2(L value)

Methods in org.apache.flink.cep that return types with arguments of type Either

Modifier and Type	Method and Description
<L,R> SingleOutputStreamOperator<Either<L,R>>	PatternStream.flatSelect(PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction, PatternFlatSelectFunction<T,R> patternFlatSelectFunction) Deprecated. Use PatternStream.flatSelect(OutputTag, PatternFlatTimeoutFunction, PatternFlatSelectFunction) that returns timed out events as a side-output
<L,R> SingleOutputStreamOperator<Either<L,R>>	PatternStream.select(PatternTimeoutFunction<T,L> patternTimeoutFunction, PatternSelectFunction<T,R> patternSelectFunction) Deprecated. Use PatternStream.select(OutputTag, PatternTimeoutFunction, PatternSelectFunction) that returns timed out events as a side-output

Uses of Either in org.apache.flink.runtime.blob

Methods in org.apache.flink.runtime.blob that return Either

Modifier and Type	Method and Description
static <T> Either<SerializedValue<T>,PermanentBlobKey>	BlobWriter.serializeAndTryOffload(T value, JobID jobId, BlobWriter blobWriter) Serializes the given value and offloads it to the BlobServer if its size exceeds the minimum offloading size of the BlobServer.

Uses of Either in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return Either

Modifier and Type	Method and Description
Either<SerializedValue<JobInformation>,PermanentBlobKey>	ExecutionGraph.getJobInformationOrBlobKey()
Either<SerializedValue<TaskInformation>,PermanentBlobKey>	ExecutionJobVertex.getTaskInformationOrBlobKey()

Uses of Either in org.apache.flink.runtime.io.network.partition

Methods in org.apache.flink.runtime.io.network.partition that return Either

Modifier and Type	Method and Description
Either<ExecutionState,Throwable>	PartitionProducerStateProvider.ResponseHandle.getProducerExecutionState()

Uses of Either in org.apache.flink.types

Subclasses of Either in org.apache.flink.types

Modifier and Type	Class and Description
static class	Either.Left<L,R> A left value of Either
static class	Either.Right<L,R> A right value of Either

Methods in org.apache.flink.types that return Either

Modifier and Type	Method and Description
static <L,R> Either<L,R>	Either.Left(L value) Create a Left value of Either
static <L,R> Either<L,R>	Either.Right(R value) Create a Right value of Either

Methods in org.apache.flink.types with parameters of type Either

Modifier and Type	Method and Description
static <L,R> Either.Left<L,R>	Either.obtainLeft(Either<L,R> input, TypeSerializer<L> leftSerializer) Utility function for EitherSerializer to support object reuse.
static <L,R> Either.Right<L,R>	Either.obtainRight(Either<L,R> input, TypeSerializer<R> rightSerializer) Utility function for EitherSerializer to support object reuse.