Modifier and Type | Method and Description |
---|---|
IterationRecord<T> |
IterationRecord.clone() |
static <T> IterationRecord<T> |
IterationRecord.newBarrier(long checkpointId) |
static <T> IterationRecord<T> |
IterationRecord.newEpochWatermark(int epoch,
String sender) |
static <T> IterationRecord<T> |
IterationRecord.newRecord(T value,
int epoch) |
Modifier and Type | Field and Description |
---|---|
static org.apache.flink.util.OutputTag<IterationRecord<Void>> |
HeadOperator.ALIGN_NOTIFY_OUTPUT_TAG |
protected BroadcastOutput<IterationRecord<T>> |
AbstractWrapperOperator.eventBroadcastOutput |
protected org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> |
AbstractWrapperOperator.output |
protected org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> |
AbstractWrapperOperator.parameters |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<?>>> |
HeadOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<?>> streamOperatorParameters) |
<T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<OUT>>> |
WrapperOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters) |
Modifier and Type | Method and Description |
---|---|
OperatorWrapper<OUT,IterationRecord<OUT>> |
WrapperOperatorFactory.getWrapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractWrapperOperator.onEpochWatermarkEvent(int inputIndex,
IterationRecord<?> iterationRecord) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<?>>> |
HeadOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<?>> streamOperatorParameters) |
<T extends org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<OUT>>> |
WrapperOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters) |
void |
TailOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> streamRecord) |
void |
HeadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> element) |
void |
OutputOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>> streamRecord) |
void |
ReplayOperator.processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>> element) |
void |
ReplayOperator.processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<Void>> element) |
void |
HeadOperator.processFeedback(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> iterationRecord) |
void |
HeadOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask,
org.apache.flink.streaming.api.graph.StreamConfig config,
org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>>> output) |
void |
ReplayOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask,
org.apache.flink.streaming.api.graph.StreamConfig config,
org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output) |
Constructor and Description |
---|
AbstractWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
WrapperOperatorFactory(org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory,
OperatorWrapper<OUT,IterationRecord<OUT>> wrapper) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.typeinfo.TypeInformation<IterationRecord<T>> |
AllRoundOperatorWrapper.getWrappedTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo) |
org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<T>> |
AllRoundOperatorWrapper.wrap(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> operatorParameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
<KEY> org.apache.flink.api.java.functions.KeySelector<IterationRecord<T>,KEY> |
AllRoundOperatorWrapper.wrapKeySelector(org.apache.flink.api.java.functions.KeySelector<T,KEY> keySelector) |
org.apache.flink.util.OutputTag<IterationRecord<T>> |
AllRoundOperatorWrapper.wrapOutputTag(org.apache.flink.util.OutputTag<T> outputTag) |
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>> |
AllRoundOperatorWrapper.wrapStreamPartitioner(org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> streamPartitioner) |
Modifier and Type | Method and Description |
---|---|
void |
OneInputAllRoundWrapperOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> element) |
void |
TwoInputAllRoundWrapperOperator.processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN1>> element) |
void |
TwoInputAllRoundWrapperOperator.processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN2>> element) |
void |
OneInputAllRoundWrapperOperator.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> record) |
org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<T>> |
AllRoundOperatorWrapper.wrap(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> operatorParameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
Constructor and Description |
---|
AbstractAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
MultipleInputAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
OneInputAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
TwoInputAllRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
Modifier and Type | Method and Description |
---|---|
void |
HeadOperatorRecordProcessor.Context.broadcastOutput(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
HeadOperatorRecordProcessor.Context.output(org.apache.flink.util.OutputTag<IterationRecord<?>> outputTag,
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
HeadOperatorRecordProcessor.Context.output(org.apache.flink.util.OutputTag<IterationRecord<?>> outputTag,
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
HeadOperatorRecordProcessor.Context.output(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
TerminatingHeadOperatorRecordProcessor.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
void |
RegularHeadOperatorRecordProcessor.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> element) |
void |
HeadOperatorRecordProcessor.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
boolean |
TerminatingHeadOperatorRecordProcessor.processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
boolean |
RegularHeadOperatorRecordProcessor.processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> element) |
boolean |
HeadOperatorRecordProcessor.processFeedbackElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<?>> record) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.typeinfo.TypeInformation<IterationRecord<T>> |
PerRoundOperatorWrapper.getWrappedTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo) |
org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<T>> |
PerRoundOperatorWrapper.wrap(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> operatorParameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
<KEY> org.apache.flink.api.java.functions.KeySelector<IterationRecord<T>,KEY> |
PerRoundOperatorWrapper.wrapKeySelector(org.apache.flink.api.java.functions.KeySelector<T,KEY> keySelector) |
org.apache.flink.util.OutputTag<IterationRecord<T>> |
PerRoundOperatorWrapper.wrapOutputTag(org.apache.flink.util.OutputTag<T> outputTag) |
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>> |
PerRoundOperatorWrapper.wrapStreamPartitioner(org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> streamPartitioner) |
Modifier and Type | Method and Description |
---|---|
void |
OneInputPerRoundWrapperOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN>> element) |
void |
TwoInputPerRoundWrapperOperator.processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN1>> element) |
void |
TwoInputPerRoundWrapperOperator.processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<IN2>> element) |
org.apache.flink.streaming.api.operators.StreamOperator<IterationRecord<T>> |
PerRoundOperatorWrapper.wrap(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> operatorParameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
Constructor and Description |
---|
AbstractPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<T>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<T> operatorFactory) |
MultipleInputPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
OneInputPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
TwoInputPerRoundWrapperOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<IterationRecord<OUT>> parameters,
org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT> operatorFactory) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>> |
ProxyStreamPartitioner.copy() |
Modifier and Type | Method and Description |
---|---|
KEY |
ProxyKeySelector.getKey(IterationRecord<T> record) |
Modifier and Type | Method and Description |
---|---|
int |
ProxyStreamPartitioner.selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> record) |
Constructor and Description |
---|
ProxyOutput(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output) |
Modifier and Type | Method and Description |
---|---|
IterationRecord<T> |
IterationRecordSerializer.copy(IterationRecord<T> from) |
IterationRecord<T> |
IterationRecordSerializer.copy(IterationRecord<T> from,
IterationRecord<T> reuse) |
IterationRecord<T> |
IterationRecordSerializer.createInstance() |
IterationRecord<T> |
IterationRecordSerializer.deserialize(org.apache.flink.core.memory.DataInputView source) |
IterationRecord<T> |
IterationRecordSerializer.deserialize(IterationRecord<T> reuse,
org.apache.flink.core.memory.DataInputView source) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>> |
IterationRecordTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config) |
org.apache.flink.api.common.typeutils.TypeSerializer<IterationRecord<T>> |
IterationRecordSerializer.duplicate() |
Class<IterationRecord<T>> |
IterationRecordTypeInfo.getTypeClass() |
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<IterationRecord<T>> |
IterationRecordSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
IterationRecord<T> |
IterationRecordSerializer.copy(IterationRecord<T> from) |
IterationRecord<T> |
IterationRecordSerializer.copy(IterationRecord<T> from,
IterationRecord<T> reuse) |
IterationRecord<T> |
IterationRecordSerializer.copy(IterationRecord<T> from,
IterationRecord<T> reuse) |
IterationRecord<T> |
IterationRecordSerializer.deserialize(IterationRecord<T> reuse,
org.apache.flink.core.memory.DataInputView source) |
void |
IterationRecordSerializer.serialize(IterationRecord<T> record,
org.apache.flink.core.memory.DataOutputView target) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.