Package io.deephaven.server.barrage

Class BarrageMessageProducer.Operation<MessageView>

java.lang.Object

io.deephaven.server.barrage.BarrageMessageProducer.Operation<MessageView>

All Implemented Interfaces:

QueryTable.MemoizableOperation<BarrageMessageProducer<MessageView>>, QueryTable.Operation<BarrageMessageProducer<MessageView>>

Enclosing class:

BarrageMessageProducer<MessageView>

public static class BarrageMessageProducer.Operation<MessageView>
extends Object
implements QueryTable.MemoizableOperation<BarrageMessageProducer<MessageView>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BarrageMessageProducer.Operation.Factory<MessageView>

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.QueryTable.Operation

QueryTable.Operation.Result<T extends DynamicNode & NotificationStepReceiver>

Constructor Summary

Constructors

Constructor	Description
Operation(Scheduler scheduler, SessionService.ErrorTransformer errorTransformer, BarrageStreamGenerator.Factory<MessageView> streamGeneratorFactory, BaseTable<?> parent, long updateIntervalMs)
Operation(Scheduler scheduler, SessionService.ErrorTransformer errorTransformer, BarrageStreamGenerator.Factory<MessageView> streamGeneratorFactory, BaseTable<?> parent, long updateIntervalMs, @Nullable Runnable onGetSnapshot)

Method Summary

Modifier and Type	Method	Description
String	getDescription()
String	getLogPrefix()
MemoizedOperationKey	getMemoizedOperationKey()
QueryTable.Operation.Result<BarrageMessageProducer<MessageView>>	initialize(boolean usePrev, long beforeClock)	Initialize this operation.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.table.impl.QueryTable.Operation

newSnapshotControl, snapshotNeeded

Constructor Details

Operation

@AssistedInject
public Operation(Scheduler scheduler,
 SessionService.ErrorTransformer errorTransformer,
 BarrageStreamGenerator.Factory<MessageView> streamGeneratorFactory,
 @Assisted
 BaseTable<?> parent,
 @Assisted
 long updateIntervalMs)

Operation

public Operation(Scheduler scheduler,
 SessionService.ErrorTransformer errorTransformer,
 BarrageStreamGenerator.Factory<MessageView> streamGeneratorFactory,
 BaseTable<?> parent,
 long updateIntervalMs,
 @Nullable
 @Nullable Runnable onGetSnapshot)

Method Details

getDescription

public String getDescription()

Specified by:

getDescription in interface QueryTable.Operation<MessageView>

Returns:

the description of this operation

getLogPrefix

public String getLogPrefix()

Specified by:

getLogPrefix in interface QueryTable.Operation<MessageView>

Returns:

the log prefix of this operation

getMemoizedOperationKey

public MemoizedOperationKey getMemoizedOperationKey()

Specified by:

getMemoizedOperationKey in interface QueryTable.MemoizableOperation<MessageView>

Returns:

the key that should be used to memoize off of

initialize

public QueryTable.Operation.Result<BarrageMessageProducer<MessageView>> initialize(boolean usePrev,
 long beforeClock)

Description copied from interface: QueryTable.Operation

Initialize this operation.

Specified by:

initialize in interface QueryTable.Operation<MessageView>

Parameters:

usePrev - data from the previous cycle should be used (otherwise use this cycle)

beforeClock - the clock value that we captured before the function began; the function can use this value to bail out early if it notices something has gone wrong.

Returns:

the result table / listener if successful, null if it should be retried.