pulsar.tableview.TableView

class documentation

class TableView: (source)

Constructor: TableView(table_view, topic, subscription, schema)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method __len__ Return the number of entries in the table view.
Method __repr__ Undocumented
Method __str__ Undocumented
Method close Close the table view.
Method for_each Iterate over all entries in the table view and call the callback function with the key and value for each entry.
Method for_each_and_listen Iterate over all entries in the table view and call the callback function with the key and value for each entry, then listen for changes. The callback will be called when a new entry is added or an existing entry is updated.
Method get Return the value associated with the given key in the table view.
Instance Variable _schema Undocumented
Instance Variable _subscription Undocumented
Instance Variable _table_view Undocumented
Instance Variable _topic Undocumented
def __init__(self, table_view: _pulsar.TableView, topic: str, subscription: str | None, schema: Schema): (source)

Undocumented

def __len__(self) -> int: (source)

Return the number of entries in the table view.

def __repr__(self) -> str: (source)

Undocumented

def __str__(self) -> str: (source)

Undocumented

def close(self): (source)

Close the table view.

def for_each(self, callback: Callable[[str, Any], None]): (source)

Iterate over all entries in the table view and call the callback function with the key and value for each entry.

Parameters
callback:Callable[[str, Any], None]The callback function to call for each entry.
def for_each_and_listen(self, callback: Callable[[str, Any], None]): (source)

Iterate over all entries in the table view and call the callback function with the key and value for each entry, then listen for changes. The callback will be called when a new entry is added or an existing entry is updated.

Parameters
callback:Callable[[str, Any], None]The callback function to call for each entry.
def get(self, key: str) -> Any | None: (source)

Return the value associated with the given key in the table view.

Parameters
key:strThe message key
Returns
Optional[Any]The value associated with the key, or None if the key does not exist.
_schema = (source)

Undocumented

_subscription = (source)

Undocumented

_table_view = (source)

Undocumented

_topic = (source)

Undocumented