deephaven_enterprise.system_table_logger

log_table(namespace, table_name, table, columnPartition, internalPartition=None, applicationVersion=None, zone=None, useLas=True, logDir=None)[source]

Write tableToLog to System storage.

The table is logged to Intraday storage and can be retrieved with db.live_table. Historical tables should be written using a merge process.

Parameters:

  • namespace (str) – the namespace of the table

  • table_name (str) – the name of the table

  • table (Table) – the table to log

  • columnPartition (str) – the column partition to log to, if None then uses the current date

  • internalPartition (Optional[str]) – the internal partition, if None an internal partition is generated

  • applicationVersion (Optional[int]) – the application version, if None defaults to zero

  • zone (Optional[str]) – the time zone ID (as interpreted by java.time.ZoneId.of)

  • useLas (bool) – use the log aggregator service (defaults to true)

  • logDir (Optional[str]) – the directory for writing binary log files (useLas must be false)

log_table_incremental(namespace, table_name, table, columnPartition, internalPartition=None, applicationVersion=None, zone=None, useLas=True, logDir=None)[source]

Write tableToLog to System storage.

The table is logged to Intraday storage and can be retrieved with db.live_table. Historical tables should be written using a merge process.

No rows should be removed or modified in tableToLog. Modifications are an error. If the table is not a <i>blink</i> table, then removals are an error.

Parameters:

  • namespace (str) – the namespace of the table

  • table_name (str) – the name of the table

  • table (Table) – the table to log

  • columnPartition (str) – the column partition to log to, if None then uses the current date

  • internalPartition (Optional[str]) – the internal partition, if None an internal partition is generated

  • applicationVersion (Optional[int]) – the application version, if None defaults to zero

  • zone (Optional[str]) – the time zone ID (as interpreted by java.time.ZoneId.of)

  • useLas (bool) – use the log aggregator service (defaults to true)

  • logDir (Optional[str]) – the directory for writing binary log files (useLas must be false)

Returns:

a context manager that can be used in a with statement, or alternatively you can call close() when complete.

Users should hold this return value to ensure liveness for writing.