Package org.apache.sysds.runtime.ooc.cache

Class OOCCacheManager.CachedGroupCallback<T>

java.lang.Object

org.apache.sysds.runtime.ooc.cache.OOCCacheManager.CachedGroupCallback<T>

All Implemented Interfaces:

AutoCloseable, OOCStream.GroupQueueCallback<T>, OOCStream.QueueCallback<T>

Enclosing class:

OOCCacheManager

public static class OOCCacheManager.CachedGroupCallback<T>
extends Object
implements OOCStream.GroupQueueCallback<T>

Method Summary

Modifier and Type	Method	Description
void	close()
void	fail(DMLRuntimeException failure)
T	get()
T	get(int idx)
BlockKey	getBlockKey()
OOCStream.QueueCallback<T>	getCallback(int idx)
boolean	isEos()
boolean	isFailure()
OOCStream.QueueCallback<T>	keepOpen()	Keeps the callback item pinned in memory until the returned callback is also closed.
void	registerQueueCallback()
int	size()

Methods inherited from class java.lang.Object

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

Method Details

getCallback

public OOCStream.QueueCallback<T> getCallback(int idx)

Specified by:

getCallback in interface OOCStream.GroupQueueCallback<T>

registerQueueCallback

public void registerQueueCallback()

get

public T get()

Specified by:

get in interface OOCStream.QueueCallback<T>

size

public int size()

Specified by:

size in interface OOCStream.GroupQueueCallback<T>

get

public T get(int idx)

keepOpen

public OOCStream.QueueCallback<T> keepOpen()

Description copied from interface: OOCStream.QueueCallback

Keeps the callback item pinned in memory until the returned callback is also closed.

Specified by:

keepOpen in interface OOCStream.QueueCallback<T>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface OOCStream.QueueCallback<T>

fail

public void fail(DMLRuntimeException failure)

Specified by:

fail in interface OOCStream.QueueCallback<T>

isEos

public boolean isEos()

Specified by:

isEos in interface OOCStream.QueueCallback<T>

isFailure

public boolean isFailure()

Specified by:

isFailure in interface OOCStream.QueueCallback<T>

getBlockKey

public BlockKey getBlockKey()