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.