org.nuxeo.lib.stream.computation

Interface ComputationContext

All Known Implementing Classes:

ComputationContextImpl

public interface ComputationContext

Since:

9.3

Method Summary

Modifier and Type	Method and Description
void	askForCheckpoint() Ask for checkpoint in order to send records, save input stream offset positions.
void	produceRecord(String streamName, Record record)
default void	produceRecord(String streamName, String key, byte[] data) Emit a record downstream.
void	setSourceLowWatermark(long watermark) Set the low watermark for a source computation.
void	setTimer(String key, long time) Register a timer callback for some point in the future

Method Detail

setTimer

void setTimer(String key,
              long time)

Register a timer callback for some point in the future

Parameters:

key - Name of the timer callback.

time - The (ms since epoch) at which the callback should be fired

produceRecord

default void produceRecord(String streamName,
                           String key,
                           byte[] data)

Emit a record downstream. Records are send effectively on checkpoint using askForCheckpoint().

Parameters:

streamName - The name of the stream on which the record should be emitted.

key - The key associated with the record. Only relevant when routing method is `GROUP_BY`.

data: - The binary blob to send downstream.

produceRecord

void produceRecord(String streamName,
                   Record record)

setSourceLowWatermark

void setSourceLowWatermark(long watermark)

Set the low watermark for a source computation.

askForCheckpoint

void askForCheckpoint()

Ask for checkpoint in order to send records, save input stream offset positions.