| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.streamer |
TODO. |
| org.apache.ignite.streamer |
Contains main Streaming APIs.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StreamerStageWrapper
Stage wrapper that handles metrics calculation and time measurement.
|
| Modifier and Type | Method and Description |
|---|---|
StreamerStage |
StreamerStageWrapper.unwrap() |
| Constructor and Description |
|---|
StreamerStageWrapper(StreamerStage<Object> delegate,
int idx) |
| Modifier and Type | Method and Description |
|---|---|
Collection<StreamerStage> |
StreamerConfiguration.getStages()
Gets collection of streamer stages.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamerConfiguration.setStages(Collection<StreamerStage> stages)
Sets stages.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015