deephaven.stream

• kafka
  • cdc
    • CDCSpec
      • CDCSpec.j_object_type
    • cdc_long_spec()
    • cdc_short_spec()
    • consume()
    • consume_raw()
  • consumer
    • ALL_PARTITIONS_DONT_SEEK
    • ALL_PARTITIONS_SEEK_TO_BEGINNING
    • ALL_PARTITIONS_SEEK_TO_END
    • DONT_SEEK
    • KeyValueSpec
      • KeyValueSpec.j_object_type
    • ProtobufProtocol
      • ProtobufProtocol.j_object_type
      • ProtobufProtocol.raw()
      • ProtobufProtocol.serdes()
    • SEEK_TO_BEGINNING
    • SEEK_TO_END
    • TableType
      • TableType.append()
      • TableType.blink()
      • TableType.j_object_type
      • TableType.ring()
      • TableType.stream()
    • avro_spec()
    • consume()
    • consume_to_partitioned_table()
    • json_spec()
    • object_processor_spec()
    • protobuf_spec()
    • simple_spec()
  • producer
    • KeyValueSpec
      • KeyValueSpec.j_object_type
    • avro_spec()
    • json_spec()
    • produce()
    • simple_spec()
  • topics()
• table_publisher
  • TablePublisher
    • TablePublisher.add()
    • TablePublisher.is_alive
    • TablePublisher.j_object_type
    • TablePublisher.publish_failure()
  • table_publisher()

Utility module for the stream subpackage.

add_only_to_blink(table)

Creates a blink table from the given add-only table. The blink table contains the rows added in the latest update cycle.

Note that the use of this function should be limited to add-only tables that are not fully in-memory, or when blink table specific aggregation semantics are desired. If the table is fully in-memory, creating a downstream blink table is not recommended because it doesn’t achieve the main benefit of blink tables, which is to reduce memory usage but instead increases memory usage.

Parameters:

table (Table) – the source table

Return type:

Table

Returns:

a blink table

Raises:

DHError –

blink_to_append_only(table)

Creates an ‘append only’ table from the blink table.

Parameters:

table (Table) – a blink table

Return type:

Table

Returns:

an append-only table

Raises:

DHError –

stream_to_append_only(table)

Deprecated synonym for blink_to_append_only

Return type:

Table