| Package | Description |
|---|---|
| ds.funnel.peer.event | |
| ds.funnel.samples | |
| ds.funnel.topic | |
| ds.funnel.traffic.analysis | |
| ds.granules.dataset |
This package contains functionality related to datasets that deployed application instances need to operate on.
|
| ds.granules.interfere.computation | |
| ds.granules.samples.uppercase |
This package contains a simple example which flips an input string from lowercase to uppercase.
|
| ds.granules.scheduler |
This package contains functionality related to scheduling the application instances.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MsgTopicData |
| Modifier and Type | Method and Description |
|---|---|
static void |
NanoTimeSample.onEvent(TopicDataEvent inEvent) |
| Modifier and Type | Method and Description |
|---|---|
void |
TopicSubscriptionHandler.onEvent(TopicDataEvent inEvent) |
void |
TopicPublisherImpl.sendEvent(TopicDataEvent inEvent,
OverlayPath... inDests) |
void |
TopicPublisher.sendEvent(TopicDataEvent inEvent,
OverlayPath... inDests) |
| Modifier and Type | Method and Description |
|---|---|
static void |
TrafficReflector.onEvent(TopicDataEvent inEvent,
long receiveTime)
If the inEvent was not published by this traffic reflector, republishes
the event to the traffic generation topic.
|
static void |
TrafficPublisher.onEvent(TopicDataEvent inEvent,
long receiveTimeNano)
If the inEvent was not published by this traffic publisher, calculates
statistics on the packet and logs them to the log file.
|
| Modifier and Type | Method and Description |
|---|---|
TopicDataEvent |
StreamDatasetImpl.getStreamingData() |
TopicDataEvent |
StreamDataset.getStreamingData()
Retrieves a portion of the streaming dataset when data is available.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamDatasetImpl.writeStreamingData(TopicDataEvent mtdEvent) |
void |
StreamDataset.writeStreamingData(TopicDataEvent mtdEvent)
This method writes data to the output dataset.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GIComputationStreams.onEvent(TopicDataEvent inResEvent) |
| Modifier and Type | Method and Description |
|---|---|
void |
UpperCaseProducer.onEvent(TopicDataEvent inEvent) |
| Modifier and Type | Method and Description |
|---|---|
void |
ExchangeProcessor.onEvent(TopicDataEvent topicEvent) |