- 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
-
- ACK - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- addBaseComponent(ComponentSpecification) - Method in class ds.funnel.traffic.factory.ComplexComponentSpecification
-
Adds the provided component specification to the list of base components
for this complex component specification, at the end of the list.
- addComponentParameter(String) - Method in class ds.funnel.traffic.factory.ComponentSpecification
-
Adds the given parameter to the list of parameters stored in this
specification, at the end of the list.
- 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.
- addEdge(GraphNode) - Method in class ds.funnel.overlay.graph.GraphNode
-
- addFile(String, String) - Method in interface ds.granules.dataset.FileAccess
-
Deprecated.
Adds a file with the specified permission "r", "w" or "rw" to this
dataset.
- addFile(String, String) - Method in interface ds.granules.dataset.FileDataset
-
Adds a file with the specified permission "r", "w" or "rw" to this
dataset.
- addFile(String, String) - Method in class ds.granules.dataset.FileDatasetImpl
-
- addFile(String, String) - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- addInputStream(Topic) - Method in interface ds.granules.dataset.StreamDataset
-
Add an input stream to this dataset.
- addInputStream(Topic) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- addInputStream(String, int) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- addInputStream(String, int) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
Add an input stream to this dataset.
- addInputStreams(Collection<Topic>) - Method in interface ds.granules.dataset.StreamDataset
-
Adds a set of input streams to this dataset.
- addInputStreams(Collection<Topic>) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- addInputStreams(ConcurrentHashMap<String, Integer>) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- addInputStreams(ConcurrentHashMap<String, Integer>) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
Adds a set of input streams to this dataset.
- addJobMonitor(GIComputation) - Method in class ds.granules.interfere.resource.component.GIResourceMonitor
-
- addLoggingHandler(Handler) - Static method in class ds.funnel.traffic.TrafficGenerator
-
Adds a log Handler to receive packet transmission log records from all
TrafficGenerators.
- 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.
- addNode(Object) - Method in class ds.funnel.overlay.graph.Graph
-
- addOutputStream(Topic) - Method in interface ds.granules.dataset.StreamDataset
-
Add an output stream to this dataset.
- addOutputStream(Topic) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- addOutputStream(String, int) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- addOutputStream(String, int) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
Add an output stream to this dataset.
- addOutputStreams(Collection<Topic>) - Method in interface ds.granules.dataset.StreamDataset
-
Adds a set of output streams to this dataset.
- addOutputStreams(Collection<Topic>) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- addOutputStreams(ConcurrentHashMap<String, Integer>) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- addOutputStreams(ConcurrentHashMap<String, Integer>) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
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
-
- addStream(String, String, String, int) - Method in class ds.granules.interfere.computation.ComputationDescription
-
- addTask() - Method in interface ds.granules.scheduler.Controller
-
- addUtilizer(PeerGroupUtilizer) - Method in interface ds.funnel.peer.PeerGroup
-
Register a utilizer with this group.
- addUtilizer(PeerGroupUtilizer) - Method in class ds.funnel.peer.PeerGroupImpl
-
- advance(int) - Method in interface ds.funnel.data.buffer.StreamBuffer
-
Adjust the position by a relative amount.
- advance(int) - Method in class ds.funnel.data.buffer.StreamBufferArrayImpl
-
- advance(int) - Method in class ds.funnel.data.buffer.StreamBufferImpl
-
- advanceRing(long) - Method in class ds.granules.interfere.prediction.UsageFutureRing
-
- ADVERT_SECONDS - Static variable in class ds.funnel.peer.PeerManagerImpl
-
- ADVERTISEMENT - Static variable in interface ds.granules.exchange.ExchangeType
-
- advertTopic - Variable in class ds.funnel.peer.event.MsgTopicAdvert
-
- allocBuffer(int) - Method in interface ds.funnel.data.buffer.BufferPool
-
Returns an empty buffer with at least minSize capacity.
- allocBuffer(int) - Method in class ds.funnel.data.buffer.BufferPoolChunk
-
- allocBuffer(int) - Method in class ds.funnel.data.buffer.BufferPoolImpl
-
- allocBuffer(int) - Method in class ds.funnel.data.buffer.BufferPoolStriped
-
- allocBufferChunk() - Method in interface ds.funnel.data.buffer.BufferPool
-
Returns an empty buffer with chunkSize capacity.
- allocBufferChunk() - Method in class ds.funnel.data.buffer.BufferPoolChunk
-
- allocBufferChunk() - Method in class ds.funnel.data.buffer.BufferPoolImpl
-
- allocBufferChunk() - Method in class ds.funnel.data.buffer.BufferPoolStriped
-
- allowInst - Static variable in class ds.granules.Granules
-
- appendData(byte[]) - Method in interface ds.synapse.files.FileAccess
-
- appendData(byte[]) - Method in class ds.synapse.files.sdht.DHTFileAccess
-
- appendNode(GraphNode) - Method in interface ds.funnel.overlay.graph.GraphBuilder
-
- appendNode(GraphNode) - Method in class ds.funnel.overlay.topology.PowerLaw
-
- appendNode(GraphNode) - Method in class ds.funnel.overlay.topology.SmallWorld
-
- appendNode(GraphNode) - Method in class ds.funnel.overlay.topology.WeightedTree
-
- appendOverlay(NodeDetails) - Method in class ds.funnel.peer.PeerGroupOverlay
-
- async - Variable in class ds.synapse.files.sdht.MsgFileGet
-
- AttrKey(String) - Constructor for class ds.funnel.overlay.graph.GraphAttributes.AttrKey
-
- AUTOSTART - Static variable in class ds.funnel.node.task.Task
-
- 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.
- avgPathLength() - Method in class ds.funnel.overlay.graph.Graph
-
- await(int) - Method in class ds.funnel.node.event.EventLimiter
-
- awaitShutdown(long) - Method in class ds.funnel.node.task.SuperThreadPool
-