Uses of Class
ds.granules.dataset.DatasetException

Packages that use DatasetException

Package	Description
ds.granules.dataset	This package contains functionality related to datasets that deployed application instances need to operate on.
ds.granules.interfere.computation
ds.granules.interfere.computation.ecg
ds.granules.interfere.computation.eeg
ds.granules.interfere.computation.thorax
ds.granules.samples.uppercase	This package contains a simple example which flips an input string from lowercase to uppercase.
ds.granules.samples.wordcount	This package contains classes that demonstrate using Granules with a simple information retrieval capability: Histogramming Word Counts in a set of files on a distributed set of machines.
ds.granules.scheduler	This package contains functionality related to scheduling the application instances.

Uses of DatasetException in ds.granules.dataset

Methods in ds.granules.dataset that throw DatasetException

Modifier and Type	Method and Description
int	DatasetCollection.addDataset(Dataset dataset) Add a dataset to this collection.
int	DatasetCollectionManagement.addDataset(Dataset dataset)
void	FileDatasetImpl.addFile(java.lang.String fileName, java.lang.String mode)
void	FileDatasetImplLegacy.addFile(java.lang.String filename, java.lang.String permissions) Deprecated.
void	FileDataset.addFile(java.lang.String fileName, java.lang.String mode) Adds a file with the specified permission "r", "w" or "rw" to this dataset.
void	FileAccess.addFile(java.lang.String filename, java.lang.String permissions) Deprecated. Adds a file with the specified permission "r", "w" or "rw" to this dataset.
int	StreamDatasetImplLegacy.addInputStream(java.lang.String streamSynopsis, int synopsisType) Deprecated.
int	StreamingAccess.addInputStream(java.lang.String streamSynopsis, int synopsisType) Deprecated. Add an input stream to this dataset.
int	StreamDatasetImpl.addInputStream(Topic topic)
int	StreamDataset.addInputStream(Topic topic) Add an input stream to this dataset.
int	StreamDatasetImpl.addInputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.addInputStreams(java.util.Collection<Topic> topics) Adds a set of input streams to this dataset.
int	StreamDatasetImplLegacy.addInputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToAdd) Deprecated.
int	StreamingAccess.addInputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToAdd) Deprecated. Adds a set of input streams to this dataset.
int	StreamDatasetImplLegacy.addOutputStream(java.lang.String streamSynopsis, int synopsisType) Deprecated.
int	StreamingAccess.addOutputStream(java.lang.String streamSynopsis, int synopsisType) Deprecated. Add an output stream to this dataset.
int	StreamDatasetImpl.addOutputStream(Topic topic)
int	StreamDataset.addOutputStream(Topic topic) Add an output stream to this dataset.
int	StreamDatasetImpl.addOutputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.addOutputStreams(java.util.Collection<Topic> topics) Adds a set of output streams to this dataset.
int	StreamDatasetImplLegacy.addOutputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToAdd) Deprecated.
int	StreamingAccess.addOutputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToAdd) Deprecated. Adds a set of output streams to this dataset.
boolean	StreamDatasetImpl.close()
boolean	FileDatasetImpl.close()
boolean	StreamDatasetImplLegacy.close() Deprecated.
boolean	FileDatasetImplLegacy.close() Deprecated.
boolean	Dataset.close() Close access to this dataset.
void	StreamDatasetImplLegacy.commitUpdates() Deprecated.
void	StreamingAccess.commitUpdates() Deprecated. Commit any changes that have been made to the set of streams managed by this dataset.
void	DataAvailabilityNotifier.deregisterDataAvailabilityObserver(DataAvailabilityObserver observer) Deregisters a data availability observer
void	DatasetNotifier.deregisterDataAvailabilityObserver(DataAvailabilityObserver observer)
Dataset	DatasetFactory.getDataset(FormatReader mFormat) Reconstructs the dataset from a set of bytes
Dataset	DatasetCollection.getDataset(java.lang.String datasetIdentifier) Retrieve a specific dataset
Dataset	DatasetCollectionManagement.getDataset(java.lang.String datasetIdentifier)
DatasetCollection	DatasetFactory.getDatasetCollection(FormatReader mFormat) Reconstruct the dataset collection from a byte[].
long	FileDatasetImpl.getPosition(java.lang.String fileName)
long	FileDatasetImplLegacy.getPosition(java.lang.String fileName) Deprecated.
long	FileDataset.getPosition(java.lang.String fileName) Retrieves the position of filePointer for the given dataset
long	FileAccess.getPosition(java.lang.String fileName) Deprecated. Retrieves the position of filePointer for the given dataset
long	FileDatasetImpl.getSize(java.lang.String fileName)
long	FileDataset.getSize(java.lang.String fileName) Returns the current size of the file in question
TopicDataEvent	StreamDatasetImpl.getStreamingData()
NBEvent	StreamDatasetImplLegacy.getStreamingData() Deprecated.
TopicDataEvent	StreamDataset.getStreamingData() Retrieves a portion of the streaming dataset when data is available.
NBEvent	StreamingAccess.getStreamingData() Deprecated. Retrieves a portion of the streaming dataset when data is available.
boolean	DatasetCollection.hasDataset(java.lang.String datasetIdentifier) Check to see if a dataset with the specified identifier is part of this collection
boolean	DatasetCollectionManagement.hasDataset(java.lang.String datasetIdentifier)
boolean	StreamDatasetImpl.initializeDataset()
boolean	FileDatasetImpl.initializeDataset()
boolean	StreamDatasetImplLegacy.initializeDataset() Deprecated.
boolean	FileDatasetImplLegacy.initializeDataset() Deprecated.
boolean	Dataset.initializeDataset() Invokes the initialization of the dataset.
void	DatasetCollection.initializeDatasets() Initializes all the constituent datasets in this collection.
void	DatasetCollectionManagement.initializeDatasets()
void	DataAvailabilityNotifier.pauseAvailabilityNotifications(DataAvailabilityObserver observer) Pauses data availability notifications for the specified observer
void	DatasetNotifier.pauseAvailabilityNotifications(DataAvailabilityObserver observer)
int	FileDatasetImpl.read(java.lang.String filename, byte[] bytesToRead)
int	FileDatasetImplLegacy.read(java.lang.String filename, byte[] bytesToRead) Deprecated.
int	FileDataset.read(java.lang.String fileName, byte[] bytesToRead) Attempts to read a set of bytes from the underlying file.
int	FileAccess.read(java.lang.String filename, byte[] bytesToRead) Deprecated. Attempts to read a set of bytes from the underlying file.
int	FileDatasetImpl.read(java.lang.String fileName, java.nio.ByteBuffer readBuffer)
int	FileDatasetImplLegacy.read(java.lang.String fileName, java.nio.ByteBuffer readBuffer) Deprecated.
int	FileDataset.read(java.lang.String fileName, java.nio.ByteBuffer readBuffer) Attempts to read a set of bytes from the underlying file.
int	FileAccess.read(java.lang.String fileName, java.nio.ByteBuffer readBuffer) Deprecated. Attempts to read a set of bytes from the underlying file.
void	DataAvailabilityNotifier.registerDataAvailabilityObserver(DataAvailabilityObserver observer) Registers a data availability observer
void	DatasetNotifier.registerDataAvailabilityObserver(DataAvailabilityObserver observer)
int	DatasetCollection.removeDataset(java.lang.String datasetIdentifier) Remove a dataset from this collection
int	DatasetCollectionManagement.removeDataset(java.lang.String datasetIdentifier)
void	FileDatasetImpl.removeFile(java.lang.String fileName)
void	FileDatasetImplLegacy.removeFile(java.lang.String filename) Deprecated.
void	FileDataset.removeFile(java.lang.String fileName) Removes a file from this dataset.
void	FileAccess.removeFile(java.lang.String filename) Deprecated. Removes a file from this dataset.
int	StreamDatasetImplLegacy.removeInputStream(java.lang.String streamSynopsis) Deprecated.
int	StreamingAccess.removeInputStream(java.lang.String streamSynopsis) Deprecated. Removes an input stream from this dataset.
int	StreamDatasetImpl.removeInputStream(Topic topic)
int	StreamDataset.removeInputStream(Topic topic) Removes an input stream from this dataset.
int	StreamDatasetImpl.removeInputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.removeInputStreams(java.util.Collection<Topic> topics) Removes a set of input streams from this dataset.
int	StreamDatasetImplLegacy.removeInputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToRemove) Deprecated.
int	StreamingAccess.removeInputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToRemove) Deprecated. Removes a set of input streams from this dataset.
int	StreamDatasetImplLegacy.removeOutputStream(java.lang.String streamSynopsis) Deprecated.
int	StreamingAccess.removeOutputStream(java.lang.String streamSynopsis) Deprecated. Removes an output stream from this dataset.
int	StreamDatasetImpl.removeOutputStream(Topic topic)
int	StreamDataset.removeOutputStream(Topic topic) Removes an output stream from this dataset.
int	StreamDatasetImpl.removeOutputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.removeOutputStreams(java.util.Collection<Topic> topics) Removes a set of output streams from this dataset.
int	StreamDatasetImplLegacy.removeOutputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToRemove) Deprecated.
int	StreamingAccess.removeOutputStreams(java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> streamsToRemove) Deprecated. Removes a set of output streams from this dataset.
void	DataAvailabilityNotifier.resumeAvailabilityNotifications(DataAvailabilityObserver observer) Resumes data availability notifications for the specified observer
void	DatasetNotifier.resumeAvailabilityNotifications(DataAvailabilityObserver observer)
void	FileDatasetImpl.setPosition(java.lang.String fileName, long newPosition)
void	FileDatasetImplLegacy.setPosition(java.lang.String fileName, long newPosition) Deprecated.
void	FileDataset.setPosition(java.lang.String fileName, long newPosition) Sets the position of filePointer for one of the file in the given dataset.
void	FileAccess.setPosition(java.lang.String fileName, long newPosition) Deprecated. Sets the position of filePointer for one of the file in the given dataset.
long	FileDatasetImplLegacy.size(java.lang.String fileName) Deprecated.
long	FileAccess.size(java.lang.String fileName) Deprecated. Returns the current size of the file in question
int	FileDatasetImpl.write(java.lang.String fileName, byte[] bytesToWrite)
int	FileDatasetImplLegacy.write(java.lang.String fileName, byte[] bytesToWrite) Deprecated.
int	FileDataset.write(java.lang.String fileName, byte[] bytesToWrite) Writes a byte[] to a give file.
int	FileAccess.write(java.lang.String fileName, byte[] bytesToWrite) Deprecated. Writes a byte[] to a give file.
int	FileDatasetImpl.write(java.lang.String fileName, java.nio.ByteBuffer writeBuffer)
int	FileDatasetImplLegacy.write(java.lang.String fileName, java.nio.ByteBuffer writeBuffer) Deprecated.
int	FileDataset.write(java.lang.String fileName, java.nio.ByteBuffer writeBuffer) Write the specified Buffer to the file corresponding to the specified file.
int	FileAccess.write(java.lang.String fileName, java.nio.ByteBuffer writeBuffer) Deprecated. Write the specified Buffer to the file corresponding to the specified file.
void	StreamDatasetImplLegacy.writeStreamingData(int synopsisType, java.lang.Object streamInfo, byte[] payload) Deprecated.
void	StreamingAccess.writeStreamingData(int synopsisType, java.lang.Object streamInfo, byte[] payload) Deprecated. This method writes data to the output dataset.
void	StreamDatasetImplLegacy.writeStreamingData(NBEvent nbEvent) Deprecated.
void	StreamingAccess.writeStreamingData(NBEvent nbEvent) Deprecated. This method writes data to the output dataset.
void	StreamDatasetImplLegacy.writeStreamingData(java.lang.Object streamInfo, byte[] payload) Deprecated.
void	StreamingAccess.writeStreamingData(java.lang.Object streamInfo, byte[] payload) Deprecated. This method writes data to the output dataset.
void	StreamDatasetImpl.writeStreamingData(Topic topic, byte[] payload)
void	StreamDataset.writeStreamingData(Topic topic, byte[] payload) This method writes data to the output dataset.
void	StreamDatasetImpl.writeStreamingData(TopicDataEvent mtdEvent)
void	StreamDataset.writeStreamingData(TopicDataEvent mtdEvent) This method writes data to the output dataset.

Constructors in ds.granules.dataset that throw DatasetException

Constructor and Description
FileDatasetImpl(FormatReader mFormat)
FileDatasetImplLegacy(FormatReader mFormat) Deprecated.

Uses of DatasetException in ds.granules.interfere.computation

Methods in ds.granules.interfere.computation that throw DatasetException

Modifier and Type	Method and Description
void	ComputationManager.deployJob(int inStreamGrp, java.lang.String inDeployStream, boolean inActive)

Uses of DatasetException in ds.granules.interfere.computation.ecg

Methods in ds.granules.interfere.computation.ecg that throw DatasetException

Modifier and Type	Method and Description
ECGMonitor	ECGDeployer.initializeRespirationMap(int opGroup, int opIndex, int distinctOps, boolean isActive, boolean hasUpdates) Initialize a specific RespirationMap instance.
void	ECGDeployer.prepareInstancesAndDeploy(double percentActive, int numMon) This method deploys RespirationMap instances over the set of available resources.

Uses of DatasetException in ds.granules.interfere.computation.eeg

Methods in ds.granules.interfere.computation.eeg that throw DatasetException

Modifier and Type	Method and Description
EEGMap	EEGDeployer.initializeEEGMap(EEGReduce reduce, int computationID)
void	EEGDeployer.prepareInstancesAndDeploy(int numOfMaps)

Uses of DatasetException in ds.granules.interfere.computation.thorax

Methods in ds.granules.interfere.computation.thorax that throw DatasetException

Modifier and Type	Method and Description
RespirationMap	RespirationMonitorDeployer.initializeRespirationMap(int opGroup, int opIndex, int distinctOps, boolean isActive, boolean hasUpdates) Initialize a specific RespirationMap instance.
void	RespirationMonitorDeployer.prepareInstancesAndDeploy(double percentActive, int numMon) This method deploys RespirationMap instances over the set of available resources.

Uses of DatasetException in ds.granules.samples.uppercase

Methods in ds.granules.samples.uppercase that throw DatasetException

Modifier and Type	Method and Description
UpperCaseMap	UpperCaseDeployer.initializeFlipMap(int postFix) Initialize a specific FlipMap instance.
void	UpperCaseDeployer.prepareInstancesAndDeploy(int numOfOperations) This method deploys FlipMap instances over the set of available resources.

Uses of DatasetException in ds.granules.samples.wordcount

Methods in ds.granules.samples.wordcount that throw DatasetException

Modifier and Type	Method and Description
void	WordCountDeployer.prepareInstancesAndDeploy(int numOfMaps, java.lang.String filenameBase) Prepares a set of Map/Reduce instances for the WordCount example and deploys it on the set of available resources.

Uses of DatasetException in ds.granules.scheduler

Methods in ds.granules.scheduler that throw DatasetException

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