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.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
ds.granules.streaming.core |
Modifier and Type | Class and Description |
---|---|
class |
DirectCommStreamDatasetImpl
StreamDataset implementation for NIO based direct communication.
|
Modifier and Type | Class and Description |
---|---|
class |
FunnelStreamDatasetImpl
This class is a streaming implementation of the dataset.
|
Modifier and Type | Method and Description |
---|---|
StreamDataset |
DatasetFactory.createStreamDataset() |
StreamDataset |
DatasetFactory.createStreamDataset(String datasetIdentifier,
String datasetDescription)
Creates a streaming dataset based on the specified arguments.
|
Modifier and Type | Field and Description |
---|---|
protected StreamDataset |
MapReduceBase.mapReduceDataset |
Modifier and Type | Method and Description |
---|---|
protected StreamDataset |
MapReduceBase.getMapReduceDataset() |
Modifier and Type | Field and Description |
---|---|
protected StreamDataset |
StreamBase.streamDataset |
Modifier and Type | Method and Description |
---|---|
protected StreamDataset |
StreamBase.getDefaultStreamDataset() |
Copyright © 2015. All rights reserved.