Modifier and Type | Method and Description |
---|---|
TypeSerializer<Either<L,R>> |
EitherTypeInfo.createSerializer(ExecutionConfig config) |
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() |
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> DataStream<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> DataStream<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> DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,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
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.