Package org.apache.wayang.java.channels
Class StreamChannel
- java.lang.Object
-
- org.apache.wayang.core.plan.executionplan.Channel
-
- org.apache.wayang.java.channels.StreamChannel
-
public class StreamChannel extends Channel
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
StreamChannel.Instance
JavaChannelInstance
implementation forStreamChannel
s.
-
Field Summary
Fields Modifier and Type Field Description static ChannelDescriptor
DESCRIPTOR
-
Constructor Summary
Constructors Constructor Description StreamChannel(ChannelDescriptor descriptor, OutputSlot<?> outputSlot)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StreamChannel
copy()
Create a copy of this instance.StreamChannel.Instance
createInstance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)
Create aChannelInstance
for this instance.-
Methods inherited from class org.apache.wayang.core.plan.executionplan.Channel
addConsumer, addSibling, getCardinalityEstimate, getConsumers, getCorrespondingSlots, getDataSetType, getDescriptor, getOriginal, getProducer, getProducerOperator, getProducerSlot, getSiblings, isBetweenStages, isCopy, isExecutionBreaker, isMarkedForInstrumentation, isReusable, isSuitableForBreakpoint, markForInstrumentation, mergeIntoOriginal, removeSiblings, removeSiblingsWhere, retain, toString, withSiblings
-
-
-
-
Field Detail
-
DESCRIPTOR
public static final ChannelDescriptor DESCRIPTOR
-
-
Constructor Detail
-
StreamChannel
public StreamChannel(ChannelDescriptor descriptor, OutputSlot<?> outputSlot)
-
-
Method Detail
-
copy
public StreamChannel copy()
Description copied from class:Channel
Create a copy of this instance. Mimics everything apart from the consumers. Also delimits already executedExecutionTask
s and those that are not executed yet. Be careful when revising this invariant.
-
createInstance
public StreamChannel.Instance createInstance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)
Description copied from class:Channel
Create aChannelInstance
for this instance.- Specified by:
createInstance
in classChannel
- Parameters:
executor
- that manages the resource ornull
if none
-
-