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() |
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) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Either<L,R>> |
EitherSerializer.duplicate() |
CompatibilityResult<Either<L,R>> |
EitherSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
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) |
Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<Either<L,R>> |
PatternStream.flatSelect(PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction)
Applies a flat select function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<Either<L,R>> |
PatternStream.select(PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
Modifier and Type | Method and Description |
---|---|
static <K,T> SingleOutputStreamOperator<Either<Tuple2<Map<String,List<T>>,Long>,Map<String,List<T>>>> |
CEPOperatorUtils.createTimeoutPatternStream(DataStream<T> inputStream,
Pattern<T,?> pattern)
Creates a data stream containing fully matching event patterns or partially matching event
patterns which have timed out.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple2<K,Either<NullValue,Message>>> |
VertexCentricIteration.MessageCombinerUdf.getProducedType() |
Modifier and Type | Method and Description |
---|---|
void |
VertexCentricIteration.MessageCombinerUdf.combine(Iterable<Tuple2<K,Either<NullValue,Message>>> values,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
void |
VertexCentricIteration.MessageCombinerUdf.combine(Iterable<Tuple2<K,Either<NullValue,Message>>> values,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
void |
VertexCentricIteration.MessageCombinerUdf.reduce(Iterable<Tuple2<K,Either<NullValue,Message>>> messages,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
void |
VertexCentricIteration.MessageCombinerUdf.reduce(Iterable<Tuple2<K,Either<NullValue,Message>>> messages,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
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 |
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
|
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. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.