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.scheduler |
This package contains functionality related to scheduling the application instances.
|
Modifier and Type | Method and Description |
---|---|
int |
DirectCommStreamDatasetImpl.addInputStream(ds.funnel.topic.Topic topic) |
int |
DirectCommStreamDatasetImpl.addInputStream(ds.funnel.topic.Topic topic,
String instanceIdentifier) |
int |
DirectCommStreamDatasetImpl.addInputStreams(Collection<ds.funnel.topic.Topic> topics) |
int |
DirectCommStreamDatasetImpl.addOutputStream(ds.funnel.topic.Topic topic) |
int |
DirectCommStreamDatasetImpl.addOutputStreams(Collection<ds.funnel.topic.Topic> topics) |
boolean |
DirectCommStreamDatasetImpl.close() |
ds.funnel.topic.TopicDataEvent |
DirectCommStreamDatasetImpl.getStreamingData() |
boolean |
DirectCommStreamDatasetImpl.initializeDataset() |
int |
DirectCommStreamDatasetImpl.removeInputStream(ds.funnel.topic.Topic topic) |
int |
DirectCommStreamDatasetImpl.removeInputStreams(Collection<ds.funnel.topic.Topic> topics) |
int |
DirectCommStreamDatasetImpl.removeOutputStream(ds.funnel.topic.Topic topic) |
int |
DirectCommStreamDatasetImpl.removeOutputStreams(Collection<ds.funnel.topic.Topic> topics) |
void |
DirectCommStreamDatasetImpl.writeStreamingData(ds.funnel.topic.Topic topic,
byte[] payload) |
void |
DirectCommStreamDatasetImpl.writeStreamingData(ds.funnel.topic.TopicDataEvent mtdEvent) |
void |
DirectCommStreamDatasetImpl.writeStreamingDataAsBatch(ds.funnel.topic.Topic topic,
StreamEvent event) |
Modifier and Type | Method and Description |
---|---|
int |
FunnelStreamDatasetImpl.addInputStream(ds.funnel.topic.Topic topic) |
int |
FunnelStreamDatasetImpl.addInputStream(ds.funnel.topic.Topic topic,
String instanceIdentifier) |
int |
FunnelStreamDatasetImpl.addInputStreams(Collection<ds.funnel.topic.Topic> topics) |
int |
FunnelStreamDatasetImpl.addOutputStream(ds.funnel.topic.Topic topic) |
int |
FunnelStreamDatasetImpl.addOutputStreams(Collection<ds.funnel.topic.Topic> topics) |
boolean |
FunnelStreamDatasetImpl.close() |
ds.funnel.topic.TopicDataEvent |
FunnelStreamDatasetImpl.getStreamingData() |
boolean |
FunnelStreamDatasetImpl.initializeDataset() |
int |
FunnelStreamDatasetImpl.removeInputStream(ds.funnel.topic.Topic topic) |
int |
FunnelStreamDatasetImpl.removeInputStreams(Collection<ds.funnel.topic.Topic> topics) |
int |
FunnelStreamDatasetImpl.removeOutputStream(ds.funnel.topic.Topic topic) |
int |
FunnelStreamDatasetImpl.removeOutputStreams(Collection<ds.funnel.topic.Topic> topics) |
void |
FunnelStreamDatasetImpl.writeStreamingData(ds.funnel.topic.Topic topic,
byte[] payload) |
void |
FunnelStreamDatasetImpl.writeStreamingData(ds.funnel.topic.TopicDataEvent mtdEvent) |
void |
FunnelStreamDatasetImpl.writeStreamingDataAsBatch(ds.funnel.topic.Topic topic,
StreamEvent event) |
Modifier and Type | Method and Description |
---|---|
int |
DatasetCollectionManagement.addDataset(Dataset dataset) |
int |
DatasetCollection.addDataset(Dataset dataset)
Add a dataset to this collection.
|
void |
FileDatasetImplLegacy.addFile(String filename,
String permissions)
Deprecated.
|
void |
FileDatasetImpl.addFile(String fileName,
String mode) |
void |
FileDataset.addFile(String fileName,
String mode)
Adds a file with the specified permission "r", "w" or "rw" to this
dataset.
|
void |
FileAccess.addFile(String filename,
String permissions)
Deprecated.
Adds a file with the specified permission "r", "w" or "rw" to this
dataset.
|
int |
StreamingAccess.addInputStream(String streamSynopsis,
int synopsisType)
Deprecated.
Add an input stream to this dataset.
|
int |
StreamDatasetImplLegacy.addInputStream(String streamSynopsis,
int synopsisType)
Deprecated.
|
int |
StreamDataset.addInputStream(ds.funnel.topic.Topic topic)
Add an input stream to this dataset.
|
int |
StreamDataset.addInputStream(ds.funnel.topic.Topic topic,
String instanceIdentifier)
Add an input stream to the data set
|
int |
StreamDataset.addInputStreams(Collection<ds.funnel.topic.Topic> topics)
Adds a set of input streams to this dataset.
|
int |
StreamingAccess.addInputStreams(ConcurrentHashMap<String,Integer> streamsToAdd)
Deprecated.
Adds a set of input streams to this dataset.
|
int |
StreamDatasetImplLegacy.addInputStreams(ConcurrentHashMap<String,Integer> streamsToAdd)
Deprecated.
|
int |
StreamingAccess.addOutputStream(String streamSynopsis,
int synopsisType)
Deprecated.
Add an output stream to this dataset.
|
int |
StreamDatasetImplLegacy.addOutputStream(String streamSynopsis,
int synopsisType)
Deprecated.
|
int |
StreamDataset.addOutputStream(ds.funnel.topic.Topic topic)
Add an output stream to this dataset.
|
int |
StreamDataset.addOutputStreams(Collection<ds.funnel.topic.Topic> topics)
Adds a set of output streams to this dataset.
|
int |
StreamingAccess.addOutputStreams(ConcurrentHashMap<String,Integer> streamsToAdd)
Deprecated.
Adds a set of output streams to this dataset.
|
int |
StreamDatasetImplLegacy.addOutputStreams(ConcurrentHashMap<String,Integer> streamsToAdd)
Deprecated.
|
boolean |
StreamDatasetImplLegacy.close()
Deprecated.
|
boolean |
FileDatasetImplLegacy.close()
Deprecated.
|
boolean |
FileDatasetImpl.close() |
boolean |
Dataset.close()
Close access to this dataset.
|
void |
StreamingAccess.commitUpdates()
Deprecated.
Commit any changes that have been made to the set of streams managed by
this dataset.
|
void |
StreamDatasetImplLegacy.commitUpdates()
Deprecated.
|
StreamDataset |
DatasetFactory.createStreamDataset() |
StreamDataset |
DatasetFactory.createStreamDataset(String datasetIdentifier,
String datasetDescription)
Creates a streaming dataset based on the specified arguments.
|
void |
DatasetNotifier.deregisterDataAvailabilityObserver(DataAvailabilityObserver observer) |
void |
DataAvailabilityNotifier.deregisterDataAvailabilityObserver(DataAvailabilityObserver observer)
Deregisters a data availability observer
|
Dataset |
DatasetFactory.getDataset(ds.funnel.data.format.FormatReader mFormat)
Reconstructs the dataset from a set of bytes
|
Dataset |
DatasetCollectionManagement.getDataset(String datasetIdentifier) |
Dataset |
DatasetCollection.getDataset(String datasetIdentifier)
Retrieve a specific dataset
|
DatasetCollection |
DatasetFactory.getDatasetCollection(ds.funnel.data.format.FormatReader mFormat)
Reconstruct the dataset collection from a byte[].
|
long |
FileDatasetImplLegacy.getPosition(String fileName)
Deprecated.
|
long |
FileDatasetImpl.getPosition(String fileName) |
long |
FileDataset.getPosition(String fileName)
Retrieves the position of filePointer for the given dataset
|
long |
FileAccess.getPosition(String fileName)
Deprecated.
Retrieves the position of filePointer for the given dataset
|
long |
FileDatasetImpl.getSize(String fileName) |
long |
FileDataset.getSize(String fileName)
Returns the current size of the file in question
|
cgl.narada.event.NBEvent |
StreamingAccess.getStreamingData()
Deprecated.
Retrieves a portion of the streaming dataset when data is available.
|
cgl.narada.event.NBEvent |
StreamDatasetImplLegacy.getStreamingData()
Deprecated.
|
ds.funnel.topic.TopicDataEvent |
StreamDataset.getStreamingData()
Retrieves a portion of the streaming dataset when data is available.
|
boolean |
DatasetCollectionManagement.hasDataset(String datasetIdentifier) |
boolean |
DatasetCollection.hasDataset(String datasetIdentifier)
Check to see if a dataset with the specified identifier is part of this
collection
|
boolean |
StreamDatasetImplLegacy.initializeDataset()
Deprecated.
|
boolean |
FileDatasetImplLegacy.initializeDataset()
Deprecated.
|
boolean |
FileDatasetImpl.initializeDataset() |
boolean |
Dataset.initializeDataset()
Invokes the initialization of the dataset.
|
void |
DatasetCollectionManagement.initializeDatasets() |
void |
DatasetCollection.initializeDatasets()
Initializes all the constituent datasets in this collection.
|
void |
DatasetNotifier.pauseAvailabilityNotifications(DataAvailabilityObserver observer) |
void |
DataAvailabilityNotifier.pauseAvailabilityNotifications(DataAvailabilityObserver observer)
Pauses data availability notifications for the specified observer
|
int |
FileDatasetImplLegacy.read(String filename,
byte[] bytesToRead)
Deprecated.
|
int |
FileDatasetImpl.read(String filename,
byte[] bytesToRead) |
int |
FileDataset.read(String fileName,
byte[] bytesToRead)
Attempts to read a set of bytes from the underlying file.
|
int |
FileAccess.read(String filename,
byte[] bytesToRead)
Deprecated.
Attempts to read a set of bytes from the underlying file.
|
int |
FileDatasetImplLegacy.read(String fileName,
ByteBuffer readBuffer)
Deprecated.
|
int |
FileDatasetImpl.read(String fileName,
ByteBuffer readBuffer) |
int |
FileDataset.read(String fileName,
ByteBuffer readBuffer)
Attempts to read a set of bytes from the underlying file.
|
int |
FileAccess.read(String fileName,
ByteBuffer readBuffer)
Deprecated.
Attempts to read a set of bytes from the underlying file.
|
void |
DatasetNotifier.registerDataAvailabilityObserver(DataAvailabilityObserver observer) |
void |
DataAvailabilityNotifier.registerDataAvailabilityObserver(DataAvailabilityObserver observer)
Registers a data availability observer
|
int |
DatasetCollectionManagement.removeDataset(String datasetIdentifier) |
int |
DatasetCollection.removeDataset(String datasetIdentifier)
Remove a dataset from this collection
|
void |
FileDatasetImplLegacy.removeFile(String filename)
Deprecated.
|
void |
FileDatasetImpl.removeFile(String fileName) |
void |
FileDataset.removeFile(String fileName)
Removes a file from this dataset.
|
void |
FileAccess.removeFile(String filename)
Deprecated.
Removes a file from this dataset.
|
int |
StreamingAccess.removeInputStream(String streamSynopsis)
Deprecated.
Removes an input stream from this dataset.
|
int |
StreamDatasetImplLegacy.removeInputStream(String streamSynopsis)
Deprecated.
|
int |
StreamDataset.removeInputStream(ds.funnel.topic.Topic topic)
Removes an input stream from this dataset.
|
int |
StreamDataset.removeInputStreams(Collection<ds.funnel.topic.Topic> topics)
Removes a set of input streams from this dataset.
|
int |
StreamingAccess.removeInputStreams(ConcurrentHashMap<String,Integer> streamsToRemove)
Deprecated.
Removes a set of input streams from this dataset.
|
int |
StreamDatasetImplLegacy.removeInputStreams(ConcurrentHashMap<String,Integer> streamsToRemove)
Deprecated.
|
int |
StreamingAccess.removeOutputStream(String streamSynopsis)
Deprecated.
Removes an output stream from this dataset.
|
int |
StreamDatasetImplLegacy.removeOutputStream(String streamSynopsis)
Deprecated.
|
int |
StreamDataset.removeOutputStream(ds.funnel.topic.Topic topic)
Removes an output stream from this dataset.
|
int |
StreamDataset.removeOutputStreams(Collection<ds.funnel.topic.Topic> topics)
Removes a set of output streams from this dataset.
|
int |
StreamingAccess.removeOutputStreams(ConcurrentHashMap<String,Integer> streamsToRemove)
Deprecated.
Removes a set of output streams from this dataset.
|
int |
StreamDatasetImplLegacy.removeOutputStreams(ConcurrentHashMap<String,Integer> streamsToRemove)
Deprecated.
|
void |
DatasetNotifier.resumeAvailabilityNotifications(DataAvailabilityObserver observer) |
void |
DataAvailabilityNotifier.resumeAvailabilityNotifications(DataAvailabilityObserver observer)
Resumes data availability notifications for the specified observer
|
void |
FileDatasetImplLegacy.setPosition(String fileName,
long newPosition)
Deprecated.
|
void |
FileDatasetImpl.setPosition(String fileName,
long newPosition) |
void |
FileDataset.setPosition(String fileName,
long newPosition)
Sets the position of filePointer for one of the file in the given
dataset.
|
void |
FileAccess.setPosition(String fileName,
long newPosition)
Deprecated.
Sets the position of filePointer for one of the file in the given
dataset.
|
long |
FileDatasetImplLegacy.size(String fileName)
Deprecated.
|
long |
FileAccess.size(String fileName)
Deprecated.
Returns the current size of the file in question
|
int |
FileDatasetImplLegacy.write(String fileName,
byte[] bytesToWrite)
Deprecated.
|
int |
FileDatasetImpl.write(String fileName,
byte[] bytesToWrite) |
int |
FileDataset.write(String fileName,
byte[] bytesToWrite)
Writes a byte[] to a give file.
|
int |
FileAccess.write(String fileName,
byte[] bytesToWrite)
Deprecated.
Writes a byte[] to a give file.
|
int |
FileDatasetImplLegacy.write(String fileName,
ByteBuffer writeBuffer)
Deprecated.
|
int |
FileDatasetImpl.write(String fileName,
ByteBuffer writeBuffer) |
int |
FileDataset.write(String fileName,
ByteBuffer writeBuffer)
Write the specified Buffer to the file corresponding to the specified
file.
|
int |
FileAccess.write(String fileName,
ByteBuffer writeBuffer)
Deprecated.
Write the specified Buffer to the file corresponding to the specified
file.
|
void |
StreamingAccess.writeStreamingData(int synopsisType,
Object streamInfo,
byte[] payload)
Deprecated.
This method writes data to the output dataset.
|
void |
StreamDatasetImplLegacy.writeStreamingData(int synopsisType,
Object streamInfo,
byte[] payload)
Deprecated.
|
void |
StreamingAccess.writeStreamingData(cgl.narada.event.NBEvent nbEvent)
Deprecated.
This method writes data to the output dataset.
|
void |
StreamDatasetImplLegacy.writeStreamingData(cgl.narada.event.NBEvent nbEvent)
Deprecated.
|
void |
StreamingAccess.writeStreamingData(Object streamInfo,
byte[] payload)
Deprecated.
This method writes data to the output dataset.
|
void |
StreamDatasetImplLegacy.writeStreamingData(Object streamInfo,
byte[] payload)
Deprecated.
|
void |
StreamDataset.writeStreamingData(ds.funnel.topic.Topic topic,
byte[] payload)
This method writes data to the output dataset.
|
void |
StreamDataset.writeStreamingData(ds.funnel.topic.TopicDataEvent mtdEvent)
This method writes data to the output dataset.
|
void |
StreamDataset.writeStreamingDataAsBatch(ds.funnel.topic.Topic topic,
StreamEvent event) |
Constructor and Description |
---|
DatasetCollectionManagement(ds.funnel.data.format.FormatReader mFormat) |
FileDatasetImpl(ds.funnel.data.format.FormatReader mFormat) |
FileDatasetImplLegacy(ds.funnel.data.format.FormatReader mFormat)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskManagement.manageExecution(String taskIdentifier,
Operation operation)
Manage the execution of the given operation
|
Constructor and Description |
---|
ExecutableTask(String taskIdentifier,
Operation operation,
TaskLifecycleObserver taskLifetimeObserver) |
Copyright © 2015. All rights reserved.