org.nuxeo.importer.stream.producer

Class FileBlobMessageProducer

java.lang.Object

org.nuxeo.lib.stream.pattern.producer.AbstractProducer<BlobMessage>

org.nuxeo.importer.stream.producer.FileBlobMessageProducer

All Implemented Interfaces:

AutoCloseable, Iterator<BlobMessage>, ProducerIterator<BlobMessage>

public class FileBlobMessageProducer
extends AbstractProducer<BlobMessage>

Use a listing file to generate BlobMessage.

Since:

9.1

Field Summary

Fields

Modifier and Type	Field and Description
protected String	basePath
protected long	count
protected Iterator<String>	fileIterator
protected Stream<String>	lines
protected File	listFile
protected long	nbBlobs

Fields inherited from class org.nuxeo.lib.stream.pattern.producer.AbstractProducer

producerId

Constructor Summary

Constructors

Constructor and Description
FileBlobMessageProducer(int producerId, File listFile, String basePath, long nbBlobs)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	getFileIterator()
int	getPartition(BlobMessage message, int partitions) Returns a partition associated with the Message.
boolean	hasNext()
BlobMessage	next()

Methods inherited from class org.nuxeo.lib.stream.pattern.producer.AbstractProducer

getProducerId

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.pattern.producer.ProducerIterator

remove

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

listFile

protected final File listFile

basePath

protected final String basePath

count

protected long count

nbBlobs

protected final long nbBlobs

fileIterator

protected Iterator<String> fileIterator

lines

protected Stream<String> lines

Constructor Detail

FileBlobMessageProducer

public FileBlobMessageProducer(int producerId,
                               File listFile,
                               String basePath,
                               long nbBlobs)

Method Detail

getFileIterator

protected void getFileIterator()

getPartition

public int getPartition(BlobMessage message,
                        int partitions)

Description copied from interface: ProducerIterator

Returns a partition associated with the Message. The value returned must be between 0 and lower than partitions.

Parameters:

message - the message to shard

partitions - the number of partitions

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractProducer<BlobMessage>

Throws:

Exception

hasNext

public boolean hasNext()

next

public BlobMessage next()