Modifier and Type | Method and Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
RecordPublisher.run(RecordPublisher.RecordBatchConsumer recordBatchConsumer)
Run the record publisher.
|
Modifier and Type | Method and Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
FanOutRecordPublisher.run(RecordPublisher.RecordBatchConsumer recordConsumer) |
Modifier and Type | Method and Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
PollingRecordPublisher.run(RecordPublisher.RecordBatchConsumer consumer) |
RecordPublisher.RecordPublisherRunResult |
AdaptivePollingRecordPublisher.run(RecordPublisher.RecordBatchConsumer consumer) |
RecordPublisher.RecordPublisherRunResult |
PollingRecordPublisher.run(RecordPublisher.RecordBatchConsumer consumer,
int maxNumberOfRecords) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.