pyignite.cursors module¶
This module contains sync and async cursors for different types of queries.
-
class
pyignite.cursors.
ScanCursor
(client, cache_id, page_size, partitions, local)¶ Synchronous scan cursor.
-
__init__
(client, cache_id, page_size, partitions, local)¶ Parameters: - client – Synchronous Apache Ignite client.
- cache_id – Cache id.
- 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.
-
cache_id
¶ Cache id.
-
client
¶ Apache Ignite client.
-
close
()¶ Close cursor.
-
connection
¶ Ignite cluster connection.
-
cursor_id
¶ Cursor id.
-
data
¶ Current fetched data.
-
more
¶ Whether cursor has more values.
-
-
class
pyignite.cursors.
SqlCursor
(client, cache_id, *args, **kwargs)¶ Synchronous SQL query cursor.
-
__init__
(client, cache_id, *args, **kwargs)¶ Parameters: - client – Synchronous Apache Ignite client.
- cache_id – Cache id.
-
cache_id
¶ Cache id.
-
client
¶ Apache Ignite client.
-
close
()¶ Close cursor.
-
connection
¶ Ignite cluster connection.
-
cursor_id
¶ Cursor id.
-
data
¶ Current fetched data.
-
more
¶ Whether cursor has more values.
-
-
class
pyignite.cursors.
SqlFieldsCursor
(client, cache_id, *args, **kwargs)¶ Synchronous SQL fields query cursor.
-
__init__
(client, cache_id, *args, **kwargs)¶ Parameters: - client – Synchronous Apache Ignite client.
- cache_id – Cache id.
-
cache_id
¶ Cache id.
-
client
¶ Apache Ignite client.
-
close
()¶ Close cursor.
-
connection
¶ Ignite cluster connection.
-
cursor_id
¶ Cursor id.
-
data
¶ Current fetched data.
-
more
¶ Whether cursor has more values.
-
-
class
pyignite.cursors.
AioScanCursor
(client, cache_id, page_size, partitions, local)¶ Asynchronous scan query cursor.
-
__init__
(client, cache_id, page_size, partitions, local)¶ Parameters: - client – Asynchronous Apache Ignite client.
- cache_id – Cache id.
- 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.
-
cache_id
¶ Cache id.
-
client
¶ Apache Ignite client.
-
close
()¶ Close cursor.
-
connection
¶ Ignite cluster connection.
-
cursor_id
¶ Cursor id.
-
data
¶ Current fetched data.
-
more
¶ Whether cursor has more values.
-
-
class
pyignite.cursors.
AioSqlFieldsCursor
(client, cache_id, *args, **kwargs)¶ Asynchronous SQL fields query cursor.
-
__init__
(client, cache_id, *args, **kwargs)¶ Parameters: - client – Synchronous Apache Ignite client.
- cache_id – Cache id.
-
cache_id
¶ Cache id.
-
client
¶ Apache Ignite client.
-
close
()¶ Close cursor.
-
connection
¶ Ignite cluster connection.
-
cursor_id
¶ Cursor id.
-
data
¶ Current fetched data.
-
more
¶ Whether cursor has more values.
-