Modifier and Type | Method and Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
RecordPublisher.run(RecordPublisher.RecordBatchConsumer recordBatchConsumer)
Run the record publisher.
|
static RecordPublisher.RecordPublisherRunResult |
RecordPublisher.RecordPublisherRunResult.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static RecordPublisher.RecordPublisherRunResult[] |
RecordPublisher.RecordPublisherRunResult.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
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.