deephaven.experimental

• data_index
  • DataIndex
    • DataIndex.j_object_type
    • DataIndex.keys
    • DataIndex.table
  • data_index()
  • has_data_index()
• ema
  • ByEmaSimple()
  • Ema()
  • EmaArray()
  • ExponentiallyDecayedSum()
• iceberg
  • IcebergCatalogAdapter
    • IcebergCatalogAdapter.create_table()
    • IcebergCatalogAdapter.j_object_type
    • IcebergCatalogAdapter.load_table()
    • IcebergCatalogAdapter.namespaces()
    • IcebergCatalogAdapter.tables()
  • IcebergReadInstructions
    • IcebergReadInstructions.j_object_type
  • IcebergTable
    • IcebergTable.abs_sum_by()
    • IcebergTable.agg_all_by()
    • IcebergTable.agg_by()
    • IcebergTable.aj()
    • IcebergTable.assert_sorted()
    • IcebergTable.attributes()
    • IcebergTable.avg_by()
    • IcebergTable.await_update()
    • IcebergTable.coalesce()
    • IcebergTable.column_names
    • IcebergTable.columns
    • IcebergTable.count_by()
    • IcebergTable.definition
    • IcebergTable.drop_columns()
    • IcebergTable.exact_join()
    • IcebergTable.first_by()
    • IcebergTable.flatten()
    • IcebergTable.format_column_where()
    • IcebergTable.format_columns()
    • IcebergTable.format_row_where()
    • IcebergTable.group_by()
    • IcebergTable.has_columns()
    • IcebergTable.head()
    • IcebergTable.head_by()
    • IcebergTable.head_pct()
    • IcebergTable.is_blink
    • IcebergTable.is_failed
    • IcebergTable.is_flat
    • IcebergTable.is_refreshing
    • IcebergTable.iter_chunk_dict()
    • IcebergTable.iter_chunk_tuple()
    • IcebergTable.iter_dict()
    • IcebergTable.iter_tuple()
    • IcebergTable.j_object_type
    • IcebergTable.join()
    • IcebergTable.last_by()
    • IcebergTable.layout_hints()
    • IcebergTable.lazy_update()
    • IcebergTable.max_by()
    • IcebergTable.median_by()
    • IcebergTable.meta_table
    • IcebergTable.min_by()
    • IcebergTable.move_columns()
    • IcebergTable.move_columns_down()
    • IcebergTable.move_columns_up()
    • IcebergTable.natural_join()
    • IcebergTable.partition_by()
    • IcebergTable.partitioned_agg_by()
    • IcebergTable.raj()
    • IcebergTable.range_join()
    • IcebergTable.remove_blink()
    • IcebergTable.rename_columns()
    • IcebergTable.restrict_sort_to()
    • IcebergTable.reverse()
    • IcebergTable.rollup()
    • IcebergTable.select()
    • IcebergTable.select_distinct()
    • IcebergTable.size
    • IcebergTable.slice()
    • IcebergTable.slice_pct()
    • IcebergTable.snapshot()
    • IcebergTable.snapshot_when()
    • IcebergTable.sort()
    • IcebergTable.sort_descending()
    • IcebergTable.std_by()
    • IcebergTable.sum_by()
    • IcebergTable.tail()
    • IcebergTable.tail_by()
    • IcebergTable.tail_pct()
    • IcebergTable.to_string()
    • IcebergTable.tree()
    • IcebergTable.ungroup()
    • IcebergTable.update()
    • IcebergTable.update_by()
    • IcebergTable.update_graph
    • IcebergTable.update_view()
    • IcebergTable.var_by()
    • IcebergTable.view()
    • IcebergTable.weighted_avg_by()
    • IcebergTable.weighted_sum_by()
    • IcebergTable.where()
    • IcebergTable.where_in()
    • IcebergTable.where_not_in()
    • IcebergTable.where_one_of()
    • IcebergTable.with_attributes()
    • IcebergTable.with_keys()
    • IcebergTable.with_order_for_column()
    • IcebergTable.with_unique_keys()
    • IcebergTable.without_attributes()
  • IcebergTableAdapter
    • IcebergTableAdapter.definition()
    • IcebergTableAdapter.j_object_type
    • IcebergTableAdapter.snapshots()
    • IcebergTableAdapter.table()
    • IcebergTableAdapter.table_writer()
  • IcebergTableWriter
    • IcebergTableWriter.append()
    • IcebergTableWriter.j_object_type
  • IcebergUpdateMode
    • IcebergUpdateMode.auto_refresh()
    • IcebergUpdateMode.j_object_type
    • IcebergUpdateMode.manual_refresh()
    • IcebergUpdateMode.static()
  • IcebergWriteInstructions
    • IcebergWriteInstructions.j_object_type
  • InferenceResolver
    • InferenceResolver.j_object_type
  • SchemaProvider
    • SchemaProvider.from_current()
    • SchemaProvider.from_current_snapshot()
    • SchemaProvider.from_schema_id()
    • SchemaProvider.from_snapshot_id()
    • SchemaProvider.j_object_type
  • SortOrderProvider
    • SortOrderProvider.from_sort_id()
    • SortOrderProvider.j_object_type
    • SortOrderProvider.unsorted()
    • SortOrderProvider.use_table_default()
    • SortOrderProvider.with_fail_on_unmapped()
    • SortOrderProvider.with_id()
  • TableParquetWriterOptions
    • TableParquetWriterOptions.j_object_type
  • UnboundResolver
    • UnboundResolver.j_object_type
  • adapter()
  • adapter_aws_glue()
  • adapter_s3_rest()
• outer_joins
  • full_outer_join()
  • left_outer_join()
• s3
  • Credentials
    • Credentials.anonymous()
    • Credentials.basic()
    • Credentials.default()
    • Credentials.j_object_type
    • Credentials.profile()
    • Credentials.resolving()
    • Credentials.session()
  • S3Instructions
    • S3Instructions.j_object_type
• sql
  • evaluate()
• table_data_service
  • TableDataService
    • TableDataService.j_object_type
    • TableDataService.make_partitioned_table()
    • TableDataService.make_table()
  • TableDataServiceBackend
    • TableDataServiceBackend.column_values()
    • TableDataServiceBackend.subscribe_to_table_location_size()
    • TableDataServiceBackend.subscribe_to_table_locations()
    • TableDataServiceBackend.table_location_size()
    • TableDataServiceBackend.table_locations()
    • TableDataServiceBackend.table_schema()
  • TableKey
  • TableLocationKey

This package contains experimental Deephaven features. Their interfaces are not yet stable and are subject to change.

time_window(table, ts_col, window, bool_col)

Creates a new table by applying a time window to the source table and adding a new Boolean column.

The value of the new Boolean column is set to false when the timestamp column value is older than the window from now or true otherwise. If the timestamp column value is null, the Boolean column value will be null as well. The result table ticks whenever the source table ticks, or modifies a row when it passes out of the window.

Parameters:

• table (Table) – the source table

• ts_col (str) – the timestamp column name

• window (int) – the size of the window in nanoseconds

• bool_col (str) – the name of the new Boolean column.

Return type:

Table

Returns:

a new Table

Raises:

DHError –