A B C D E F G H I J K L M N O P Q R S T U V W 

A

ABNORMAL_TERMINATION - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
abnormalOperationTermination(String, String) - Method in interface ds.granules.scheduler.TaskLifecycleObserver
Indicates that the task in question has terminated abnormally.
abnormalOperationTermination(String, String) - Method in class ds.granules.scheduler.TaskManagement
 
ABORT - Static variable in interface ds.granules.bridge.ControlMessage
 
ABORT - Static variable in class ds.granules.exchange.DeploymentMessage
 
ABORTED - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
abortTask(String, String) - Method in class ds.granules.operation.JobSubmission
Send an abort request for a specific task.
abortTask() - Method in interface ds.granules.scheduler.Controller
 
activate() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
Set this worker as active.
activate() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
Set this worker as active.
activateWorker(int, int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Activate one worker.
activateWorker(int, int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Activate one worker.
active() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
 
active() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
 
active() - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
 
activeList - Variable in class ds.granules.naadsm.dynamicmerge.WorkerList
 
activeList - Variable in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
 
activePiece - Variable in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 
add(String) - Method in class ds.granules.learning.classification.common.GranTuple
 
addBoundaries() - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
 
addBoundaries() - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
 
addBoundaries() - Method in class ds.granules.naadsm.event.Checkpoint
 
addBoundaries() - Method in class ds.granules.naadsm.event.Restore
 
addCheckpoint(Checkpoint) - Method in class ds.granules.naadsm.ft.Snapshot
 
addDataset(Dataset) - Method in interface ds.granules.dataset.DatasetCollection
Add a dataset to this collection.
addDataset(Dataset) - Method in class ds.granules.dataset.DatasetCollectionManagement
 
addDeploymentRequest(String, DeploymentMessage) - Method in class ds.granules.scheduler.Diagnostics
Add the deployment request associated with the task.
addFile(String, String) - Method in interface ds.granules.dataset.FileAccess
Adds a file with the specified permission "r", "w" or "rw" to this dataset.
addFile(String, String) - Method in class ds.granules.dataset.FileDataset
 
addInputStream(String, int) - Method in class ds.granules.dataset.StreamDataset
 
addInputStream(String, int) - Method in interface ds.granules.dataset.StreamingAccess
Add an input stream to this dataset.
addInputStreams(ConcurrentHashMap<String, Integer>) - Method in class ds.granules.dataset.StreamDataset
 
addInputStreams(ConcurrentHashMap<String, Integer>) - Method in interface ds.granules.dataset.StreamingAccess
Adds a set of input streams to this dataset.
addLoad(long[]) - Method in class ds.granules.samples.sort.SortingOperation
 
addMap(Map) - Method in class ds.granules.operation.MapReduceBase
 
addMap(Map) - Method in interface ds.granules.operation.Reduce
Adds a Map that will be reduced.
addMapper(Map) - Method in class ds.granules.operation.MapReduceBase
This method is called on a Reduce, once it has been added to a Map using the Map.addReduce() method.
addMergeNode(int, int) - Method in class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
 
addNextDay(LBDayNode) - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
 
addOutputStream(String, int) - Method in class ds.granules.dataset.StreamDataset
 
addOutputStream(String, int) - Method in interface ds.granules.dataset.StreamingAccess
Add an output stream to this dataset.
addOutputStreams(ConcurrentHashMap<String, Integer>) - Method in class ds.granules.dataset.StreamDataset
 
addOutputStreams(ConcurrentHashMap<String, Integer>) - Method in interface ds.granules.dataset.StreamingAccess
Adds a set of output streams to this dataset.
addReduce(Reduce) - Method in interface ds.granules.operation.Map
Adds a Reduce for this particular Map.
addReduce(Reduce) - Method in class ds.granules.operation.MapReduceBase
 
addReducer(Reduce) - Method in class ds.granules.operation.MapReduceBase
This method is called on a Map, once it has been added to a Reduce using the Reduce.addMap() method.
addSplitNode(int, int) - Method in class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
 
addTask() - Method in interface ds.granules.scheduler.Controller
 
addWorker(WorkerInfo) - Method in class ds.granules.naadsm.ft.HostInfo
 
ADVERTISEMENT - Static variable in interface ds.granules.exchange.ExchangeType
 
allWorkersSuspended() - Method in class ds.granules.naadsm.ft.RecoveryProcess
 
ATTEMPT_TO_INFECT - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
ATTEMPT_TO_INFECT - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
ATTEMPT_TO_INFECT - Static variable in class ds.granules.naadsm.event.EventType
 
ATTEMPT_TO_INFECT - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
ATTEMPT_TO_INFECT - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
ATTEMPT_TO_INFECT - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
AttemptToInfect - Class in ds.granules.naadsm.dynamicmerge.event
ATTEMPT_TO_INFECT message
AttemptToInfect() - Constructor for class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
 
AttemptToInfect - Class in ds.granules.naadsm.dynamicsplit.event
ATTEMPT_TO_INFECT message
AttemptToInfect() - Constructor for class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
 
AttemptToInfect - Class in ds.granules.naadsm.event
 
AttemptToInfect() - Constructor for class ds.granules.naadsm.event.AttemptToInfect
 
AttemptToInfect - Class in ds.granules.naadsm.portionaldynamicmerge.event
ATTEMPT_TO_INFECT message
AttemptToInfect() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
 
AttemptToInfect - Class in ds.granules.naadsm.resplit.event
ATTEMPT_TO_INFECT message
AttemptToInfect() - Constructor for class ds.granules.naadsm.resplit.event.AttemptToInfect
 
AttemptToInfect - Class in ds.granules.naadsm.staticsplit.event
ATTEMPT message
AttemptToInfect() - Constructor for class ds.granules.naadsm.staticsplit.event.AttemptToInfect
 
averageRateOfTaskArrivals() - Method in class ds.granules.scheduler.Diagnostics
 
averageTaskExecutionTime() - Method in interface ds.granules.scheduler.ResourceProfile
Retrieves the average execution time for a given task.

B

BayesDeployer - Class in ds.granules.learning.classification.bayes
The deployer to use the Mahout implementation of Bayes classification.
BayesDeployer(Properties) - Constructor for class ds.granules.learning.classification.bayes.BayesDeployer
Initializes the deployer.
BayesFinalStage - Class in ds.granules.learning.classification.bayes
This is the final stage of Bayes Classification, previous stages are similar for both Bayes and Complimentary Bayes, found in ds.granules.learning.classification.common
BayesFinalStage() - Constructor for class ds.granules.learning.classification.bayes.BayesFinalStage
 
BayesPrepStage1 - Class in ds.granules.learning.classification.common
First step to Mahout's Naive Bayes classification (both complimentary and not).
BayesPrepStage1() - Constructor for class ds.granules.learning.classification.common.BayesPrepStage1
 
BayesPrepStage2 - Class in ds.granules.learning.classification.common
Second stage of Bayes classification.
BayesPrepStage2() - Constructor for class ds.granules.learning.classification.common.BayesPrepStage2
 
BayesPrepStage3 - Class in ds.granules.learning.classification.common
Final common stage of Bayes classification.
BayesPrepStage3() - Constructor for class ds.granules.learning.classification.common.BayesPrepStage3
 
beat() - Method in class ds.granules.naadsm.ft.Heartbeat
Sends the heartbeat message.
BYTE_ARR - Static variable in interface ds.granules.bridge.ControlMessage
 
bytes2float(byte[]) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
4 digit of byte array to float number
bytes2float(byte[]) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
4 digit of byte array to float number
bytes2float(byte[]) - Static method in class ds.granules.naadsm.event.EventTypeFactory
 
bytes2float(byte[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
4 digit of byte array to float number
bytes2float(byte[]) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
4 digit of byte array to float number
bytes2float(byte[]) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
4 digit of byte array to float number
bytes2int(byte[]) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
 
bytes2int(byte[]) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
 
bytes2int(byte[]) - Static method in class ds.granules.naadsm.event.EventTypeFactory
 
bytes2int(byte[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
 
bytes2int(byte[]) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
 
bytes2int(byte[]) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
 

C

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
 

D

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
This class contains a list of LBDayNode.
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.

E

END_OF_DAY - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
END_OF_DAY - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
END_OF_DAY - Static variable in class ds.granules.naadsm.event.EventType
 
END_OF_DAY - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
END_OF_DAY - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
END_OF_DAY - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
END_OF_SIMULATION - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
END_OF_SIMULATION - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
END_OF_SIMULATION - Static variable in class ds.granules.naadsm.event.EventType
 
END_OF_SIMULATION - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
END_OF_SIMULATION - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
END_OF_SIMULATION - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
EndOfDayEvent - Class in ds.granules.naadsm.dynamicmerge.event
END_OF_DAY message
EndOfDayEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
 
EndOfDayEvent - Class in ds.granules.naadsm.dynamicsplit.event
END_OF_DAY message
EndOfDayEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
 
EndOfDayEvent - Class in ds.granules.naadsm.event
 
EndOfDayEvent() - Constructor for class ds.granules.naadsm.event.EndOfDayEvent
 
EndOfDayEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
END_OF_DAY message
EndOfDayEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
 
EndOfDayEvent - Class in ds.granules.naadsm.resplit.event
END_OF_DAY message
EndOfDayEvent() - Constructor for class ds.granules.naadsm.resplit.event.EndOfDayEvent
 
EndOfDayEvent - Class in ds.granules.naadsm.staticsplit.event
END_OF_DAY message
EndOfDayEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
 
EndOfSimulationEvent - Class in ds.granules.naadsm.dynamicmerge.event
END_OF_SIMULATION message
EndOfSimulationEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
 
EndOfSimulationEvent(int) - Constructor for class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
 
EndOfSimulationEvent(int, boolean) - Constructor for class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
 
EndOfSimulationEvent - Class in ds.granules.naadsm.dynamicsplit.event
END_OF_SIMULATION message
EndOfSimulationEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.EndOfSimulationEvent
 
EndOfSimulationEvent - Class in ds.granules.naadsm.event
 
EndOfSimulationEvent() - Constructor for class ds.granules.naadsm.event.EndOfSimulationEvent
 
EndOfSimulationEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
END_OF_SIMULATION message
EndOfSimulationEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
 
EndOfSimulationEvent(int) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
 
EndOfSimulationEvent(int, boolean) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
 
EndOfSimulationEvent - Class in ds.granules.naadsm.resplit.event
END_OF_SIMULATION message
EndOfSimulationEvent() - Constructor for class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
 
EndOfSimulationEvent(int) - Constructor for class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
 
EndOfSimulationEvent(int, boolean) - Constructor for class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
 
EndOfSimulationEvent - Class in ds.granules.naadsm.staticsplit.event
 
EndOfSimulationEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.EndOfSimulationEvent
 
equals(Object) - Method in class ds.granules.scheduler.ExecutableTask
 
EventSize - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
EventSize - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
EventSize - Static variable in class ds.granules.naadsm.event.EventType
 
EventSize - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
EventSize - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
EventSize - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
EventType - Class in ds.granules.naadsm.dynamicmerge.event
Base class for all event classes
EventType() - Constructor for class ds.granules.naadsm.dynamicmerge.event.EventType
 
EventType - Class in ds.granules.naadsm.dynamicsplit.event
Base class for all event classes
EventType() - Constructor for class ds.granules.naadsm.dynamicsplit.event.EventType
 
EventType - Class in ds.granules.naadsm.event
 
EventType() - Constructor for class ds.granules.naadsm.event.EventType
 
EventType - Class in ds.granules.naadsm.portionaldynamicmerge.event
Base class for all event classes
EventType() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
EventType - Class in ds.granules.naadsm.resplit.event
Base class for all event classes
EventType() - Constructor for class ds.granules.naadsm.resplit.event.EventType
 
EventType - Class in ds.granules.naadsm.staticsplit.event
Base class for all event classes
EventType() - Constructor for class ds.granules.naadsm.staticsplit.event.EventType
 
EventTypeFactory - Class in ds.granules.naadsm.dynamicmerge.event
Factory to create all the events.
EventTypeFactory() - Constructor for class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
 
EventTypeFactory - Class in ds.granules.naadsm.dynamicsplit.event
Factory to create all the events.
EventTypeFactory() - Constructor for class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
 
EventTypeFactory - Class in ds.granules.naadsm.event
 
EventTypeFactory() - Constructor for class ds.granules.naadsm.event.EventTypeFactory
 
EventTypeFactory - Class in ds.granules.naadsm.portionaldynamicmerge.event
Factory to create all the events.
EventTypeFactory() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
 
EventTypeFactory - Class in ds.granules.naadsm.resplit.event
Factory to create all the events.
EventTypeFactory() - Constructor for class ds.granules.naadsm.resplit.event.EventTypeFactory
 
EventTypeFactory - Class in ds.granules.naadsm.staticsplit.event
Factory to create all the events.
EventTypeFactory() - Constructor for class ds.granules.naadsm.staticsplit.event.EventTypeFactory
 
Exchange - Class in ds.granules.exchange
This is the base class for exchanges.
Exchange() - Constructor for class ds.granules.exchange.Exchange
 
ExchangeFactory - Class in ds.granules.exchange
This is a singleton class which encapsulates functionality related to creation and reconstructing various exchanges.
ExchangeProcessor - Class in ds.granules.scheduler
This is a class which is reponsible for processing various exchanges related to the deployment, discovery and advertisement of application instances and resources.
ExchangeProcessor(Diagnostics, String, int) - Constructor for class ds.granules.scheduler.ExchangeProcessor
 
ExchangeType - Interface in ds.granules.exchange
This is an interface which outlines the different types of exchanges that are currently supported.
ExecutableTask - Class in ds.granules.scheduler
This is an executable task, which manages the execution of the operation.
ExecutableTask(String, Operation, TaskLifecycleObserver) - Constructor for class ds.granules.scheduler.ExecutableTask
 
execute() - Method in class ds.granules.learning.classification.bayes.BayesFinalStage
 
execute() - Method in class ds.granules.learning.classification.cbayes.CBayesFinalStage
 
execute() - Method in class ds.granules.learning.classification.common.BayesPrepStage1
 
execute() - Method in class ds.granules.learning.classification.common.BayesPrepStage2
 
execute() - Method in class ds.granules.learning.classification.common.BayesPrepStage3
 
execute() - Method in class ds.granules.learning.clustering.dirichlet.DirichletMapper
 
execute() - Method in class ds.granules.learning.clustering.dirichlet.DirichletReducer
 
execute() - Method in class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansMapper
 
execute() - Method in class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansReducer
 
execute() - Method in class ds.granules.learning.clustering.kmeans.KMeansMapper
 
execute() - Method in class ds.granules.learning.clustering.kmeans.KMeansReducer
 
execute() - Method in class ds.granules.learning.clustering.lda.LDAMapper
 
execute() - Method in class ds.granules.learning.clustering.lda.LDAReducer
 
execute() - Method in class ds.granules.naadsm.ClusterMap
 
execute() - Method in class ds.granules.naadsm.Controller
 
execute() - Method in class ds.granules.naadsm.dynamicmerge.Controller
 
execute() - Method in class ds.granules.naadsm.dynamicmerge.Worker
 
execute() - Method in class ds.granules.naadsm.dynamicsplit.Controller
 
execute() - Method in class ds.granules.naadsm.dynamicsplit.Worker
 
execute() - Method in class ds.granules.naadsm.ft.Heartbeat
 
execute() - Method in class ds.granules.naadsm.ft.Speculator
 
execute() - Method in class ds.granules.naadsm.OutputVariableCollector
 
execute() - Method in class ds.granules.naadsm.portionaldynamicmerge.Controller
 
execute() - Method in class ds.granules.naadsm.portionaldynamicmerge.Worker
 
execute() - Method in class ds.granules.naadsm.relaunch.ClusterMap
 
execute() - Method in class ds.granules.naadsm.resplit.Controller
 
execute() - Method in class ds.granules.naadsm.resplit.Worker
 
execute() - Method in class ds.granules.naadsm.staticsplit.Controller
Implement execute() function in MapReduceBase class.
execute() - Method in class ds.granules.naadsm.staticsplit.Worker
 
execute() - Method in class ds.granules.naadsm.Worker
 
execute() - Method in interface ds.granules.operation.Operation
Execute the operation.
execute() - Method in class ds.granules.operation.OperationBase
 
execute() - Method in class ds.granules.samples.bioinf.ClusterMap
 
execute() - Method in class ds.granules.samples.bridge.FibMap
 
execute() - Method in class ds.granules.samples.checksum.ChecksumMap
 
execute() - Method in class ds.granules.samples.flip.FlipMap
 
execute() - Method in class ds.granules.samples.grep.GrepCountMap
 
execute() - Method in class ds.granules.samples.grep.GrepCountReduce
 
execute() - Method in class ds.granules.samples.iterative.StageOne
 
execute() - Method in class ds.granules.samples.iterative.StageThree
 
execute() - Method in class ds.granules.samples.iterative.StageTwo
 
execute() - Method in class ds.granules.samples.kmeans.KMStageOne
 
execute() - Method in class ds.granules.samples.kmeans.KMStageThree
 
execute() - Method in class ds.granules.samples.kmeans.KMStageTwo
 
execute() - Method in class ds.granules.samples.matrix.MatrixMap
 
execute() - Method in class ds.granules.samples.periodic.PeriodicMap
 
execute() - Method in class ds.granules.samples.periodic.PeriodicReduce
 
execute() - Method in class ds.granules.samples.pythonColl.PyCollMap
 
execute() - Method in class ds.granules.samples.pythonColl.PyCollReduce
 
execute() - Method in class ds.granules.samples.pythonColl.PyCollReduceRep
 
execute() - Method in class ds.granules.samples.sort.SortingOperation
 
execute() - Method in class ds.granules.samples.sort.SortMap
 
execute() - Method in class ds.granules.samples.sort.SortReduce
 
execute() - Method in class ds.granules.samples.wordcount.WordCountMap
 
execute() - Method in class ds.granules.samples.wordcount.WordCountReduce
 
executeCommand(String, String[], File, boolean) - Method in class ds.granules.util.SystemCommand
This method executes a system command based on the specified parameter.
EXECUTING - Static variable in interface ds.granules.exchange.ConditionFlag
 
executing - Variable in class ds.granules.scheduler.ExecutableTask
 
EXECUTING - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
EXECUTION_STATUS - Static variable in interface ds.granules.exchange.ExchangeType
 
ExecutionProfile - Interface in ds.granules.operation
This interfaces encapsulates the execution profile of the operation.
ExecutionProfileSetup - Class in ds.granules.operation
Implements the ExecutionProfile.
ExecutionProfileSetup(String) - Constructor for class ds.granules.operation.ExecutionProfileSetup
 
ExecutionProfileSetup(byte[]) - Constructor for class ds.granules.operation.ExecutionProfileSetup
 
ExecutionStatus - Class in ds.granules.exchange
This class encapsulates exchanges related to retrieving the status of a message.
ExecutionStatus() - Constructor for class ds.granules.exchange.ExecutionStatus
 
ExecutionStatus(String, String, String) - Constructor for class ds.granules.exchange.ExecutionStatus
 
ExecutionStatus(String, String, int, String, TaskLifecycleMetrics, String) - Constructor for class ds.granules.exchange.ExecutionStatus
 
executionTime(int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Get the execution time of all the workers.
executionTime - Variable in class ds.granules.naadsm.dynamicmerge.WorkerNode
 
expectedBeginTime() - Method in interface ds.granules.scheduler.ResourceProfile
Retrieves the expect starting time for a given task's execution.
EXPOSURE - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
EXPOSURE - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
EXPOSURE - Static variable in class ds.granules.naadsm.event.EventType
 
EXPOSURE - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
EXPOSURE - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
EXPOSURE - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
ExposureEvent - Class in ds.granules.naadsm.dynamicmerge.event
EXPOSURE message
ExposureEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
 
ExposureEvent - Class in ds.granules.naadsm.dynamicsplit.event
EXPOSURE message
ExposureEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
 
ExposureEvent - Class in ds.granules.naadsm.event
 
ExposureEvent() - Constructor for class ds.granules.naadsm.event.ExposureEvent
 
ExposureEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
EXPOSURE message
ExposureEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
 
ExposureEvent - Class in ds.granules.naadsm.resplit.event
EXPOSURE message
ExposureEvent() - Constructor for class ds.granules.naadsm.resplit.event.ExposureEvent
 
ExposureEvent - Class in ds.granules.naadsm.staticsplit.event
EXPOSURE message
ExposureEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.ExposureEvent
 

F

FAILURE - Static variable in interface ds.granules.exchange.ConditionFlag
 
FibDeployer - Class in ds.granules.samples.bridge
 
FibDeployer(Properties) - Constructor for class ds.granules.samples.bridge.FibDeployer
Initializes the deployer.
fibInit() - Method in class ds.granules.samples.bridge.FibMap
Simple function to actually initialize the program
FibMap - Class in ds.granules.samples.bridge
Simple example of using python through Granules Bridges This example is designed to handle a simple Fibonacci script.
FibMap() - Constructor for class ds.granules.samples.bridge.FibMap
 
FileAccess - Interface in ds.granules.dataset
The interface for accessing a dataset comprising files.
FileDataset - Class in ds.granules.dataset
An implementation of the FileAccess dataset interface.
FileDataset(String, String) - Constructor for class ds.granules.dataset.FileDataset
 
FileDataset(byte[]) - Constructor for class ds.granules.dataset.FileDataset
 
FILES - Static variable in interface ds.granules.dataset.Dataset
 
finish() - Method in class ds.granules.bridge.StreamWriter
Cleans up afterwards, and closes the stream it opened
finish() - Method in class ds.granules.naadsm.dynamicmerge.WorkerNode
Set this worker as finished.
finish() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
Set this worker as finished.
finishWorker(int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Finish one worker with worker number.
finishWorker(int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Finish one worker with worker number.
FlipDeployer - Class in ds.granules.samples.flip
 
FlipDeployer(Properties) - Constructor for class ds.granules.samples.flip.FlipDeployer
Initializes the deployer.
FlipMap - Class in ds.granules.samples.flip
 
FlipMap() - Constructor for class ds.granules.samples.flip.FlipMap
 
FLOAT - Static variable in class ds.granules.results.ResultPayload
 
float2bytes(float) - Static method in class ds.granules.naadsm.dynamicmerge.event.EventTypeFactory
Float number to 4 digit of byte array
float2bytes(float) - Static method in class ds.granules.naadsm.dynamicsplit.event.EventTypeFactory
Float number to 4 digit of byte array
float2bytes(float) - Static method in class ds.granules.naadsm.event.EventTypeFactory
 
float2bytes(float) - Static method in class ds.granules.naadsm.portionaldynamicmerge.event.EventTypeFactory
Float number to 4 digit of byte array
float2bytes(float) - Static method in class ds.granules.naadsm.resplit.event.EventTypeFactory
Float number to 4 digit of byte array
float2bytes(float) - Static method in class ds.granules.naadsm.staticsplit.event.EventTypeFactory
Float number to 4 digit of byte array
FLOAT_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
 
FLOAT_ARRAY - Static variable in class ds.granules.results.ResultPayload
 
fromBytes(byte[]) - Static method in class ds.granules.samples.kmeans.ObjectMarshaller
 
FuzzyKMeansDeployer - Class in ds.granules.learning.clustering.fuzzykmeans
The Deployer for Mahout's Fuzzy K-Means clustering implementation.
FuzzyKMeansDeployer(Properties) - Constructor for class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansDeployer
Initializes the deployer.
FuzzyKMeansMapper - Class in ds.granules.learning.clustering.fuzzykmeans
A Mapper for the Mahout implementation of Fuzzy K-Means clustering.
FuzzyKMeansMapper() - Constructor for class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansMapper
 
FuzzyKMeansReducer - Class in ds.granules.learning.clustering.fuzzykmeans
The reducer for Mahout's Fuzzy K-Means using Granules for communications
FuzzyKMeansReducer() - Constructor for class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansReducer
 

G

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
Get the LBDayNode of current day.
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
 

H

handleMessage(byte[]) - Method in interface ds.granules.bridge.JavaMessageHandler
Function to handle messages recieved via a StreamReader.
handleMessage(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.Worker
 
handleMessage(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.Worker
 
handleMessage(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.Worker
 
handleMessage(byte[]) - Method in class ds.granules.naadsm.resplit.Worker
 
handleMessage(byte[]) - Method in class ds.granules.naadsm.staticsplit.Worker
 
handleMessage(byte[]) - Method in class ds.granules.naadsm.Worker
 
handleMessage(byte[]) - Method in class ds.granules.samples.bridge.FibMap
 
handleMessage(byte[]) - Method in class ds.granules.samples.pythonColl.PyCollMap
 
handleMessage(byte[]) - Method in class ds.granules.samples.pythonColl.PyCollReduce
 
handleMessage(byte[]) - Method in class ds.granules.samples.pythonColl.PyCollReduceRep
 
hasDataset() - Method in interface ds.granules.dataset.DatasetCollection
Check to see if any dataset is part of this collection.
hasDataset(String) - Method in interface ds.granules.dataset.DatasetCollection
Check to see if a dataset with the specified identifier is part of this collection
hasDataset() - Method in class ds.granules.dataset.DatasetCollectionManagement
 
hasDataset(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
 
hasDatasetCollection() - Method in interface ds.granules.operation.Operation
Returns true if this operation operates on an underlying dataset collection.
hasDatasetCollection() - Method in class ds.granules.operation.OperationBase
 
hasExecutionProfile() - Method in interface ds.granules.operation.Operation
Check to see if this operation has an execution profile
hasExecutionProfile() - Method in class ds.granules.operation.OperationBase
 
hash(byte[]) - Method in class ds.granules.util.Checksum
Produce a checksum/hashsum of a given block of data.
hashCode() - Method in class ds.granules.scheduler.ExecutableTask
 
HASHMAP - Static variable in class ds.granules.results.ResultPayload
 
HASHTABLE - Static variable in class ds.granules.results.ResultPayload
 
hashToHexString(byte[]) - Method in class ds.granules.util.Checksum
Convert a hash to a hexidecimal String.
hasInputStreams() - Method in class ds.granules.dataset.StreamDataset
 
hasInputStreams() - Method in interface ds.granules.dataset.StreamingAccess
Check to see if this dataset has any registered input streams.
hasMaxSequence() - Method in interface ds.granules.results.SequencingInfo
Check to see if the max sequence Info has been set.
hasMaxSequence() - Method in class ds.granules.results.SequencingWidget
 
hasOutputStreams() - Method in class ds.granules.dataset.StreamDataset
 
hasOutputStreams() - Method in interface ds.granules.dataset.StreamingAccess
Check to see if this dataset has any registered output streams.
hasProcessingDirectives() - Method in interface ds.granules.operation.Operation
Checks to see if the operation has processing directives
hasProcessingDirectives() - Method in class ds.granules.operation.OperationBase
 
hasRespondTo() - Method in interface ds.granules.results.Results
Check to see if a respondTo field has been included as part of this result.
hasRespondTo() - Method in class ds.granules.results.ResultsWidget
 
hasSequenceRange() - Method in interface ds.granules.results.SequencingInfo
Check to see if a sequence range has been specified.
hasSequenceRange() - Method in class ds.granules.results.SequencingWidget
 
hasSequencingInfo() - Method in interface ds.granules.results.Results
Check to see if a Sequencing Info has been associated with this result.
hasSequencingInfo() - Method in class ds.granules.results.ResultsWidget
 
hasSingleSequence() - Method in interface ds.granules.results.SequencingInfo
Checks to see if this contains information about a single sequence
hasSingleSequence() - Method in class ds.granules.results.SequencingWidget
 
hasWorker(int) - Method in class ds.granules.naadsm.ft.HostInfo
 
Heartbeat - Class in ds.granules.naadsm.ft
Simple periodically-executing heartbeat computation for detecting failed machines.
Heartbeat() - Constructor for class ds.granules.naadsm.ft.Heartbeat
 
HEARTBEAT_INTERVAL_MS - Static variable in class ds.granules.naadsm.ft.Speculator
 
HEARTBEAT_SYNOPSIS - Static variable in class ds.granules.naadsm.ft.Speculator
 
HIERARCHICAL_SYNOPSIS - Static variable in interface ds.granules.dataset.StreamingAccess
 
HOST_TIMEOUT_MS - Static variable in class ds.granules.naadsm.ft.Speculator
 
HostInfo - Class in ds.granules.naadsm.ft
Collects information about a host running a Granules Resource.
HostInfo(String) - Constructor for class ds.granules.naadsm.ft.HostInfo
 
howToSplit - Variable in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
 
howToSplit - Variable in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
 
howToSplit - Variable in class ds.granules.naadsm.event.SplitEvent
 
howToSplit - Variable in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
 
howToSplit - Variable in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
 
howToSplit - Variable in class ds.granules.naadsm.resplit.event.SplitByDensity
 
howToSplit - Variable in class ds.granules.naadsm.resplit.event.SplitEvent
 

I

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 StageTwos.
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.

J

JavaByteMessage - Class in ds.granules.bridge
Basic message to handle communications between C++ and Java programs
JavaByteMessage(int) - Constructor for class ds.granules.bridge.JavaByteMessage
Initializes a JavaCppMessage, message type is set at creation, and cannot be changed.
JavaByteMessage(byte[]) - Constructor for class ds.granules.bridge.JavaByteMessage
Initializes a JavaCppMessage, based off of a byte[], used to reconstruct a message sent from a c++ program
JavaGenericComputation - Class in ds.granules.bridge
 
JavaGenericComputation(String) - Constructor for class ds.granules.bridge.JavaGenericComputation
Constructor, simply grabs the runtime, needs a program name
JavaMessageHandler - Interface in ds.granules.bridge
Very simple interface which needs to be implemented to use StreamReader
JavaPythonCommunication - Class in ds.granules.samples.pythonColl
 
JavaPythonCommunication(String, JavaMessageHandler) - Constructor for class ds.granules.samples.pythonColl.JavaPythonCommunication
Initializes and returns a reference to a JavaPythonComputation.
JavaPythonCommunication(String, JavaMessageHandler, int) - Constructor for class ds.granules.samples.pythonColl.JavaPythonCommunication
 
JobLifecycleObserver - Interface in ds.granules.operation
JobLifecycleObserver is the interface which needs to be implemented by an entity which wishes to observe the execution of a Job and its constituent tasks.
JobSubmission - Class in ds.granules.operation
This class manages the submission, tracking and cancellation of Jobs and their constituent tasks.

K

killJob(String) - Method in class ds.granules.operation.InstanceDeployer
Kill a Job with specified jobIdentifer
killJob(String) - Method in class ds.granules.operation.JobSubmission
Attempts to kill the job while it is in execution at different sites
KMeansDeployer - Class in ds.granules.learning.clustering.kmeans
The deployer for the Mahout implementation of K-Means Clustering
KMeansDeployer(Properties) - Constructor for class ds.granules.learning.clustering.kmeans.KMeansDeployer
Initializes the deployer.
KMeansMapper - Class in ds.granules.learning.clustering.kmeans
An example demonstrating the Map role within a Word Count operation.
KMeansMapper() - Constructor for class ds.granules.learning.clustering.kmeans.KMeansMapper
 
KMeansReducer - Class in ds.granules.learning.clustering.kmeans
Reduce code for the Mahout K-Means clustering function
KMeansReducer() - Constructor for class ds.granules.learning.clustering.kmeans.KMeansReducer
 
KMStageOne - Class in ds.granules.samples.kmeans
Kmeans Clustering - StageOne.
KMStageOne() - Constructor for class ds.granules.samples.kmeans.KMStageOne
 
KMStageThree - Class in ds.granules.samples.kmeans
Kmeans Clustering - StageThree.
KMStageThree() - Constructor for class ds.granules.samples.kmeans.KMStageThree
 
KMStageTwo - Class in ds.granules.samples.kmeans
Kmeans Clustering - StageTwo.
KMStageTwo() - Constructor for class ds.granules.samples.kmeans.KMStageTwo
 
KMVectorData - Class in ds.granules.samples.kmeans
A widget to hold vector data.
KMVectorData() - Constructor for class ds.granules.samples.kmeans.KMVectorData
 
KMVectorData(int, int, double[][]) - Constructor for class ds.granules.samples.kmeans.KMVectorData
 
KMVectorData(String) - Constructor for class ds.granules.samples.kmeans.KMVectorData
Read data from a given file.

L

LBDayNode - Class in ds.granules.naadsm.portionaldynamicmerge
This class contains load balancing operation information of one simulation day.
LBDayNode() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.LBDayNode
 
LBOperationNode - Class in ds.granules.naadsm.portionaldynamicmerge
This class contains the information of one load balancing operation.
LBOperationNode(int, int) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.LBOperationNode
 
LDADeployer - Class in ds.granules.learning.clustering.lda
The Deployer for Mahout's Latent Dirichlet Allocation (LDA) clustering algorithm
LDADeployer(Properties) - Constructor for class ds.granules.learning.clustering.lda.LDADeployer
Initializes the deployer.
LDAMapper - Class in ds.granules.learning.clustering.lda
An example demonstrating the Map role within a Word Count operation.
LDAMapper() - Constructor for class ds.granules.learning.clustering.lda.LDAMapper
 
LDAReducer - Class in ds.granules.learning.clustering.lda
The Reducer for the Latent Dirichlet Allocation (LDA) clustering algorithm with Mahout
LDAReducer() - Constructor for class ds.granules.learning.clustering.lda.LDAReducer
 
LDAState - Class in ds.granules.learning.clustering.lda
Used by the LDAMapper to maintain state information.
LDAState(int, int, double, Matrix, double[], double) - Constructor for class ds.granules.learning.clustering.lda.LDAState
 
left - Variable in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
 
left - Variable in class ds.granules.naadsm.dynamicsplit.event.Restore
 
left - Variable in class ds.granules.naadsm.event.Checkpoint
 
left - Variable in class ds.granules.naadsm.event.Restore
 
leftBound - Variable in class ds.granules.naadsm.dynamicmerge.WorkerNode
 
LibraryException - Exception in ds.granules.scheduler
This is an exception that is thrown when there are problems loading or unloading libraries that are associated with application instances.
LibraryException() - Constructor for exception ds.granules.scheduler.LibraryException
Constructs an LibraryException with no detail message.
LibraryException(String) - Constructor for exception ds.granules.scheduler.LibraryException
Constructs an LibraryException with the specified detail message.
LibraryManager - Interface in ds.granules.scheduler
This is an interface that outlines functionality needed for managing the loading and unloading of classes and Jar files.
libraryRegisteredForOperation() - Method in interface ds.granules.scheduler.LibraryManager
 
list - Variable in class ds.granules.naadsm.dynamicmerge.WorkerList
 
list - Variable in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
 
listOfLoadedLibraries() - Method in interface ds.granules.scheduler.LibraryManager
 
loadClass() - Method in interface ds.granules.scheduler.LibraryManager
 
LoadGenerator - Class in ds.granules.naadsm.dynamicmerge
Load generator is to start the experiment by sending out the BOOTSTRAP message and finalize the experiment.
LoadGenerator(Properties) - Constructor for class ds.granules.naadsm.dynamicmerge.LoadGenerator
 
LoadGenerator - Class in ds.granules.naadsm.dynamicsplit
Load generator is to start the experiment by sending out the BOOTSTRAP message and finalize the experiment.
LoadGenerator(Properties) - Constructor for class ds.granules.naadsm.dynamicsplit.LoadGenerator
 
LoadGenerator - Class in ds.granules.naadsm
 
LoadGenerator(Properties) - Constructor for class ds.granules.naadsm.LoadGenerator
 
LoadGenerator - Class in ds.granules.naadsm.portionaldynamicmerge
Load generator is to start the experiment by sending out the BOOTSTRAP message and finalize the experiment.
LoadGenerator(Properties) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
 
LoadGenerator - Class in ds.granules.naadsm.resplit
Load generator is to start the experiment by sending out the BOOTSTRAP message and finalize the experiment.
LoadGenerator(Properties) - Constructor for class ds.granules.naadsm.resplit.LoadGenerator
 
LoadGenerator - Class in ds.granules.naadsm.staticsplit
Load generator is to start the experiment by sending out the BOOTSTRAP message and finalize the experiment.
LoadGenerator(Properties) - Constructor for class ds.granules.naadsm.staticsplit.LoadGenerator
 
LoadGenerator - Class in ds.granules.samples.bridge
 
LoadGenerator() - Constructor for class ds.granules.samples.bridge.LoadGenerator
 
LoadGenerator - Class in ds.granules.samples.flip
 
LoadGenerator() - Constructor for class ds.granules.samples.flip.LoadGenerator
 
loadJarLibrary() - Method in interface ds.granules.scheduler.LibraryManager
 
loadLibrary() - Method in interface ds.granules.scheduler.Controller
 
loadNativeLibraries() - Method in interface ds.granules.scheduler.LibraryManager
 
LONG - Static variable in interface ds.granules.bridge.ControlMessage
 
LONG - Static variable in class ds.granules.results.ResultPayload
 
LONG_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
 
LONG_ARRAY - Static variable in class ds.granules.results.ResultPayload
 
LONG_ENTRIES - Static variable in class ds.granules.util.Matrix
 
lowerBound - Variable in class ds.granules.naadsm.dynamicmerge.WorkerNode
 

M

main(String[]) - Static method in class ds.granules.dataset.DatasetCollectionManagement
 
main(String[]) - Static method in class ds.granules.dataset.FileDataset
 
main(String[]) - Static method in class ds.granules.exchange.ExchangeFactory
 
main(String[]) - Static method in class ds.granules.exchange.ResourceDiscovery
 
main(String[]) - Static method in class ds.granules.learning.classification.bayes.BayesDeployer
 
main(String[]) - Static method in class ds.granules.learning.classification.cbayes.CBayesDeployer
 
main(String[]) - Static method in class ds.granules.learning.clustering.dirichlet.DirichletDeployer
 
main(String[]) - Static method in class ds.granules.learning.clustering.fuzzykmeans.FuzzyKMeansDeployer
 
main(String[]) - Static method in class ds.granules.learning.clustering.kmeans.KMeansDeployer
 
main(String[]) - Static method in class ds.granules.learning.clustering.lda.LDADeployer
 
main(String[]) - Static method in class ds.granules.naadsm.ClusterDeployer
 
main(String[]) - Static method in class ds.granules.naadsm.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.dynamicmerge.DataPrepare
 
main(String[]) - Static method in class ds.granules.naadsm.dynamicmerge.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
 
main(String[]) - Static method in class ds.granules.naadsm.dynamicsplit.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
 
main(String[]) - Static method in class ds.granules.naadsm.ft.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.LoadGenerator
 
main(String[]) - Static method in class ds.granules.naadsm.ml.NeuralPredictor
 
main(String[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.DataPrepare
 
main(String[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.DayList
 
main(String[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
 
main(String[]) - Static method in class ds.granules.naadsm.relaunch.ClusterDeployer
 
main(String[]) - Static method in class ds.granules.naadsm.resplit.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.resplit.event.test
 
main(String[]) - Static method in class ds.granules.naadsm.resplit.LoadGenerator
 
main(String[]) - Static method in class ds.granules.naadsm.staticsplit.Deployer
 
main(String[]) - Static method in class ds.granules.naadsm.staticsplit.LoadGenerator
 
main(String[]) - Static method in class ds.granules.naadsm.testIO
 
main(String[]) - Static method in class ds.granules.naadsm.testNN
 
main(String[]) - Static method in class ds.granules.results.ResultsFactory
 
main(String[]) - Static method in class ds.granules.results.ResultsWidget
 
main(String[]) - Static method in class ds.granules.samples.bioinf.ClusterDeployer
 
main(String[]) - Static method in class ds.granules.samples.bridge.FibDeployer
 
main(String[]) - Static method in class ds.granules.samples.bridge.LoadGenerator
 
main(String[]) - Static method in class ds.granules.samples.checksum.ChecksumDeployer
 
main(String[]) - Static method in class ds.granules.samples.checksum.Client
 
main(String[]) - Static method in class ds.granules.samples.flip.FlipDeployer
 
main(String[]) - Static method in class ds.granules.samples.flip.LoadGenerator
 
main(String[]) - Static method in class ds.granules.samples.grep.GrepCountDeployer
 
main(String[]) - Static method in class ds.granules.samples.iterative.IterativeDeployer
 
main(String[]) - Static method in class ds.granules.samples.matrix.MatrixDeployer
 
main(String[]) - Static method in class ds.granules.samples.matrix.MatrixSharedMemory
 
main(String[]) - Static method in class ds.granules.samples.periodic.PeriodicDeployer
 
main(String[]) - Static method in class ds.granules.samples.pythonColl.PyCollDeploy1Shot
 
main(String[]) - Static method in class ds.granules.samples.pythonColl.PyCollDeployer
 
main(String[]) - Static method in class ds.granules.samples.pythonColl.PyCollDeployerRep
 
main(String[]) - Static method in class ds.granules.samples.pythonColl.PyLoadGen
 
main(String[]) - Static method in class ds.granules.samples.pythonColl.PyLoadGenRep
 
main(String[]) - Static method in class ds.granules.samples.sort.NumberGenerator
 
main(String[]) - Static method in class ds.granules.samples.sort.SortDeployer
 
main(String[]) - Static method in class ds.granules.samples.wordcount.WordCountDeployer
 
main(String[]) - Static method in class ds.granules.scheduler.Resource
Main entry point for a Granules computational resource.
main(String[]) - Static method in class ds.granules.scheduler.ResourceMetrics
 
main(String[]) - Static method in class ds.granules.scheduler.StreamingService
 
main(String[]) - Static method in class ds.granules.util.Matrix
 
main(String[]) - Static method in class ds.granules.util.MatrixColumnMajor
 
main(String[]) - Static method in class ds.granules.util.SystemCommand
 
main(String[]) - Static method in class ds.granules.util.Version
 
manageExecution(String, Operation) - Method in class ds.granules.scheduler.TaskManagement
Manage the execution of the given operation
Map - Interface in ds.granules.operation
This interface corresponds to the Map role in a Map-Reduce operation.
MapReduce - Interface in ds.granules.operation
This is an interface which encapsulates functionality that is common to both the Map and Reduce roles that are associated with the applications.
MapReduceBase - Class in ds.granules.operation
This is the base class which will serve as the base for implementations of the Map and Reduce interface.
MapReduceBase() - Constructor for class ds.granules.operation.MapReduceBase
 
MapReduceException - Exception in ds.granules.operation
This is the exception that would be thrown if there are problems in performing Map-Reduce operations.
MapReduceException() - Constructor for exception ds.granules.operation.MapReduceException
Constructs an ProcessingException with no detail message.
MapReduceException(String) - Constructor for exception ds.granules.operation.MapReduceException
Constructs an ProcessingException with the specified detail message.
markInitializationAsComplete() - Method in class ds.granules.operation.OperationBase
 
marshallExchangeSpecificElements() - Method in class ds.granules.exchange.DeploymentMessage
 
marshallExchangeSpecificElements() - Method in class ds.granules.exchange.Exchange
This method is utilized by the derived classes to marshall (or serialize) elements that are specific to the derived class.
marshallExchangeSpecificElements() - Method in class ds.granules.exchange.ExecutionStatus
 
marshallExchangeSpecificElements() - Method in class ds.granules.exchange.ResourceDiscovery
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.EventType
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForVaccination
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.RequestOfDestruction
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.TraceResult
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.Vaccination
 
marshalling() - Method in class ds.granules.naadsm.dynamicmerge.event.VaccinationCanceled
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfSimulationEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.EventType
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.RequestOfDestruction
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
 
marshalling() - Method in class ds.granules.naadsm.dynamicsplit.event.TraceResult
 
marshalling() - Method in class ds.granules.naadsm.event.AttemptToInfect
 
marshalling() - Method in class ds.granules.naadsm.event.Checkpoint
 
marshalling() - Method in class ds.granules.naadsm.event.DestructionEvent
 
marshalling() - Method in class ds.granules.naadsm.event.EndOfDayEvent
 
marshalling() - Method in class ds.granules.naadsm.event.EndOfSimulationEvent
 
marshalling() - Method in class ds.granules.naadsm.event.EventType
 
marshalling() - Method in class ds.granules.naadsm.event.ExposureEvent
 
marshalling() - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
 
marshalling() - Method in class ds.granules.naadsm.event.QuarantineEvent
 
marshalling() - Method in class ds.granules.naadsm.event.RequestForZoneFocus
 
marshalling() - Method in class ds.granules.naadsm.event.RequestOfDestruction
 
marshalling() - Method in class ds.granules.naadsm.event.Restore
 
marshalling() - Method in class ds.granules.naadsm.event.SplitEvent
 
marshalling() - Method in class ds.granules.naadsm.event.StartNewDayEvent
 
marshalling() - Method in class ds.granules.naadsm.event.TraceResult
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForVaccination
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestOfDestruction
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.TraceResult
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Vaccination
 
marshalling() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.VaccinationCanceled
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.Checkpoint
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.Detection
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.EventType
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.MultiRestore
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.RequestForVaccination
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.RequestOfDestruction
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.Restore
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.SplitByDensity
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.SplitEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.TraceResult
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.Vaccination
 
marshalling() - Method in class ds.granules.naadsm.resplit.event.VaccinationCanceled
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.EndOfSimulationEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.EventType
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.RequestOfDestruction
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.SplitEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
 
marshalling() - Method in class ds.granules.naadsm.staticsplit.event.TraceResult
 
MarshallingException - Exception in ds.granules.exception
This is an exception that is thrown if there are problems marshalling or unmarshalling exchanges.
MarshallingException() - Constructor for exception ds.granules.exception.MarshallingException
Constructs an MarshallingException with no detail message.
MarshallingException(String) - Constructor for exception ds.granules.exception.MarshallingException
Constructs an MarshallingException with the specified detail message.
MarshallingUtil - Class in ds.granules.util
This is a utility class which includes methods for marshalling and un-marshalling several commonly used data types.
Matrix - Class in ds.granules.util
A class that encapsulates a Matrix.
Matrix(String, int, int, boolean, int) - Constructor for class ds.granules.util.Matrix
 
Matrix(String) - Constructor for class ds.granules.util.Matrix
 
MatrixColumnMajor - Class in ds.granules.util
A matrix encapsulator where the Matrix is stored in column-major format for faster reads from the underlying file system.
MatrixColumnMajor(String, int, int, boolean, int) - Constructor for class ds.granules.util.MatrixColumnMajor
 
MatrixColumnMajor(String) - Constructor for class ds.granules.util.MatrixColumnMajor
 
MatrixDeployer - Class in ds.granules.samples.matrix
An example demonstrating the calculation of matrix products on a set of machines.
MatrixDeployer(Properties, String) - Constructor for class ds.granules.samples.matrix.MatrixDeployer
Initializes the deployer.
MatrixFactory - Class in ds.granules.util
This is a Factory class which creates matrices that are stored either in row major or column major formats.
MatrixMap - Class in ds.granules.samples.matrix
An example demonstrating the Map role within a Parallel-sort operation.
MatrixMap() - Constructor for class ds.granules.samples.matrix.MatrixMap
 
MatrixSharedMemory - Class in ds.granules.samples.matrix
 
MD5Checksum - Class in ds.granules.util
A class that calculate checksum for a string.
MD5Checksum() - Constructor for class ds.granules.util.MD5Checksum
 
mergeWorkers(int, int) - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Merge two adjacent workers together.
mergeWorkers(int, int) - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Merge two adjacent workers
messageSwitch(byte[]) - Method in class ds.granules.samples.pythonColl.PyCollReduce
 
messageSwitch(byte[]) - Method in class ds.granules.samples.pythonColl.PyCollReduceRep
 
MonitorTimer - Class in ds.granules.naadsm.relaunch
 
MonitorTimer(ClusterDeployer) - Constructor for class ds.granules.naadsm.relaunch.MonitorTimer
 
MULTI_RESTORE - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
MULTI_SPLIT_BY_DENSITY - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
MultiRestore - Class in ds.granules.naadsm.resplit.event
RESTORE message
MultiRestore() - Constructor for class ds.granules.naadsm.resplit.event.MultiRestore
 
MultiRestore(int, boolean, int, int, int, byte[]) - Constructor for class ds.granules.naadsm.resplit.event.MultiRestore
 
MultiSplitByDensity - Class in ds.granules.naadsm.resplit.event
SPLIT message
MultiSplitByDensity() - Constructor for class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 
MultiSplitByDensity(int, int, float[], int) - Constructor for class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 

N

needsInitialization() - Method in interface ds.granules.dataset.Dataset
Indicates whether the dataset needs to be initialized prior to being used.
needsInitialization() - Method in class ds.granules.dataset.FileDataset
 
needsInitialization() - Method in class ds.granules.dataset.StreamDataset
 
needsInitialization() - Method in interface ds.granules.operation.Operation
Returns an indicator that indicates if the initialization needs to be performed.
needsInitialization() - Method in class ds.granules.operation.OperationBase
 
network - Variable in class ds.granules.naadsm.ml.NeuralState
 
NeuralPredictor - Class in ds.granules.naadsm.ml
This class contains training, predicting and serialization of artificial neural network.
NeuralPredictor() - Constructor for class ds.granules.naadsm.ml.NeuralPredictor
 
NeuralState - Class in ds.granules.naadsm.ml
This class contains the state of a neural network.
NeuralState() - Constructor for class ds.granules.naadsm.ml.NeuralState
 
nextDay() - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
 
nextDay() - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
 
nextDay() - Method in class ds.granules.naadsm.event.StartNewDayEvent
 
nextDay() - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
 
nextDay() - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
 
nextDay() - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
 
nextSpareWorker() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Get the worker number of the next spare worker.
nextSpareWorker() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Get the worker number of the next spare worker.
NOT_SET - Static variable in interface ds.granules.exchange.ConditionFlag
 
NOT_SET - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
NumberGenerator - Class in ds.granules.samples.sort
A class that will generate numbers (to be sorted) continually.
NumberGenerator(int) - Constructor for class ds.granules.samples.sort.NumberGenerator
 
numberOfActiveWorkers() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Get total number of active workers.
numberOfActiveWorkers() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Get total number of active workers.
numberOfPieces - Variable in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 
numberOfSpareWorkers() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Get number of spare workers.
numberOfSpareWorkers() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Get number of spare workers.
numberOfWorkers() - Method in class ds.granules.naadsm.dynamicmerge.WorkerList
Get total number of workers.
numberOfWorkers() - Method in class ds.granules.naadsm.portionaldynamicmerge.WorkerList
Get total number of workers.

O

OBJECT - Static variable in class ds.granules.results.ResultPayload
 
OBJECT_2D_ARRAY - Static variable in class ds.granules.results.ResultPayload
 
OBJECT_ARRAY - Static variable in class ds.granules.results.ResultPayload
 
ObjectMarshaller - Class in ds.granules.samples.kmeans
Object marshalling and unmarshalling utility used for Kmeans clustering.
ObjectMarshaller() - Constructor for class ds.granules.samples.kmeans.ObjectMarshaller
 
onDataAvailability(String) - Method in interface ds.granules.dataset.DataAvailabilityObserver
This method is invoked on the observers to reflect the availability of new data in the input dataset
onDataAvailability(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
 
onDataAvailability() - Method in interface ds.granules.dataset.DatasetCollectionObserver
This method is invoked on the observers to reflect the availability of new data in the dataset collection.
onDataAvailability() - Method in class ds.granules.scheduler.ExecutableTask
 
onDatasetClosure(String) - Method in interface ds.granules.dataset.DataAvailabilityObserver
This method is invoked on the observer when the dataset will be closed and thus no more data will be available.
onDatasetClosure(String) - Method in class ds.granules.dataset.DatasetCollectionManagement
 
onDatasetCollectionClosure() - Method in interface ds.granules.dataset.DatasetCollectionObserver
This method is invoked on the observers to reflect the closure of the dataset collection.
onDatasetCollectionClosure() - Method in class ds.granules.scheduler.ExecutableTask
 
onEvent(NBEvent) - Method in class ds.granules.dataset.StreamDataset
 
onEvent(NBEvent) - Method in class ds.granules.naadsm.dynamicmerge.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.naadsm.dynamicsplit.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.naadsm.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.naadsm.portionaldynamicmerge.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.naadsm.resplit.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.naadsm.staticsplit.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.operation.JobSubmission
 
onEvent(NBEvent) - Method in class ds.granules.samples.bridge.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.samples.flip.LoadGenerator
 
onEvent(NBEvent) - Method in class ds.granules.samples.matrix.MatrixDeployer
 
onEvent(NBEvent) - Method in class ds.granules.samples.pythonColl.PyLoadGen
 
onEvent(NBEvent) - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
 
onEvent(NBEvent) - Method in class ds.granules.scheduler.ExchangeProcessor
 
Operation - Interface in ds.granules.operation
This is the interface which encapsulates an application instance that will be deployed.
OperationBase - Class in ds.granules.operation
This is an implementation of the Operation and OperationConfiguration interfaces.
OperationBase() - Constructor for class ds.granules.operation.OperationBase
 
OperationConfiguration - Interface in ds.granules.operation
This is an interface that allows application instances to be configured.
OUTPUT_VARIABLE_VALUE - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
OUTPUT_VARIABLE_VALUE - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
OUTPUT_VARIABLE_VALUE - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
OutputVariableCollector - Class in ds.granules.naadsm
This is the output variable collector of distributed NAADSM.
OutputVariableCollector() - Constructor for class ds.granules.naadsm.OutputVariableCollector
 
OutputVariableValue - Class in ds.granules.naadsm.dynamicmerge.event
ATTEMPT_TO_INFECT message
OutputVariableValue() - Constructor for class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
 
OutputVariableValue - Class in ds.granules.naadsm.portionaldynamicmerge.event
ATTEMPT_TO_INFECT message
OutputVariableValue() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
 
OutputVariableValue - Class in ds.granules.naadsm.resplit.event
ATTEMPT_TO_INFECT message
OutputVariableValue() - Constructor for class ds.granules.naadsm.resplit.event.OutputVariableValue
 

P

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 StageTwos.
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
 

Q

QUARANTINE - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
QUARANTINE - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
QUARANTINE - Static variable in class ds.granules.naadsm.event.EventType
 
QUARANTINE - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
QUARANTINE - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
QUARANTINE - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
QuarantineEvent - Class in ds.granules.naadsm.dynamicmerge.event
QUARANTINE message
QuarantineEvent() - Constructor for class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
 
QuarantineEvent - Class in ds.granules.naadsm.dynamicsplit.event
QUARANTINE message
QuarantineEvent() - Constructor for class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
 
QuarantineEvent - Class in ds.granules.naadsm.event
 
QuarantineEvent() - Constructor for class ds.granules.naadsm.event.QuarantineEvent
 
QuarantineEvent - Class in ds.granules.naadsm.portionaldynamicmerge.event
QUARANTINE message
QuarantineEvent() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
 
QuarantineEvent - Class in ds.granules.naadsm.resplit.event
QUARANTINE message
QuarantineEvent() - Constructor for class ds.granules.naadsm.resplit.event.QuarantineEvent
 
QuarantineEvent - Class in ds.granules.naadsm.staticsplit.event
QUARANTINE message
QuarantineEvent() - Constructor for class ds.granules.naadsm.staticsplit.event.QuarantineEvent
 
QUEUED_FOR_EXECUTION - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 

R

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
 

S

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
 

T

TAG_VALUE_PAIRS - Static variable in interface ds.granules.dataset.StreamingAccess
 
targetMax - Variable in class ds.granules.naadsm.ml.NeuralState
 
targetMin - Variable in class ds.granules.naadsm.ml.NeuralState
 
TaskLifecycleMetrics - Interface in ds.granules.scheduler
This is an interface that snapshots the lifecyle of a task.
TaskLifecycleMetricsReader - Class in ds.granules.exchange
 
TaskLifecycleMetricsReader(byte[]) - Constructor for class ds.granules.exchange.TaskLifecycleMetricsReader
 
TaskLifecycleObserver - Interface in ds.granules.scheduler
The observer whose method invocation track the lifetime of a task
TaskManagement - Class in ds.granules.scheduler
This is the class that is responsible for managing tasks.
TaskManagement(int, Diagnostics) - Constructor for class ds.granules.scheduler.TaskManagement
 
taskReadyToExecute() - Method in interface ds.granules.scheduler.Controller
 
TCP - Static variable in interface ds.granules.bridge.ControlMessage
 
terminateJob() - Method in class ds.granules.naadsm.ft.Deployer
This method attempts to terminate the job that was previously submitted.
terminateJob() - Method in class ds.granules.samples.checksum.ChecksumDeployer
This method attempts to terminate the job that was previously submitted.
terminateJob() - Method in class ds.granules.samples.flip.FlipDeployer
This method attempts to terminate the job that was previously submitted.
terminationConditionReached() - Method in interface ds.granules.operation.Operation
This indicates if the operation has completed or not.
terminationConditionReached() - Method in class ds.granules.operation.OperationBase
 
test - Class in ds.granules.naadsm.resplit.event
 
test() - Constructor for class ds.granules.naadsm.resplit.event.test
 
testIO - Class in ds.granules.naadsm
 
testIO() - Constructor for class ds.granules.naadsm.testIO
 
testNN - Class in ds.granules.naadsm
 
testNN() - Constructor for class ds.granules.naadsm.testNN
 
timeUp() - Method in class ds.granules.naadsm.relaunch.ClusterDeployer
 
toByteArray() - Method in class ds.granules.bridge.JavaByteMessage
Function to convert the JavaCppMessage to a byte[] to be sent to another program
toClusterObservations() - Method in class ds.granules.learning.clustering.fuzzykmeans.GranulesObservations
 
toClusterObservations() - Method in class ds.granules.learning.clustering.kmeans.GranulesObservations
 
toString() - Method in class ds.granules.bridge.JavaByteMessage
Helper to view the contents of a JavaCppMessage - useful for debugging
toString() - Method in class ds.granules.dataset.DatasetCollectionManagement
 
toString() - Method in class ds.granules.exchange.DeploymentMessage
 
toString() - Method in class ds.granules.exchange.ExecutionStatus
 
toString() - Method in class ds.granules.exchange.TaskLifecycleMetricsReader
 
toString() - Method in class ds.granules.learning.classification.common.GranTuple
 
toString() - Method in class ds.granules.operation.ExecutionProfileSetup
 
toString() - Method in interface ds.granules.operation.Operation
A summarized String-based representation of the operation
toString() - Method in class ds.granules.operation.OperationBase
 
toString() - Method in class ds.granules.operation.ProgressTrackerWidget
 
toString() - Method in class ds.granules.scheduler.ResourceMetrics
 
TRACE_RESULT - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
TRACE_RESULT - Static variable in class ds.granules.naadsm.dynamicsplit.event.EventType
 
TRACE_RESULT - Static variable in class ds.granules.naadsm.event.EventType
 
TRACE_RESULT - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
TRACE_RESULT - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
TRACE_RESULT - Static variable in class ds.granules.naadsm.staticsplit.event.EventType
 
TraceResult - Class in ds.granules.naadsm.dynamicmerge.event
TRACE_RESULT message
TraceResult() - Constructor for class ds.granules.naadsm.dynamicmerge.event.TraceResult
 
TraceResult - Class in ds.granules.naadsm.dynamicsplit.event
TRACE_RESULT message
TraceResult() - Constructor for class ds.granules.naadsm.dynamicsplit.event.TraceResult
 
TraceResult - Class in ds.granules.naadsm.event
 
TraceResult() - Constructor for class ds.granules.naadsm.event.TraceResult
 
TraceResult - Class in ds.granules.naadsm.portionaldynamicmerge.event
TRACE_RESULT message
TraceResult() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.TraceResult
 
TraceResult - Class in ds.granules.naadsm.resplit.event
TRACE_RESULT message
TraceResult() - Constructor for class ds.granules.naadsm.resplit.event.TraceResult
 
TraceResult - Class in ds.granules.naadsm.staticsplit.event
TRACE_RESULT message
TraceResult() - Constructor for class ds.granules.naadsm.staticsplit.event.TraceResult
 
train(String) - Method in class ds.granules.naadsm.ml.NeuralPredictor
Use input file to train the neural network.
train(String) - Method in interface ds.granules.naadsm.ml.Predictor
 

U

unloadClass() - Method in interface ds.granules.scheduler.LibraryManager
 
unloadJarLibrary() - Method in interface ds.granules.scheduler.LibraryManager
 
unloadLibrary() - Method in interface ds.granules.scheduler.Controller
 
unloadNativeLibraries() - Method in interface ds.granules.scheduler.LibraryManager
 
unmarshall(byte[]) - Method in class ds.granules.operation.MapReduceBase
 
unmarshall(byte[]) - Method in interface ds.granules.operation.Operation
Unmarshall the operation from a set of marshalled bytes.
unmarshall(byte[]) - Method in class ds.granules.operation.OperationBase
 
unmarshallExchangeSpecificElements(byte[]) - Method in class ds.granules.exchange.DeploymentMessage
 
unmarshallExchangeSpecificElements(byte[]) - Method in class ds.granules.exchange.Exchange
This method is utilized by the derived classes to reconstruct elements that are specific to the derived class.
unmarshallExchangeSpecificElements(byte[]) - Method in class ds.granules.exchange.ExecutionStatus
 
unmarshallExchangeSpecificElements(byte[]) - Method in class ds.granules.exchange.ResourceDiscovery
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.AttemptToInfect
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.Checkpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.DestructionEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.Detection
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.EndOfSimulationEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.EventType
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.ExposureEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.PublicAnnouncementEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.QuarantineEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForFTCheckpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForVaccination
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestForZoneFocus
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.RequestOfDestruction
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.Restore
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.StartNewDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.TraceResult
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.Vaccination
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicmerge.event.VaccinationCanceled
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.AttemptToInfect
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.DestructionEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.EndOfSimulationEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.EventType
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.ExposureEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.PublicAnnouncementEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.QuarantineEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.RequestForZoneFocus
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.RequestOfDestruction
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.Restore
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.StartNewDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.dynamicsplit.event.TraceResult
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.AttemptToInfect
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.Checkpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.DestructionEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.EndOfDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.EndOfSimulationEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.EventType
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.ExposureEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.PublicAnnouncementEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.QuarantineEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.RequestForZoneFocus
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.RequestOfDestruction
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.Restore
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.SplitEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.StartNewDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.event.TraceResult
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.AttemptToInfect
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Checkpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.DestructionEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Detection
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EndOfSimulationEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.ExposureEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.PublicAnnouncementEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.QuarantineEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForFTCheckpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForVaccination
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestForZoneFocus
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.RequestOfDestruction
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Restore
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.StartNewDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.TraceResult
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.Vaccination
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.portionaldynamicmerge.event.VaccinationCanceled
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.AttemptToInfect
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.Checkpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.DestructionEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.Detection
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.EndOfDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.EndOfSimulationEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.EventType
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.ExposureEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.MultiRestore
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.OutputVariableValue
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.PublicAnnouncementEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.QuarantineEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.RequestForFTCheckpoint
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.RequestForVaccination
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.RequestForZoneFocus
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.RequestOfDestruction
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.Restore
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.SplitByDensity
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.SplitEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.StartNewDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.TraceResult
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.Vaccination
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.resplit.event.VaccinationCanceled
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.AttemptToInfect
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.DestructionEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.EndOfDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.EndOfSimulationEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.EventType
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.ExposureEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.PublicAnnouncementEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.QuarantineEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.RequestForZoneFocus
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.RequestOfDestruction
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.SplitEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.StartNewDayEvent
 
unmarshalling(byte[]) - Method in class ds.granules.naadsm.staticsplit.event.TraceResult
 
unsubscribe() - Method in class ds.granules.samples.bridge.LoadGenerator
 
unsubscribe() - Method in class ds.granules.samples.flip.LoadGenerator
 
unsubscribe() - Method in class ds.granules.samples.pythonColl.PyLoadGen
 
unsubscribe() - Method in class ds.granules.samples.pythonColl.PyLoadGenRep
 
up - Variable in class ds.granules.naadsm.dynamicsplit.event.Checkpoint
 
up - Variable in class ds.granules.naadsm.dynamicsplit.event.Restore
 
up - Variable in class ds.granules.naadsm.event.Checkpoint
 
up - Variable in class ds.granules.naadsm.event.Restore
 
updateTaskExecutionStatus(String, String, TaskLifecycleMetrics, String) - Method in class ds.granules.operation.ProgressTrackerWidget
Updates the task execution status associated with a given task.
UPIPES - Static variable in interface ds.granules.bridge.ControlMessage
 
upperBound - Variable in class ds.granules.naadsm.dynamicmerge.WorkerNode
 

V

VACCINATION - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
Vaccination - Class in ds.granules.naadsm.dynamicmerge.event
REQUEST_OF_DESTRUCTION message
Vaccination() - Constructor for class ds.granules.naadsm.dynamicmerge.event.Vaccination
 
VACCINATION - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
Vaccination - Class in ds.granules.naadsm.portionaldynamicmerge.event
REQUEST_OF_DESTRUCTION message
Vaccination() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.Vaccination
 
VACCINATION - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
Vaccination - Class in ds.granules.naadsm.resplit.event
REQUEST_OF_DESTRUCTION message
Vaccination() - Constructor for class ds.granules.naadsm.resplit.event.Vaccination
 
VACCINATION_CANCELED - Static variable in class ds.granules.naadsm.dynamicmerge.event.EventType
 
VACCINATION_CANCELED - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.EventType
 
VACCINATION_CANCELED - Static variable in class ds.granules.naadsm.resplit.event.EventType
 
VaccinationCanceled - Class in ds.granules.naadsm.dynamicmerge.event
REQUEST_OF_DESTRUCTION message
VaccinationCanceled() - Constructor for class ds.granules.naadsm.dynamicmerge.event.VaccinationCanceled
 
VaccinationCanceled - Class in ds.granules.naadsm.portionaldynamicmerge.event
REQUEST_OF_DESTRUCTION message
VaccinationCanceled() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.event.VaccinationCanceled
 
VaccinationCanceled - Class in ds.granules.naadsm.resplit.event
REQUEST_OF_DESTRUCTION message
VaccinationCanceled() - Constructor for class ds.granules.naadsm.resplit.event.VaccinationCanceled
 
VAR_NUM - Static variable in class ds.granules.naadsm.dynamicmerge.event.OutputVariableValue
 
VAR_NUM - Static variable in class ds.granules.naadsm.portionaldynamicmerge.event.OutputVariableValue
 
VAR_NUM - Static variable in class ds.granules.naadsm.resplit.event.OutputVariableValue
 
Version - Class in ds.granules.util
This class is a utility class for identifying the version of the GRANULES system.
Version() - Constructor for class ds.granules.util.Version
 

W

WAITING_FOR_DATA - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
WordCountDeployer - Class in ds.granules.samples.wordcount
The deployer for the WORD Count information retrieval example, which allows one to histogram words from given set of files over a distributed set of resources.
WordCountDeployer(Properties) - Constructor for class ds.granules.samples.wordcount.WordCountDeployer
Initializes the deployer.
WordCountMap - Class in ds.granules.samples.wordcount
An example demonstrating the Map role within a Word Count operation.
WordCountMap() - Constructor for class ds.granules.samples.wordcount.WordCountMap
 
WordCountReduce - Class in ds.granules.samples.wordcount
An example demonstrating the Reduce role within a Word Count operation.
WordCountReduce() - Constructor for class ds.granules.samples.wordcount.WordCountReduce
 
Worker - Class in ds.granules.naadsm.dynamicmerge
This is the worker for distributed NAADSM.
Worker() - Constructor for class ds.granules.naadsm.dynamicmerge.Worker
Constructor.
Worker - Class in ds.granules.naadsm.dynamicsplit
This is the worker for distributed NAADSM.
Worker() - Constructor for class ds.granules.naadsm.dynamicsplit.Worker
Constructor.
Worker - Class in ds.granules.naadsm.portionaldynamicmerge
This is the worker for distributed NAADSM.
Worker() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.Worker
Constructor.
Worker - Class in ds.granules.naadsm.resplit
This is the worker for distributed NAADSM.
Worker() - Constructor for class ds.granules.naadsm.resplit.Worker
Constructor.
Worker - Class in ds.granules.naadsm.staticsplit
This is the worker for distributed NAADSM.
Worker() - Constructor for class ds.granules.naadsm.staticsplit.Worker
Constructor.
Worker - Class in ds.granules.naadsm
 
Worker() - Constructor for class ds.granules.naadsm.Worker
 
worker_ID - Variable in class ds.granules.naadsm.dynamicmerge.event.SplitEvent
 
worker_ID - Variable in class ds.granules.naadsm.dynamicsplit.event.Restore
 
worker_ID - Variable in class ds.granules.naadsm.dynamicsplit.event.SplitEvent
 
worker_ID - Variable in class ds.granules.naadsm.event.Restore
 
worker_ID - Variable in class ds.granules.naadsm.event.SplitEvent
 
worker_ID - Variable in class ds.granules.naadsm.portionaldynamicmerge.event.SplitByDensity
 
worker_ID - Variable in class ds.granules.naadsm.portionaldynamicmerge.event.SplitEvent
 
worker_ID - Variable in class ds.granules.naadsm.resplit.event.MultiSplitByDensity
 
worker_ID - Variable in class ds.granules.naadsm.resplit.event.SplitByDensity
 
worker_ID - Variable in class ds.granules.naadsm.resplit.event.SplitEvent
 
WorkerInfo - Class in ds.granules.naadsm.ft
Tracks various Worker instances in a distributed NAADSM run for fault tolerance purposes.
WorkerInfo(int) - Constructor for class ds.granules.naadsm.ft.WorkerInfo
 
WorkerList - Class in ds.granules.naadsm.dynamicmerge
This class maintains a list of workers, their attributes and corresponding functions.
WorkerList(int) - Constructor for class ds.granules.naadsm.dynamicmerge.WorkerList
 
WorkerList() - Constructor for class ds.granules.naadsm.dynamicmerge.WorkerList
 
WorkerList - Class in ds.granules.naadsm.portionaldynamicmerge
This class maintains a list of workers, their attributes and corresponding functions.
WorkerList(int) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.WorkerList
 
WorkerList() - Constructor for class ds.granules.naadsm.portionaldynamicmerge.WorkerList
 
WorkerNode - Class in ds.granules.naadsm.dynamicmerge
This class maintains information about a worker, its attributes and corresponding functions.
WorkerNode(int) - Constructor for class ds.granules.naadsm.dynamicmerge.WorkerNode
 
WorkerNode - Class in ds.granules.naadsm.portionaldynamicmerge
This class maintains information about a worker, its attributes and corresponding functions.
WorkerNode(int) - Constructor for class ds.granules.naadsm.portionaldynamicmerge.WorkerNode
 
write(String, ByteBuffer) - Method in interface ds.granules.dataset.FileAccess
Write the specified Buffer to the file corresponding to the specified file.
write(String, byte[]) - Method in interface ds.granules.dataset.FileAccess
Writes a byte[] to a give file.
write(String, byte[]) - Method in class ds.granules.dataset.FileDataset
 
write(String, ByteBuffer) - Method in class ds.granules.dataset.FileDataset
 
writeIntMatrixColumn(int, int[]) - Method in class ds.granules.util.Matrix
Write a column of the matrix to the underlying file.
writeIntMatrixColumn(int, int[]) - Method in class ds.granules.util.MatrixColumnMajor
 
writeIntMatrixElement(int, int, int) - Method in class ds.granules.util.Matrix
Write a specific matrix element code>[rowId, columnId] to the file.
writeIntMatrixElement(int, int, int) - Method in class ds.granules.util.MatrixColumnMajor
 
writeIntMatrixRow(int, int[]) - Method in class ds.granules.util.Matrix
Write a row of the matrix to the underlying file.
writeIntMatrixRow(int, int[]) - Method in class ds.granules.util.MatrixColumnMajor
 
writeLongMatrixColumn(int, long[]) - Method in class ds.granules.util.Matrix
Write a column of the matrix to the underlying file.
writeLongMatrixColumn(int, long[]) - Method in class ds.granules.util.MatrixColumnMajor
 
writeLongMatrixElement(int, int, long) - Method in class ds.granules.util.Matrix
Write a specific matrix element code>[rowId, columnId] to the file.
writeLongMatrixElement(int, int, long) - Method in class ds.granules.util.MatrixColumnMajor
 
writeLongMatrixRow(int, long[]) - Method in class ds.granules.util.Matrix
Write a row of the matrix to the underlying file.
writeLongMatrixRow(int, long[]) - Method in class ds.granules.util.MatrixColumnMajor
 
writeMapToFile(String) - Method in class ds.granules.naadsm.portionaldynamicmerge.DayList
Write the list into a file
writeProperties(DataOutputStream, Properties) - Method in class ds.granules.util.MarshallingUtil
Writes a java.util.Properties object to the underlying DataOutputStream
writeResults(Results) - Method in interface ds.granules.operation.MapReduce
Writes the specified results to the default output stream.
writeResults(String, Results) - Method in interface ds.granules.operation.MapReduce
Writes the specified results to a specific output stream.
writeResults(int, String, Results) - Method in interface ds.granules.operation.MapReduce
Writes the specified results to a specific output stream.
writeResults(Results) - Method in class ds.granules.operation.MapReduceBase
 
writeResults(String, Results) - Method in class ds.granules.operation.MapReduceBase
 
writeResults(int, String, Results) - Method in class ds.granules.operation.MapReduceBase
 
writeStreamingData(NBEvent) - Method in class ds.granules.dataset.StreamDataset
 
writeStreamingData(Object, byte[]) - Method in class ds.granules.dataset.StreamDataset
 
writeStreamingData(int, Object, byte[]) - Method in class ds.granules.dataset.StreamDataset
 
writeStreamingData(NBEvent) - Method in interface ds.granules.dataset.StreamingAccess
This method writes data to the output dataset.
writeStreamingData(Object, byte[]) - Method in interface ds.granules.dataset.StreamingAccess
This method writes data to the output dataset.
writeStreamingData(int, Object, byte[]) - Method in interface ds.granules.dataset.StreamingAccess
This method writes data to the output dataset.
writeString(DataOutputStream, String) - Method in class ds.granules.util.MarshallingUtil
Writes a String to the underlying DataOutputStream
writeToStream(String, byte[]) - Method in class ds.granules.scheduler.StreamingService
Writes a byte[] payload onto the specified stream
writeToStream(String, int, byte[]) - Method in class ds.granules.scheduler.StreamingService
Writes a byte[] payload onto the specified stream
A B C D E F G H I J K L M N O P Q R S T U V W