Uses of Interface
org.apache.sysds.runtime.ooc.stream.message.OOCStreamMessage

Packages that use OOCStreamMessage

Package	Description
org.apache.sysds.runtime.instructions.ooc
org.apache.sysds.runtime.ooc.stream
org.apache.sysds.runtime.ooc.stream.message

Uses of OOCStreamMessage in org.apache.sysds.runtime.instructions.ooc

Methods in org.apache.sysds.runtime.instructions.ooc with parameters of type OOCStreamMessage

Modifier and Type	Method	Description
void	CachingStream.messageDownstream(OOCStreamMessage msg)
void	OOCStreamable.messageDownstream(OOCStreamMessage msg)
void	PlaybackStream.messageDownstream(OOCStreamMessage msg)
void	SubscribableTaskQueue.messageDownstream(OOCStreamMessage msg)
void	CachingStream.messageUpstream(OOCStreamMessage msg)
void	OOCStreamable.messageUpstream(OOCStreamMessage msg)
void	PlaybackStream.messageUpstream(OOCStreamMessage msg)
void	SubscribableTaskQueue.messageUpstream(OOCStreamMessage msg)

Method parameters in org.apache.sysds.runtime.instructions.ooc with type arguments of type OOCStreamMessage

Modifier and Type	Method	Description
void	CachingStream.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	OOCStreamable.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	PlaybackStream.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubscribableTaskQueue.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	CachingStream.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	OOCStreamable.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	PlaybackStream.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubscribableTaskQueue.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	CachingStream.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	OOCStreamable.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	PlaybackStream.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubscribableTaskQueue.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	CachingStream.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	OOCStreamable.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	PlaybackStream.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubscribableTaskQueue.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Uses of OOCStreamMessage in org.apache.sysds.runtime.ooc.stream

Methods in org.apache.sysds.runtime.ooc.stream with parameters of type OOCStreamMessage

Modifier and Type	Method	Description
void	FilteredOOCStream.messageDownstream(OOCStreamMessage msg)
void	MergedOOCStream.messageDownstream(OOCStreamMessage msg)
void	SourceOOCStreamable.messageDownstream(OOCStreamMessage msg)
void	SplittingOOCStream.messageDownstream(OOCStreamMessage msg)
void	SubOOCStream.messageDownstream(OOCStreamMessage msg)
void	FilteredOOCStream.messageUpstream(OOCStreamMessage msg)
void	MergedOOCStream.messageUpstream(OOCStreamMessage msg)
void	SourceOOCStream.messageUpstream(OOCStreamMessage msg)
void	SourceOOCStreamable.messageUpstream(OOCStreamMessage msg)
void	SplittingOOCStream.messageUpstream(OOCStreamMessage msg)
void	SubOOCStream.messageUpstream(OOCStreamMessage msg)

Method parameters in org.apache.sysds.runtime.ooc.stream with type arguments of type OOCStreamMessage

Modifier and Type	Method	Description
void	FilteredOOCStream.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	MergedOOCStream.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SourceOOCStreamable.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SplittingOOCStream.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubOOCStream.addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	FilteredOOCStream.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	MergedOOCStream.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SourceOOCStreamable.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SplittingOOCStream.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubOOCStream.addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	FilteredOOCStream.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	MergedOOCStream.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SourceOOCStreamable.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SplittingOOCStream.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubOOCStream.setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	FilteredOOCStream.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	MergedOOCStream.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SourceOOCStreamable.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SplittingOOCStream.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	SubOOCStream.setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Uses of OOCStreamMessage in org.apache.sysds.runtime.ooc.stream.message

Classes in org.apache.sysds.runtime.ooc.stream.message that implement OOCStreamMessage

Modifier and Type	Class	Description
class	OOCGetStreamTypeMessage

Methods in org.apache.sysds.runtime.ooc.stream.message that return OOCStreamMessage

Modifier and Type	Method	Description
default OOCStreamMessage	OOCStreamMessage.split()