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()
    • 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.

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