org.nuxeo.ecm.core.bulk

Class BulkServiceImpl

java.lang.Object

org.nuxeo.ecm.core.bulk.BulkServiceImpl

All Implemented Interfaces:

BulkService

public class BulkServiceImpl
extends Object
implements BulkService

Basic implementation of BulkService.

Since:

10.2

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	COMMAND
protected static String	PROCESSED_DOCUMENTS
protected static String	SCROLL_END_TIME
protected static String	SCROLL_START_TIME
protected static String	SCROLLED_DOCUMENT_COUNT
protected static String	SET_STREAM_NAME
protected static String	STATE
protected static String	SUBMIT_TIME

Constructor Summary

Constructors

Constructor and Description
BulkServiceImpl()

Method Summary

Modifier and Type	Method and Description
boolean	await(String commandId, Duration duration) Waits for completion of given bulk command.
KeyValueStore	getKvStore()
BulkStatus	getStatus(String commandId)
String	submit(BulkCommand command) Submits a BulkCommand that will be processed asynchronously.

Methods inherited from class java.lang.Object

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

Field Detail

SET_STREAM_NAME

protected static final String SET_STREAM_NAME

See Also:

Constant Field Values

COMMAND

protected static final String COMMAND

See Also:

Constant Field Values

SUBMIT_TIME

protected static final String SUBMIT_TIME

See Also:

Constant Field Values

SCROLL_START_TIME

protected static final String SCROLL_START_TIME

See Also:

Constant Field Values

SCROLL_END_TIME

protected static final String SCROLL_END_TIME

See Also:

Constant Field Values

STATE

protected static final String STATE

See Also:

Constant Field Values

PROCESSED_DOCUMENTS

protected static final String PROCESSED_DOCUMENTS

See Also:

Constant Field Values

SCROLLED_DOCUMENT_COUNT

protected static final String SCROLLED_DOCUMENT_COUNT

See Also:

Constant Field Values

Constructor Detail

BulkServiceImpl

public BulkServiceImpl()

Method Detail

submit

public String submit(BulkCommand command)

Description copied from interface: BulkService

Submits a BulkCommand that will be processed asynchronously.

Specified by:

submit in interface BulkService

Parameters:

command - the command to submit

Returns:

a unique bulk command identifier

getStatus

public BulkStatus getStatus(String commandId)

Specified by:

getStatus in interface BulkService

Returns:

the command status corresponding to the command identifier.

await

public boolean await(String commandId,
                     Duration duration)
              throws InterruptedException

Description copied from interface: BulkService

Waits for completion of given bulk command.

Specified by:

await in interface BulkService

Parameters:

commandId - the command to wait

duration - the duration to wait

Returns:

true if bulk command completed or false if computation has not finished after the timeout

Throws:

InterruptedException

getKvStore

public KeyValueStore getKvStore()