Package | Description |
---|---|
org.apache.ignite.streamer |
Contains main Streaming APIs.
|
org.apache.ignite.streamer.router |
Contains streamer event router implementations.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamerEventRouterAdapter
Streamer adapter for event routers.
|
Modifier and Type | Method and Description |
---|---|
StreamerEventRouter |
StreamerConfiguration.getRouter()
Gets streamer event router.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamerConfiguration.setRouter(StreamerEventRouter router)
Sets router for streamer.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamerAffinityEventRouter
Router used to colocate identical streamer events or events with identical affinity
key on the same node.
|
class |
StreamerCacheAffinityEventRouter
Router used to colocate streamer events with data stored in a partitioned cache.
|
class |
StreamerLocalEventRouter
Local router.
|
class |
StreamerRandomEventRouter
Random router.
|
class |
StreamerRoundRobinEventRouter
Round robin router.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015