org.nuxeo.ecm.core.bulk

Class StreamBulkProcessor.KeyValueWriterComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.StreamBulkProcessor.KeyValueWriterComputation

All Implemented Interfaces:

Computation

Enclosing class:

StreamBulkProcessor

public static class StreamBulkProcessor.KeyValueWriterComputation
extends AbstractComputation

Field Summary

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

metadata

Constructor Summary

Constructors

Constructor and Description
KeyValueWriterComputation(String name)

Method Summary

Modifier and Type	Method and 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, 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

KeyValueWriterComputation

public KeyValueWriterComputation(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.