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

I

IGNORENULL - Static variable in class ds.funnel.node.task.Task
 
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).
info(String) - Method in class ds.funnel.node.FunnelLogger
 
initialize(Graph) - Method in interface ds.funnel.overlay.graph.GraphBuilder
 
initialize(Graph) - Method in class ds.funnel.overlay.topology.PowerLaw
 
initialize(Graph) - Method in class ds.funnel.overlay.topology.SmallWorld
 
initialize(Graph) - Method in class ds.funnel.overlay.topology.WeightedTree
 
INITIALIZE - Static variable in interface ds.granules.bridge.ControlMessage
 
initialize(Properties) - Method in class ds.granules.interfere.computation.GIComputation
 
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.uppercase.UpperCaseMap
 
initialize() - Method in class ds.granules.samples.uppercase.UpperCaseProducer
 
initialize(Properties) - Method in class ds.granules.samples.wordcount.WordCountMap
 
initialize(Properties) - Method in class ds.granules.samples.wordcount.WordCountReduce
 
initialize() - Method in class ds.granules.scheduler.ExchangeProcessor
 
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.FileDatasetImpl
 
initializeDataset() - Method in class ds.granules.dataset.FileDatasetImplLegacy
Deprecated.
 
initializeDataset() - Method in class ds.granules.dataset.StreamDatasetImpl
 
initializeDataset() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
Deprecated.
 
initializeDatasets() - Method in interface ds.granules.dataset.DatasetCollection
Initializes all the constituent datasets in this collection.
initializeDatasets() - Method in class ds.granules.dataset.DatasetCollectionManagement
 
initializeEEGMap(EEGReduce, int) - Method in class ds.granules.interfere.computation.eeg.EEGDeployer
 
initializeFlipMap(int) - Method in class ds.granules.samples.uppercase.UpperCaseDeployer
Initialize a specific FlipMap instance.
initializeRespirationMap(int, int, int, boolean, boolean) - Method in class ds.granules.interfere.computation.ecg.ECGDeployer
Initialize a specific RespirationMap instance.
initializeRespirationMap(int, int, int, boolean, boolean) - Method in class ds.granules.interfere.computation.thorax.RespirationMonitorDeployer
Initialize a specific RespirationMap instance.
INITIALIZING - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
 
insert(boolean) - Method in interface ds.funnel.data.buffer.StreamBuffer
Set the current insert mode.
insert(boolean) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
 
insert(boolean) - Method in class ds.funnel.data.buffer.StreamBufferImpl
 
insertBefore(SynapseDHTDetails) - Method in class ds.synapse.peer.DHTPredecessor
 
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
 
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
 
intArrayToByteArray(int[]) - Method in class cgl.narada.event.ByteUtilities
Deprecated.
 
intArrayToByteArray(int[], int, int) - Static method in class cgl.narada.event.ByteUtilities
Deprecated.
 
INTEGER - Static variable in interface cgl.narada.event.TemplateProfileAndSynopsisTypes
Deprecated.
 
interference(ComputationUsage) - Method in class ds.granules.interfere.computation.ComputationUsage
 
interference(ComputationUsage, boolean) - Method in class ds.granules.interfere.computation.ComputationUsage
 
interference(PredictionRing, int, boolean) - Method in class ds.granules.interfere.prediction.PredictionRing
 
interference(ComputationUsage) - Method in class ds.granules.interfere.prediction.UsageFutureRing
 
interference(ComputationUsage, boolean) - Method in class ds.granules.interfere.prediction.UsageFutureRing
 
InterfereTest - Class in ds.granules.interfere
 
InterfereTest() - Constructor for class ds.granules.interfere.InterfereTest
 
IOTestNode - Class in ds.funnel.samples
 
IOTestNode(String...) - Constructor for class ds.funnel.samples.IOTestNode
 
isActive() - Method in interface ds.funnel.overlay.OverlayVersion
 
isActive() - Method in class ds.funnel.overlay.OverlayVersionImpl
 
isAlive() - Method in interface ds.funnel.data.msglink.MessageLink
 
isAlive() - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
 
isAlive() - Method in class ds.funnel.node.compnt.NodeComponentLinkImpl
 
isAlive() - Method in class ds.funnel.overlay.OverlayLinkImpl
 
isAlive() - Method in class ds.synapse.peer.DHTConnection
Deprecated.
 
isAvailable() - Method in interface ds.funnel.topic.Topic
 
isAvailable() - Method in class ds.funnel.topic.TopicBase
 
isAvailable() - Method in interface ds.granules.dataset.Dataset
A check to see if the dataset is available
isAvailable() - Method in class ds.granules.dataset.FileDatasetImpl
 
isAvailable() - Method in class ds.granules.dataset.FileDatasetImplLegacy
Deprecated.
 
isAvailable() - Method in class ds.granules.dataset.StreamDatasetImpl
 
isAvailable() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
Deprecated.
 
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.
isCancelled() - Method in class ds.funnel.node.task.Task
 
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
 
isClient() - Method in interface ds.funnel.data.msglink.MessageLink
 
isClient() - Method in class ds.funnel.data.msglink.protocol3.MessageProtocol
 
isClient - Variable in class ds.funnel.node.compnt.NodeComponentLinkImpl.OpenedComponentLink
 
isClient() - Method in class ds.funnel.overlay.OverlayLinkImpl
 
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 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
 
isCompressed() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if the payload has been compressed.
isCompressed() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if the payload has been compressed.
isCoord - Variable in class ds.funnel.peer.event.MsgTopicNeighbor
 
isCoord() - Method in interface ds.funnel.peer.PeerDetails
 
isCoord() - Method in class ds.funnel.peer.PeerDetailsImpl
 
isCoordSuccessor() - Method in interface ds.funnel.peer.PeerDetails
 
isCoordSuccessor() - Method in class ds.funnel.peer.PeerDetailsImpl
 
isCorrelated() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if this event is correlated with any other event.
isCorrelated() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if this event is correlated with any other event.
isCurrent() - Method in interface ds.funnel.overlay.OverlayVersion
 
isCurrent() - Method in class ds.funnel.overlay.OverlayVersionImpl
 
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.FileDatasetImpl
 
isDataAvailable() - Method in class ds.granules.dataset.FileDatasetImplLegacy
Deprecated.
 
isDataAvailable() - Method in class ds.granules.dataset.StreamDatasetImpl
 
isDataAvailable() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
Deprecated.
 
isDataOut() - Method in interface ds.funnel.overlay.OverlayLink
 
isDataOut() - Method in class ds.funnel.overlay.OverlayLinkImpl
 
isDropSafe() - Method in class ds.funnel.data.msglink.LinkClosedEvent
 
isDropSafe() - Method in interface ds.funnel.data.msglink.MessageEvent
 
isDropSafe() - Method in class ds.funnel.data.msglink.protocol3.MessageBase
 
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
 
isExisting() - Method in interface ds.synapse.files.FileAccess
 
isExisting() - Method in class ds.synapse.files.sdht.DHTFileAccess
 
isFragmented() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if this event is a fragment of a larger event
isFragmented() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if this event is a fragment of a larger event
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.FileDatasetImpl
 
isInitialized() - Method in class ds.granules.dataset.FileDatasetImplLegacy
Deprecated.
 
isInitialized() - Method in class ds.granules.dataset.StreamDatasetImpl
 
isInitialized() - Method in class ds.granules.dataset.StreamDatasetImplLegacy
Deprecated.
 
isInitialized() - Method in interface ds.granules.operation.Operation
Check if the operation has been initialized
isInitialized() - Method in class ds.granules.operation.OperationBase
 
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
 
isKnown() - Method in interface ds.funnel.peer.PeerDetails
 
isKnown() - Method in class ds.funnel.peer.PeerDetailsImpl
 
isLastFragment() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if this is the last fragment in the series of fragmented events
isLastFragment() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if this is the last fragment in the series of fragmented events
isLinked(NodeDetails) - Method in interface ds.funnel.overlay.OverlayVersion
Check if a link to another node exists.
isLinked(NodeDetails) - Method in class ds.funnel.overlay.OverlayVersionImpl
 
isLoaded() - Method in interface ds.synapse.files.FileAccess
 
isLoaded() - Method in class ds.synapse.files.sdht.DHTFileAccess
 
isModified() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if the EventHeader has been modified since the last time that it was serialized.
isModified() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
 
isModified() - Method in interface cgl.narada.event.EventProperties
Deprecated.
Indicates if the EventProperties has been modified since the last time that it was serialized.
isModified() - Method in class cgl.narada.event.EventPropertiesImpl
Deprecated.
 
isMsgFiltered(MessageEvent) - Static method in class ds.funnel.node.FunnelLogger
 
isMutable(Object) - Method in interface cgl.narada.event.EventProperties
Deprecated.
Check to see if this is a mutable property.
isMutable(Object) - Method in class cgl.narada.event.EventPropertiesImpl
Deprecated.
Check to see if this is a mutable property.
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
 
isOwner(BigInteger) - Method in class ds.synapse.peer.DHTFingerTable
Checks to see if the key is stored on this node.
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
 
isPartitioned() - Method in class ds.funnel.overlay.graph.Graph
 
isPartOfDataset(String) - Method in interface ds.granules.dataset.FileAccess
Deprecated.
Checks to see if the file is part of a given dataset
isPartOfDataset(String) - Method in class ds.granules.dataset.FileDatasetImplLegacy
Deprecated.
 
isPayloadCompressionFinalStep() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if the payload was compressed after operations such as securing, computing message digests were performed
isPayloadCompressionFinalStep() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if the payload was compressed after operations such as securing, computing message digests were performed
isPersistent() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if the event is a persistent one.
isPersistent() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if the event is a persistent one.
isPrimary() - Method in interface ds.funnel.overlay.OverlayLink
 
isPrimary() - Method in class ds.funnel.overlay.OverlayLinkImpl
 
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
 
isPublishing() - Method in interface ds.funnel.topic.Topic
 
isPublishing() - Method in class ds.funnel.topic.TopicBase
 
isReachable(GraphNode) - Method in class ds.funnel.overlay.graph.GraphNode
 
isReadable() - Method in interface ds.funnel.data.channel.ChannelManager
 
isReadable() - Method in class ds.funnel.data.channel.ChannelManagerImpl
 
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
isRequestDataIn() - Method in interface ds.funnel.overlay.OverlayManager
 
isRequestDataIn() - Method in class ds.funnel.overlay.OverlayManagerImpl
 
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
 
isSecure() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if this event is a secure event
isSecure() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if this event is a secure event
isSelf() - Method in interface ds.funnel.node.NodeDetails
 
isSelf() - Method in class ds.funnel.node.NodeDetailsBase
 
isSelf() - Method in interface ds.funnel.peer.PeerDetails
 
isSelf() - Method in class ds.funnel.peer.PeerDetailsImpl
 
isSliced() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
 
isSliced() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
 
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
 
isSubscribing() - Method in interface ds.funnel.topic.Topic
 
isSubscribing() - Method in class ds.funnel.topic.TopicBase
 
isSuccessful() - Method in interface ds.granules.operation.ProgressTracker
Check to see if the Job completed successfully.
isSuccessful() - Method in class ds.granules.operation.ProgressTrackerWidget
 
isTransient() - Method in interface cgl.narada.event.EventHeaders
Deprecated.
Indicates if this event is a transient event.
isTransient() - Method in class cgl.narada.event.EventHeadersImpl
Deprecated.
Indicates if this event is a transient event.
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.
isWaiting() - Method in class ds.funnel.data.msglink.ReplyStatus
 
isWaitingFor(MessageEvent) - Method in class ds.funnel.data.msglink.ReplyStatus
 
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
 
isWritable() - Method in interface ds.funnel.data.channel.ChannelManager
 
isWritable() - Method in class ds.funnel.data.channel.ChannelManagerImpl
 
A B C D E F G H I J K L M N O P Q R S T U V W X 
Skip navigation links