org.apache.ignite.internal.processors.platform.cache.query

Class PlatformFieldsQueryCursor

java.lang.Object

org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

org.apache.ignite.internal.processors.platform.cache.query.PlatformAbstractQueryCursor<List<?>>

org.apache.ignite.internal.processors.platform.cache.query.PlatformFieldsQueryCursor

All Implemented Interfaces:

AutoCloseable, PlatformTarget

public class PlatformFieldsQueryCursor
extends PlatformAbstractQueryCursor<List<?>>

Interop cursor for fields query.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

ERROR, FALSE, log, platformCtx, TRUE

Constructor Summary

Constructors

Constructor and Description
PlatformFieldsQueryCursor(PlatformContext platformCtx, QueryCursorEx<List<?>> cursor, int batchSize) Constructor.

Method Summary

Modifier and Type	Method and Description
void	processOutStream(int type, BinaryRawWriterEx writer) Process OUT operation.
protected void	write(BinaryRawWriterEx writer, List vals) Write value to the stream.

Methods inherited from class org.apache.ignite.internal.processors.platform.cache.query.PlatformAbstractQueryCursor

close, cursor, processInLongOutLong

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PlatformFieldsQueryCursor

public PlatformFieldsQueryCursor(PlatformContext platformCtx,
                                 QueryCursorEx<List<?>> cursor,
                                 int batchSize)

Constructor.

Parameters:

platformCtx - Platform context.

cursor - Backing cursor.

batchSize - Batch size.

Method Detail

write

protected void write(BinaryRawWriterEx writer,
                     List vals)

Write value to the stream. Extension point to perform conversions on the object before writing it.

Specified by:

write in class PlatformAbstractQueryCursor<List<?>>

Parameters:

writer - Writer.

vals - Value.

processOutStream

public void processOutStream(int type,
                             BinaryRawWriterEx writer)
                      throws IgniteCheckedException

Process OUT operation.

Specified by:

processOutStream in interface PlatformTarget

Overrides:

processOutStream in class PlatformAbstractQueryCursor<List<?>>

Parameters:

type - Type.

writer - Binary writer.

Throws:

IgniteCheckedException - In case of exception.