Uses of Class
ds.granules.dataset.StreamEvent

Packages that use StreamEvent

Package	Description
ds.granules.communication.direct
ds.granules.communication.funnel
ds.granules.dataset	This package contains functionality related to datasets that deployed application instances need to operate on.
ds.granules.streaming.core
ds.granules.streaming.core.datatype
ds.granules.streaming.core.partition
ds.granules.streaming.core.partition.scheme

Uses of StreamEvent in ds.granules.communication.direct

Methods in ds.granules.communication.direct with parameters of type StreamEvent

Modifier and Type	Method and Description
void	DirectCommStreamDatasetImpl.writeStreamingDataAsBatch(ds.funnel.topic.Topic topic, StreamEvent event)

Uses of StreamEvent in ds.granules.communication.funnel

Methods in ds.granules.communication.funnel with parameters of type StreamEvent

Modifier and Type	Method and Description
void	FunnelStreamDatasetImpl.writeStreamingDataAsBatch(ds.funnel.topic.Topic topic, StreamEvent event)

Uses of StreamEvent in ds.granules.dataset

Methods in ds.granules.dataset with parameters of type StreamEvent

Modifier and Type	Method and Description
void	StreamDataset.writeStreamingDataAsBatch(ds.funnel.topic.Topic topic, StreamEvent event)

Uses of StreamEvent in ds.granules.streaming.core

Methods in ds.granules.streaming.core with parameters of type StreamEvent

Modifier and Type	Method and Description
abstract void	StreamProcessor.onEvent(StreamEvent event) This method will be invoked by the framework when data is available in one of the input streams.
protected void	StreamBase.writeToStream(String streamId, StreamEvent event) Write a stream data element to a Stream.

Uses of StreamEvent in ds.granules.streaming.core.datatype

Subclasses of StreamEvent in ds.granules.streaming.core.datatype

Modifier and Type	Class and Description
class	AbstractStreamEvent Abstracts out the boilerplate code from different data type implementations for Granules streaming API.
class	StreamingString

Uses of StreamEvent in ds.granules.streaming.core.partition

Methods in ds.granules.streaming.core.partition with parameters of type StreamEvent

Modifier and Type	Method and Description
ds.funnel.topic.Topic[]	Partitioner.partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)

Uses of StreamEvent in ds.granules.streaming.core.partition.scheme

Methods in ds.granules.streaming.core.partition.scheme with parameters of type StreamEvent

Modifier and Type	Method and Description
ds.funnel.topic.Topic[]	SendToRandomPartitioner.partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)
ds.funnel.topic.Topic[]	SendToOnePartitioner.partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)
ds.funnel.topic.Topic[]	SendToAllPartitioner.partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)
ds.funnel.topic.Topic[]	FieldPartitioner.partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)