org.nuxeo.importer.stream.automation

Class RandomDocumentProducers

java.lang.Object

org.nuxeo.importer.stream.automation.RandomDocumentProducers

All Implemented Interfaces:

RebalanceListener

public class RandomDocumentProducers
extends Object
implements RebalanceListener

Since:

9.1

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	avgBlobSizeKB
protected OperationContext	ctx
static String	DEFAULT_DOC_LOG_NAME
static String	ID
protected String	lang
protected String	logBlobInfoName
protected String	logConfig
protected String	logName
protected Integer	logSize
protected Integer	nbDocuments
protected Integer	nbThreads

Constructor Summary

Constructors

Constructor and Description
RandomDocumentProducers()

Method Summary

Modifier and Type	Method and Description
protected String	getLogConfig()
protected String	getLogName()
protected int	getLogSize()
void	onPartitionsAssigned(Collection<LogPartition> partitions)
void	onPartitionsRevoked(Collection<LogPartition> partitions)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

ID

public static final String ID

See Also:

Constant Field Values

DEFAULT_DOC_LOG_NAME

public static final String DEFAULT_DOC_LOG_NAME

See Also:

Constant Field Values

ctx

protected OperationContext ctx

nbDocuments

protected Integer nbDocuments

nbThreads

protected Integer nbThreads

avgBlobSizeKB

protected Integer avgBlobSizeKB

lang

protected String lang

logName

protected String logName

logSize

protected Integer logSize

logBlobInfoName

protected String logBlobInfoName

logConfig

protected String logConfig

Constructor Detail

RandomDocumentProducers

public RandomDocumentProducers()

Method Detail

run

public void run()

getLogConfig

protected String getLogConfig()

getLogName

protected String getLogName()

getLogSize

protected int getLogSize()

onPartitionsRevoked

public void onPartitionsRevoked(Collection<LogPartition> partitions)

Specified by:

onPartitionsRevoked in interface RebalanceListener

onPartitionsAssigned

public void onPartitionsAssigned(Collection<LogPartition> partitions)

Specified by:

onPartitionsAssigned in interface RebalanceListener