Package org.apache.wayang.java.channels

Interface JavaChannelInstance

All Superinterfaces:

ChannelInstance, ExecutionResource, ReferenceCountable

All Known Implementing Classes:

CollectionChannel.Instance, StreamChannel.Instance

public interface JavaChannelInstance
extends ChannelInstance

Defines execution logic to handle a Channel.

Method Summary

Modifier and Type	Method	Description
<T> Stream<T>	provideStream()	Provide the producer's result to a consumer.

Methods inherited from interface org.apache.wayang.core.platform.ChannelInstance

getChannel, 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

Method Details

provideStream

<T> Stream<T> provideStream()

Provide the producer's result to a consumer.

Returns:

the producer's result