Package org.apache.ignite.internal.processors.streamer

TODO.

See: Description

Interface Summary

Interface	Description
IgniteStreamerEx	Extended streamer context with methods intended for internal use.

Class Summary

Class	Description
GridStreamerAttributes
GridStreamerCancelRequest	Streamer cancel request.
GridStreamerContextDelegate	Context delegate allowing to override next stage name.
GridStreamerContextImpl	Streamer context implementation.
GridStreamerExecutionBatch	Streamer execution batch which should be processed on one node.
GridStreamerExecutionRequest
GridStreamerResponse
GridStreamerStageExecutionFuture	Streamer execution future.
GridStreamerWindowIterator<T>	Helper iterator extension which prevents regular element remove and adds removex() method tracking which element was actually removed.
GridStreamProcessor
IgniteStreamerImpl
StreamerMBeanAdapter	Streamer MBean implementation.
StreamerMetricsAdapter	Streamer metrics adapter.
StreamerMetricsHolder	Metrics holder.
StreamerStageMBeanAdapter	Streamer stage MBean adapter.
StreamerStageMetricsAdapter	Streamer stage metrics adapter.
StreamerStageMetricsHolder	Streamer stage metrics holder.
StreamerStageWrapper	Stage wrapper that handles metrics calculation and time measurement.
StreamerWindowMetricsAdapter	Streamer window metrics adapter.
StreamerWindowMetricsHolder	Streamer window metrics holder.

Exception Summary

Exception	Description
GridStreamerRouteFailedException	Exception thrown when router did not return route map.

Package org.apache.ignite.internal.processors.streamer Description

TODO.