org.nuxeo.lib.stream.computation

Class AbstractComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

All Implemented Interfaces:

Computation

Direct Known Subclasses:

StreamAuditWriter.AuditLogWriterComputation, WorkComputation

public abstract class AbstractComputation
extends Object
implements Computation

An abstract Computation that manages the metadata init. The inputs streams are named i1, i2 ... The output streams are named o1, o2 ...

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected ComputationMetadata	metadata

Constructor Summary

Constructors

Constructor and Description
AbstractComputation(String name, int nbInputStreams, int nbOutputStreams)

Method Summary

Modifier and Type	Method and Description
void	init(ComputationContext context) Called when the framework has registered the computation successfully.
ComputationMetadata	metadata() Identify the computation.
void	processTimer(ComputationContext context, String key, long timestamp) Process a timer callback previously set via ComputationContext.setTimer(String, long).

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

destroy, processRecord

Field Detail

metadata

protected final ComputationMetadata metadata

Constructor Detail

AbstractComputation

public AbstractComputation(String name,
                           int nbInputStreams,
                           int nbOutputStreams)

Method Detail

init

public void init(ComputationContext context)

Description copied from interface: Computation

Called when the framework has registered the computation successfully. Gives users a first opportunity to schedule timer callbacks and produce records.

Specified by:

init in interface Computation

Parameters:

context - The computation context object provided by the system.

processTimer

public void processTimer(ComputationContext context,
                         String key,
                         long timestamp)

Description copied from interface: Computation

Process a timer callback previously set via ComputationContext.setTimer(String, long).

Specified by:

processTimer in interface Computation

Parameters:

context - The computation context object provided by the system.

key - The name of the timer.

timestamp - The timestamp (in ms) for which the callback was scheduled.

metadata

public ComputationMetadata metadata()

Description copied from interface: Computation

Identify the computation.

Specified by:

metadata in interface Computation

Returns:

computation's metadata.