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 aChannel
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> java.util.stream.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
-
-