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 Description PlatformFieldsQueryCursor(PlatformContext platformCtx, QueryCursorEx<List<?>> cursor, int batchSize)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidprocessOutStream(int type, BinaryRawWriterEx writer)Process OUT operation.protected voidwrite(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
-
-
-
-
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:
writein classPlatformAbstractQueryCursor<List<?>>- Parameters:
writer- Writer.vals- Value.
-
processOutStream
public void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedExceptionProcess OUT operation.- Specified by:
processOutStreamin interfacePlatformTarget- Overrides:
processOutStreamin classPlatformAbstractQueryCursor<List<?>>- Parameters:
type- Type.writer- Binary writer.- Throws:
IgniteCheckedException- In case of exception.
-
-