-
Packages that use org.apache.ignite.internal.processors.streamer Package Description org.apache.ignite.internal Contains main implementation.org.apache.ignite.internal.processors.streamer 
TODO.org.apache.ignite.streamer.window Contains streamer window implementations. -
Classes in org.apache.ignite.internal.processors.streamer used by org.apache.ignite.internal Class and Description GridStreamProcessor -
Classes in org.apache.ignite.internal.processors.streamer used by org.apache.ignite.internal.processors.streamer Class and Description GridStreamerExecutionBatch Streamer execution batch which should be processed on one node.GridStreamerStageExecutionFuture Streamer execution future.IgniteStreamerEx Extended streamer context with methods intended for internal use.IgniteStreamerImpl StreamerMetricsHolder Metrics holder.StreamerStageMetricsHolder Streamer stage metrics holder.StreamerWindowMetricsHolder Streamer window metrics holder. -
Classes in org.apache.ignite.internal.processors.streamer used by org.apache.ignite.streamer.window Class and Description GridStreamerWindowIterator Helper iterator extension which prevents regular element remove and adds removex() method tracking which element was actually removed.