Package | Description |
---|---|
org.nuxeo.importer.stream.consumer | |
org.nuxeo.importer.stream.message | |
org.nuxeo.importer.stream.producer |
Modifier and Type | Method and Description |
---|---|
Consumer<BlobMessage> |
BlobMessageConsumerFactory.createConsumer(String consumerId) |
Modifier and Type | Method and Description |
---|---|
void |
BlobMessageConsumer.accept(BlobMessage message) |
protected BlobMessageConsumer.CloseableBlob |
BlobWatermarkMessageConsumer.addWatermark(BlobMessage message,
String watermark,
Watermarker watermarker) |
protected BlobMessageConsumer.CloseableBlob |
BlobWatermarkMessageConsumer.getBlob(BlobMessage message) |
protected BlobMessageConsumer.CloseableBlob |
BlobMessageConsumer.getBlob(BlobMessage message) |
protected void |
BlobMessageConsumer.saveBlobInfo(BlobMessage message,
String digest,
long length,
File blobFile) |
Modifier and Type | Method and Description |
---|---|
BlobMessage |
BlobMessage.StringMessageBuilder.build() |
Modifier and Type | Method and Description |
---|---|
BlobMessage |
RandomStringBlobMessageProducer.next() |
BlobMessage |
FileBlobMessageProducer.next() |
Modifier and Type | Method and Description |
---|---|
ProducerIterator<BlobMessage> |
RandomStringBlobMessageProducerFactory.createProducer(int producerId) |
ProducerIterator<BlobMessage> |
FileBlobMessageProducerFactory.createProducer(int producerId) |
Modifier and Type | Method and Description |
---|---|
int |
RandomStringBlobMessageProducer.getPartition(BlobMessage message,
int partitions) |
int |
FileBlobMessageProducer.getPartition(BlobMessage message,
int partitions) |
Copyright © 2019 Nuxeo. All rights reserved.