Package io.deephaven.iceberg.util

Interface IcebergTable

All Superinterfaces:

AttributeMap<Table>, DynamicNode, GridAttributes<Table>, LivenessManager, LivenessNode, LivenessReferent, LogOutputAppendable, LongSizedDataStructure, NotificationQueue.Dependency, SystemicObject<Table>, Table, TableOperations<Table,Table>

All Known Implementing Classes:

IcebergTableImpl

public interface IcebergTable
extends Table

Field Summary

Fields inherited from interface io.deephaven.engine.table.GridAttributes

COLUMN_DESCRIPTIONS_ATTRIBUTE, DESCRIPTION_ATTRIBUTE, LAYOUT_HINTS_ATTRIBUTE, SORTABLE_COLUMNS_ATTRIBUTE

Fields inherited from interface io.deephaven.engine.table.Table

ADD_ONLY_TABLE_ATTRIBUTE, AGGREGATION_ROW_LOOKUP_ATTRIBUTE, APPEND_ONLY_TABLE_ATTRIBUTE, BARRAGE_PERFORMANCE_KEY_ATTRIBUTE, BLINK_TABLE_ATTRIBUTE, FILTERABLE_COLUMNS_ATTRIBUTE, INITIALLY_EMPTY_COALESCED_SOURCE_TABLE_ATTRIBUTE, INPUT_TABLE_ATTRIBUTE, KEY_COLUMNS_ATTRIBUTE, MERGED_TABLE_ATTRIBUTE, NON_DISPLAY_TABLE, PLUGIN_NAME, PREVIEW_PARENT_TABLE, SNAPSHOT_VIEWPORT_TYPE, SORT_REVERSE_LOOKUP_ATTRIBUTE, SORTED_COLUMNS_ATTRIBUTE, SYSTEMIC_TABLE_ATTRIBUTE, TEST_SOURCE_TABLE_ATTRIBUTE, TOTALS_TABLE_ATTRIBUTE, UNIQUE_KEYS_ATTRIBUTE

Fields inherited from interface io.deephaven.api.TableOperations

AGG_BY_PRESERVE_EMPTY_DEFAULT

Method Summary

Modifier and Type	Method	Description
void	update()	When the update mode for this table is IcebergUpdateMode.manualRefreshingMode(), this call will update the table with the latest snapshot from the catalog.
void	update(long snapshotId)	When the update mode for this table is IcebergUpdateMode.manualRefreshingMode(), this call will update the table with a specific snapshot from the catalog.
void	update(@NotNull org.apache.iceberg.Snapshot snapshot)	When the update mode for this table is IcebergUpdateMode.manualRefreshingMode(), this call will update the table with a specific snapshot from the catalog.

Methods inherited from interface io.deephaven.engine.table.AttributeMap

getAttribute, getAttributeKeys, getAttributes, getAttributes, hasAttribute, retainingAttributes, withAttributes, withAttributes, withoutAttributes

Methods inherited from interface io.deephaven.engine.updategraph.DynamicNode

addParentReference, setRefreshing

Methods inherited from interface io.deephaven.engine.table.GridAttributes

clearSortingRestrictions, restrictSortTo, setLayoutHints, withColumnDescription, withColumnDescriptions, withDescription

Methods inherited from interface io.deephaven.engine.liveness.LivenessManager

manage, tryManage, tryUnmanage, tryUnmanage, unmanage, unmanage

Methods inherited from interface io.deephaven.engine.liveness.LivenessReferent

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

Methods inherited from interface io.deephaven.base.log.LogOutputAppendable

append

Methods inherited from interface io.deephaven.util.datastructures.LongSizedDataStructure

intSize, intSize, size

Methods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency

getUpdateGraph, getUpdateGraph, satisfied

Methods inherited from interface io.deephaven.engine.util.systemicmarking.SystemicObject

isSystemicObject, markSystemic

Methods inherited from interface io.deephaven.engine.table.Table

addUpdateListener, addUpdateListener, addUpdateListener, addUpdateListener, apply, applyToAllBy, applyToAllBy, applyToAllBy, awaitUpdate, awaitUpdate, byteColumnIterator, characterColumnIterator, close, coalesce, columnIterator, doubleColumnIterator, dropColumnFormats, flatten, floatColumnIterator, formatColumns, formatColumnWhere, formatRowWhere, getColumnSource, getColumnSource, getColumnSource, getColumnSourceMap, getColumnSources, getDefinition, getDescription, getRowSet, getSubTable, hasColumns, hasColumns, headBy, headBy, headPct, integerColumnIterator, isEmpty, isFailed, isFlat, isRefreshing, longColumnIterator, meta, moveColumns, moveColumnsDown, moveColumnsUp, numColumns, objectColumnIterator, objectColumnIterator, partitionBy, partitionBy, partitionedAggBy, releaseCachedResources, removeBlink, removeUpdateListener, removeUpdateListener, renameAllColumns, renameColumns, renameColumns, rollup, rollup, rollup, rollup, rollup, rollup, setTotalsTable, shortColumnIterator, sizeForInstrumentation, slicePct, tailBy, tailBy, tailPct, tree, withKeys, withUniqueKeys, wouldMatch, wouldMatch

Methods inherited from interface io.deephaven.api.TableOperations

absSumBy, absSumBy, absSumBy, absSumBy, aggAllBy, aggAllBy, aggAllBy, aggAllBy, aggBy, aggBy, aggBy, aggBy, aggBy, aggBy, aggBy, aggBy, aj, aj, asOfJoin, avgBy, avgBy, avgBy, avgBy, countBy, countBy, countBy, countBy, dropColumns, dropColumns, dropColumns, exactJoin, exactJoin, exactJoin, firstBy, firstBy, firstBy, firstBy, groupBy, groupBy, groupBy, head, join, join, join, join, join, lastBy, lastBy, lastBy, lastBy, lazyUpdate, lazyUpdate, maxBy, maxBy, maxBy, maxBy, medianBy, medianBy, medianBy, medianBy, minBy, minBy, minBy, minBy, naturalJoin, naturalJoin, naturalJoin, raj, raj, rangeJoin, rangeJoin, reverse, select, select, select, selectDistinct, selectDistinct, selectDistinct, slice, snapshot, snapshotWhen, snapshotWhen, snapshotWhen, sort, sort, sortDescending, stdBy, stdBy, stdBy, stdBy, sumBy, sumBy, sumBy, sumBy, tail, ungroup, ungroup, ungroup, ungroup, ungroup, update, update, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateView, updateView, varBy, varBy, varBy, varBy, view, view, wavgBy, wavgBy, wavgBy, wavgBy, where, where, whereIn, whereIn, whereNotIn, whereNotIn, wsumBy, wsumBy, wsumBy, wsumBy

Method Details

update

void update()

When the update mode for this table is IcebergUpdateMode.manualRefreshingMode(), this call will update the table with the latest snapshot from the catalog.

If any other update mode is specified, this call will throw an UnsupportedOperationException.

update

void update(long snapshotId)

When the update mode for this table is IcebergUpdateMode.manualRefreshingMode(), this call will update the table with a specific snapshot from the catalog. If the snapshotId is not found in the list of snapshots for the table, an IllegalArgumentException is thrown. The input snapshot must also be newer (higher in sequence number) than the current snapshot or an IllegalArgumentException is thrown.

If any other update mode is specified, this call will throw an UnsupportedOperationException.

Parameters:

snapshotId - The identifier of the snapshot to use when updating the table.

update

void update(@NotNull
 @NotNull org.apache.iceberg.Snapshot snapshot)

When the update mode for this table is IcebergUpdateMode.manualRefreshingMode(), this call will update the table with a specific snapshot from the catalog. The input snapshot must be newer (higher in sequence number) than the current snapshot or an IllegalArgumentException is thrown.

If any other update mode is specified, this call will throw an UnsupportedOperationException.

Parameters:

snapshot - The snapshot to use when updating the table.