Package io.deephaven.kafka
Interface KafkaTools.TableType
- All Known Implementing Classes:
KafkaTools.TableType.Append
,KafkaTools.TableType.Blink
,KafkaTools.TableType.Ring
- Enclosing class:
- KafkaTools
public static interface KafkaTools.TableType
Type for the result
Table
returned by kafka consumers.-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic class
Consume data into an in-memory append-only table.static class
Consume data into an in-memory blink table, which will present only newly-available rows to downstream operations and visualizations.static class
Consume data into an in-memory ring table.static interface
-
Method Summary
Modifier and TypeMethodDescriptionstatic KafkaTools.TableType.Append
append()
static KafkaTools.TableType.Blink
blink()
static KafkaTools.TableType.Ring
ring
(int capacity) <T> T
walk
(KafkaTools.TableType.Visitor<T> visitor)
-
Method Details
-
blink
-
append
-
ring
-
walk
-