Package io.deephaven.kafka

Class KafkaTools.TableType.Ring

java.lang.Object

io.deephaven.kafka.KafkaTools.TableType.Ring

All Implemented Interfaces:

KafkaTools.TableType

Enclosing interface:

KafkaTools.TableType

@Immutable
public abstract static class KafkaTools.TableType.Ring
extends Object
implements KafkaTools.TableType

Consume data into an in-memory ring table.

See Also:

• RingTableTools.of(Table, int)

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

Constructor	Description
Ring()

Method Summary

Modifier and Type	Method	Description
abstract int	capacity()
static KafkaTools.TableType.Ring	of(int capacity)
final <T> T	walk(KafkaTools.TableType.Visitor<T> visitor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Ring

public Ring()

Method Details

of

public static KafkaTools.TableType.Ring of(int capacity)

capacity

@Parameter
public abstract int capacity()

walk

public final <T> T walk(KafkaTools.TableType.Visitor<T> visitor)

Specified by:

walk in interface KafkaTools.TableType