Interface | Description |
---|---|
MaxSegmentProvider |
Functional interface returning the maximum amount of segments a
Coordinator may claim, based on the given
processingGroup . |
Class | Description |
---|---|
PooledStreamingEventProcessor |
A
StreamingEventProcessor implementation which pools its resources to enhance processing speed. |
PooledStreamingEventProcessor.Builder |
Builder class to instantiate a
PooledStreamingEventProcessor . |
Copyright © 2010–2024. All rights reserved.