Uses of Class
ds.granules.dataset.DatasetException

Packages that use DatasetException

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.

Uses of DatasetException in ds.granules.communication.direct

Methods in ds.granules.communication.direct that throw DatasetException

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)

Uses of DatasetException in ds.granules.communication.funnel

Methods in ds.granules.communication.funnel that throw DatasetException

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)

Uses of DatasetException in ds.granules.dataset

Methods in ds.granules.dataset that throw DatasetException

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)

Constructors in ds.granules.dataset that throw DatasetException

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.

Uses of DatasetException in ds.granules.scheduler

Methods in ds.granules.scheduler that throw DatasetException

Modifier and Type	Method and Description
void	TaskManagement.manageExecution(String taskIdentifier, Operation operation) Manage the execution of the given operation

Constructors in ds.granules.scheduler that throw DatasetException

Constructor and Description
ExecutableTask(String taskIdentifier, Operation operation, TaskLifecycleObserver taskLifetimeObserver)