pyignite.cursors module¶
This module contains sync and async cursors for different types of queries.
- class pyignite.cursors.AioScanCursor(client, cache_info, page_size, partitions, local)¶
Asynchronous scan query cursor.
- __init__(client, cache_info, page_size, partitions, local)¶
- Parameters
client – Asynchronous Apache Ignite client.
cache_info – Cache meta info.
page_size – page size.
partitions – number of partitions to query (negative to query entire cache).
local – pass True if this query should be executed on local node only.
- property cache_info¶
Cache id.
- property client¶
Apache Ignite client.
- async close()¶
Close cursor.
- property connection¶
Ignite cluster connection.
- property cursor_id¶
Cursor id.
- property data¶
Current fetched data.
- property more¶
Whether cursor has more values.
- class pyignite.cursors.AioSqlFieldsCursor(client, cache_info, *args, **kwargs)¶
Asynchronous SQL fields query cursor.
- __init__(client, cache_info, *args, **kwargs)¶
- Parameters
client – Synchronous Apache Ignite client.
cache_info – Cache meta info.
- property cache_info¶
Cache id.
- property client¶
Apache Ignite client.
- async close()¶
Close cursor.
- property connection¶
Ignite cluster connection.
- property cursor_id¶
Cursor id.
- property data¶
Current fetched data.
- property more¶
Whether cursor has more values.
- class pyignite.cursors.ScanCursor(client, cache_info, page_size, partitions, local)¶
Synchronous scan cursor.
- __init__(client, cache_info, page_size, partitions, local)¶
- Parameters
client – Synchronous Apache Ignite client.
cache_info – Cache meta info.
page_size – page size.
partitions – number of partitions to query (negative to query entire cache).
local – pass True if this query should be executed on local node only.
- property cache_info¶
Cache id.
- property client¶
Apache Ignite client.
- close()¶
Close cursor.
- property connection¶
Ignite cluster connection.
- property cursor_id¶
Cursor id.
- property data¶
Current fetched data.
- property more¶
Whether cursor has more values.
- class pyignite.cursors.SqlCursor(client, cache_info, *args, **kwargs)¶
Synchronous SQL query cursor.
- __init__(client, cache_info, *args, **kwargs)¶
- Parameters
client – Synchronous Apache Ignite client.
cache_info – Cache meta info.
- property cache_info¶
Cache id.
- property client¶
Apache Ignite client.
- close()¶
Close cursor.
- property connection¶
Ignite cluster connection.
- property cursor_id¶
Cursor id.
- property data¶
Current fetched data.
- property more¶
Whether cursor has more values.
- class pyignite.cursors.SqlFieldsCursor(client, cache_info, *args, **kwargs)¶
Synchronous SQL fields query cursor.
- __init__(client, cache_info, *args, **kwargs)¶
- Parameters
client – Synchronous Apache Ignite client.
cache_info – Cache meta info.
- property cache_info¶
Cache id.
- property client¶
Apache Ignite client.
- close()¶
Close cursor.
- property connection¶
Ignite cluster connection.
- property cursor_id¶
Cursor id.
- property data¶
Current fetched data.
- property more¶
Whether cursor has more values.