Package org.nuxeo.ecm.core.bulk.message
Class BulkCommand
- java.lang.Object
-
- org.nuxeo.ecm.core.bulk.message.BulkCommand
-
- All Implemented Interfaces:
Serializable
public class BulkCommand extends Object implements Serializable
A message representing a bulk command- Since:
- 10.2
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classBulkCommand.Builder
-
Field Summary
Fields Modifier and Type Field Description protected Stringactionprotected intbatchSizeprotected LongbatchTransactionTimeoutprotected intbucketSizeprotected Booleanexclusiveprotected booleanexternalScrollerprotected booleangenericScrollerprotected Stringidprotected Map<String,Serializable>paramsprotected Stringqueryprotected LongqueryLimitprotected Stringrepositoryprotected Stringscrollerprotected BooleansequentialProcessingprotected BooleansequentialScrollprotected Stringusername
-
Constructor Summary
Constructors Modifier Constructor Description protectedBulkCommand()BulkCommand(BulkCommand.Builder builder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)StringgetAction()intgetBatchSize()DurationgetBatchTransactionTimeout()Precision is second.intgetBucketSize()BooleangetExclusive()StringgetId()<T> TgetParam(String key)Map<String,Serializable>getParams()StringgetQuery()LonggetQueryLimit()When greater than 0, the limit applied to the query resultsStringgetRepository()StringgetScroller()BooleangetSequentialProcessing()BooleangetSequentialScroll()StringgetUsername()inthashCode()voidsetBatchSize(int batchSize)voidsetBatchTransactionTimeout(Duration timeout)Precision is second.voidsetBucketSize(int bucketSize)voidsetQueryLimit(Long limit)voidsetRepository(String repository)voidsetScroller(String scrollerName)StringtoString()booleanuseExternalScroller()True if the command uses an external scroller.booleanuseGenericScroller()True if the command uses a generic scroller.
-
-
-
Field Detail
-
id
protected String id
-
action
protected String action
-
query
protected String query
-
queryLimit
@Nullable protected Long queryLimit
-
username
protected String username
-
repository
@Nullable protected String repository
-
bucketSize
protected int bucketSize
-
batchSize
protected int batchSize
-
batchTransactionTimeout
@Nullable protected Long batchTransactionTimeout
-
scroller
@Nullable protected String scroller
-
genericScroller
protected boolean genericScroller
-
externalScroller
protected boolean externalScroller
-
sequentialScroll
@Nullable protected Boolean sequentialScroll
-
sequentialProcessing
@Nullable protected Boolean sequentialProcessing
-
exclusive
@Nullable protected Boolean exclusive
-
params
protected Map<String,Serializable> params
-
-
Constructor Detail
-
BulkCommand
protected BulkCommand()
-
BulkCommand
public BulkCommand(BulkCommand.Builder builder)
-
-
Method Detail
-
getUsername
public String getUsername()
-
getRepository
public String getRepository()
-
getQuery
public String getQuery()
-
getAction
public String getAction()
-
getScroller
public String getScroller()
-
getSequentialScroll
public Boolean getSequentialScroll()
-
getSequentialProcessing
public Boolean getSequentialProcessing()
-
getExclusive
public Boolean getExclusive()
-
useGenericScroller
public boolean useGenericScroller()
True if the command uses a generic scroller.- Since:
- 11.1
-
useExternalScroller
public boolean useExternalScroller()
True if the command uses an external scroller.- Since:
- 11.3
-
getParams
public Map<String,Serializable> getParams()
-
getParam
public <T> T getParam(String key)
-
getId
public String getId()
-
getBucketSize
public int getBucketSize()
-
getBatchSize
public int getBatchSize()
-
getBatchTransactionTimeout
public Duration getBatchTransactionTimeout()
Precision is second.- Since:
- 11.5
-
getQueryLimit
public Long getQueryLimit()
When greater than 0, the limit applied to the query results- Since:
- 11.4
-
setQueryLimit
public void setQueryLimit(Long limit)
-
setBatchSize
public void setBatchSize(int batchSize)
-
setBucketSize
public void setBucketSize(int bucketSize)
-
setBatchTransactionTimeout
public void setBatchTransactionTimeout(Duration timeout)
Precision is second.- Since:
- 11.5
-
setRepository
public void setRepository(String repository)
-
setScroller
public void setScroller(String scrollerName)
-
-