Package io.deephaven.extensions.barrage.chunk

Class DictionaryWriterRegistryImpl

java.lang.Object

io.deephaven.extensions.barrage.chunk.DictionaryWriterRegistryImpl

All Implemented Interfaces:

DictionaryWriterRegistry

public final class DictionaryWriterRegistryImpl
extends Object
implements DictionaryWriterRegistry

The server-side DictionaryWriterRegistry implementation, backed by fastutil maps.

Two construction modes:

• Local (default constructor) — for viewport subscriptions and snapshots. Each registry creates LocalDictionaryWriterState instances that are fully private to this stream.
• Shared-backed (DictionaryWriterRegistryImpl(Long2ObjectOpenHashMap) constructor) — for full subscriptions and growing subscriptions targeting a full subscription. Each registry creates SharedDictionaryWriterState instances that delegate index lookups to the table-level SharedWriterDictionary, so all full subscribers share the same value-to-index mapping.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.extensions.barrage.chunk.DictionaryWriterRegistry

DictionaryWriterRegistry.Entry

Constructor Summary

Constructors

Constructor	Description
DictionaryWriterRegistryImpl()	Creates a local registry for viewport subscriptions and snapshots.
DictionaryWriterRegistryImpl(@NotNull it.unimi.dsi.fastutil.longs.Long2ObjectOpenHashMap<SharedWriterDictionary> sharedDictionaries)	Creates a shared-backed registry for full subscriptions and growing subscriptions targeting a full subscription.

Method Summary

Modifier and Type	Method	Description
@NotNull Collection<DictionaryWriterRegistry.Entry>	entries()	Returns all registered entries.
@NotNull DictionaryWriterState	getOrCreate(long dictId, @NotNull ChunkWriter<Chunk<Values>> valuesWriter, @NotNull ChunkType valuesChunkType)	Returns (or creates) the DictionaryWriterState for the given dictionary id.
boolean	hasAnyDelta()	Returns true if any registered dictionary has a pending delta that needs a DictionaryBatch message.
void	resetDeltas()	Advances the delta boundary for every registered state that currently has a pending delta.
void	resetOverflowedEntries(long liveRowCount)	Checks each registered DictionaryWriterState for overflow: if its totalSize exceeds liveRowCount, calls DictionaryWriterState.reset() so the next DictionaryBatch will be isDelta=false with a compacted dictionary.

Methods inherited from class java.lang.Object

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

Constructor Details

DictionaryWriterRegistryImpl

public DictionaryWriterRegistryImpl()

Creates a local registry for viewport subscriptions and snapshots.

DictionaryWriterRegistryImpl

public DictionaryWriterRegistryImpl(@NotNull
 @NotNull it.unimi.dsi.fastutil.longs.Long2ObjectOpenHashMap<SharedWriterDictionary> sharedDictionaries)

Creates a shared-backed registry for full subscriptions and growing subscriptions targeting a full subscription. The sharedDictionaries map is owned by the io.deephaven.server.barrage.BarrageMessageProducer and lives for the lifetime of the table's producer; it is never cleared.

Method Details

getOrCreate

@NotNull
public @NotNull DictionaryWriterState getOrCreate(long dictId,
 @NotNull
 @NotNull ChunkWriter<Chunk<Values>> valuesWriter,
 @NotNull
 @NotNull ChunkType valuesChunkType)

Description copied from interface: DictionaryWriterRegistry

Returns (or creates) the DictionaryWriterState for the given dictionary id.

The first call for a given dictId registers the valuesWriter for that id and creates the appropriate state type. Subsequent calls for the same id return the existing state.

Specified by:

getOrCreate in interface DictionaryWriterRegistry

entries

@NotNull
public @NotNull Collection<DictionaryWriterRegistry.Entry> entries()

Description copied from interface: DictionaryWriterRegistry

Returns all registered entries.

Specified by:

entries in interface DictionaryWriterRegistry

hasAnyDelta

public boolean hasAnyDelta()

Description copied from interface: DictionaryWriterRegistry

Returns true if any registered dictionary has a pending delta that needs a DictionaryBatch message.

Specified by:

hasAnyDelta in interface DictionaryWriterRegistry

resetDeltas

public void resetDeltas()

Description copied from interface: DictionaryWriterRegistry

Advances the delta boundary for every registered state that currently has a pending delta.

Specified by:

resetDeltas in interface DictionaryWriterRegistry

resetOverflowedEntries

public void resetOverflowedEntries(long liveRowCount)

Description copied from interface: DictionaryWriterRegistry

Checks each registered DictionaryWriterState for overflow: if its totalSize exceeds liveRowCount, calls DictionaryWriterState.reset() so the next DictionaryBatch will be isDelta=false with a compacted dictionary. Only call this for local (viewport/snapshot) registries; for shared-backed registries the SharedWriterDictionary is reset externally.

Specified by:

resetOverflowedEntries in interface DictionaryWriterRegistry

Parameters:

liveRowCount - the current number of live rows visible to this subscription