Package org.apache.wayang.java.channels
Class StreamChannel.Instance
java.lang.Object
org.apache.wayang.core.util.AbstractReferenceCountable
org.apache.wayang.core.platform.ExecutionResourceTemplate
org.apache.wayang.core.platform.AbstractChannelInstance
org.apache.wayang.java.channels.StreamChannel.Instance
- All Implemented Interfaces:
ChannelInstance
,ExecutionResource
,ReferenceCountable
,JavaChannelInstance
- Enclosing class:
- StreamChannel
JavaChannelInstance
implementation for StreamChannel
s.-
Constructor Summary
ConstructorsConstructorDescriptionInstance
(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex) -
Method Summary
Modifier and TypeMethodDescriptionvoid
accept
(Collection<?> collection) <T> void
protected void
Performs the actual disposing work of this instance.Optionally provides the measured cardinality of this instance.<T> Stream<T>
Provide the producer's result to a consumer.Methods inherited from class org.apache.wayang.core.platform.AbstractChannelInstance
getLineage, getProducerOperatorContext, markProduced, setMeasuredCardinality, toString, wasProduced
Methods inherited from class org.apache.wayang.core.platform.ExecutionResourceTemplate
dispose, disposeUnreferenced
Methods inherited from class org.apache.wayang.core.util.AbstractReferenceCountable
disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.wayang.core.platform.ChannelInstance
getLineage, getProducerOperatorContext, isMarkedForInstrumentation, markProduced, setMeasuredCardinality, wasProduced
Methods inherited from interface org.apache.wayang.core.platform.ExecutionResource
dispose
Methods inherited from interface org.apache.wayang.core.util.ReferenceCountable
disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference
-
Constructor Details
-
Instance
public Instance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)
-
-
Method Details
-
accept
-
accept
-
provideStream
Description copied from interface:JavaChannelInstance
Provide the producer's result to a consumer.- Specified by:
provideStream
in interfaceJavaChannelInstance
- Returns:
- the producer's result
-
getChannel
- Specified by:
getChannel
in interfaceChannelInstance
- Returns:
- the
Channel
that is implemented by this instance
-
getMeasuredCardinality
Description copied from interface:ChannelInstance
Optionally provides the measured cardinality of this instance. However, such a cardinality might not be available for several reasons. For instance, the measurement might not have been requested or could not be implemented by the executingPlatform
.- Specified by:
getMeasuredCardinality
in interfaceChannelInstance
- Overrides:
getMeasuredCardinality
in classAbstractChannelInstance
- Returns:
- the measured cardinality if available
-
doDispose
Description copied from class:ExecutionResourceTemplate
Performs the actual disposing work of this instance.- Specified by:
doDispose
in classExecutionResourceTemplate
- Throws:
WayangException
-