Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.utils |
Class and Description |
---|
ForeachActionDispatcher
An
ForeachAction implementation that dispatches ForeachAction.apply(Object, Object)
invocation to registered actions. |
Lifecycle |
StateService
Return KafkaStream state.
|
WaitForDataService
This is a local implementation of our Data lookup AsyncBiFunctionService.
|
Class and Description |
---|
ForeachActionDispatcher
An
ForeachAction implementation that dispatches ForeachAction.apply(Object, Object)
invocation to registered actions. |
LongGenerator |
Copyright © 2020 Red Hat. All rights reserved.