Package org.nuxeo.ecm.core.bulk.computation

Class BulkStatusComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.computation.BulkStatusComputation

All Implemented Interfaces:

Computation

public class BulkStatusComputation
extends AbstractComputation

Saves the status into a key value store.

Inputs:

• i1: Reads BulkStatus sharded by command id

Outputs:

• o1: Write BulkStatus full into the done stream.

Since:

10.2

Field Summary

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
BulkStatusComputation(String name)

Method Summary

Modifier and Type	Method	Description
void	processRecord(ComputationContext context, String inputStreamName, Record record)	Process an incoming record on one of the computation's input streams.

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

init, metadata, processFailure, processRetry, processTimer

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, signalStop

Constructor Detail

BulkStatusComputation

public BulkStatusComputation(String name)

Method Detail

processRecord

public void processRecord(ComputationContext context,
                          String inputStreamName,
                          Record record)

Description copied from interface: Computation

Process an incoming record on one of the computation's input streams.

Parameters:

context - The computation context object provided by the system.

inputStreamName - Name of the input stream that provides the record.

record - The record.