- CBayesDeployer - Class in ds.granules.learning.classification.cbayes
-
Deployer for Mahout's Complimentary Naive Bayes implementation
- CBayesDeployer(Properties) - Constructor for class ds.granules.learning.classification.cbayes.CBayesDeployer
-
Initializes the deployer.
- CBayesFinalStage - Class in ds.granules.learning.classification.cbayes
-
Final stage of Mahout's Complimentary Naive Bayes implementaion.
- CBayesFinalStage() - Constructor for class ds.granules.learning.classification.cbayes.CBayesFinalStage
-
- CHANGE_BRIDGE_TYPE - Static variable in interface ds.granules.bridge.ControlMessage
-
- changeToExecuteFixedNumberOfTimes(int) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- changeToExecuteFixedNumberOfTimes(int) - Method in class ds.granules.operation.OperationBase
-
This is a protected method, which allows only the sub-classes of
Operation to change the execution profile of the operation appropriately.
- changeToExecuteOnce() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- changeToExecuteOnce() - Method in class ds.granules.operation.OperationBase
-
This is a protected method, which allows only the sub-classes of
Operation to change the execution profile of the operation appropriately.
- changeToExecutePeriodically(long) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- changeToExecutePeriodically(long) - Method in class ds.granules.operation.OperationBase
-
This is a protected method, which allows only the sub-classes of
Operation to change the execution profile of the operation appropriately.
- changeToExecuteWhenDataAvailable() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- changeToExecuteWhenDataAvailable() - Method in class ds.granules.operation.OperationBase
-
This is a protected method, which allows only the sub-classes of
Operation to change the execution profile of the operation appropriately.
- changeToStayAlive() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- changeToStayAlive() - Method in class ds.granules.operation.OperationBase
-
This is a protected method, which allows only the sub-classes of
Operation to change the execution profile of the operation appropriately.
- checkActivePiece(double[], int) - Method in class ds.granules.naadsm.resplit.Controller
-
Calculate the number of active pieces of one worker.
- checkPieceNumber(double[], int) - Method in class ds.granules.naadsm.resplit.Controller
-
Calculate the number that one worker will be split into
- Checkpoint - Class in ds.granules.naadsm.dynamicmerge.event
-
CHECKPOINT message
- Checkpoint() - Constructor for class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- CHECKPOINT - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- Checkpoint - Class in ds.granules.naadsm.dynamicsplit.event
-
CHECKPOINT message
- Checkpoint() - Constructor for class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- CHECKPOINT - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- Checkpoint - Class in ds.granules.naadsm.event
-
- Checkpoint() - Constructor for class ds.granules.naadsm.event.Checkpoint
-
- CHECKPOINT - Static variable in class ds.granules.naadsm.event.EventType
-
- Checkpoint - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
CHECKPOINT message
- Checkpoint() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- CHECKPOINT - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- Checkpoint - Class in ds.granules.naadsm.resplit.event
-
CHECKPOINT message
- Checkpoint() - Constructor for class ds.granules.naadsm.resplit.event.Checkpoint
-
- CHECKPOINT - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- Checksum - Class in ds.granules.util
-
Provides convenience functions for dealing with MessageDigest algorithms.
- Checksum() - Constructor for class ds.granules.util.Checksum
-
Initializes a new Checksum generator using the default SHA-1 algorithm.
- Checksum(String) - Constructor for class ds.granules.util.Checksum
-
Initializes a new Checksum generator using the specified algorithm.
- ChecksumDeployer - Class in ds.granules.samples.checksum
-
- ChecksumDeployer(Properties) - Constructor for class ds.granules.samples.checksum.ChecksumDeployer
-
- ChecksumMap - Class in ds.granules.samples.checksum
-
- ChecksumMap() - Constructor for class ds.granules.samples.checksum.ChecksumMap
-
- clear() - Method in class ds.granules.naadsm.ft.Snapshot
-
Resets a snapshot, clearing the state information it contains.
- clearExternalLibraries() - Method in interface ds.granules.scheduler.LibraryManager
-
- Client - Class in ds.granules.samples.checksum
-
- Client() - Constructor for class ds.granules.samples.checksum.Client
-
- close() - Method in interface ds.granules.dataset.Dataset
-
Close access to this dataset.
- close() - Method in class ds.granules.dataset.FileDataset
-
- close() - Method in class ds.granules.dataset.StreamDataset
-
- closeBrokerConnection() - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.naadsm.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.naadsm.resplit.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.samples.bridge.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.samples.checksum.Client
-
- closeBrokerConnection() - Method in class ds.granules.samples.flip.LoadGenerator
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.samples.pythonColl.PyLoadGen
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
-
Closes the connection to the broker.
- closeBrokerConnection() - Method in class ds.granules.samples.sort.NumberGenerator
-
Closes the connection to the broker.
- closeConnection() - Method in class ds.granules.bridge.JavaGenericComputation
-
Function to close all open connections
- closingStream() - Method in class ds.granules.bridge.StreamReader
-
- ClusterDeployer - Class in ds.granules.naadsm
-
A bio-informatics example demonstrating the use of the CAP3 sequence assembly
program to assemble mRNA fragments on a distributed set of resources.
- ClusterDeployer(Properties, String) - Constructor for class ds.granules.naadsm.ClusterDeployer
-
Initializes the deployer.
- ClusterDeployer - Class in ds.granules.naadsm.relaunch
-
A bio-informatics example demonstrating the use of the CAP3 sequence assembly
program to assemble mRNA fragments on a distributed set of resources.
- ClusterDeployer(Properties, String) - Constructor for class ds.granules.naadsm.relaunch.ClusterDeployer
-
Initializes the deployer.
- ClusterDeployer - Class in ds.granules.samples.bioinf
-
A bio-informatics example demonstrating the use of the CAP3 sequence assembly
program to assemble mRNA fragments on a distributed set of resources.
- ClusterDeployer(Properties, String) - Constructor for class ds.granules.samples.bioinf.ClusterDeployer
-
Initializes the deployer.
- ClusterMap - Class in ds.granules.naadsm
-
This map is a component within a bio informatics application that uses CAP3
to assemble mRNA sequences.
- ClusterMap() - Constructor for class ds.granules.naadsm.ClusterMap
-
- ClusterMap - Class in ds.granules.naadsm.relaunch
-
- ClusterMap() - Constructor for class ds.granules.naadsm.relaunch.ClusterMap
-
- ClusterMap - Class in ds.granules.samples.bioinf
-
This map is a component within a bio informatics application that uses CAP3
to assemble mRNA sequences.
- ClusterMap() - Constructor for class ds.granules.samples.bioinf.ClusterMap
-
- combineByte(byte[], byte[]) - Static method in class ds.granules.naadsm.dynamicmerge.Controller
-
Combine two messages into one byte array
- combineByte(byte[], byte[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.Controller
-
Combine two messages into one byte array
- combineByte(byte[], byte[]) - Static method in class ds.granules.naadsm.resplit.Controller
-
Combine two messages into one byte array
- commitUpdates() - Method in class ds.granules.dataset.StreamDataset
-
- commitUpdates() - Method in interface ds.granules.dataset.StreamingAccess
-
Commit any changes that have been made to the set of streams managed by
this dataset.
- CommunicationsException - Exception in ds.granules.exception
-
This is an exception that is thrown when there are communications related
problems that have been encountered.
- CommunicationsException() - Constructor for exception ds.granules.exception.CommunicationsException
-
Constructs an CommunicationsException
with no detail
message.
- CommunicationsException(String) - Constructor for exception ds.granules.exception.CommunicationsException
-
Constructs an CommunicationsException
with the specified
detail message.
- COMPLETE - Static variable in interface ds.granules.bridge.ControlMessage
-
- COMPLETE - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
-
- completedExecution(String, String, TaskLifecycleMetrics) - Method in class ds.granules.operation.InstanceDeployer
-
- completedExecution(String, String, TaskLifecycleMetrics) - Method in interface ds.granules.operation.JobLifecycleObserver
-
This method is invoked when a task has completed execution either
successfully or due to an abnormal termination or previously issued abort
request.
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.naadsm.Deployer
-
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.naadsm.dynamicmerge.Deployer
-
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.naadsm.dynamicsplit.Deployer
-
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.naadsm.portionaldynamicmerge.Deployer
-
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.naadsm.resplit.Deployer
-
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.naadsm.staticsplit.Deployer
-
- completedSuccessfully(String, ProgressTracker) - Method in class ds.granules.operation.InstanceDeployer
-
- completedSuccessfully(String, ProgressTracker) - Method in interface ds.granules.operation.JobLifecycleObserver
-
This method is invoked when all the constituent distributed tasks have
finished executing successfully.
- completedTask(String) - Method in class ds.granules.scheduler.Diagnostics
-
Process the completion of the task.
- completedWithErrors(String, ProgressTracker) - Method in class ds.granules.operation.InstanceDeployer
-
- completedWithErrors(String, ProgressTracker) - Method in interface ds.granules.operation.JobLifecycleObserver
-
This method is invoked when we have heard from all the sub-tasks, and one
or more errors have been encountered in the execution of constituent
tasks.
- computeProbWeight(double, Iterable<Double>) - Method in class ds.granules.learning.clustering.dirichlet.DirichletMapper
-
Computes the probability of a point belonging to a cluster
- computeProbWeight(double, List<Double>, int) - Method in class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansMapper
-
Computes the probability of a point belonging to a cluster
- ConditionFlag - Interface in ds.granules.exchange
-
This interface outlines the status associated with various exchanges.
- Controller - Class in ds.granules.naadsm
-
- Controller() - Constructor for class ds.granules.naadsm.Controller
-
- Controller - Class in ds.granules.naadsm.dynamicmerge
-
This is the controller for distributed NAADSM.
- Controller() - Constructor for class ds.granules.naadsm.dynamicmerge.Controller
-
Constructor.
- Controller - Class in ds.granules.naadsm.dynamicsplit
-
This is the controller for distributed NAADSM.
- Controller() - Constructor for class ds.granules.naadsm.dynamicsplit.Controller
-
Constructor.
- Controller - Class in ds.granules.naadsm.portionaldynamicmerge
-
This is the controller for distributed NAADSM.
- Controller() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.Controller
-
Constructor.
- Controller - Class in ds.granules.naadsm.resplit
-
This is the controller for distributed NAADSM.
- Controller() - Constructor for class ds.granules.naadsm.resplit.Controller
-
Constructor.
- Controller - Class in ds.granules.naadsm.staticsplit
-
- Controller() - Constructor for class ds.granules.naadsm.staticsplit.Controller
-
Constructor, allocate memory for local buffer and initialize signals
variables.
- Controller - Interface in ds.granules.scheduler
-
This is an interface which snapshots functionalities that need to be
supported for managing tasks and their constituent libraries.
- ControlMessage - Interface in ds.granules.bridge
-
Responsible for enumerating communication types across a bridge.
- convertByteArrayToLongArray(byte[]) - Method in class ds.granules.util.MarshallingUtil
-
Converts a byte[] into a long[]
- convertLongArrayToByteArray(long[]) - Method in class ds.granules.util.MarshallingUtil
-
Converts a long[] into a byte[].
- convertTimeToRatio(double[]) - Method in class ds.granules.naadsm.resplit.Controller
-
- coordinate - Variable in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- coordinate - Variable in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- coordinate - Variable in class ds.granules.naadsm.event.SplitEvent
-
- coordinate - Variable in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- coordinate - Variable in class ds.granules.naadsm.resplit.event.SplitEvent
-
- createBenchmarkMatrices(String, int, int, String, int, int) - Method in class ds.granules.samples.matrix.MatrixDeployer
-
Creates benchmark Matrices based on the specified arguments.
- createConsumer(NBEventListener) - Method in class ds.granules.scheduler.StreamingService
-
Create an event consumer
- createDatasetCollection() - Method in class ds.granules.dataset.DatasetFactory
-
Creates a dataset collection
- createDenseIntColumn(int) - Method in class ds.granules.util.Matrix
-
- createDenseIntRow() - Method in class ds.granules.util.Matrix
-
- createDeploymentResponse(String, String, int, int, String) - Method in class ds.granules.exchange.ExchangeFactory
-
Creates a deployment response, to a previously issued request.
- createDeploymentStatusOrAbortRequest(String, String, String, int) - Method in class ds.granules.exchange.ExchangeFactory
-
Creates a DeploymentMessage that is a request for either getting the
STATUS or ABORTing a previously deployment operation.
- createDepoymentRequest(String, Operation, String) - Method in class ds.granules.exchange.ExchangeFactory
-
Creates a deployment request based on the specified parameters.
- createdTask(String, TaskLifecycleMetrics) - Method in class ds.granules.scheduler.Diagnostics
-
Manage information about the newly created task.
- createEvent(String, byte[]) - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
-
- createEvent(String, byte[]) - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
-
- createEvent(String, byte[]) - Method in class ds.granules.naadsm.LoadGenerator
-
- createEvent(String, byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
-
- createEvent(String, byte[]) - Method in class ds.granules.naadsm.resplit.LoadGenerator
-
- createEvent(String, byte[]) - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
-
- createEventType(byte[]) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
-
- createEventType(byte[]) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
-
- createEventType(byte[]) - Static method in class ds.granules.naadsm.event.EventTypeFactory
-
- createEventType(byte[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
-
- createEventType(byte[]) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
-
- createEventType(byte[]) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
-
- createExecutionStatusRequest(String, String, String) - Method in class ds.granules.exchange.ExchangeFactory
-
Creates an ExecutionStatus
REQUEST based on the specified
parameters
- createExecutionStatusResponse(String, String, int, String, TaskLifecycleMetrics, String) - Method in class ds.granules.exchange.ExchangeFactory
-
Creates an ExecutionStatus
RESPONSE based on the specified
parameters
- createFileDataset(String, String) - Method in class ds.granules.dataset.DatasetFactory
-
Creates a file dataset based on the specified arguments.
- createJobIdentifier() - Method in class ds.granules.operation.InstanceDeployer
-
Create a Job Identifier.
- createJobIdentifier() - Method in class ds.granules.operation.JobSubmission
-
Creates a Job Identifier
- createProducer() - Method in class ds.granules.scheduler.StreamingService
-
Create a stream producer
- createProfile(String, int) - Method in class ds.granules.scheduler.StreamingService
-
Create a profile based on the synopsisTypeString and the synopsis
- createResourceDiscoveryRequest(int, String) - Method in class ds.granules.exchange.ExchangeFactory
-
Create a ResourceDiscovery request
- createResourceDiscoveryResponse(int, String, ResourceMetrics, String) - Method in class ds.granules.exchange.ExchangeFactory
-
Creates a ResourceDiscovery
response
- createResplitMessages(double[]) - Method in class ds.granules.naadsm.resplit.Controller
-
From the ratio of work load, get the resplit messages.
- createRestoreMessage(double[], Checkpoint[]) - Method in class ds.granules.naadsm.resplit.Controller
-
From the ratio of work load and checkpoint messages, create the restore messages.
- createResult(String, boolean, boolean) - Method in class ds.granules.results.ResultsFactory
-
This method creates a Results object.
- createResults(boolean, boolean) - Method in interface ds.granules.operation.MapReduce
-
Create the Results
type to be used for reporting results
produced as a result of the processing.
- createResults(boolean, boolean) - Method in class ds.granules.operation.MapReduceBase
-
- createSequenceInfo() - Method in interface ds.granules.results.Results
-
Create the sequencing information to be associated with this result.
- createSequenceInfo() - Method in class ds.granules.results.ResultsWidget
-
- createSequencingInfo() - Method in class ds.granules.results.ResultsFactory
-
Creates a sequencing info object.
- createStreamingDataset(String, String) - Method in class ds.granules.dataset.DatasetFactory
-
Creates a streaming dataset based on the specified arguments.
- currentDay - Variable in class ds.granules.naadsm.dynamicmerge.WorkerList
-
- currentDay - Variable in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
- DATA - Static variable in interface ds.granules.bridge.ControlMessage
-
- DataAvailabilityNotifier - Interface in ds.granules.dataset
-
This is a notifier that keeps track of when data is available on a given
dataset and then proceeds to notify the availability of the data to the
registered observers.
- DataAvailabilityObserver - Interface in ds.granules.dataset
-
This is the interface which allows an observer to track the availability of a
dataset.
- dataAvailable(String) - Method in class ds.granules.dataset.DatasetNotifier
-
Called by the dataset as soon as additional data is available.
- DATABASE - Static variable in interface ds.granules.dataset.Dataset
-
- DataPrepare - Class in ds.granules.naadsm.dynamicmerge
-
This class transforms the raw output data from the Controller and Workers
into a training data file that can be used to train a learning algorithm.
- DataPrepare() - Constructor for class ds.granules.naadsm.dynamicmerge.DataPrepare
-
- DataPrepare - Class in ds.granules.naadsm.portionaldynamicmerge
-
This class transforms the raw output data from the Controller and Workers
into a training data file that can be used to train a learning algorithm.
- DataPrepare() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.DataPrepare
-
- Dataset - Interface in ds.granules.dataset
-
The interface outlines the core functionalities that need to be supported
within datasets.
- datasetClosure(String) - Method in class ds.granules.dataset.DatasetNotifier
-
Called by the dataset, just before it is ready to close down.
- DatasetCollection - Interface in ds.granules.dataset
-
The DataCollection
interface manages a collection of datasets
that would be operated upon by an application instance.
- DatasetCollectionManagement - Class in ds.granules.dataset
-
This is an implementation of the DataCollection
Interface.
- DatasetCollectionManagement() - Constructor for class ds.granules.dataset.DatasetCollectionManagement
-
- DatasetCollectionManagement(byte[]) - Constructor for class ds.granules.dataset.DatasetCollectionManagement
-
- DatasetCollectionObserver - Interface in ds.granules.dataset
-
The observer interface for the DatasetCollection
.
- DatasetException - Exception in ds.granules.dataset
-
The DatasetException
is thrown when problems are encountered
with the dataset.
- DatasetException() - Constructor for exception ds.granules.dataset.DatasetException
-
Constructs an DatasetException
with no detail message.
- DatasetException(String) - Constructor for exception ds.granules.dataset.DatasetException
-
Constructs an DatasetException
with the specified detail
message.
- DatasetFactory - Class in ds.granules.dataset
-
A factory for creating different types of datasets.
- datasetIdentifier - Static variable in class ds.granules.naadsm.ft.Deployer
-
- DatasetNotifier - Class in ds.granules.dataset
-
This is a class which implements the DataAvailabilityNotifier
interface.
- DatasetNotifier(String, String) - Constructor for class ds.granules.dataset.DatasetNotifier
-
- DayList - Class in ds.granules.naadsm.portionaldynamicmerge
-
- DayList() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.DayList
-
- deactivate() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Set this worker as inactive.
- deactivate() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Set this worker as inactive.
- deactivateWorker(int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Set one worker as inactive.
- deactivateWorker(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Set one worker as inactive.
- DEPLOY - Static variable in class ds.granules.exchange.DeploymentMessage
-
These constants correspond to the ExchangeSubType
- deploy(ClusterMap[]) - Method in class ds.granules.naadsm.relaunch.ClusterDeployer
-
- deploy(Operation[], int, String, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
- Deployer - Class in ds.granules.naadsm
-
- Deployer(Properties) - Constructor for class ds.granules.naadsm.Deployer
-
- Deployer - Class in ds.granules.naadsm.dynamicmerge
-
Deployer is to deploy the controller and the workers.
- Deployer(Properties) - Constructor for class ds.granules.naadsm.dynamicmerge.Deployer
-
Constructor.
- Deployer - Class in ds.granules.naadsm.dynamicsplit
-
Deployer is to deploy the controller and the workers.
- Deployer(Properties) - Constructor for class ds.granules.naadsm.dynamicsplit.Deployer
-
Constructor.
- Deployer - Class in ds.granules.naadsm.ft
-
Deploys fault tolerance components.
- Deployer(Properties) - Constructor for class ds.granules.naadsm.ft.Deployer
-
Initializes the deployer.
- Deployer - Class in ds.granules.naadsm.portionaldynamicmerge
-
Deployer is to deploy the controller and the workers.
- Deployer(Properties) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.Deployer
-
Constructor.
- Deployer - Class in ds.granules.naadsm.resplit
-
Deployer is to deploy the controller and the workers.
- Deployer(Properties) - Constructor for class ds.granules.naadsm.resplit.Deployer
-
Constructor.
- Deployer - Class in ds.granules.naadsm.staticsplit
-
- Deployer(Properties) - Constructor for class ds.granules.naadsm.staticsplit.Deployer
-
Constructor.
- deployHeartbeats(int) - Method in class ds.granules.naadsm.ft.Deployer
-
- DEPLOYMENT - Static variable in interface ds.granules.exchange.ExchangeType
-
- DeploymentException - Exception in ds.granules.exception
-
This is an exception that is thrown when there are problems in
deployment-related actions that are initiated on operations.
- DeploymentException() - Constructor for exception ds.granules.exception.DeploymentException
-
Constructs an DeploymentException
with no detail message.
- DeploymentException(String) - Constructor for exception ds.granules.exception.DeploymentException
-
Constructs an DeploymentException
with the specified detail
message.
- DeploymentMessage - Class in ds.granules.exchange
-
This class encapsulates the exchanges related to the deployment of an
application instance.
- DeploymentMessage() - Constructor for class ds.granules.exchange.DeploymentMessage
-
The null constructor for the DeploymnetMessage
- DeploymentMessage(String, Operation, String) - Constructor for class ds.granules.exchange.DeploymentMessage
-
Creates a deployment message based on the specified parameters.
- DeploymentMessage(String, String, String, int) - Constructor for class ds.granules.exchange.DeploymentMessage
-
Creates a DeploymentMessage that is a request for either getting the
STATUS or ABORTing a previously deployment operation.
- DeploymentMessage(String, String, int, int, String) - Constructor for class ds.granules.exchange.DeploymentMessage
-
Creates a deployment response, to a previously issued request.
- deployOperations(Operation[]) - Method in class ds.granules.operation.InstanceDeployer
-
This method deploys a set of operations on a specified number of
resources.
- deployOperations(Operation[], String) - Method in class ds.granules.operation.InstanceDeployer
-
This method deploys a set of operations on the set of available
resources.
- deployOperations(Operation[], int, String) - Method in class ds.granules.operation.InstanceDeployer
-
This method deploys a set of operations on a specified number of
resources.
- deregisterDataAvailabilityObserver(DataAvailabilityObserver) - Method in interface ds.granules.dataset.DataAvailabilityNotifier
-
Deregisters a data availability observer
- deregisterDataAvailabilityObserver(DataAvailabilityObserver) - Method in class ds.granules.dataset.DatasetNotifier
-
- deserialize(String) - Method in class ds.granules.naadsm.ml.NeuralPredictor
-
Deserialize one file into a network.
- deserialize(String) - Method in interface ds.granules.naadsm.ml.Predictor
-
- DESTRUCTION - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- DESTRUCTION - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- DESTRUCTION - Static variable in class ds.granules.naadsm.event.EventType
-
- DESTRUCTION - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- DESTRUCTION - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- DESTRUCTION - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
-
- DestructionEvent - Class in ds.granules.naadsm.dynamicmerge.event
-
DESTRUCTION message
- DestructionEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- DestructionEvent - Class in ds.granules.naadsm.dynamicsplit.event
-
DESTRUCTION message
- DestructionEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- DestructionEvent - Class in ds.granules.naadsm.event
-
- DestructionEvent() - Constructor for class ds.granules.naadsm.event.DestructionEvent
-
- DestructionEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
DESTRUCTION message
- DestructionEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- DestructionEvent - Class in ds.granules.naadsm.resplit.event
-
DESTRUCTION message
- DestructionEvent() - Constructor for class ds.granules.naadsm.resplit.event.DestructionEvent
-
- DestructionEvent - Class in ds.granules.naadsm.staticsplit.event
-
DESTRUCTION message
- DestructionEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- Detection - Class in ds.granules.naadsm.dynamicmerge.event
-
DESTRUCTION message
- Detection() - Constructor for class ds.granules.naadsm.dynamicmerge.event.Detection
-
- DETECTION - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- Detection - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
DESTRUCTION message
- Detection() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- DETECTION - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- Detection - Class in ds.granules.naadsm.resplit.event
-
DESTRUCTION message
- Detection() - Constructor for class ds.granules.naadsm.resplit.event.Detection
-
- DETECTION - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- DIAGNOSTIC - Static variable in interface ds.granules.exchange.ExchangeType
-
- Diagnostics - Class in ds.granules.scheduler
-
This class keeps track of various diagnostic-related elements.
- Diagnostics(String, int) - Constructor for class ds.granules.scheduler.Diagnostics
-
- DirectivesException - Exception in ds.granules.exception
-
This is an exception that is thrown when there are problems enforcing the
directives associated with an application instance.
- DirectivesException() - Constructor for exception ds.granules.exception.DirectivesException
-
Constructs an DirectivesException
with no detail message.
- DirectivesException(String) - Constructor for exception ds.granules.exception.DirectivesException
-
Constructs an DirectivesException
with the specified detail
message.
- DirichletDeployer - Class in ds.granules.learning.clustering.dirichlet
-
The deployer to use the Mahout implementation of Dirichlet clustering.
- DirichletDeployer(Properties) - Constructor for class ds.granules.learning.clustering.dirichlet.DirichletDeployer
-
Initializes the deployer.
- DirichletMapper - Class in ds.granules.learning.clustering.dirichlet
-
An example demonstrating the Map
role within a Word Count
operation.
- DirichletMapper() - Constructor for class ds.granules.learning.clustering.dirichlet.DirichletMapper
-
- DirichletReducer - Class in ds.granules.learning.clustering.dirichlet
-
An example demonstrating the Map
role within a Word Count
operation.
- DirichletReducer() - Constructor for class ds.granules.learning.clustering.dirichlet.DirichletReducer
-
- discoverResource() - Method in class ds.granules.operation.JobSubmission
-
Discovers the available computational resources.
- dispose() - Method in interface ds.granules.operation.Operation
-
Reclaim resources if any prior to exiting ...
- dispose() - Method in class ds.granules.operation.OperationBase
-
- done() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Set this worker as finished in current day.
- done() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Set this worker as finished in current day.
- DOUBLE - Static variable in class ds.granules.results.ResultPayload
-
- DOUBLE_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- DOUBLE_ARR - Static variable in interface ds.granules.bridge.ControlMessage
-
- DOUBLE_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- down - Variable in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- down - Variable in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- down - Variable in class ds.granules.naadsm.event.Checkpoint
-
- down - Variable in class ds.granules.naadsm.event.Restore
-
- ds.granules.bridge - package ds.granules.bridge
-
This package contains basic Granules Bridging code.
- ds.granules.dataset - package ds.granules.dataset
-
This package contains functionality related to datasets that deployed application instances need to operate on.
- ds.granules.exception - package ds.granules.exception
-
This package contains exceptions that are used across multiple packages within the project.
- ds.granules.exchange - package ds.granules.exchange
-
This package contains classes related to processing exchanges.
- ds.granules.learning.classification.bayes - package ds.granules.learning.classification.bayes
-
- ds.granules.learning.classification.cbayes - package ds.granules.learning.classification.cbayes
-
- ds.granules.learning.classification.common - package ds.granules.learning.classification.common
-
- ds.granules.learning.clustering.dirichlet - package ds.granules.learning.clustering.dirichlet
-
Granules implementation of Mahout's Dirichlet clustering algorithm.
- ds.granules.learning.clustering.fuzzykmeans - package ds.granules.learning.clustering.fuzzykmeans
-
Granules implementation of Mahout's Fuzzy K-Means clustering algorithm.
- ds.granules.learning.clustering.kmeans - package ds.granules.learning.clustering.kmeans
-
Granules implementation of Mahout's K-Means clustering algorithm.
- ds.granules.learning.clustering.lda - package ds.granules.learning.clustering.lda
-
Granules implementation of Mahout's Latent Dirichlet Allocation (LDA) clustering algorithm.
- ds.granules.naadsm - package ds.granules.naadsm
-
- ds.granules.naadsm.dynamicmerge - package ds.granules.naadsm.dynamicmerge
-
This package contains an implementation of the dynamic merge+split algorithm (split based
on area) for NAADSM computations.
- ds.granules.naadsm.dynamicmerge.event - package ds.granules.naadsm.dynamicmerge.event
-
This sub-package contains all the events that are used in the dynamicmerge package.
- ds.granules.naadsm.dynamicsplit - package ds.granules.naadsm.dynamicsplit
-
This package contains the dynamic split method for NAADSM computations.
- ds.granules.naadsm.dynamicsplit.event - package ds.granules.naadsm.dynamicsplit.event
-
This sub-package contains all the events that are used in the dynamicsplit package.
- ds.granules.naadsm.event - package ds.granules.naadsm.event
-
- ds.granules.naadsm.ft - package ds.granules.naadsm.ft
-
Provides optional fault tolerance functionality for distributed NAADSM runs.
- ds.granules.naadsm.ml - package ds.granules.naadsm.ml
-
This package contains functionality for training and generating prediction using machine learning
techniques (including artificial neural networks).
- ds.granules.naadsm.portionaldynamicmerge - package ds.granules.naadsm.portionaldynamicmerge
-
This package contains an implementation of the dynamic merge+split algorithm based on herd
density rather than geographic regions.
- ds.granules.naadsm.portionaldynamicmerge.event - package ds.granules.naadsm.portionaldynamicmerge.event
-
This sub-package contains all the events that are used in the portionaldynamicmerge package.
- ds.granules.naadsm.relaunch - package ds.granules.naadsm.relaunch
-
This package provides configurable relaunching of failed computations capability
for NAADSM.
- ds.granules.naadsm.resplit - package ds.granules.naadsm.resplit
-
This package contains an implementation of the dynamic resplit algorithm based on herd
density rather than geographic regions.
- ds.granules.naadsm.resplit.event - package ds.granules.naadsm.resplit.event
-
This sub-package contains all the events that are used in the resplit package.
- ds.granules.naadsm.staticsplit - package ds.granules.naadsm.staticsplit
-
This package contains the static split method for NAADSM computations.
- ds.granules.naadsm.staticsplit.event - package ds.granules.naadsm.staticsplit.event
-
- ds.granules.operation - package ds.granules.operation
-
This package encapsulates functionality related to application instances that will be deployed on the cloud.
- ds.granules.results - package ds.granules.results
-
Functionality for processing results generated by application instances.
- ds.granules.samples.bioinf - package ds.granules.samples.bioinf
-
This package contains classes that demonstrate using the CAP3 mRNA sequence assembly program with Granules.
- ds.granules.samples.bridge - package ds.granules.samples.bridge
-
- ds.granules.samples.checksum - package ds.granules.samples.checksum
-
- ds.granules.samples.flip - package ds.granules.samples.flip
-
- ds.granules.samples.grep - package ds.granules.samples.grep
-
This package contains classes that demonstrate using Granules with a simple information retrieval capability: GREP.
- ds.granules.samples.iterative - package ds.granules.samples.iterative
-
This package contains sample programs that demonstrate iterative execution of
cascaded map-reduce stages.
- ds.granules.samples.kmeans - package ds.granules.samples.kmeans
-
- ds.granules.samples.matrix - package ds.granules.samples.matrix
-
This package contains classes that demonstrate using Granules to perform a simple matrix multiplication on a set of machines.
- ds.granules.samples.periodic - package ds.granules.samples.periodic
-
This package contains classes that demonstrate using Granules to perform operations at regular intervals on a distributed set of machines.
- ds.granules.samples.pythonColl - package ds.granules.samples.pythonColl
-
- ds.granules.samples.sort - package ds.granules.samples.sort
-
This package contains classes that demonstrate using Granules to perform a simple parallel-sort on a set of machine for a sequence of generated numbers (long
).
- ds.granules.samples.wordcount - package 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 - package ds.granules.scheduler
-
This package contains functionality related to scheduling the application instances.
- ds.granules.util - package ds.granules.util
-
This package contains utility classes used by several components.
- generate(int) - Method in class ds.granules.samples.sort.NumberGenerator
-
- generateMatrixARowStreams(int, int, int) - Method in class ds.granules.samples.matrix.MatrixDeployer
-
Generates a set of column streams for the specified range of row streams.
- generateMatrixStreams(int, int, int) - Method in class ds.granules.samples.matrix.MatrixDeployer
-
- generateWorkload(int, int, int, int) - Method in class ds.granules.samples.matrix.MatrixDeployer
-
Generates workloads for the various MatrixMap
instances that
have been deployed on the available resources.
- getArrivalTime() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getArrivalTime() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the time at which the operation arrived at this node.
- getAwaitingOutputsFrom() - Method in class ds.granules.operation.MapReduceBase
-
- getAwaitingOutputsFrom() - Method in interface ds.granules.operation.Reduce
-
Retrieves the set of Map identifiers from which an Output has not been
received so far.
- getBoundaries(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- getBoundaries(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- getBoundaries(byte[]) - Method in class ds.granules.naadsm.event.Checkpoint
-
- getBoundaries(byte[]) - Method in class ds.granules.naadsm.event.Restore
-
- getBytes() - Method in interface ds.granules.dataset.Dataset
-
A serialized representation of this dataset, which would allow one to
reconstruct and initialize it from this marshalled representation.
- getBytes() - Method in interface ds.granules.dataset.DatasetCollection
-
Returns this collection as a stream of bytes.
- getBytes() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- getBytes() - Method in class ds.granules.dataset.FileDataset
-
- getBytes() - Method in class ds.granules.dataset.StreamDataset
-
- getBytes() - Method in class ds.granules.exchange.Exchange
-
Retrieve the byte[] representation of the exchange.
- getBytes() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getBytes(int) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
-
Returns the bytes that are associated with an integer value.
- getBytes(int) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
-
Returns the bytes that are associated with an integer value.
- getBytes(int) - Static method in class ds.granules.naadsm.event.EventTypeFactory
-
Returns the bytes that are associated with an integer value.
- getBytes(int) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
-
Returns the bytes that are associated with an integer value.
- getBytes(int) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
-
Returns the bytes that are associated with an integer value.
- getBytes(int) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
-
Returns the bytes that are associated with an integer value.
- getBytes() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- getBytes() - Method in class ds.granules.operation.MapReduceBase
-
- getBytes() - Method in interface ds.granules.operation.Operation
-
Marshall this operation as a stream of bytes
- getBytes() - Method in class ds.granules.operation.OperationBase
-
- getBytes(int) - Method in class ds.granules.results.ResultPayload
-
This method converts an int
into a byte[]
.
- getBytes(short) - Method in class ds.granules.results.ResultPayload
-
This method converts a short
into a byte[]
.
- getBytes(long) - Method in class ds.granules.results.ResultPayload
-
This method converts a long
into a byte[]
.
- getBytes(double) - Method in class ds.granules.results.ResultPayload
-
This method converts a double
into a byte[]
.
- getBytes(float) - Method in class ds.granules.results.ResultPayload
-
This method converts a float
into a byte[]
.
- getBytes(String) - Method in class ds.granules.results.ResultPayload
-
This method converts a String
into a byte[]
.
- getBytes(int[]) - Method in class ds.granules.results.ResultPayload
-
This method converts an int[] into a byte[].
- getBytes(short[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a short[] into a byte[].
- getBytes(long[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a long[] into a byte[].
- getBytes(double[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a double[] into a byte[].
- getBytes(float[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a float[] into a byte[].
- getBytes(String[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a String[] into a byte[].
- getBytes(Hashtable) - Method in class ds.granules.results.ResultPayload
-
This method converts a Hashtable into a byte[].
- getBytes(HashMap) - Method in class ds.granules.results.ResultPayload
-
This method converts a HashMap into a byte[].
- getBytes(int[][]) - Method in class ds.granules.results.ResultPayload
-
This method converts a int[][]
into a byte[]
.
- getBytes(short[][]) - Method in class ds.granules.results.ResultPayload
-
This method converts a short[][]
into a byte[]
.
- getBytes(long[][]) - Method in class ds.granules.results.ResultPayload
-
This method converts a long[][]
into a byte[]
.
- getBytes(double[][]) - Method in class ds.granules.results.ResultPayload
-
This method converts a double[][]
into a byte[]
.
- getBytes(float[][]) - Method in class ds.granules.results.ResultPayload
-
This method converts a float[][]
into a byte[]
.
- getBytes(Object[]) - Method in class ds.granules.results.ResultPayload
-
This method converts an Object[]
into a byte[]
.
- getBytes() - Method in interface ds.granules.results.Results
-
Marshall the result as a set of bytes
- getBytes() - Method in class ds.granules.results.ResultsWidget
-
- getBytes() - Method in interface ds.granules.results.SequencingInfo
-
Retrieve a byte[] representation of the object.
- getBytes() - Method in class ds.granules.results.SequencingWidget
-
- getBytes(Serializable) - Static method in class ds.granules.samples.kmeans.ObjectMarshaller
-
- getBytes() - Method in class ds.granules.scheduler.ResourceMetrics
-
- getBytes() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Create the serialized representation of this class.
- getCheckpoints() - Method in class ds.granules.naadsm.ft.Snapshot
-
- getClassName() - Method in class ds.granules.exchange.DeploymentMessage
-
- getCluster() - Method in class ds.granules.learning.clustering.dirichlet.GranulesDirichletCluster
-
- getCluster() - Method in class ds.granules.learning.clustering.fuzzykmeans.GranulesSoftCluster
-
- getCluster() - Method in class ds.granules.learning.clustering.kmeans.GranulesCluster
-
- getCompletionStatus(String) - Method in interface ds.granules.operation.ProgressTracker
-
Retrieve the completion status for a specific taskIdentifier
- getCompletionStatus(String) - Method in class ds.granules.operation.ProgressTrackerWidget
-
- getCompletionTime() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getCompletionTime() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the time at which this task was completed
- getConditionFlag() - Method in class ds.granules.exchange.Exchange
-
- getContactType() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getContactType() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getContactType() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getContactType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getContactType() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getContactType() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getContent() - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- getContent() - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- getContent() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- getContent() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- getContent() - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- getContent() - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getContent() - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getCONTROL() - Method in class ds.granules.bridge.JavaByteMessage
-
- getCPUBoundTime() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getCPUBoundTime() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the CPU-bound time of the computation.
- getCreationTime() - Method in class ds.granules.naadsm.ft.Snapshot
-
- getCurrentDay() - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
-
- getData() - Method in class ds.granules.samples.kmeans.KMVectorData
-
- getDataAvailabilityNotifier() - Method in interface ds.granules.dataset.Dataset
-
Retrieve the data availability notifier for this dataset.
- getDataAvailabilityNotifier() - Method in class ds.granules.dataset.FileDataset
-
- getDataAvailabilityNotifier() - Method in class ds.granules.dataset.StreamDataset
-
- getDataset(String) - Method in interface ds.granules.dataset.DatasetCollection
-
Retrieve a specific dataset
- getDataset(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- getDataset(byte[]) - Method in class ds.granules.dataset.DatasetFactory
-
Reconstructs the dataset from a set of bytes
- getDatasetCollection(byte[]) - Method in class ds.granules.dataset.DatasetFactory
-
Reconstruct the dataset collection from a byte[].
- getDatasetCollection() - Method in class ds.granules.operation.MapReduceBase
-
- getDatasetCollection() - Method in interface ds.granules.operation.Operation
-
Retrieve the dataset that is associated with this particular operation.
- getDatasetCollection() - Method in class ds.granules.operation.OperationBase
-
- getDatasetIdentifier() - Method in interface ds.granules.dataset.DataAvailabilityNotifier
-
Indicates the dataset being reported on
- getDatasetIdentifier() - Method in class ds.granules.dataset.DatasetNotifier
-
- getDatasets() - Method in interface ds.granules.dataset.DatasetCollection
-
Retrieve an iterator to iterate over the datasets.
- getDatasets() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- getDatasetType() - Method in interface ds.granules.dataset.Dataset
-
Retrieve the type of the data set
- getDatasetType(byte[]) - Method in class ds.granules.dataset.DatasetFactory
-
Retrieves the dataset type information from a stream of bytes.
- getDatasetType() - Method in class ds.granules.dataset.FileDataset
-
- getDatasetType() - Method in class ds.granules.dataset.StreamDataset
-
- getDay() - Method in class ds.granules.naadsm.ft.Snapshot
-
- getDayNum() - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
-
- getDayNumber() - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.event.AttemptToInfect
-
- getDayNumber() - Method in class ds.granules.naadsm.event.DestructionEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.event.EndOfDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.event.QuarantineEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.event.RequestForZoneFocus
-
- getDayNumber() - Method in class ds.granules.naadsm.event.StartNewDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
-
- getDayNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.Detection
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
-
- getDayNumber() - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
-
- getDayNumber() - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- getDeploymentMessage(byte[]) - Method in class ds.granules.exchange.ExchangeFactory
-
Reconstructs the Deployment Message from a stream of bytes
- getDeploymentStream() - Method in class ds.granules.naadsm.ft.HostInfo
-
- getDeploymentStream(String) - Method in interface ds.granules.operation.ProgressTracker
-
Retrieve the deployment stream associated with a given task.
- getDeploymentStream(String) - Method in class ds.granules.operation.ProgressTrackerWidget
-
- getDeploymentStream() - Method in class ds.granules.scheduler.ResourceMetrics
-
- getDescription() - Method in class ds.granules.bridge.JavaByteMessage
-
- getDescription() - Method in interface ds.granules.dataset.Dataset
-
Retrieve a description of the dataset
- getDescription() - Method in class ds.granules.dataset.FileDataset
-
- getDescription() - Method in class ds.granules.dataset.StreamDataset
-
- getDescription() - Method in class ds.granules.exchange.Exchange
-
Retrieve the description associated with this exchange.
- getDiagnostics() - Method in class ds.granules.scheduler.Resource
-
Provides diagnostic information for this Resource.
- getDomain() - Method in interface ds.granules.operation.Operation
-
Get information about the domain for this operation
- getDomain() - Method in class ds.granules.operation.OperationBase
-
- getDouble(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a double
.
- getDouble2DArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a double[][]
.
- getDoubleArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a double[].
- getEntriesType() - Method in class ds.granules.util.Matrix
-
- getEuclidean(double[], double[], int) - Method in class ds.granules.samples.kmeans.KMStageOne
-
Returns the euclidean distance (square value) of given two vectors.
- getEuclidean2(double[], double[], int) - Method in class ds.granules.samples.kmeans.KMStageTwo
-
Returns the euclidean distance (square value) of given two vectors.
- getExchangeSubType() - Method in class ds.granules.exchange.Exchange
-
- getExchangeType() - Method in class ds.granules.exchange.Exchange
-
- getExchangeType(byte[]) - Method in class ds.granules.exchange.ExchangeFactory
-
Retrieves the exchange type information from a stream of bytes.
- getExecutionInterval() - Method in interface ds.granules.operation.ExecutionProfile
-
Retrieve the execution interval.
- getExecutionInterval() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- getExecutionInterval() - Method in class ds.granules.scheduler.ExecutableTask
-
For a task that needs to be executed periodically, this method is used to
retrieve the interval at which the task needs to be executed
periodically.
- getExecutionProfile() - Method in interface ds.granules.operation.Operation
-
Retrieve the execution profile associated with this operation
- getExecutionProfile() - Method in class ds.granules.operation.OperationBase
-
- getExecutionStatus(byte[]) - Method in class ds.granules.exchange.ExchangeFactory
-
Reconstruct the execution status object from a byte[].
- getExecutionStatus() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getExecutionStatus() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the execution status associated with the operation.
- getExecutionTime(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Get the execution time of all the workers.
- getExecutionTime() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Get the execution time of the current worker.
- getFileDataset(byte[]) - Method in class ds.granules.dataset.DatasetFactory
-
Reconstruct the file dataset from a byte[] representation of it.
- getFilenames() - Method in interface ds.granules.dataset.FileAccess
-
Retrieves the list of files in this dataset
- getFilenames() - Method in class ds.granules.dataset.FileDataset
-
- getFloat(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a float
.
- getFloat2DArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a float[][]
.
- getFloatArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a float[].
- getFreeMemory() - Method in class ds.granules.scheduler.ResourceMetrics
-
Retrieve the available free memory in MB.
- getFValue() - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getFValue() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getFValue() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getGlobalState() - Method in class ds.granules.naadsm.ft.Snapshot
-
- getHashMap(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a HashMap.
- getHashtable(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a Hashtable.
- getHerd() - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- getHerd() - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
-
- getHerd() - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
-
- getHerd() - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- getHerd() - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
-
- getHerd() - Method in class ds.granules.naadsm.event.DestructionEvent
-
- getHerd() - Method in class ds.granules.naadsm.event.QuarantineEvent
-
- getHerd() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- getHerd() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- getHerd() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
-
- getHerd() - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
-
- getHerd() - Method in class ds.granules.naadsm.resplit.event.Detection
-
- getHerd() - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
-
- getHerd() - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- getHerd() - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
-
- getIdentifier() - Method in interface ds.granules.dataset.DataAvailabilityObserver
-
This retrieves the identifier associated with the observer.
- getIdentifier() - Method in interface ds.granules.dataset.Dataset
-
Retrieve the identifier for this dataset.
- getIdentifier() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- getIdentifier() - Method in class ds.granules.dataset.FileDataset
-
- getIdentifier() - Method in class ds.granules.dataset.StreamDataset
-
- getIdentifier() - Method in class ds.granules.exchange.Exchange
-
- getIdentifier() - Method in interface ds.granules.operation.ProgressTracker
-
Retrieve the Job identifier
- getIdentifier() - Method in class ds.granules.operation.ProgressTrackerWidget
-
- getIdentifier() - Method in class ds.granules.scheduler.ExecutableTask
-
Retrieve the identifier for the executable task
- getIndexExposedHerd() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getIndexExposedHerd() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getIndexExposedHerd() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getIndexExposedHerd() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getIndexExposedHerd() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getIndexExposedHerd() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getIndexExposingHerd() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getIndexExposingHerd() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getIndexExposingHerd() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getIndexExposingHerd() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getIndexExposingHerd() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getIndexExposingHerd() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getInitialDelayForPeriodicTask() - Method in class ds.granules.scheduler.ExecutableTask
-
This method returns the time at which the periodic task will execute for
the first time.
- getInitializationDirectives() - Method in class ds.granules.dataset.FileDataset
-
- getInput() - Method in class ds.granules.bridge.JavaByteMessage
-
- getInputStreams() - Method in class ds.granules.dataset.StreamDataset
-
- getInputStreams() - Method in interface ds.granules.dataset.StreamingAccess
-
Retrieve a HashMap of the constituent input streams.
- getInstance() - Static method in class ds.granules.dataset.DatasetFactory
-
Retrieve the singleton instance of the dataset factory
- getInstance() - Static method in class ds.granules.exchange.ExchangeFactory
-
Retrieve the singleton instance for this factory.
- getInstance() - Static method in class ds.granules.operation.JobSubmission
-
- getInstance() - Static method in class ds.granules.results.ResultPayload
-
Retrieve the payload instance
- getInstance() - Static method in class ds.granules.results.ResultsFactory
-
Retrieve the singleton instance of the ResultsFactory.
- getInstance() - Static method in class ds.granules.samples.matrix.MatrixSharedMemory
-
- getInstance() - Static method in class ds.granules.scheduler.Resource
-
Retrieves singleton instance of the Resource.
- getInstance() - Static method in class ds.granules.scheduler.StreamingService
-
Get an instance of the StreamingService
- getInstance() - Static method in class ds.granules.util.MarshallingUtil
-
Retrieve the singleton instance of the MarshallingUtil
- getInstance() - Static method in class ds.granules.util.MatrixFactory
-
Retrieve the singleton instance of the Matrix Factory.
- getInstance() - Static method in class ds.granules.util.ParamsReader
-
Retrieve the instance of the Params-Reader
- getInstanceIdentifier() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getInstanceIdentifier() - Method in interface ds.granules.operation.Operation
-
Retrieve the instance identifier for this operation.
- getInstanceIdentifier() - Method in class ds.granules.operation.OperationBase
-
- getInstanceIdentifier() - Method in interface ds.granules.results.Results
-
Retrieve the instance identifier of the application instance that has
generated the result(s).
- getInstanceIdentifier() - Method in class ds.granules.results.ResultsWidget
-
- getInstanceIdentifier() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the instance identifier of the operation that was encapsulated
within a Task.
- getInt(byte[]) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt(byte[]) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt(byte[]) - Static method in class ds.granules.naadsm.event.EventTypeFactory
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt(byte[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt(byte[]) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt(byte[]) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into an int
.
- getInt(byte[], int) - Method in class ds.granules.util.MarshallingUtil
-
Given a sequence of bytes, this method returns the int value associated
with the sequence of bytes.
- getInt2DArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a int[][]
.
- getIntArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into an int[].
- getIValue() - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getIValue() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getIValue() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getJobId() - Method in class ds.granules.samples.periodic.PeriodicDeployer
-
Retrieves the ID of the submitted Job
- getJobIdentifier() - Method in class ds.granules.exchange.DeploymentMessage
-
- getJobIdentifier() - Method in class ds.granules.exchange.ExecutionStatus
-
- getJudgementTime(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Get the time that is as criteria for load balancing operations
- getJudgementTime() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Get the time that is as the criteria of load balancing operations
- getLastHeartbeatTime() - Method in class ds.granules.naadsm.ft.HostInfo
-
- getLastModificationTime() - Method in interface ds.granules.dataset.Dataset
-
Retrieve the last update to this dataset
- getLastModificationTime() - Method in class ds.granules.dataset.FileDataset
-
- getLastModificationTime() - Method in class ds.granules.dataset.StreamDataset
-
- getLastUpdateTime() - Method in class ds.granules.naadsm.ft.WorkerInfo
-
- getLength() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- getLength() - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- getLength() - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getLength() - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getListOfJobs() - Method in class ds.granules.operation.JobSubmission
-
Get the complete list of jobs that have been submitted from this node.
- getLong(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a long
.
- getLong2DArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a long[][]
.
- getLongArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a long[].
- getLower() - Method in interface ds.granules.results.SequencingInfo
-
Retrieve the lower-bound of the specified range.
- getLower() - Method in class ds.granules.results.SequencingWidget
-
- getMapIdentifiers() - Method in class ds.granules.operation.MapReduceBase
-
- getMapIdentifiers() - Method in interface ds.granules.operation.Reduce
-
Retrieves the set of Map identifiers
- getMapReduceDataset() - Method in class ds.granules.operation.MapReduceBase
-
- getMatrix(String, int, int, int, boolean) - Method in class ds.granules.util.MatrixFactory
-
Retrieve/create a matrix based on the specified arguments.
- getMatrix(String) - Method in class ds.granules.util.MatrixFactory
-
Retrieve the Matrix
associated with the matrix that was
stored in a file.
- getMaxSequence() - Method in interface ds.granules.results.SequencingInfo
-
Retrieve the value of the max-sequence info.
- getMaxSequence() - Method in class ds.granules.results.SequencingWidget
-
- getMD5Checksum(byte[]) - Static method in class ds.granules.util.MD5Checksum
-
- getMemoryUtilization() - Method in class ds.granules.scheduler.ResourceMetrics
-
Retrieve the memory utilization in MB.
- getMemoryUtilization() - Method in interface ds.granules.scheduler.ResourceProfile
-
The memory utilization at the resource
- getMergeNode() - Method in class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
-
- getMetadataLength() - Method in class ds.granules.util.Matrix
-
- getName() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getNameLength() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getNameLength() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForVaccination
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestOfDestruction
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.TraceResult
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Vaccination
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicmerge.event.VaccinationCanceled
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfSimulationEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.RequestOfDestruction
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.dynamicsplit.event.TraceResult
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.AttemptToInfect
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.Checkpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.DestructionEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.EndOfDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.EndOfSimulationEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.QuarantineEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.RequestForZoneFocus
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.RequestOfDestruction
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.Restore
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.SplitEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.StartNewDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.event.TraceResult
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForVaccination
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestOfDestruction
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.TraceResult
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Vaccination
-
- getNextBytes(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.VaccinationCanceled
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.Detection
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.RequestForVaccination
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.RequestOfDestruction
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.SplitByDensity
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.SplitEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.TraceResult
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.Vaccination
-
- getNextBytes(int) - Method in class ds.granules.naadsm.resplit.event.VaccinationCanceled
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.EndOfSimulationEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.RequestOfDestruction
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.SplitEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- getNextBytes(int) - Method in class ds.granules.naadsm.staticsplit.event.TraceResult
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForVaccination
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestOfDestruction
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.TraceResult
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Vaccination
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicmerge.event.VaccinationCanceled
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfSimulationEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.RequestOfDestruction
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.dynamicsplit.event.TraceResult
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.AttemptToInfect
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.Checkpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.DestructionEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.EndOfDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.EndOfSimulationEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.EventType
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.QuarantineEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.RequestForZoneFocus
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.RequestOfDestruction
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.Restore
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.SplitEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.StartNewDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.event.TraceResult
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForVaccination
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestOfDestruction
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.TraceResult
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Vaccination
-
- getNextValue(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.VaccinationCanceled
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.Detection
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.EventType
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.RequestForVaccination
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.RequestOfDestruction
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.SplitByDensity
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.SplitEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.TraceResult
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.Vaccination
-
- getNextValue(int) - Method in class ds.granules.naadsm.resplit.event.VaccinationCanceled
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.EndOfSimulationEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.EventType
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.RequestOfDestruction
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.SplitEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- getNextValue(int) - Method in class ds.granules.naadsm.staticsplit.event.TraceResult
-
- getNumberOfAvailableResources() - Method in class ds.granules.operation.JobSubmission
-
Retrieves the number of available resources.
- getNumberOfColumns() - Method in class ds.granules.util.Matrix
-
- getNumberOfCompletedTasks() - Method in class ds.granules.scheduler.Diagnostics
-
- getNumberOfComputations() - Method in class ds.granules.scheduler.ResourceMetrics
-
- getNumberOfConcurrentDeployments() - Method in interface ds.granules.operation.ProgressTracker
-
Gets the number of concurrent deployments.
- getNumberOfConcurrentDeployments() - Method in class ds.granules.operation.ProgressTrackerWidget
-
- getNumberOfDatasets() - Method in interface ds.granules.dataset.DatasetCollection
-
Get the number of datasets in this collection.
- getNumberOfDatasets() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- getNumberOfInputStreams() - Method in class ds.granules.dataset.StreamDataset
-
- getNumberOfInputStreams() - Method in interface ds.granules.dataset.StreamingAccess
-
Retrieve the number of input streams in this dataset
- getNumberofIterationsSoFar() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getNumberofIterationsSoFar() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the number of iterations performed for the operation so far
- getNumberOfMaps() - Method in class ds.granules.operation.MapReduceBase
-
- getNumberOfMaps() - Method in interface ds.granules.operation.Reduce
-
Retrieves the number of registered Map instances
- getNumberOfOutputStreams() - Method in class ds.granules.dataset.StreamDataset
-
- getNumberOfOutputStreams() - Method in interface ds.granules.dataset.StreamingAccess
-
Retrieve the number of output streams in this dataset.
- getNumberOfProcessors() - Method in class ds.granules.scheduler.ResourceMetrics
-
Retrieve the number of processors available to this resource.
- getNumberOfReducers() - Method in interface ds.granules.operation.Map
-
Retrieves the number of registered Reduce instances
- getNumberOfReducers() - Method in class ds.granules.operation.MapReduceBase
-
- getNumberOfResources() - Method in class ds.granules.operation.JobSubmission
-
- getNumberOfRows() - Method in class ds.granules.util.Matrix
-
- getNumberOfTimesToExecute() - Method in interface ds.granules.operation.ExecutionProfile
-
Retrieves the number of times the operation needs to be executed.
- getNumberOfTimesToExecute() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- getNumVectors() - Method in class ds.granules.samples.kmeans.KMVectorData
-
- getObjectArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into an Object[]
.
- getOperation() - Method in class ds.granules.exchange.DeploymentMessage
-
- getOperation() - Method in class ds.granules.scheduler.ExecutableTask
-
Retrieve the operation that will be executed by this task
- getOperationIdentifier() - Method in interface ds.granules.operation.Operation
-
Retrieve the identifier associated with this operation.
- getOperationIdentifier() - Method in class ds.granules.operation.OperationBase
-
- getOutput() - Method in class ds.granules.bridge.JavaByteMessage
-
- getOutputStreams() - Method in class ds.granules.dataset.StreamDataset
-
- getOutputStreams() - Method in interface ds.granules.dataset.StreamingAccess
-
Retrieve a HashMap of the constituent output streams.
- getOverwrite() - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- getOverwrite() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- getOverwrite() - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getOverwrite() - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getPosition(String) - Method in interface ds.granules.dataset.FileAccess
-
Retrieves the position of filePointer for the given dataset
- getPosition(String) - Method in class ds.granules.dataset.FileDataset
-
- getPredictedTime(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Get the predicted time of all the workers.
- getPredictedTime() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Get the predicted time of the current worker.
- getProcessingDirectives() - Method in interface ds.granules.operation.Operation
-
These properties encapsulate the set of processing directives that are
needed to initialize the operation in question.
- getProcessingDirectives() - Method in class ds.granules.operation.OperationBase
-
- getProcessorInfo() - Method in interface ds.granules.scheduler.ResourceProfile
-
Retrieve the processor information
- getProperties(String) - Method in class ds.granules.util.ParamsReader
-
Constructs a set of properties from the specified configuration file.
- getQueueSize() - Method in interface ds.granules.scheduler.ResourceProfile
-
Retrieve the queue size at the resource/
- getReduceIdentifiers() - Method in interface ds.granules.operation.Map
-
Retrieves the set of Reduce identifiers
- getReduceIdentifiers() - Method in class ds.granules.operation.MapReduceBase
-
- getResourceDiscovery(byte[]) - Method in class ds.granules.exchange.ExchangeFactory
-
Reconstructs the ResourceDiscovery
from a stream of bytes
- getResourceMetrics() - Method in class ds.granules.exchange.ResourceDiscovery
-
- getResourceMetrics() - Method in class ds.granules.scheduler.Diagnostics
-
Retrieve the resource metrics
- getResourceType() - Method in class ds.granules.exchange.ResourceDiscovery
-
- getRespondTo() - Method in class ds.granules.exchange.Exchange
-
Retrieve the respondTo field for this exchange.
- getRespondTo() - Method in interface ds.granules.results.Results
-
Retrieve the respondTo field for the Results
- getRespondTo() - Method in class ds.granules.results.ResultsWidget
-
- getRestartHistory() - Method in interface ds.granules.scheduler.ResourceProfile
-
Retrieves the restart history of this resource.
- getResultIdentifier() - Method in interface ds.granules.results.Results
-
Gets the identifier for this slice of the results.
- getResultIdentifier() - Method in class ds.granules.results.ResultsWidget
-
- getResultPayload() - Method in interface ds.granules.results.Results
-
Retrieve the payload associated with this result.
- getResultPayload() - Method in class ds.granules.results.ResultsWidget
-
- getResults(byte[]) - Method in class ds.granules.results.ResultsFactory
-
Recreate the Results object from a byte[].
- getResultType() - Method in interface ds.granules.results.Results
-
Get the type of the result encapsulated within the payload.
- getResultType() - Method in class ds.granules.results.ResultsWidget
-
- getRow(String, NBEvent) - Method in class ds.granules.samples.matrix.MatrixSharedMemory
-
- getSequencingInfo() - Method in interface ds.granules.results.Results
-
Retrieves the sequencing information associated with this result.
- getSequencingInfo(byte[]) - Method in class ds.granules.results.ResultsFactory
-
Creates a sequencing info from a set of bytes.
- getSequencingInfo() - Method in class ds.granules.results.ResultsWidget
-
- getShort(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a short
.
- getShort2DArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a short[][]
.
- getShortArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a short[].
- getSingleSequence() - Method in interface ds.granules.results.SequencingInfo
-
Retrieve the single-sequence information.
- getSingleSequence() - Method in class ds.granules.results.SequencingWidget
-
- getSnapshot() - Method in class ds.granules.naadsm.ft.RecoveryProcess
-
- getSource() - Method in class ds.granules.naadsm.portionaldynamicmerge.LBOperationNode
-
- getSplitNode() - Method in class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
-
- getSplittedWorker(int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Get the list that contains all the split workers.
- getSplittedWorker(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Get the list that contains all the split workers.
- getStartTime() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getStartTime() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the time this operation was first launched
- getStatus() - Method in class ds.granules.operation.InstanceDeployer
-
Returns the status of all Jobs that have been submitted from this node in
question.
- getStatus() - Method in class ds.granules.operation.JobSubmission
-
This method returns a String representation of the status of all jobs
that have been submitted from this node.
- getStatusOfJob(String) - Method in class ds.granules.operation.JobSubmission
-
Retrieve the status of a specific job that was submitted from this node.
- getStatusOfTask(String, String) - Method in class ds.granules.operation.JobSubmission
-
Retrieve the status of a task.
- getStatusOfTask(String) - Method in class ds.granules.scheduler.Diagnostics
-
Retrieve the status associated with a specific task.
- getStorageInfo() - Method in interface ds.granules.scheduler.ResourceProfile
-
Retrieves information about the available storage.
- getStreamIdentifier() - Method in class ds.granules.bridge.JavaByteMessage
-
- getStreamingData() - Method in class ds.granules.dataset.StreamDataset
-
- getStreamingData() - Method in interface ds.granules.dataset.StreamingAccess
-
Retrieves a portion of the streaming dataset when data is available.
- getStreamingDataset(byte[]) - Method in class ds.granules.dataset.DatasetFactory
-
Reconstruct the streaming dataset from a byte[] representation of it.
- getString(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[]
into a String
.
- getStringArray(byte[]) - Method in class ds.granules.results.ResultPayload
-
This method converts a byte[] into a String[].
- getTail(byte[], int) - Static method in class ds.granules.naadsm.resplit.Controller
-
Get the last few bytes of a byte array
- getTarget() - Method in class ds.granules.naadsm.portionaldynamicmerge.LBOperationNode
-
- getTaskCompletionInfo() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getTaskCompletionInfo() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve information about the completion of a task.
- getTaskIdentifier() - Method in class ds.granules.exchange.DeploymentMessage
-
- getTaskIdentifier() - Method in class ds.granules.exchange.ExecutionStatus
-
- getTaskIdentifiers() - Method in interface ds.granules.operation.ProgressTracker
-
Gets the task identifiers associated with the concurrent deployments
- getTaskIdentifiers() - Method in class ds.granules.operation.ProgressTrackerWidget
-
- getTaskLifecycleMetrics() - Method in class ds.granules.exchange.ExecutionStatus
-
Retrieve the TaskLifecycleMetrics
associated with the
RESPONSE.
- getTaskLifecycleMetrics(String) - Method in interface ds.granules.operation.ProgressTracker
-
Retrieve the TaskLifecycleMetrics associated with a given task.
- getTaskLifecycleMetrics(String) - Method in class ds.granules.operation.ProgressTrackerWidget
-
- getTaskLifecycleMetrics() - Method in class ds.granules.scheduler.ExecutableTask
-
Retrieve the TaskLifecyleMetrics associated with this task.
- getThreadPoolSize() - Method in class ds.granules.scheduler.ResourceMetrics
-
Retrieve the thread pool size.
- getTimeResidentInMemory() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
-
- getTimeResidentInMemory() - Method in interface ds.granules.scheduler.TaskLifecycleMetrics
-
Retrieve the time this operation spent residing in memory
- getTimestamp() - Method in class ds.granules.exchange.Exchange
-
Retrieve the timestamp for this exchange.
- getTimestamp() - Method in interface ds.granules.results.Results
-
Retrieve the timestamp for this result.
- getTimestamp() - Method in class ds.granules.results.ResultsWidget
-
- getTotalMemory() - Method in class ds.granules.scheduler.ResourceMetrics
-
Retrieve the total memory assigned to the resource in MB.
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForVaccination
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestOfDestruction
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.TraceResult
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.Vaccination
-
- getType() - Method in class ds.granules.naadsm.dynamicmerge.event.VaccinationCanceled
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfSimulationEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.RequestOfDestruction
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- getType() - Method in class ds.granules.naadsm.dynamicsplit.event.TraceResult
-
- getType() - Method in class ds.granules.naadsm.event.AttemptToInfect
-
- getType() - Method in class ds.granules.naadsm.event.Checkpoint
-
- getType() - Method in class ds.granules.naadsm.event.DestructionEvent
-
- getType() - Method in class ds.granules.naadsm.event.EndOfDayEvent
-
- getType() - Method in class ds.granules.naadsm.event.EndOfSimulationEvent
-
- getType() - Method in class ds.granules.naadsm.event.EventType
-
- getType() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getType() - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
-
- getType() - Method in class ds.granules.naadsm.event.QuarantineEvent
-
- getType() - Method in class ds.granules.naadsm.event.RequestForZoneFocus
-
- getType() - Method in class ds.granules.naadsm.event.RequestOfDestruction
-
- getType() - Method in class ds.granules.naadsm.event.Restore
-
- getType() - Method in class ds.granules.naadsm.event.SplitEvent
-
- getType() - Method in class ds.granules.naadsm.event.StartNewDayEvent
-
- getType() - Method in class ds.granules.naadsm.event.TraceResult
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForVaccination
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestOfDestruction
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.TraceResult
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Vaccination
-
- getType() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.VaccinationCanceled
-
- getType() - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
-
- getType() - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- getType() - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.Detection
-
- getType() - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.EventType
-
- getType() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getType() - Method in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
-
- getType() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getType() - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- getType() - Method in class ds.granules.naadsm.resplit.event.RequestForVaccination
-
- getType() - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
-
- getType() - Method in class ds.granules.naadsm.resplit.event.RequestOfDestruction
-
- getType() - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getType() - Method in class ds.granules.naadsm.resplit.event.SplitByDensity
-
- getType() - Method in class ds.granules.naadsm.resplit.event.SplitEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- getType() - Method in class ds.granules.naadsm.resplit.event.TraceResult
-
- getType() - Method in class ds.granules.naadsm.resplit.event.Vaccination
-
- getType() - Method in class ds.granules.naadsm.resplit.event.VaccinationCanceled
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.EndOfSimulationEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.EventType
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.RequestOfDestruction
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.SplitEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- getType() - Method in class ds.granules.naadsm.staticsplit.event.TraceResult
-
- getUpper() - Method in interface ds.granules.results.SequencingInfo
-
Retrieve the upper-bound of the specified range.
- getUpper() - Method in class ds.granules.results.SequencingWidget
-
- getUptime() - Method in interface ds.granules.scheduler.ResourceProfile
-
Retrieves the time for which this resource has been up-and-running
continuously without failures.
- getVarCode() - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getVarCode() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getVarCode() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getVecLen() - Method in class ds.granules.samples.kmeans.KMVectorData
-
- getVersion() - Static method in class ds.granules.util.Version
-
- getVersionInformation() - Method in interface ds.granules.operation.Operation
-
A monotonically increasing version number needs to be associated with the
operations.
- getVersionInformation() - Method in class ds.granules.operation.OperationBase
-
- getWorker(int) - Method in class ds.granules.naadsm.ft.HostInfo
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.AttemptToInfect
-
- getWorkerID() - Method in class ds.granules.naadsm.event.Checkpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.event.DestructionEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.EndOfDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.QuarantineEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.RequestForZoneFocus
-
- getWorkerID() - Method in class ds.granules.naadsm.event.Restore
-
- getWorkerID() - Method in class ds.granules.naadsm.event.SplitEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.event.StartNewDayEvent
-
- getWorkerId() - Method in class ds.granules.naadsm.ft.WorkerInfo
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.Detection
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.Restore
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.SplitByDensity
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.SplitEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.SplitEvent
-
- getWorkerID() - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- getWorkerList() - Method in class ds.granules.naadsm.ft.Snapshot
-
- getWorkerNumber() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Get the worker number.
- getWorkerNumber() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Get the worker number.
- GranTuple - Class in ds.granules.learning.classification.common
-
Helper class needed because Mahout's StringTuple is not normally serializable.
- GranTuple() - Constructor for class ds.granules.learning.classification.common.GranTuple
-
- GranulesCluster - Class in ds.granules.learning.clustering.kmeans
-
Wrapper for Mahout's Cluster
class.
- GranulesCluster(Cluster) - Constructor for class ds.granules.learning.clustering.kmeans.GranulesCluster
-
- GranulesDirichletCluster - Class in ds.granules.learning.clustering.dirichlet
-
Wrapper for Mahout's DirichletCluster
- GranulesDirichletCluster(DirichletCluster) - Constructor for class ds.granules.learning.clustering.dirichlet.GranulesDirichletCluster
-
- GranulesObservations - Class in ds.granules.learning.clustering.fuzzykmeans
-
- GranulesObservations(ClusterObservations) - Constructor for class ds.granules.learning.clustering.fuzzykmeans.GranulesObservations
-
- GranulesObservations - Class in ds.granules.learning.clustering.kmeans
-
Wrapper for Mahout's Observation
class.
- GranulesObservations(ClusterObservations) - Constructor for class ds.granules.learning.clustering.kmeans.GranulesObservations
-
- GranulesSoftCluster - Class in ds.granules.learning.clustering.fuzzykmeans
-
- GranulesSoftCluster(SoftCluster) - Constructor for class ds.granules.learning.clustering.fuzzykmeans.GranulesSoftCluster
-
- GrepCountDeployer - Class in ds.granules.samples.grep
-
The deployer for the GREP information retrieval example, which allows one to
perform a regular expressions query on given set of files over a distributed
set of resources.
- GrepCountDeployer(Properties) - Constructor for class ds.granules.samples.grep.GrepCountDeployer
-
Initializes the deployer.
- GrepCountMap - Class in ds.granules.samples.grep
-
An example demonstrating the Map
role within a Grep Count
operation.
- GrepCountMap() - Constructor for class ds.granules.samples.grep.GrepCountMap
-
- GrepCountReduce - Class in ds.granules.samples.grep
-
An example demonstrating the Reduce
role within a Grep Count
operation.
- GrepCountReduce() - Constructor for class ds.granules.samples.grep.GrepCountReduce
-
- IllegalModificationException - Exception in ds.granules.results
-
This is a RuntimeException
that will be thrown when an attempt
is made to modify results (and its constituent elements) after they have been
marked as immutable.
- IllegalModificationException() - Constructor for exception ds.granules.results.IllegalModificationException
-
Constructs an IllegalArgumentException
with no detail
message.
- IllegalModificationException(String) - Constructor for exception ds.granules.results.IllegalModificationException
-
Constructs an IllegalArgumentException
with the specified
detail message.
- IllegalModificationException(String, Throwable) - Constructor for exception ds.granules.results.IllegalModificationException
-
Constructs a new exception with the specified detail message and cause.
- IllegalModificationException(Throwable) - Constructor for exception ds.granules.results.IllegalModificationException
-
Constructs a new exception with the specified cause and a detail message
of (cause==null ? null : cause.toString()) (which typically
contains the class and detail message of cause).
- incrementNumberOfDeployments() - Method in class ds.granules.operation.ProgressTrackerWidget
-
- incrementSuspendedWorkers() - Method in class ds.granules.naadsm.ft.RecoveryProcess
-
- INITIALIZE - Static variable in interface ds.granules.bridge.ControlMessage
-
- initialize(Properties) - Method in class ds.granules.naadsm.ft.Heartbeat
-
- initialize(Properties) - Method in class ds.granules.naadsm.ft.Speculator
-
- initialize(Properties) - Method in class ds.granules.operation.InstanceDeployer
-
This initializes the deployer based on the specified argument.
- initialize(Properties, String) - Method in class ds.granules.operation.InstanceDeployer
-
This initializes the deployer based on the specified arguments.
- initialize(String, int, Properties, String) - Method in class ds.granules.operation.InstanceDeployer
-
This initializes the deployer based on the specified arguments.
- initialize(String, int, Properties, String) - Method in class ds.granules.operation.JobSubmission
-
Initializes communications based on the specified parameters.
- initialize(Properties) - Method in interface ds.granules.operation.Operation
-
Initialize the operation based on the specified processing directives.
- initialize(Properties) - Method in class ds.granules.operation.OperationBase
-
- initialize(Properties) - Method in class ds.granules.samples.checksum.ChecksumMap
-
- initialize() - Method in class ds.granules.scheduler.ExchangeProcessor
-
- initialize(String, int, Properties, String) - Method in class ds.granules.scheduler.StreamingService
-
Initialize the streaming service based on the specified parameters
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.naadsm.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.naadsm.resplit.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.samples.bridge.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.samples.checksum.Client
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.samples.flip.LoadGenerator
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.samples.pythonColl.PyLoadGen
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
-
- initializeBrokerCommunications(Properties, String) - Method in class ds.granules.samples.sort.NumberGenerator
-
- initializeConsumer() - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.naadsm.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.naadsm.resplit.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.samples.bridge.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.samples.flip.LoadGenerator
-
- initializeConsumer() - Method in class ds.granules.samples.pythonColl.PyLoadGen
-
- initializeConsumer() - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
-
- initializeController(int) - Method in class ds.granules.naadsm.Deployer
-
- initializeController(int, int, int, int, int) - Method in class ds.granules.naadsm.dynamicmerge.Deployer
-
Initialize the controller
- initializeController(int) - Method in class ds.granules.naadsm.dynamicsplit.Deployer
-
Initialize the controller
- initializeController(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.Deployer
-
Initialize the controller
- initializeController(int) - Method in class ds.granules.naadsm.resplit.Deployer
-
Initialize the controller
- initializeController(int) - Method in class ds.granules.naadsm.staticsplit.Deployer
-
Initialize the controller
- INITIALIZED - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
-
- initializeDataset() - Method in interface ds.granules.dataset.Dataset
-
Invokes the initialization of the dataset.
- initializeDataset() - Method in class ds.granules.dataset.FileDataset
-
- initializeDataset() - Method in class ds.granules.dataset.StreamDataset
-
- initializeDatasets() - Method in interface ds.granules.dataset.DatasetCollection
-
Initializes all the constituent datasets in this collection.
- initializeDatasets() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- initializeFibMap(int, String, int) - Method in class ds.granules.samples.bridge.FibDeployer
-
Initialize a specific FibMap
instance.
- initializeFlipMap(int) - Method in class ds.granules.samples.flip.FlipDeployer
-
Initialize a specific FlipMap
instance.
- initializeMatrixMap(int, int, int) - Method in class ds.granules.samples.matrix.MatrixDeployer
-
Initializes a MatrixMap
instance based on the specified
arguments.
- initializeProducer() - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.naadsm.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.naadsm.resplit.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.samples.bridge.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.samples.checksum.Client
-
- initializeProducer() - Method in class ds.granules.samples.flip.LoadGenerator
-
- initializeProducer() - Method in class ds.granules.samples.pythonColl.PyLoadGen
-
- initializeProducer() - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
-
- initializeProducer() - Method in class ds.granules.samples.sort.NumberGenerator
-
- initializePyCollMap(PyCollReduce, int, String, int) - Method in class ds.granules.samples.pythonColl.PyCollDeploy1Shot
-
Initialize a specific FibMap
instance.
- initializePyCollMap(PyCollReduce, int, String, int) - Method in class ds.granules.samples.pythonColl.PyCollDeployer
-
Initialize a specific FibMap
instance.
- initializePyCollMap(PyCollReduceRep, int, String, int) - Method in class ds.granules.samples.pythonColl.PyCollDeployerRep
-
Initialize a specific FibMap
instance.
- initializeSortingOperation(int) - Method in class ds.granules.samples.sort.SortDeployer
-
Initialize a specific SortingOperation
instance.
- initializeSortMap(SortReduce, int) - Method in class ds.granules.samples.sort.SortDeployer
-
Initializes a SortMap
instance based on the specified
arguments.
- initializeStageTwos(StageOne, StageThree, int, String, int) - Method in class ds.granules.samples.iterative.IterativeDeployer
-
Initialize a set of StageTwo
s.
- initializeWorker(int, int, int, int, int, int) - Method in class ds.granules.naadsm.Deployer
-
- initializeWorker(int, int, int, int, int, int) - Method in class ds.granules.naadsm.dynamicmerge.Deployer
-
Initialize one worker
- initializeWorker(int, int, int, int, int, int) - Method in class ds.granules.naadsm.dynamicsplit.Deployer
-
Initialize one worker
- initializeWorker(int, int) - Method in class ds.granules.naadsm.portionaldynamicmerge.Deployer
-
Initialize one worker
- initializeWorker(int, int) - Method in class ds.granules.naadsm.resplit.Deployer
-
Initialize one worker
- initializeWorker(int, int, int, int, int, int, int) - Method in class ds.granules.naadsm.staticsplit.Deployer
-
Initialize one worker
- INITIALIZING - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
-
- inputMax - Variable in class ds.granules.naadsm.ml.NeuralState
-
- inputMin - Variable in class ds.granules.naadsm.ml.NeuralState
-
- InstanceDeployer - Class in ds.granules.operation
-
This is a class that encapsulates several of the functionality that need to
be supported by Granules application deployers.
- InstanceDeployer() - Constructor for class ds.granules.operation.InstanceDeployer
-
- INT - Static variable in interface ds.granules.bridge.ControlMessage
-
- INT - Static variable in class ds.granules.results.ResultPayload
-
- int2bytes(int) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
-
- int2bytes(int) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
-
- int2bytes(int) - Static method in class ds.granules.naadsm.event.EventTypeFactory
-
- int2bytes(int) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
-
- int2bytes(int) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
-
- int2bytes(int) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
-
- INT_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- INT_ARR - Static variable in interface ds.granules.bridge.ControlMessage
-
- INT_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- INT_ENTRIES - Static variable in class ds.granules.util.Matrix
-
- isActive() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Check whether this worker is active.
- isActive() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Check whether this worker is active.
- isAdequate() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- isAdequate() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- isAdequate() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- isAdequate() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- isAdequate() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- isAdequate() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- isAllDone() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Check whether all the workers have finished the simulation of current day.
- isAllDone() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Check whether all the workers have finished the simulation of current
day.
- isAllFinished() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Check whether all the workers have finished the whole simulation.
- isAllFinished() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Check whether all the workers have finished the whole simulation.
- isAvailable() - Method in interface ds.granules.dataset.Dataset
-
A check to see if the dataset is available
- isAvailable() - Method in class ds.granules.dataset.FileDataset
-
- isAvailable() - Method in class ds.granules.dataset.StreamDataset
-
- isAwaitingOutputs() - Method in class ds.granules.operation.MapReduceBase
-
- isAwaitingOutputs() - Method in interface ds.granules.operation.Reduce
-
Check to see is the Reducer is missing outputs from any of the registered
Maps.
- isChangedPeriodicExecution(String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
-
Indicates that the task in question has changed it execution profile.
- isChangedPeriodicExecution(String) - Method in class ds.granules.scheduler.TaskManagement
-
- isClosed() - Method in interface ds.granules.dataset.DatasetCollection
-
This method indicates whether this dataset collection is closed.
- isClosed() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- isColumnMajorFormat() - Method in class ds.granules.util.Matrix
-
- isComplete() - Method in class ds.granules.naadsm.ft.Snapshot
-
A Snapshot is only complete when it has information from every active
Worker.
- isComplete() - Method in interface ds.granules.operation.ProgressTracker
-
Check to see if the Job has completed.
- isComplete() - Method in class ds.granules.operation.ProgressTrackerWidget
-
- isComplete(String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
-
Indicates that the task in question has finished processing.
- isComplete(String) - Method in class ds.granules.scheduler.TaskManagement
-
- isCompleteResult() - Method in interface ds.granules.results.Results
-
Check to see if this results encapsulates the complete result from
processing.
- isCompleteResult() - Method in class ds.granules.results.ResultsWidget
-
- isDataAvailable() - Method in interface ds.granules.dataset.Dataset
-
This polls the dataset to see if data is available for consumption.
- isDataAvailable() - Method in interface ds.granules.dataset.DatasetCollection
-
Reports on the availability of data in any of the underlying datasets
that are part of this collection.
- isDataAvailable() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- isDataAvailable() - Method in class ds.granules.dataset.FileDataset
-
- isDataAvailable() - Method in class ds.granules.dataset.StreamDataset
-
- isDone() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Check whether the worker has finished the simulation of current day.
- isDone() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Check whether the worker has finished the simulation of current day.
- isExcuteAFixedNumberOfTimes() - Method in interface ds.granules.operation.ExecutionProfile
-
Indicates whether the operation needs to be executed a fixed number of
times
- isExcuteAFixedNumberOfTimes() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- isExecuteOnce() - Method in interface ds.granules.operation.ExecutionProfile
-
This indicates if the operation needs to be executed exactly once
- isExecuteOnce() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- isExecutePeriodically() - Method in interface ds.granules.operation.ExecutionProfile
-
Indicates whether the operation needs to be executed periodically.
- isExecutePeriodically() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- isExecutePeriodically() - Method in class ds.granules.scheduler.ExecutableTask
-
A check to see if the task in question needs to be executed periodically.
- isExecuteWhenDataAvailable() - Method in interface ds.granules.operation.ExecutionProfile
-
This indicates that the operation should be run when new data is made
available on its input datasets.
- isExecuteWhenDataAvailable() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- isExecuting(String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
-
Indicates that the task in question has been scheduled for execution and
is currently executing.
- isExecuting(String) - Method in class ds.granules.scheduler.TaskManagement
-
- isFinished() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
-
- isFinished() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Check whether the worker has finished the whole simulation.
- isFinished() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
-
- isFinished() - Method in class ds.granules.naadsm.event.EndOfDayEvent
-
- isFinished() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
-
- isFinished() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Check whether the worker has finished the whole simulation.
- isFinished() - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
-
- isFinished() - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
-
- isFromJava() - Method in class ds.granules.bridge.JavaByteMessage
-
- isInitialized() - Method in interface ds.granules.dataset.Dataset
-
Check to see if the dataset has been initialized
- isInitialized() - Method in class ds.granules.dataset.FileDataset
-
- isInitialized() - Method in class ds.granules.dataset.StreamDataset
-
- isInitialized() - Method in interface ds.granules.operation.Operation
-
Check if the operation has been initialized
- isInitialized() - Method in class ds.granules.operation.OperationBase
-
- isInitialized() - Method in class ds.granules.scheduler.StreamingService
-
Checks to see if the streaming service has been initialized.
- isInitializing(String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
-
Indicates that the task is question is currently performing
initialization related operations.
- isInitializing(String) - Method in class ds.granules.scheduler.TaskManagement
-
- isMutable() - Method in interface ds.granules.results.Results
-
Checks to see if this data structure is mutable.
- isMutable() - Method in class ds.granules.results.ResultsWidget
-
- isMutable() - Method in interface ds.granules.results.SequencingInfo
-
Check to see if the sequencing information is mutable.
- isMutable() - Method in class ds.granules.results.SequencingWidget
-
- isPartialResult() - Method in interface ds.granules.results.Results
-
Check to see if this is a partial result, within a stream of results that
constitute the final result.
- isPartialResult() - Method in class ds.granules.results.ResultsWidget
-
- isPartOfDataset(String) - Method in interface ds.granules.dataset.FileAccess
-
Checks to see if the file is part of a given dataset
- isPartOfDataset(String) - Method in class ds.granules.dataset.FileDataset
-
- isProcessingComplete() - Method in interface ds.granules.results.Results
-
Check to see if the instance has completed processing of its input
dataset.
- isProcessingComplete() - Method in class ds.granules.results.ResultsWidget
-
- isReady(String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
-
When a task is ready for execution, this method is invoked on its
registered observer.
- isReady(String) - Method in class ds.granules.scheduler.TaskManagement
-
- isRequest() - Method in class ds.granules.exchange.Exchange
-
Indicates whether this exchange is a Request
- isResponse() - Method in class ds.granules.exchange.Exchange
-
Indicates whether this exchange is a Response to a previously issued
request.
- isRowMajorFormat() - Method in class ds.granules.util.Matrix
-
- isStayAlive() - Method in interface ds.granules.operation.ExecutionProfile
-
This indicates that the operation should be allowed to continually run
until the operation deems necessary.
- isStayAlive() - Method in class ds.granules.operation.ExecutionProfileSetup
-
- isSuccessful() - Method in interface ds.granules.operation.ProgressTracker
-
Check to see if the Job completed successfully.
- isSuccessful() - Method in class ds.granules.operation.ProgressTrackerWidget
-
- isTraceable() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
-
- isTraceable() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
-
- isTraceable() - Method in class ds.granules.naadsm.event.ExposureEvent
-
- isTraceable() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
-
- isTraceable() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
-
- isTraceable() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
-
- isValidExchangeSubType() - Method in class ds.granules.exchange.DeploymentMessage
-
- isValidExchangeSubType() - Method in class ds.granules.exchange.Exchange
-
Checks to see if the exchange sub-type in the reconstructed exchange is a
valid one.
- isValidExchangeSubType() - Method in class ds.granules.exchange.ExecutionStatus
-
- isValidExchangeSubType() - Method in class ds.granules.exchange.ResourceDiscovery
-
- isValidExchangeType(int) - Method in class ds.granules.exchange.ExchangeFactory
-
Checks to see if a given exchange type is a valid one.
- isWaitingForData(String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
-
Indicates that the task in question is waiting for the arrival of data to
begin processing.
- isWaitingForData(String) - Method in class ds.granules.scheduler.TaskManagement
-
- IterativeDeployer - Class in ds.granules.samples.iterative
-
The deployer for the example demonstrating iterative semantics using
Granules.
- IterativeDeployer(Properties) - Constructor for class ds.granules.samples.iterative.IterativeDeployer
-
Initializes the deployer.
- ParamsReader - Class in ds.granules.util
-
This is a utility class which is useful in reading specified configuration
parameters.
- parseEvents(byte[]) - Static method in class ds.granules.naadsm.resplit.Controller
-
Get list of events from a byte array.
- passesReadinessCheck() - Method in class ds.granules.scheduler.ExecutableTask
-
Checks to see if the task is ready for execution.
- PAUSE_RESUME - Static variable in interface ds.granules.bridge.ControlMessage
-
- pauseAvailabilityNotifications(DataAvailabilityObserver) - Method in interface ds.granules.dataset.DataAvailabilityNotifier
-
Pauses data availability notifications for the specified observer
- pauseAvailabilityNotifications(DataAvailabilityObserver) - Method in class ds.granules.dataset.DatasetNotifier
-
- pauseTask() - Method in interface ds.granules.scheduler.Controller
-
- PeriodicDeployer - Class in ds.granules.samples.periodic
-
The deployer for the example that demonstrates using Granules to perform
operations at regular intervals on a distributed set of machines.
- PeriodicDeployer(Properties) - Constructor for class ds.granules.samples.periodic.PeriodicDeployer
-
Initializes the deployer.
- PeriodicMap - Class in ds.granules.samples.periodic
-
An example demonstrating support for periodicity.
- PeriodicMap() - Constructor for class ds.granules.samples.periodic.PeriodicMap
-
- PeriodicReduce - Class in ds.granules.samples.periodic
-
- PeriodicReduce() - Constructor for class ds.granules.samples.periodic.PeriodicReduce
-
- pickupEndOfDay(LinkedList<EventType>) - Static method in class ds.granules.naadsm.resplit.Controller
-
Get the end of day event from a list of events.
- pickupEndOfDay(byte[]) - Static method in class ds.granules.naadsm.resplit.Controller
-
From a whole message, pick up the END_OF_DAY message
- pickupOutputVariableValue(LinkedList<EventType>) - Method in class ds.granules.naadsm.resplit.Controller
-
Get the output variable values from a list of events.
- pickupOutputVariableValue(byte[]) - Method in class ds.granules.naadsm.resplit.Controller
-
Get output variable values from a byte array.
- predict(MLData) - Method in class ds.granules.naadsm.ml.NeuralPredictor
-
Predict one data with the current network.
- predict(MLData) - Method in interface ds.granules.naadsm.ml.Predictor
-
- Predictor - Interface in ds.granules.naadsm.ml
-
This is the interface of all the predictor.
- prepareBaseInstances(String, int, String, String) - Method in class ds.granules.naadsm.relaunch.ClusterDeployer
-
Prepares a set of instances to be deployed.
- prepareBaseInstancesAndDeploy(String, int, String, String) - Method in class ds.granules.naadsm.ClusterDeployer
-
Prepares a set of instances to be deployed.
- prepareBaseInstancesAndDeploy(String, String, int, int) - Method in class ds.granules.samples.bioinf.ClusterDeployer
-
Prepares a set of instances to be deployed.
- prepareBaseInstancesAndDeploy(int) - Method in class ds.granules.samples.sort.SortDeployer
-
This method deploys vanilla SortingOperation
instances over
the set of available resources.
- prepareInstancesAndDeploy(int, int, int, String, String, int, String) - Method in class ds.granules.learning.classification.bayes.BayesDeployer
-
- prepareInstancesAndDeploy(int, int, int, String, String, int, String) - Method in class ds.granules.learning.classification.cbayes.CBayesDeployer
-
- prepareInstancesAndDeploy(int, String, int, String, int, String, String, String, String, int) - Method in class ds.granules.learning.clustering.dirichlet.DirichletDeployer
-
Prepares and deploys Mappers and a Reducer
- prepareInstancesAndDeploy(int, String, int, String, int, String, String, String, String) - Method in class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansDeployer
-
Prepares and deploys Mappers and a Reducer
- prepareInstancesAndDeploy(int, String, int, String, int, String, String, String) - Method in class ds.granules.learning.clustering.kmeans.KMeansDeployer
-
Prepares and deploys Mappers and a Reducer
- prepareInstancesAndDeploy(int, String, int, String, int, String, String, String, String) - Method in class ds.granules.learning.clustering.lda.LDADeployer
-
Prepares and deploys Mappers and a Reducer
- prepareInstancesAndDeploy(int, int, int, int, int) - Method in class ds.granules.naadsm.Deployer
-
- prepareInstancesAndDeploy(int, int, int, int, int) - Method in class ds.granules.naadsm.dynamicmerge.Deployer
-
Initialize the controller and all the workers
- prepareInstancesAndDeploy(int, int, int, int, int) - Method in class ds.granules.naadsm.dynamicsplit.Deployer
-
Initialize the controller and all the workers
- prepareInstancesAndDeploy(int) - Method in class ds.granules.naadsm.ft.Deployer
-
This method deploys GalileoMap
instances over the set of
available resources.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.Deployer
-
Initialize the controller and all the workers
- prepareInstancesAndDeploy(int) - Method in class ds.granules.naadsm.resplit.Deployer
-
Initialize the controller and all the workers
- prepareInstancesAndDeploy(int, int, int, int, int, int) - Method in class ds.granules.naadsm.staticsplit.Deployer
-
Initialize the controller and all the workers
- prepareInstancesAndDeploy(int, String, int) - Method in class ds.granules.samples.bridge.FibDeployer
-
This method deploys FibMap
instances over the set of
available resources.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.samples.checksum.ChecksumDeployer
-
This method deploys ChecksumMap instances over the set of
available resources.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.samples.flip.FlipDeployer
-
This method deploys FlipMap
instances over the set of
available resources.
- prepareInstancesAndDeploy(int, String, int) - Method in class ds.granules.samples.grep.GrepCountDeployer
-
Prepares a set of Map/Reduce instances for the Grep example and deploys
it on the set of available resources.
- prepareInstancesAndDeploy(int, String, int) - Method in class ds.granules.samples.iterative.IterativeDeployer
-
Prepares and deploys an iterative pipeline comprising one
StageOne
and StageThree
instances, and the
specified number of StageTwo
s.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.samples.periodic.PeriodicDeployer
-
Prepares the set of Map/Reduce instances to be deployed on a set of
machines.
- prepareInstancesAndDeploy(int, String, String, String, int, int, int, String, String) - Method in class ds.granules.samples.pythonColl.PyCollDeploy1Shot
-
This method deploys FibMap
instances over the set of
available resources.
- prepareInstancesAndDeploy(int, String, String, String, int, int, int, String, String) - Method in class ds.granules.samples.pythonColl.PyCollDeployer
-
This method deploys FibMap
instances over the set of
available resources.
- prepareInstancesAndDeploy(int, String, String, String, int, int, int, String, String) - Method in class ds.granules.samples.pythonColl.PyCollDeployerRep
-
This method deploys FibMap
instances over the set of
available resources.
- prepareInstancesAndDeploy(int) - Method in class ds.granules.samples.sort.SortDeployer
-
Prepares the set of Map/Reduce instances to be deployed on a set of
machines.
- prepareInstancesAndDeploy(int, String, int) - Method in class ds.granules.samples.wordcount.WordCountDeployer
-
Prepares a set of Map/Reduce instances for the WordCount example and
deploys it on the set of available resources.
- printEventMessage(EventType) - Static method in class ds.granules.naadsm.resplit.Controller
-
Print out the byte array of an event.
- printMap() - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
-
Pretty print the list.
- printVersionInformation() - Method in class ds.granules.util.Version
-
- PROBLEMS_ENCOUNTERED - Static variable in interface ds.granules.exchange.ConditionFlag
-
- processExecutionStatusRequest(ExecutionStatus) - Method in class ds.granules.scheduler.Diagnostics
-
- ProcessingException - Exception in ds.granules.operation
-
This exception is thrown when an operation wishes to report problems in its
execution.
- ProcessingException() - Constructor for exception ds.granules.operation.ProcessingException
-
Constructs an ProcessingException
with no detail message.
- ProcessingException(String) - Constructor for exception ds.granules.operation.ProcessingException
-
Constructs an ProcessingException
with the specified detail
message.
- processResourceDiscoveryRequest(ResourceDiscovery) - Method in class ds.granules.scheduler.Diagnostics
-
- processStreamPacket(NBEvent) - Method in class ds.granules.naadsm.ft.Speculator
-
Handles incoming events.
- ProgressTracker - Interface in ds.granules.operation
-
The ProgressTracker
encapsulates information about the status of
jobs.
- ProgressTrackerWidget - Class in ds.granules.operation
-
An implementation of the ProgressTracker
interface.
- ProgressTrackerWidget(String, String, JobLifecycleObserver) - Constructor for class ds.granules.operation.ProgressTrackerWidget
-
- proportion - Variable in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- proportion - Variable in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
-
- proportion - Variable in class ds.granules.naadsm.resplit.event.SplitByDensity
-
- PUBLIC_ANNOUNCEMENT - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- PUBLIC_ANNOUNCEMENT - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- PUBLIC_ANNOUNCEMENT - Static variable in class ds.granules.naadsm.event.EventType
-
- PUBLIC_ANNOUNCEMENT - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- PUBLIC_ANNOUNCEMENT - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- PUBLIC_ANNOUNCEMENT - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
-
- PublicAnnouncementEvent - Class in ds.granules.naadsm.dynamicmerge.event
-
PUBLIC_ANNOUNCEMENT message
- PublicAnnouncementEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
-
- PublicAnnouncementEvent - Class in ds.granules.naadsm.dynamicsplit.event
-
PUBLIC_ANNOUNCEMENT message
- PublicAnnouncementEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
-
- PublicAnnouncementEvent - Class in ds.granules.naadsm.event
-
- PublicAnnouncementEvent() - Constructor for class ds.granules.naadsm.event.PublicAnnouncementEvent
-
- PublicAnnouncementEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
PUBLIC_ANNOUNCEMENT message
- PublicAnnouncementEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
-
- PublicAnnouncementEvent - Class in ds.granules.naadsm.resplit.event
-
PUBLIC_ANNOUNCEMENT message
- PublicAnnouncementEvent() - Constructor for class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
-
- PublicAnnouncementEvent - Class in ds.granules.naadsm.staticsplit.event
-
PUBLIC_ANNOUNCEMENT message
- PublicAnnouncementEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
-
- publishComputeCommand() - Method in class ds.granules.samples.sort.NumberGenerator
-
- publishEvent(String, byte[]) - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
-
- publishEvent(String, byte[]) - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
-
- publishEvent(String, byte[]) - Method in class ds.granules.naadsm.LoadGenerator
-
- publishEvent(String, byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
-
- publishEvent(String, byte[]) - Method in class ds.granules.naadsm.resplit.LoadGenerator
-
- publishEvent(String, byte[]) - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
-
- publishEvent(long) - Method in class ds.granules.samples.bridge.LoadGenerator
-
- publishEvent(byte[]) - Method in class ds.granules.samples.bridge.LoadGenerator
-
- publishEvent(byte[]) - Method in class ds.granules.samples.checksum.Client
-
- publishEvent(String) - Method in class ds.granules.samples.flip.LoadGenerator
-
- publishEvent(byte[]) - Method in class ds.granules.samples.flip.LoadGenerator
-
- publishEvent(byte[]) - Method in class ds.granules.samples.pythonColl.PyLoadGen
-
- publishEvent(byte[]) - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
-
- publishEvent(byte[], String) - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
-
- publishEvent(String, long[]) - Method in class ds.granules.samples.sort.NumberGenerator
-
- PyCollDeploy1Shot - Class in ds.granules.samples.pythonColl
-
- PyCollDeploy1Shot(Properties) - Constructor for class ds.granules.samples.pythonColl.PyCollDeploy1Shot
-
Initializes the deployer.
- PyCollDeployer - Class in ds.granules.samples.pythonColl
-
- PyCollDeployer(Properties) - Constructor for class ds.granules.samples.pythonColl.PyCollDeployer
-
Initializes the deployer.
- PyCollDeployerRep - Class in ds.granules.samples.pythonColl
-
- PyCollDeployerRep(Properties) - Constructor for class ds.granules.samples.pythonColl.PyCollDeployerRep
-
Initializes the deployer.
- pyCollInit() - Method in class ds.granules.samples.pythonColl.PyCollMap
-
Simple function to actually initialize the c++ program
- PyCollMap - Class in ds.granules.samples.pythonColl
-
- PyCollMap() - Constructor for class ds.granules.samples.pythonColl.PyCollMap
-
- PyCollReduce - Class in ds.granules.samples.pythonColl
-
- PyCollReduce() - Constructor for class ds.granules.samples.pythonColl.PyCollReduce
-
- pyCollReduceInit() - Method in class ds.granules.samples.pythonColl.PyCollReduce
-
- pyCollReduceInit() - Method in class ds.granules.samples.pythonColl.PyCollReduceRep
-
- PyCollReduceRep - Class in ds.granules.samples.pythonColl
-
- PyCollReduceRep() - Constructor for class ds.granules.samples.pythonColl.PyCollReduceRep
-
- PyLoadGen - Class in ds.granules.samples.pythonColl
-
- PyLoadGen() - Constructor for class ds.granules.samples.pythonColl.PyLoadGen
-
- PyLoadGenRep - Class in ds.granules.samples.pythonColl
-
- PyLoadGenRep() - Constructor for class ds.granules.samples.pythonColl.PyLoadGenRep
-
- rdcrTopic - Variable in class ds.granules.samples.pythonColl.PyLoadGenRep
-
- read(String, byte[]) - Method in interface ds.granules.dataset.FileAccess
-
Attempts to read a set of bytes from the underlying file.
- read(String, ByteBuffer) - Method in interface ds.granules.dataset.FileAccess
-
Attempts to read a set of bytes from the underlying file.
- read(String, byte[]) - Method in class ds.granules.dataset.FileDataset
-
- read(String, ByteBuffer) - Method in class ds.granules.dataset.FileDataset
-
- readIntMatrix() - Method in class ds.granules.util.Matrix
-
Read a matrix that has been written to a file (specified in the
constructor) based on the specified rows and columns.
- readIntMatrix() - Method in class ds.granules.util.MatrixColumnMajor
-
- readIntMatrixColumn(int) - Method in class ds.granules.util.Matrix
-
This method reads a specified column from the matrix that has been
written to a file.
- readIntMatrixColumn(int) - Method in class ds.granules.util.MatrixColumnMajor
-
- readIntMatrixElement(int, int) - Method in class ds.granules.util.Matrix
-
Reads a matrix element from the underlying file based on the specified
[rowId, columId]
.
- readIntMatrixElement(int, int) - Method in class ds.granules.util.MatrixColumnMajor
-
- readIntMatrixRow(int) - Method in class ds.granules.util.Matrix
-
This method reads the specified row of a matrix that has been written to
a file.
- readIntMatrixRow(int) - Method in class ds.granules.util.MatrixColumnMajor
-
- readListFromFile(String) - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
-
Create the list from a file.
- readLongMatrix() - Method in class ds.granules.util.Matrix
-
Read a matrix that has been written to a file (specified in the
constructor) based on the specified rows and columns.
- readLongMatrix() - Method in class ds.granules.util.MatrixColumnMajor
-
- readLongMatrixColumn(int) - Method in class ds.granules.util.Matrix
-
This method reads a specified column from the matrix that has been
written to a file.
- readLongMatrixColumn(int) - Method in class ds.granules.util.MatrixColumnMajor
-
- readLongMatrixElement(int, int) - Method in class ds.granules.util.Matrix
-
Reads a matrix element from the underlying file based on the specified
[rowId, columId]
.
- readLongMatrixElement(int, int) - Method in class ds.granules.util.MatrixColumnMajor
-
- readLongMatrixRow(int) - Method in class ds.granules.util.Matrix
-
This method reads the specified row of a matrix that has been written to
a file.
- readLongMatrixRow(int) - Method in class ds.granules.util.MatrixColumnMajor
-
- readProperties(DataInputStream) - Method in class ds.granules.util.MarshallingUtil
-
Reads a property object from the underlying DataInputStream
- readString(DataInputStream) - Method in class ds.granules.util.MarshallingUtil
-
Reads a String from the underlying DataInputStream
- READY - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
-
- reconstruct(byte[]) - Method in class ds.granules.exchange.Exchange
-
Reconstruct the exchange from the byte[] representation.
- RecoveryProcess - Class in ds.granules.naadsm.ft
-
Tracks a recovery operation throughout its lifecycle.
- RecoveryProcess(Snapshot) - Constructor for class ds.granules.naadsm.ft.RecoveryProcess
-
- Reduce - Interface in ds.granules.operation
-
This interface corresponds to the Reduce role in a Map-Reduce
operation.
- refreshStatus(String) - Method in class ds.granules.operation.InstanceDeployer
-
This method refreshes the status of various tasks that comprise a Job.
- refreshStatus(String, String) - Method in class ds.granules.operation.InstanceDeployer
-
This method refreshes the status of a specific task that is part of the
Job in question.
- REG_EXPRESSIONS_SYNOPSIS - Static variable in interface ds.granules.dataset.StreamingAccess
-
- registerDataAvailabilityObserver(DataAvailabilityObserver) - Method in interface ds.granules.dataset.DataAvailabilityNotifier
-
Registers a data availability observer
- registerDataAvailabilityObserver(DataAvailabilityObserver) - Method in class ds.granules.dataset.DatasetNotifier
-
- rejectedExecution(Runnable, ThreadPoolExecutor) - Method in class ds.granules.scheduler.TaskManagement
-
- removeDataset(String) - Method in interface ds.granules.dataset.DatasetCollection
-
Remove a dataset from this collection
- removeDataset(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- removeDeploymentRequest(String) - Method in class ds.granules.scheduler.Diagnostics
-
Remove the deployment request associated with a task.
- removeFile(String) - Method in interface ds.granules.dataset.FileAccess
-
Removes a file from this dataset.
- removeFile(String) - Method in class ds.granules.dataset.FileDataset
-
- removeInputStream(String) - Method in class ds.granules.dataset.StreamDataset
-
- removeInputStream(String) - Method in interface ds.granules.dataset.StreamingAccess
-
Removes an input stream from this dataset.
- removeInputStreams(ConcurrentHashMap<String, Integer>) - Method in class ds.granules.dataset.StreamDataset
-
- removeInputStreams(ConcurrentHashMap<String, Integer>) - Method in interface ds.granules.dataset.StreamingAccess
-
Removes a set of input streams from this dataset.
- removeMap(String) - Method in class ds.granules.operation.MapReduceBase
-
- removeMap(String) - Method in interface ds.granules.operation.Reduce
-
Removes a Map from the list of Maps that are registered to this reducer.
- removeMapper(Map) - Method in class ds.granules.operation.MapReduceBase
-
This method is called on a Reduce, once it has been removed from a
Map
using the Map.removeReduce() method.
- removeOutputStream(String) - Method in class ds.granules.dataset.StreamDataset
-
- removeOutputStream(String) - Method in interface ds.granules.dataset.StreamingAccess
-
Removes an output stream from this dataset.
- removeOutputStreams(ConcurrentHashMap<String, Integer>) - Method in class ds.granules.dataset.StreamDataset
-
- removeOutputStreams(ConcurrentHashMap<String, Integer>) - Method in interface ds.granules.dataset.StreamingAccess
-
Removes a set of output streams from this dataset.
- removeReduce(String) - Method in interface ds.granules.operation.Map
-
Removes a given reducer from the list of Reducers for a given Map
function.
- removeReduce(String) - Method in class ds.granules.operation.MapReduceBase
-
- removeReducer(Reduce) - Method in class ds.granules.operation.MapReduceBase
-
This method is called on a Map, once it has been removed from a
Reduce
using the Reduce.removeMap() method.
- replaceLibrary() - Method in interface ds.granules.scheduler.LibraryManager
-
- REQUEST_FOR_FT_CHECKPOINT - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- REQUEST_FOR_FT_CHECKPOINT - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- REQUEST_FOR_FT_CHECKPOINT - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- REQUEST_FOR_VACCINATION - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- REQUEST_FOR_VACCINATION - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- REQUEST_FOR_VACCINATION - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- REQUEST_FOR_ZONE_FOCUS - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- REQUEST_FOR_ZONE_FOCUS - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- REQUEST_FOR_ZONE_FOCUS - Static variable in class ds.granules.naadsm.event.EventType
-
- REQUEST_FOR_ZONE_FOCUS - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- REQUEST_FOR_ZONE_FOCUS - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- REQUEST_FOR_ZONE_FOCUS - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
-
- REQUEST_OF_DESTRUCTION - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- REQUEST_OF_DESTRUCTION - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- REQUEST_OF_DESTRUCTION - Static variable in class ds.granules.naadsm.event.EventType
-
- REQUEST_OF_DESTRUCTION - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- REQUEST_OF_DESTRUCTION - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- REQUEST_OF_DESTRUCTION - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
-
- RequestForFTCheckpoint - Class in ds.granules.naadsm.dynamicmerge.event
-
CHECKPOINT message
- RequestForFTCheckpoint() - Constructor for class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- RequestForFTCheckpoint(int, byte, boolean) - Constructor for class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- RequestForFTCheckpoint - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
CHECKPOINT message
- RequestForFTCheckpoint() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- RequestForFTCheckpoint(int, byte, boolean) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- RequestForFTCheckpoint - Class in ds.granules.naadsm.resplit.event
-
CHECKPOINT message
- RequestForFTCheckpoint() - Constructor for class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- RequestForFTCheckpoint(int, byte, boolean) - Constructor for class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- RequestForVaccination - Class in ds.granules.naadsm.dynamicmerge.event
-
REQUEST_OF_DESTRUCTION message
- RequestForVaccination() - Constructor for class ds.granules.naadsm.dynamicmerge.event.RequestForVaccination
-
- RequestForVaccination - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
REQUEST_OF_DESTRUCTION message
- RequestForVaccination() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.RequestForVaccination
-
- RequestForVaccination - Class in ds.granules.naadsm.resplit.event
-
REQUEST_OF_DESTRUCTION message
- RequestForVaccination() - Constructor for class ds.granules.naadsm.resplit.event.RequestForVaccination
-
- RequestForZoneFocus - Class in ds.granules.naadsm.dynamicmerge.event
-
REQUEST_FOR_ZONE_FOCUS message
- RequestForZoneFocus() - Constructor for class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
-
- RequestForZoneFocus - Class in ds.granules.naadsm.dynamicsplit.event
-
REQUEST_FOR_ZONE_FOCUS message
- RequestForZoneFocus() - Constructor for class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
-
- RequestForZoneFocus - Class in ds.granules.naadsm.event
-
- RequestForZoneFocus() - Constructor for class ds.granules.naadsm.event.RequestForZoneFocus
-
- RequestForZoneFocus - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
REQUEST_FOR_ZONE_FOCUS message
- RequestForZoneFocus() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
-
- RequestForZoneFocus - Class in ds.granules.naadsm.resplit.event
-
REQUEST_FOR_ZONE_FOCUS message
- RequestForZoneFocus() - Constructor for class ds.granules.naadsm.resplit.event.RequestForZoneFocus
-
- RequestForZoneFocus - Class in ds.granules.naadsm.staticsplit.event
-
REQUEST_FOR_ZONE_FOCUS message
- RequestForZoneFocus() - Constructor for class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
-
- RequestOfDestruction - Class in ds.granules.naadsm.dynamicmerge.event
-
REQUEST_OF_DESTRUCTION message
- RequestOfDestruction() - Constructor for class ds.granules.naadsm.dynamicmerge.event.RequestOfDestruction
-
- RequestOfDestruction - Class in ds.granules.naadsm.dynamicsplit.event
-
REQUEST_OF_DESTRUCTION message
- RequestOfDestruction() - Constructor for class ds.granules.naadsm.dynamicsplit.event.RequestOfDestruction
-
- RequestOfDestruction - Class in ds.granules.naadsm.event
-
- RequestOfDestruction() - Constructor for class ds.granules.naadsm.event.RequestOfDestruction
-
- RequestOfDestruction - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
REQUEST_OF_DESTRUCTION message
- RequestOfDestruction() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.RequestOfDestruction
-
- RequestOfDestruction - Class in ds.granules.naadsm.resplit.event
-
REQUEST_OF_DESTRUCTION message
- RequestOfDestruction() - Constructor for class ds.granules.naadsm.resplit.event.RequestOfDestruction
-
- RequestOfDestruction - Class in ds.granules.naadsm.staticsplit.event
-
REQUEST_OF_DESTRUCTION message
- RequestOfDestruction() - Constructor for class ds.granules.naadsm.staticsplit.event.RequestOfDestruction
-
- resetCurrentDay() - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
-
- resetOutputTracker() - Method in class ds.granules.operation.MapReduceBase
-
- resetOutputTracker() - Method in interface ds.granules.operation.Reduce
-
This method resets the output tracker associated with the reducer.
- resetTrackers() - Method in class ds.granules.operation.InstanceDeployer
-
Resets the task completion counts maintained by this class.
- Resource - Class in ds.granules.scheduler
-
This is a class which encapsulates the functionality of a computational
resource.
- RESOURCE_DISCOVERY - Static variable in interface ds.granules.exchange.ExchangeType
-
- ResourceDiscovery - Class in ds.granules.exchange
-
This class encapsulates exchanges related the discovery of resources.
- ResourceDiscovery() - Constructor for class ds.granules.exchange.ResourceDiscovery
-
- ResourceDiscovery(int, String) - Constructor for class ds.granules.exchange.ResourceDiscovery
-
- ResourceDiscovery(int, String, ResourceMetrics, String) - Constructor for class ds.granules.exchange.ResourceDiscovery
-
- ResourceMetrics - Class in ds.granules.scheduler
-
This class encapsulates various metrics associated with the resource.
- ResourceMetrics(int, String) - Constructor for class ds.granules.scheduler.ResourceMetrics
-
- ResourceMetrics(byte[]) - Constructor for class ds.granules.scheduler.ResourceMetrics
-
- ResourceProfile - Interface in ds.granules.scheduler
-
This is an interface that snapshots the profile of a given resource.
- RESTORE - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- Restore - Class in ds.granules.naadsm.dynamicmerge.event
-
RESTORE message
- Restore() - Constructor for class ds.granules.naadsm.dynamicmerge.event.Restore
-
- RESTORE - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- Restore - Class in ds.granules.naadsm.dynamicsplit.event
-
RESTORE message
- Restore() - Constructor for class ds.granules.naadsm.dynamicsplit.event.Restore
-
- RESTORE - Static variable in class ds.granules.naadsm.event.EventType
-
- Restore - Class in ds.granules.naadsm.event
-
- Restore() - Constructor for class ds.granules.naadsm.event.Restore
-
- RESTORE - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- Restore - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
RESTORE message
- Restore() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- RESTORE - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- Restore - Class in ds.granules.naadsm.resplit.event
-
RESTORE message
- Restore() - Constructor for class ds.granules.naadsm.resplit.event.Restore
-
- ResultPayload - Class in ds.granules.results
-
This is a utility class which can be used for marshalling and unmarshalling
some of the most commonly used result primitives.
- RESULTS - Static variable in interface ds.granules.bridge.ControlMessage
-
- Results - Interface in ds.granules.results
-
The results interface allows functions to encapsulate results and other
lightweight metadata information that would be associated with them.
- ResultsFactory - Class in ds.granules.results
-
This is a singleton-class that is used for creating and reconstructing
Results
and the elements that comprise it such as
SequencingInfo
.
- ResultsWidget - Class in ds.granules.results
-
This class is an implementation of the Results
interface.
- ResultsWidget(String, String, boolean, boolean) - Constructor for class ds.granules.results.ResultsWidget
-
- ResultsWidget(byte[]) - Constructor for class ds.granules.results.ResultsWidget
-
Reconstructs the ResultsWidget from a set of bytes
- resumeAvailabilityNotifications(DataAvailabilityObserver) - Method in interface ds.granules.dataset.DataAvailabilityNotifier
-
Resumes data availability notifications for the specified observer
- resumeAvailabilityNotifications() - Method in interface ds.granules.dataset.DatasetCollection
-
Resume data availability notifications for this collection.
- resumeAvailabilityNotifications() - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- resumeAvailabilityNotifications(DataAvailabilityObserver) - Method in class ds.granules.dataset.DatasetNotifier
-
- returnRow(String) - Method in class ds.granules.samples.matrix.MatrixSharedMemory
-
- right - Variable in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
-
- right - Variable in class ds.granules.naadsm.dynamicsplit.event.Restore
-
- right - Variable in class ds.granules.naadsm.event.Checkpoint
-
- right - Variable in class ds.granules.naadsm.event.Restore
-
- rightBound - Variable in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
- run() - Method in class ds.granules.bridge.StreamReader
-
Run function of the StreamReader thread.
- run() - Method in class ds.granules.bridge.StreamStringReader
-
- run() - Method in class ds.granules.bridge.StreamWriter
-
- run() - Method in class ds.granules.naadsm.relaunch.MonitorTimer
-
- run() - Method in class ds.granules.scheduler.ExecutableTask
-
- SchedulingException - Exception in ds.granules.scheduler
-
This is an exception that is thrown when there are problems in scheduling
tasks for execution.
- SchedulingException() - Constructor for exception ds.granules.scheduler.SchedulingException
-
Constructs an SchedulingException
with no detail message.
- SchedulingException(String) - Constructor for exception ds.granules.scheduler.SchedulingException
-
Constructs an SchedulingException
with the specified detail
message.
- sendMessage(JavaByteMessage) - Method in class ds.granules.bridge.JavaGenericComputation
-
Function which allows the resource to send messages to an attached
computation
- sendMessage(byte[]) - Method in class ds.granules.bridge.StreamWriter
-
Responsible for sending messages
- sendMessage(JavaByteMessage) - Method in class ds.granules.samples.pythonColl.JavaPythonCommunication
-
- SequencingInfo - Interface in ds.granules.results
-
Some applications often need to include sequencing descriptors along with
their results.
- SequencingWidget - Class in ds.granules.results
-
This class is an implementation of the SequencingInfo
interface.
- SequencingWidget() - Constructor for class ds.granules.results.SequencingWidget
-
- SequencingWidget(byte[]) - Constructor for class ds.granules.results.SequencingWidget
-
- serialize(String) - Method in class ds.granules.naadsm.ml.NeuralPredictor
-
Serialize the current network into file.
- serialize(String) - Method in interface ds.granules.naadsm.ml.Predictor
-
- setAsExecuteFixedNumberOfTimes(String, int) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecuteFixedNumberOfTimes(int) - Method in class ds.granules.operation.OperationBase
-
- setAsExecuteFixedNumberOfTimes(int) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable a fixed number of times.
- setAsExecuteOnce(String) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecuteOnce() - Method in class ds.granules.operation.OperationBase
-
- setAsExecuteOnce() - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable exactly once.
- setAsExecutePeriodically(String, long) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecutePeriodically(long) - Method in class ds.granules.operation.OperationBase
-
- setAsExecutePeriodically(long) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable periodically at the specified
intervals.
- setAsExecuteWhenDataAvailable(String) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsExecuteWhenDataAvailable() - Method in class ds.granules.operation.OperationBase
-
- setAsExecuteWhenDataAvailable() - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being executable when data is available
- setAsStayAlive(String) - Method in class ds.granules.operation.ExecutionProfileSetup
-
- setAsStayAlive() - Method in class ds.granules.operation.OperationBase
-
- setAsStayAlive() - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the operation as being stayAlive.
- setBoundaries(float, float, float, float) - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Set the boundaries of the current worker.
- setCheckpoint(byte[]) - Method in class ds.granules.naadsm.ft.WorkerInfo
-
- setConditionFlag(int) - Method in class ds.granules.exchange.Exchange
-
- setContent(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- setContent(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- setContent(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- setContent(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- setContent(byte[]) - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- setContent(byte[]) - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- setContent(byte[]) - Method in class ds.granules.naadsm.resplit.event.Restore
-
- setCurrentDay(int) - Method in class ds.granules.naadsm.ft.WorkerInfo
-
- setData(double[][]) - Method in class ds.granules.samples.kmeans.KMVectorData
-
- setDatasetCollection(DatasetCollection) - Method in class ds.granules.operation.OperationBase
-
- setDatasetCollection(DatasetCollection) - Method in interface ds.granules.operation.OperationConfiguration
-
Establish the dataset needed by the application in question
- setDatasetCollectionObserver(DatasetCollectionObserver) - Method in interface ds.granules.dataset.DatasetCollection
-
Register an observer for the DatasetCollection
- setDatasetCollectionObserver(DatasetCollectionObserver) - Method in class ds.granules.dataset.DatasetCollectionManagement
-
- setDescription(String) - Method in class ds.granules.bridge.JavaByteMessage
-
- setDescription(String) - Method in class ds.granules.exchange.Exchange
-
- setDomain(String) - Method in class ds.granules.operation.OperationBase
-
- setDomain(String) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the domain for this operation
- setExchangeSubType(int) - Method in class ds.granules.exchange.Exchange
-
- setExchangeType(int) - Method in class ds.granules.exchange.Exchange
-
- setExecutionStatus(int) - Method in class ds.granules.scheduler.ExecutableTask
-
Set the execution status for the lifecycle metrics.
- setExecutionTime(long) - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Set the execution time for the current worker.
- setExecutionTime(long) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Set the execution time for the current worker.
- setFromJava(boolean) - Method in class ds.granules.bridge.JavaByteMessage
-
- setGlobalState(byte[]) - Method in class ds.granules.naadsm.ft.Snapshot
-
- setGoInactive(boolean) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- setGoInactive(boolean) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- setGoInactive(boolean) - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- setHeartbeatTime() - Method in class ds.granules.naadsm.ft.HostInfo
-
Sets the last time a heartbeat was received to NOW.
- setIdentifier(String) - Method in class ds.granules.exchange.Exchange
-
- setImmutable() - Method in class ds.granules.results.ResultsWidget
-
- setImmutable() - Method in class ds.granules.results.SequencingWidget
-
- setInitializationComplete() - Method in class ds.granules.operation.OperationBase
-
- setInitializationComplete() - Method in interface ds.granules.operation.OperationConfiguration
-
Mark the initialization of the application as having completed
- setInitializationNeeded(boolean) - Method in class ds.granules.operation.OperationBase
-
- setInitializationNeeded(boolean) - Method in interface ds.granules.operation.OperationConfiguration
-
Set/Unset whether this operation needs initialization.
- setInput(byte[]) - Method in class ds.granules.bridge.JavaByteMessage
-
- setInstanceIdentifier(String) - Method in class ds.granules.operation.OperationBase
-
- setInstanceIdentifier(String) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the instance identifier associated with a given operation.
- setMaxSequence(long) - Method in interface ds.granules.results.SequencingInfo
-
Sets the max-sequence information.
- setMaxSequence(long) - Method in class ds.granules.results.SequencingWidget
-
- setMergeList(LinkedList<LBOperationNode>) - Method in class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
-
- setNumberOfComputations(int) - Method in class ds.granules.scheduler.ResourceMetrics
-
- setNumVectors(int) - Method in class ds.granules.samples.kmeans.KMVectorData
-
- setOperationIdentifier(String) - Method in class ds.granules.operation.OperationBase
-
- setOperationIdentifier(String) - Method in interface ds.granules.operation.OperationConfiguration
-
This method sets the operation identifier for a given operation
- setOutput(byte[]) - Method in class ds.granules.bridge.JavaByteMessage
-
- setOverwrite(boolean) - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- setOverwrite(boolean) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- setOverwrite(boolean) - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- setOverwrite(boolean) - Method in class ds.granules.naadsm.resplit.event.Restore
-
- setPosition(String, long) - Method in interface ds.granules.dataset.FileAccess
-
Sets the position of filePointer for one of the file in the given
dataset.
- setPosition(String, long) - Method in class ds.granules.dataset.FileDataset
-
- setProcessingDirectives(Properties) - Method in class ds.granules.operation.OperationBase
-
- setProcessingDirectives(Properties) - Method in interface ds.granules.operation.OperationConfiguration
-
Set the processing directives for the operation
- setReceivedOutputFrom(String) - Method in class ds.granules.operation.MapReduceBase
-
- setReceivedOutputFrom(String) - Method in interface ds.granules.operation.Reduce
-
Mark the receipt of Output from a given Map instance
- setRequest() - Method in class ds.granules.exchange.Exchange
-
Sets this exchange as a request.
- setRespondTo(String) - Method in class ds.granules.exchange.Exchange
-
Set the repondTo field for this exchange.
- setRespondTo(String) - Method in interface ds.granules.results.Results
-
Set the respondTo field for the Results
- setRespondTo(String) - Method in class ds.granules.results.ResultsWidget
-
- setResponse() - Method in class ds.granules.exchange.Exchange
-
Sets this exchange as a reponse.
- setResultPayload(byte[]) - Method in interface ds.granules.results.Results
-
Sets the payload for the Results.
- setResultPayload(byte[]) - Method in class ds.granules.results.ResultsWidget
-
- setResultType(int) - Method in interface ds.granules.results.Results
-
Set the type of the result encapsulated within the payload.
- setResultType(int) - Method in class ds.granules.results.ResultsWidget
-
- setSequenceRange(long, long) - Method in interface ds.granules.results.SequencingInfo
-
Sets the sequence range based on the specified upper and lower-bounds.
- setSequenceRange(long, long) - Method in class ds.granules.results.SequencingWidget
-
- setSingleSequence(long) - Method in interface ds.granules.results.SequencingInfo
-
Set the single sequence Information.
- setSingleSequence(long) - Method in class ds.granules.results.SequencingWidget
-
- setSocketPort(int) - Method in class ds.granules.samples.pythonColl.JavaPythonCommunication
-
- setSource(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.LBOperationNode
-
- setSplitList(LinkedList<LBOperationNode>) - Method in class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
-
- setStartTime() - Method in class ds.granules.operation.InstanceDeployer
-
Resets the start timer which tracks the time at which an application
began execution.
- setStreamIdentifier(String) - Method in class ds.granules.bridge.JavaByteMessage
-
- setTarget(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.LBOperationNode
-
- setTaskCompletionInfo(String) - Method in class ds.granules.scheduler.ExecutableTask
-
Include some information about the completion of the task.
- setTeminationConditionReached() - Method in class ds.granules.operation.OperationBase
-
- setTeminationConditionReached() - Method in interface ds.granules.operation.OperationConfiguration
-
Mark the termination condition of this operation as having reached.
- setTimestamp(long) - Method in class ds.granules.exchange.Exchange
-
Set the timestamp for this exchange.
- setType(byte) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- setType(byte) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- setType(byte) - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- setUpdateTime() - Method in class ds.granules.naadsm.ft.WorkerInfo
-
- setVecLen(int) - Method in class ds.granules.samples.kmeans.KMVectorData
-
- setVersionInformation(long) - Method in class ds.granules.operation.OperationBase
-
- setVersionInformation(long) - Method in interface ds.granules.operation.OperationConfiguration
-
Sets the version information for this operation.
- setWorker(int) - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- setWorker(int) - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- setWorker(int) - Method in class ds.granules.naadsm.event.StartNewDayEvent
-
- setWorker(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- setWorker(int) - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- setWorker(int) - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- setWorker_ID(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
-
- setWorker_ID(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
-
- setWorker_ID(int) - Method in class ds.granules.naadsm.resplit.event.Checkpoint
-
- setWorkerID(int) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
-
- setWorkerID(int) - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
-
- setWorkerID(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
-
- setWorkerID(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
-
- setWorkerID(int) - Method in class ds.granules.naadsm.resplit.event.MultiRestore
-
- setWorkerID(int) - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
-
- setWorkerID(int) - Method in class ds.granules.naadsm.resplit.event.Restore
-
- setWorkerList(WorkerList) - Method in class ds.granules.naadsm.ft.Snapshot
-
- SHORT - Static variable in class ds.granules.results.ResultPayload
-
- SHORT_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- SHORT_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- size(String) - Method in interface ds.granules.dataset.FileAccess
-
Returns the current size of the file in question
- size(String) - Method in class ds.granules.dataset.FileDataset
-
- size() - Method in class ds.granules.util.Matrix
-
- sizeOfExternalLibraries() - Method in interface ds.granules.scheduler.LibraryManager
-
- Snapshot - Class in ds.granules.naadsm.ft
-
State information from every Worker in a distributed NAADSM execution, plus
state from the Controller makes up a system Snapshot that can be used to
resume execution or roll back to a previous state.
- Snapshot(int) - Constructor for class ds.granules.naadsm.ft.Snapshot
-
- SortDeployer - Class in ds.granules.samples.sort
-
The deployer for the periodicity example.
- SortDeployer(Properties) - Constructor for class ds.granules.samples.sort.SortDeployer
-
Initializes the deployer.
- SortingOperation - Class in ds.granules.samples.sort
-
An example performing Parallel-sort using the Map Reduce framework.
- SortingOperation() - Constructor for class ds.granules.samples.sort.SortingOperation
-
- SortMap - Class in ds.granules.samples.sort
-
An example demonstrating the Map
role within a Parallel-sort
operation.
- SortMap() - Constructor for class ds.granules.samples.sort.SortMap
-
- SortReduce - Class in ds.granules.samples.sort
-
An example demonstrating the Reduce
role within a Parallel-sort
operation.
- SortReduce() - Constructor for class ds.granules.samples.sort.SortReduce
-
- Speculator - Class in ds.granules.naadsm.ft
-
- Speculator() - Constructor for class ds.granules.naadsm.ft.Speculator
-
- SPLIT - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- SPLIT - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- SPLIT - Static variable in class ds.granules.naadsm.event.EventType
-
- SPLIT - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- SPLIT - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- SPLIT - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
-
- SPLIT_BY_DENSITY - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- SPLIT_BY_DENSITY - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- SplitByDensity - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
SPLIT message
- SplitByDensity() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- SplitByDensity(int, int, float) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
-
- SplitByDensity - Class in ds.granules.naadsm.resplit.event
-
SPLIT message
- SplitByDensity() - Constructor for class ds.granules.naadsm.resplit.event.SplitByDensity
-
- SplitByDensity(int, int, float) - Constructor for class ds.granules.naadsm.resplit.event.SplitByDensity
-
- SplitEvent - Class in ds.granules.naadsm.dynamicmerge.event
-
SPLIT message
- SplitEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- SplitEvent(int, int, float) - Constructor for class ds.granules.naadsm.dynamicmerge.event.SplitEvent
-
- SplitEvent - Class in ds.granules.naadsm.dynamicsplit.event
-
SPLIT message
- SplitEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- SplitEvent(int, int, float) - Constructor for class ds.granules.naadsm.dynamicsplit.event.SplitEvent
-
- SplitEvent - Class in ds.granules.naadsm.event
-
- SplitEvent() - Constructor for class ds.granules.naadsm.event.SplitEvent
-
- SplitEvent(int, int, float) - Constructor for class ds.granules.naadsm.event.SplitEvent
-
- SplitEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
SPLIT message
- SplitEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- SplitEvent(int, int, float) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
-
- SplitEvent - Class in ds.granules.naadsm.resplit.event
-
SPLIT message
- SplitEvent() - Constructor for class ds.granules.naadsm.resplit.event.SplitEvent
-
- SplitEvent(int, int, float) - Constructor for class ds.granules.naadsm.resplit.event.SplitEvent
-
- SplitEvent - Class in ds.granules.naadsm.staticsplit.event
-
SPLIT message
- SplitEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.SplitEvent
-
- SplitEvent(int, int, float) - Constructor for class ds.granules.naadsm.staticsplit.event.SplitEvent
-
- splitWorker(int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Split one worker based on equal area .
- splitWorker(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Split one worker based on number of herds .
- StageOne - Class in ds.granules.samples.iterative
-
An example demonstrating the Map
role within a Word Count
operation.
- StageOne() - Constructor for class ds.granules.samples.iterative.StageOne
-
- StageThree - Class in ds.granules.samples.iterative
-
An example demonstrating the Map
role within a Word Count
operation.
- StageThree() - Constructor for class ds.granules.samples.iterative.StageThree
-
- StageTwo - Class in ds.granules.samples.iterative
-
An example demonstrating the Map
role within a Word Count
operation.
- StageTwo() - Constructor for class ds.granules.samples.iterative.StageTwo
-
- start() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Start a new day for the current worker.
- start() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Start a new day for the current worker.
- START_NEW_DAY - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
-
- START_NEW_DAY - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
-
- START_NEW_DAY - Static variable in class ds.granules.naadsm.event.EventType
-
- START_NEW_DAY - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
-
- START_NEW_DAY - Static variable in class ds.granules.naadsm.resplit.event.EventType
-
- START_NEW_DAY - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
-
- START_STOP - Static variable in interface ds.granules.bridge.ControlMessage
-
- startAll() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Start new day for all the workers.
- startAll() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Start new day for all the workers.
- startedExecution(String, String, TaskLifecycleMetrics) - Method in class ds.granules.operation.InstanceDeployer
-
- startedExecution(String, String, TaskLifecycleMetrics) - Method in interface ds.granules.operation.JobLifecycleObserver
-
This method is invoked when the first task reports that it has
begun execution.
- startExecution(String, int, JavaMessageHandler) - Method in class ds.granules.bridge.JavaGenericComputation
-
Starts execution of a bridged program, needs actual execution command,
type of communication, and a link to the appropriate message handler As a
note, error stream is used even with TCP communications
- StartNewDayEvent - Class in ds.granules.naadsm.dynamicmerge.event
-
START_NEW_DAY message
- StartNewDayEvent(int, int) - Constructor for class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- StartNewDayEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
-
- StartNewDayEvent - Class in ds.granules.naadsm.dynamicsplit.event
-
START_NEW_DAY message
- StartNewDayEvent(int, int) - Constructor for class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- StartNewDayEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
-
- StartNewDayEvent - Class in ds.granules.naadsm.event
-
- StartNewDayEvent(int, int) - Constructor for class ds.granules.naadsm.event.StartNewDayEvent
-
- StartNewDayEvent() - Constructor for class ds.granules.naadsm.event.StartNewDayEvent
-
- StartNewDayEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
-
START_NEW_DAY message
- StartNewDayEvent(int, int) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- StartNewDayEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
-
- StartNewDayEvent - Class in ds.granules.naadsm.resplit.event
-
START_NEW_DAY message
- StartNewDayEvent(int, int) - Constructor for class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- StartNewDayEvent() - Constructor for class ds.granules.naadsm.resplit.event.StartNewDayEvent
-
- StartNewDayEvent - Class in ds.granules.naadsm.staticsplit.event
-
START_NEW_DAY message
- StartNewDayEvent(int, int) - Constructor for class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- StartNewDayEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
-
- STATUS - Static variable in interface ds.granules.bridge.ControlMessage
-
- STATUS - Static variable in class ds.granules.exchange.DeploymentMessage
-
- stop(int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
-
Stop one worker with worker number.
- stop() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
-
Finish the current day for the current worker.
- stop(int, double) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Stop one worker with worker number and predicted time.
- stop(int, Predictor, double[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Stop one worker with worker number and use a given predictor to predict
the next simulation day.
- stop(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
-
Stop one worker with worker number.
- stop() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Finish the current day for the current worker.
- stop(double) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Finish the current day for the current worker and set the predicted time
as criteria
- stop(Predictor, double[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
-
Finish the current day for the current worker and use the predictor to
predict the execution time of the next simulation day.
- StreamDataset - Class in ds.granules.dataset
-
This class is a streaming implementation of the dataset.
- StreamDataset(String, String) - Constructor for class ds.granules.dataset.StreamDataset
-
Share the instance of the client service, so that multiple connections
are not created to the same broker.
- StreamDataset(byte[]) - Constructor for class ds.granules.dataset.StreamDataset
-
- StreamingAccess - Interface in ds.granules.dataset
-
The interface which augments the Dataset
interface to support
streaming capabilities.
- StreamingService - Class in ds.granules.scheduler
-
A streaming service class which abstracts minimal operations needed for
communications.
- StreamReader - Class in ds.granules.bridge
-
- StreamReader(InputStream, JavaMessageHandler) - Constructor for class ds.granules.bridge.StreamReader
-
Initializes and starts the StreamReader thread.
- STREAMS - Static variable in interface ds.granules.dataset.Dataset
-
- StreamStringReader - Class in ds.granules.bridge
-
- StreamStringReader(InputStream) - Constructor for class ds.granules.bridge.StreamStringReader
-
Initializes and starts a StreamStringReader
thread
- StreamWriter - Class in ds.granules.bridge
-
- StreamWriter(OutputStream) - Constructor for class ds.granules.bridge.StreamWriter
-
Initializes and starts the StreamWriter thread.
- STRING - Static variable in interface ds.granules.bridge.ControlMessage
-
- STRING - Static variable in class ds.granules.results.ResultPayload
-
- STRING_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- STRING_ARR - Static variable in interface ds.granules.bridge.ControlMessage
-
- STRING_ARRAY - Static variable in class ds.granules.results.ResultPayload
-
- STRING_SYNOPSIS - Static variable in interface ds.granules.dataset.StreamingAccess
-
- stringAt(int) - Method in class ds.granules.learning.classification.common.GranTuple
-
- submit(Operation, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
Submit the given operation for execution.
- submit(Operation, String, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
Submit the given operation for execution.
- submit(Operation, String, String, JobLifecycleObserver) - Method in class ds.granules.operation.JobSubmission
-
This method allows one to group a set of related tasks together in a Job.
- SUCCESS - Static variable in interface ds.granules.exchange.ConditionFlag
-
- supportsDataAvailabilityNotifications() - Method in interface ds.granules.dataset.Dataset
-
Indicates whether this dataset supports dynamic data availability
notifications
- supportsDataAvailabilityNotifications() - Method in class ds.granules.dataset.FileDataset
-
- supportsDataAvailabilityNotifications() - Method in class ds.granules.dataset.StreamDataset
-
- SuppressedException - Exception in ds.granules.scheduler
-
This is a utility exception class that is used when it is not possible to
propagated exceptions either within a VM or to a remote VM.
- SuppressedException() - Constructor for exception ds.granules.scheduler.SuppressedException
-
Constructs an SuppressedException
with no detail message.
- SuppressedException(String) - Constructor for exception ds.granules.scheduler.SuppressedException
-
Constructs an SuppressedException
with the specified detail
message.
- switchCommunication(JavaByteMessage, int) - Method in class ds.granules.bridge.JavaGenericComputation
-
Allows the user to switch communication types from Java.
- switchStream(InputStream) - Method in class ds.granules.bridge.StreamReader
-
- switchStream(OutputStream) - Method in class ds.granules.bridge.StreamWriter
-
- SystemCommand - Class in ds.granules.util
-
This is a utility class that allows one to execute native commands from Java.
- SystemCommand() - Constructor for class ds.granules.util.SystemCommand
-