IcebergUpdateMode
The IcebergUpdateMode
class defines the modes available for updating Deephaven tables that are backed by Iceberg tables. The update modes determine how the Deephaven table reflects changes made to the underlying Iceberg table.
Constructors
An instance of IcebergUpdateMode
is created using one of the class's static methods:
import io.deephaven.iceberg.util.IcebergUpdateMode
autoRefreshingMode = IcebergUpdateMode.autoRefreshingMode()
autoRefreshingModeRefreshInterval = IcebergUpdateMode.autoRefreshingMode(refreshMs)
manualRefreshingMode = IcebergUpdateMode.manualRefreshingMode()
staticMode = IcebergUpdateMode.staticMode()
Parameters
refreshMs
: The milliseconds between refreshes when using the auto-refreshing mode. If not specified, the default is 60,000 milliseconds (1 minute).
Methods
The IcebergUpdateMode
class provides the following methods:
autoRefreshMs
: Set the refresh interval in milliseconds for the auto-refreshing mode. Use of this method is only necessary if auto-refreshing mode was created with the zero-argument constructor.updateType
: Set the update mode for the resultant table. The default is static mode.
Examples
The following code block constructs update modes for static, manual refreshing, and auto-refreshing Iceberg tables:
import io.deephaven.iceberg.util.IcebergUpdateMode
staticMode = IcebergUpdateMode.staticMode()
manualRefreshingMode = IcebergUpdateMode.manualRefreshingMode()
autoRefreshingMode = IcebergUpdateMode.autoRefreshingMode()
autoRefreshingMode30s = IcebergUpdateMode.autoRefreshingMode(30000)