Package io.deephaven.kafka
Class KafkaTools.TableType.Blink
java.lang.Object
io.deephaven.kafka.KafkaTools.TableType.Blink
- All Implemented Interfaces:
KafkaTools.TableType
- Enclosing interface:
- KafkaTools.TableType
@Immutable
public abstract static class KafkaTools.TableType.Blink
extends Object
implements KafkaTools.TableType
Consume data into an in-memory blink table, which will present only newly-available rows to downstream operations and visualizations.
See Table.BLINK_TABLE_ATTRIBUTE
for a detailed explanation of blink table semantics, and
BlinkTableTools
for related tooling.
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.deephaven.kafka.KafkaTools.TableType
KafkaTools.TableType.Append, KafkaTools.TableType.Blink, KafkaTools.TableType.Ring, KafkaTools.TableType.Visitor<T>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic KafkaTools.TableType.Blink
of()
final <T> T
walk
(KafkaTools.TableType.Visitor<T> visitor)
-
Constructor Details
-
Blink
public Blink()
-
-
Method Details
-
of
-
walk
- Specified by:
walk
in interfaceKafkaTools.TableType
-