Package org.nuxeo.ecm.platform.video.computation

Class RecomputeVideoInfoComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

org.nuxeo.ecm.platform.video.computation.RecomputeVideoInfoComputation

All Implemented Interfaces:

Computation

public class RecomputeVideoInfoComputation
extends AbstractBulkComputation

Computation that fills Video Info.

Since:

11.5

Field Summary

Fields

Modifier and Type	Field	Description
static String	NAME
static String	RECOMPUTE_ALL_VIDEO_INFO
protected Boolean	recomputeAll
protected Record	record

Fields inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

command, commands, delta, SELECT_DOCUMENTS_IN

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
RecomputeVideoInfoComputation()

Method Summary

Modifier and Type	Method	Description
protected void	compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)
void	endBucket(ComputationContext context, BulkStatus delta)	Can be overridden to write to downstream computation or add results to status
protected Duration	getBatchTransactionTimeout()
void	processRecord(ComputationContext context, String inputStreamName, Record record)	Process an incoming record on one of the computation's input streams.
void	startBucket(String bucketKey)	Can be overridden to init stuff before processing the bucket

Methods inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, loadDocumentsOneByOne, loginSystemOrUser, processBatchOfDocuments, processFailure, updateStatus

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

init, metadata, 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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

RECOMPUTE_ALL_VIDEO_INFO

public static final String RECOMPUTE_ALL_VIDEO_INFO

See Also:

Constant Field Values

recomputeAll

protected Boolean recomputeAll

record

protected Record record

Constructor Detail

RecomputeVideoInfoComputation

public RecomputeVideoInfoComputation()

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.

Specified by:

processRecord in interface Computation

Overrides:

processRecord in class AbstractBulkComputation

Parameters:

context - The computation context object provided by the system.

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

record - The record.

getBatchTransactionTimeout

protected Duration getBatchTransactionTimeout()

Overrides:

getBatchTransactionTimeout in class AbstractBulkComputation

Returns:

the transaction timeout to use to process the bucket, <= 0 for the default

startBucket

public void startBucket(String bucketKey)

Description copied from class: AbstractBulkComputation

Can be overridden to init stuff before processing the bucket

Overrides:

startBucket in class AbstractBulkComputation

compute

protected void compute(CoreSession session,
                       List<String> ids,
                       Map<String,Serializable> properties)

Specified by:

compute in class AbstractBulkComputation

endBucket

public void endBucket(ComputationContext context,
                      BulkStatus delta)

Description copied from class: AbstractBulkComputation

Can be overridden to write to downstream computation or add results to status

Overrides:

endBucket in class AbstractBulkComputation