Package io.deephaven.iceberg.util
Class IcebergUpdateMode
java.lang.Object
io.deephaven.iceberg.util.IcebergUpdateMode
-
Nested Class Summary
Modifier and TypeClassDescriptionprotected static interface
static enum
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic IcebergUpdateMode
Set an automatically-refreshing update mode for this table using the default refresh interval of 60 seconds.static IcebergUpdateMode
autoRefreshingMode
(long refreshMs) Set an automatically-refreshing update mode for this table using the provided refresh interval.long
When the update type isIcebergUpdateMode.IcebergUpdateType.AUTO_REFRESHING
, this value specifies the minimum interval in milliseconds between automatic refreshes of the table.protected void
static IcebergUpdateMode
Set a manually-refreshing update mode for this table.static IcebergUpdateMode
Set a static update mode for this table.Set the update mode for the result table.
-
Constructor Details
-
IcebergUpdateMode
public IcebergUpdateMode()
-
-
Method Details
-
staticMode
Set a static update mode for this table. -
manualRefreshingMode
Set a manually-refreshing update mode for this table. The ordering of the data in the table will depend on the order in which the data files are discovered on refresh. -
autoRefreshingMode
Set an automatically-refreshing update mode for this table using the default refresh interval of 60 seconds. The ordering of the data in the table will depend on the order in which the data files are discovered on refresh. -
autoRefreshingMode
Set an automatically-refreshing update mode for this table using the provided refresh interval. The ordering of the data in the table will depend on the order in which the data files are discovered on refresh.- Parameters:
refreshMs
- the refresh interval in milliseconds
-
updateType
Set the update mode for the result table. The default isIcebergUpdateMode.IcebergUpdateType.STATIC
. -
autoRefreshMs
@Default public long autoRefreshMs()When the update type isIcebergUpdateMode.IcebergUpdateType.AUTO_REFRESHING
, this value specifies the minimum interval in milliseconds between automatic refreshes of the table. -
checkAutoRefreshingInterval
@Check protected void checkAutoRefreshingInterval()
-