Package org.apache.sysds.runtime.ooc.stream

Class SourceOOCStreamable

java.lang.Object

org.apache.sysds.runtime.ooc.stream.SourceOOCStreamable

All Implemented Interfaces:

OOCStreamable<IndexedMatrixValue>

public class SourceOOCStreamable
extends Object
implements OOCStreamable<IndexedMatrixValue>

Constructor Summary

Constructors

Constructor	Description
SourceOOCStreamable(CacheableData<?> data)

Method Summary

Modifier and Type	Method	Description
void	addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	clearDownstreamMessageRelays()
void	clearUpstreamMessageRelays()
CacheableData<?>	getData()
DataCharacteristics	getDataCharacteristics()
OOCStream<IndexedMatrixValue>	getReadStream()
CachingStream	getStreamCache()
OOCStream<IndexedMatrixValue>	getWriteStream()
boolean	hasStreamCache()
boolean	isProcessed()
void	messageDownstream(OOCStreamMessage msg)
void	messageUpstream(OOCStreamMessage msg)
void	setData(CacheableData<?> data)
void	setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)
void	setIXTransform(BiFunction<Boolean,IndexRange,IndexRange> transform)
void	setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SourceOOCStreamable

public SourceOOCStreamable(CacheableData<?> data)

Method Details

getReadStream

public OOCStream<IndexedMatrixValue> getReadStream()

Specified by:

getReadStream in interface OOCStreamable<IndexedMatrixValue>

getWriteStream

public OOCStream<IndexedMatrixValue> getWriteStream()

Specified by:

getWriteStream in interface OOCStreamable<IndexedMatrixValue>

hasStreamCache

public boolean hasStreamCache()

Specified by:

hasStreamCache in interface OOCStreamable<IndexedMatrixValue>

getStreamCache

public CachingStream getStreamCache()

Specified by:

getStreamCache in interface OOCStreamable<IndexedMatrixValue>

isProcessed

public boolean isProcessed()

Specified by:

isProcessed in interface OOCStreamable<IndexedMatrixValue>

getDataCharacteristics

public DataCharacteristics getDataCharacteristics()

Specified by:

getDataCharacteristics in interface OOCStreamable<IndexedMatrixValue>

getData

public CacheableData<?> getData()

Specified by:

getData in interface OOCStreamable<IndexedMatrixValue>

setData

public void setData(CacheableData<?> data)

Specified by:

setData in interface OOCStreamable<IndexedMatrixValue>

messageUpstream

public void messageUpstream(OOCStreamMessage msg)

Specified by:

messageUpstream in interface OOCStreamable<IndexedMatrixValue>

messageDownstream

public void messageDownstream(OOCStreamMessage msg)

Specified by:

messageDownstream in interface OOCStreamable<IndexedMatrixValue>

setUpstreamMessageRelay

public void setUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Specified by:

setUpstreamMessageRelay in interface OOCStreamable<IndexedMatrixValue>

setDownstreamMessageRelay

public void setDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Specified by:

setDownstreamMessageRelay in interface OOCStreamable<IndexedMatrixValue>

addUpstreamMessageRelay

public void addUpstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Specified by:

addUpstreamMessageRelay in interface OOCStreamable<IndexedMatrixValue>

addDownstreamMessageRelay

public void addDownstreamMessageRelay(Consumer<OOCStreamMessage> relay)

Specified by:

addDownstreamMessageRelay in interface OOCStreamable<IndexedMatrixValue>

clearUpstreamMessageRelays

public void clearUpstreamMessageRelays()

Specified by:

clearUpstreamMessageRelays in interface OOCStreamable<IndexedMatrixValue>

clearDownstreamMessageRelays

public void clearDownstreamMessageRelays()

Specified by:

clearDownstreamMessageRelays in interface OOCStreamable<IndexedMatrixValue>

setIXTransform

public void setIXTransform(BiFunction<Boolean,IndexRange,IndexRange> transform)

Specified by:

setIXTransform in interface OOCStreamable<IndexedMatrixValue>