| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.streamer |
TODO. |
| org.apache.ignite.internal.visor.streamer |
| Modifier and Type | Method and Description |
|---|---|
IgniteStreamer |
Ignite.streamer(String name)
Gets an instance of streamer by name, if one does not exist then
IllegalArgumentException will be thrown. |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteStreamer> |
Ignite.streamers()
Gets all instances of streamers.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteStreamer |
IgniteKernal.streamer(String name)
Gets an instance of streamer by name, if one does not exist then
IllegalArgumentException will be thrown. |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteStreamer> |
IgniteKernal.streamers()
Gets all instances of streamers.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
IgniteStreamerEx
Extended streamer context with methods intended for internal use.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteStreamerImpl |
| Modifier and Type | Method and Description |
|---|---|
IgniteStreamer |
GridStreamProcessor.streamer() |
IgniteStreamer |
GridStreamProcessor.streamer(String name) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteStreamer> |
GridStreamProcessor.streamers() |
| Modifier and Type | Method and Description |
|---|---|
static VisorStreamerMetrics |
VisorStreamerMetrics.from(IgniteStreamer streamer) |
static VisorStreamer |
VisorStreamer.from(IgniteStreamer s) |
static Collection<VisorStreamerStageMetrics> |
VisorStreamerStageMetrics.stages(IgniteStreamer streamer)
Create data transfer objects for all stages.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015