Package org.apache.wayang.java.channels

Class CollectionChannel.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.CollectionChannel.Instance

All Implemented Interfaces:

ChannelInstance, ExecutionResource, ReferenceCountable, JavaChannelInstance

Enclosing class:

CollectionChannel

public class CollectionChannel.Instance
extends AbstractChannelInstance
implements JavaChannelInstance

JavaChannelInstance implementation for the CollectionChannel.

Constructor Summary

Constructors

Constructor	Description
Instance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)

Method Summary

Modifier and Type	Method	Description
void	accept(Collection<?> collection)
protected void	doDispose()	Performs the actual disposing work of this instance.
Channel	getChannel()
<T> Collection<T>	provideCollection()
<T> Stream<T>	provideStream()	Provide the producer's result to a consumer.

Methods inherited from class org.apache.wayang.core.platform.AbstractChannelInstance

getLineage, getMeasuredCardinality, 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, getMeasuredCardinality, 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

public void accept(Collection<?> collection)

provideCollection

public <T> Collection<T> provideCollection()

provideStream

public <T> Stream<T> provideStream()

Description copied from interface: JavaChannelInstance

Provide the producer's result to a consumer.

Specified by:

provideStream in interface JavaChannelInstance

Returns:

the producer's result

getChannel

public Channel getChannel()

Specified by:

getChannel in interface ChannelInstance

Returns:

the Channel that is implemented by this instance

doDispose

protected void doDispose()

Description copied from class: ExecutionResourceTemplate

Performs the actual disposing work of this instance.

Specified by:

doDispose in class ExecutionResourceTemplate