Class PlatformAbstractQueryCursor<T>
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.cache.query.PlatformAbstractQueryCursor<T>
-
- All Implemented Interfaces:
AutoCloseable,PlatformTarget
- Direct Known Subclasses:
PlatformFieldsQueryCursor,PlatformQueryCursor
public abstract class PlatformAbstractQueryCursor<T> extends PlatformAbstractTarget implements AutoCloseable
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidclose()QueryCursorEx<T>cursor()Gets the cursor.longprocessInLongOutLong(int type, long val)Process IN operation.voidprocessOutStream(int type, BinaryRawWriterEx writer)Process OUT operation.protected abstract voidwrite(BinaryRawWriterEx writer, T val)Write value to the stream.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutLong, processInStreamOutObject, processInStreamOutStream, processOutObject, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Method Detail
-
processOutStream
public void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedExceptionProcess OUT operation.- Specified by:
processOutStreamin interfacePlatformTarget- Overrides:
processOutStreamin classPlatformAbstractTarget- Parameters:
type- Type.writer- Binary writer.- Throws:
IgniteCheckedException- In case of exception.
-
processInLongOutLong
public long processInLongOutLong(int type, long val) throws IgniteCheckedExceptionProcess IN operation.- Specified by:
processInLongOutLongin interfacePlatformTarget- Overrides:
processInLongOutLongin classPlatformAbstractTarget- Parameters:
type- Type.val- Value.- Returns:
- Result.
- Throws:
IgniteCheckedException- In case of exception.
-
close
public void close() throws Exception- Specified by:
closein interfaceAutoCloseable- Throws:
Exception
-
write
protected abstract void write(BinaryRawWriterEx writer, T val)
Write value to the stream. Extension point to perform conversions on the object before writing it.- Parameters:
writer- Writer.val- Value.
-
cursor
public QueryCursorEx<T> cursor()
Gets the cursor.- Returns:
- Cursor.
-
-