org.nuxeo.ecm.core.bulk

Class StreamBulkProcessor.BulkDocumentScrollerComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.StreamBulkProcessor.BulkDocumentScrollerComputation

All Implemented Interfaces:

Computation

Enclosing class:

StreamBulkProcessor

public static class StreamBulkProcessor.BulkDocumentScrollerComputation
extends AbstractComputation

Field Summary

Fields

Modifier and Type	Field and Description
protected int	bucketSize
protected List<String>	documentIds
protected int	scrollBatchSize
protected int	scrollKeepAliveSeconds

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

metadata

Constructor Summary

Constructors

Constructor and Description
BulkDocumentScrollerComputation(String name, int nbOutputStreams, int scrollBatchSize, int scrollKeepAliveSeconds, int bucketSize)

Method Summary

Modifier and Type	Method and Description
protected void	processRecord(ComputationContext context, Record record)
void	processRecord(ComputationContext context, String inputStreamName, Record record) Process an incoming record on one of the computation's input streams.
protected void	produceBucket(ComputationContext context, String action, String commandId, long nbDocSent) Produces a bucket as a record to appropriate bulk action stream.

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

Field Detail

scrollBatchSize

protected final int scrollBatchSize

scrollKeepAliveSeconds

protected final int scrollKeepAliveSeconds

bucketSize

protected final int bucketSize

documentIds

protected final List<String> documentIds

Constructor Detail

BulkDocumentScrollerComputation

public BulkDocumentScrollerComputation(String name,
                                       int nbOutputStreams,
                                       int scrollBatchSize,
                                       int scrollKeepAliveSeconds,
                                       int bucketSize)

Parameters:

name - the computation name

nbOutputStreams - the number of registered bulk action streams

scrollBatchSize - the batch size to scroll

scrollKeepAliveSeconds - the scroll lifetime

bucketSize - the number of document to send per bucket

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.

processRecord

protected void processRecord(ComputationContext context,
                             Record record)

produceBucket

protected void produceBucket(ComputationContext context,
                             String action,
                             String commandId,
                             long nbDocSent)

Produces a bucket as a record to appropriate bulk action stream.