Interface | Description |
---|---|
CoordinatedBolt.FinishedCallback | |
CoordinatedBolt.TimeoutCallback | |
IBatchBolt<T> |
Class | Description |
---|---|
BatchBoltExecutor | |
BatchOutputCollector | |
BatchOutputCollectorImpl | |
BatchSubtopologyBuilder | |
CoordinatedBolt |
Coordination requires the request ids to be globally unique for awhile.
|
CoordinatedBolt.IdStreamSpec | |
CoordinatedBolt.SourceArgs | |
CoordinatedBolt.TrackingInfo |
Copyright © 2022 The Apache Software Foundation. All rights reserved.