public class BulkLoadContextCursor extends Object implements FieldsQueryCursor<List<?>>
Constructor and Description |
---|
BulkLoadContextCursor(org.apache.ignite.internal.processors.bulkload.BulkLoadProcessor processor,
org.apache.ignite.internal.processors.bulkload.BulkLoadAckClientParameters clientParams)
Creates a cursor.
|
Modifier and Type | Method and Description |
---|---|
org.apache.ignite.internal.processors.bulkload.BulkLoadProcessor |
bulkLoadProcessor()
Returns a bulk load context.
|
org.apache.ignite.internal.processors.bulkload.BulkLoadAckClientParameters |
clientParams()
Returns the bulk load parameters to send to the client.
|
void |
close()
Closes all resources related to this cursor.
|
List<List<?>> |
getAll()
Gets all query results and stores them in the collection.
|
int |
getColumnsCount()
Gets number of columns in a row.
|
String |
getFieldName(int idx)
Gets field name.
|
@NotNull Iterator<List<?>> |
iterator() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public BulkLoadContextCursor(org.apache.ignite.internal.processors.bulkload.BulkLoadProcessor processor, org.apache.ignite.internal.processors.bulkload.BulkLoadAckClientParameters clientParams)
processor
- Bulk load context object to store.clientParams
- Parameters to send to client.public org.apache.ignite.internal.processors.bulkload.BulkLoadProcessor bulkLoadProcessor()
public org.apache.ignite.internal.processors.bulkload.BulkLoadAckClientParameters clientParams()
public List<List<?>> getAll()
Since all the results will be fetched, all the resources will be closed
automatically after this call, e.g. there is no need to call QueryCursor.close()
method in this case.
getAll
in interface QueryCursor<List<?>>
public void close()
Note: don't forget to close query cursors. Not doing so may lead to various resource leaks.
close
in interface AutoCloseable
close
in interface QueryCursor<List<?>>
public String getFieldName(int idx)
getFieldName
in interface FieldsQueryCursor<List<?>>
idx
- field index.public int getColumnsCount()
getColumnsCount
in interface FieldsQueryCursor<List<?>>
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024