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

Class OOCCacheManager.CachedQueueCallback<T>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, OOCStream.QueueCallback<T>

Enclosing class:

OOCCacheManager

public static class OOCCacheManager.CachedQueueCallback<T>
extends Object
implements OOCStream.QueueCallback<T>

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

get

public T get()

Specified by:

get in interface OOCStream.QueueCallback<T>

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>

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>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface OOCStream.QueueCallback<T>

getBlockKey

public BlockKey getBlockKey()