- ECG - Static variable in class ds.funnel.traffic.component.types.PacketGeneratorType
-
- ECG - Static variable in class ds.funnel.traffic.component.types.TimeDistributionType
-
- ECGCompFactory - Class in ds.granules.interfere.computation.ecg
-
- ECGCompFactory(GIPlacementNode) - Constructor for class ds.granules.interfere.computation.ecg.ECGCompFactory
-
- ECGCompManager - Class in ds.granules.interfere.computation.ecg
-
- ECGCompManager(GIPlacementNode, int, int, int) - Constructor for class ds.granules.interfere.computation.ecg.ECGCompManager
-
- ECGDeployer - Class in ds.granules.interfere.computation.ecg
-
- ECGDeployer() - Constructor for class ds.granules.interfere.computation.ecg.ECGDeployer
-
- ECGDeployer(Properties) - Constructor for class ds.granules.interfere.computation.ecg.ECGDeployer
-
Initializes the deployer.
- ECGMonitor - Class in ds.granules.interfere.computation.ecg
-
- ECGMonitor() - Constructor for class ds.granules.interfere.computation.ecg.ECGMonitor
-
- ECGPacketGenerator - Class in ds.funnel.traffic.component.packetgenerator
-
A packet generator which generates ECG readings based upon data read from a
file.
- ECGPacketGenerator(String) - Constructor for class ds.funnel.traffic.component.packetgenerator.ECGPacketGenerator
-
Creates a new ECGPacketGenerator which will use data from the provided
file to generate packets.
- ECGTimeDistribution - Class in ds.funnel.traffic.component.timedistribution
-
Defines a time distribution in which packets are sent at regular 1 second
intervals.
- ECGTimeDistribution() - Constructor for class ds.funnel.traffic.component.timedistribution.ECGTimeDistribution
-
- EEG - Static variable in class ds.funnel.traffic.component.types.PacketGeneratorType
-
- EEG - Static variable in class ds.funnel.traffic.component.types.TimeDistributionType
-
- EEGCompFactory - Class in ds.granules.interfere.computation.eeg
-
- EEGCompFactory(GIPlacementNode) - Constructor for class ds.granules.interfere.computation.eeg.EEGCompFactory
-
- EEGCompManager - Class in ds.granules.interfere.computation.eeg
-
- EEGCompManager(GIPlacementNode, int, int, int) - Constructor for class ds.granules.interfere.computation.eeg.EEGCompManager
-
- EEGDeployer - Class in ds.granules.interfere.computation.eeg
-
First pass at refactoring - need to add stress test specific stuff eventually...
- EEGDeployer() - Constructor for class ds.granules.interfere.computation.eeg.EEGDeployer
-
- EEGDeployer(Properties) - Constructor for class ds.granules.interfere.computation.eeg.EEGDeployer
-
Initializes the deployer.
- EEGMap - Class in ds.granules.interfere.computation.eeg
-
revamped eeg classification in granules
- EEGMap() - Constructor for class ds.granules.interfere.computation.eeg.EEGMap
-
- EEGPacketGenerator - Class in ds.funnel.traffic.component.packetgenerator
-
A packet generator which produces packets containing segments of EEG readings
using data read from provided files.
- EEGPacketGenerator(String, String) - Constructor for class ds.funnel.traffic.component.packetgenerator.EEGPacketGenerator
-
Creates a new EEGPacketGenerator with the given values.
- EEGReduce - Class in ds.granules.interfere.computation.eeg
-
Cleaned version of a reducer to handle streaming EEG data with bridges
- EEGReduce() - Constructor for class ds.granules.interfere.computation.eeg.EEGReduce
-
- EEGTimeDistribution - Class in ds.funnel.traffic.component.timedistribution
-
Defines a time distribution in which packets are sent at regular 250
millisecond intervals.
- EEGTimeDistribution() - Constructor for class ds.funnel.traffic.component.timedistribution.EEGTimeDistribution
-
- EMPTY_PATH - Static variable in interface ds.funnel.overlay.OverlayPath
-
- endTimer(long) - Method in class ds.granules.interfere.computation.StreamTimer
-
- enterMultiCommands() - Static method in class ds.funnel.node.NodeBase
-
- equals(Object) - Method in class cgl.narada.event.EventID
-
Deprecated.
Compares two objects for equality.
- equals(Object) - Method in class ds.funnel.data.channel.tcp.TCPChannelAddr
-
- equals(Object) - Method in class ds.funnel.data.channel.udp.UDPChannelAddr
-
- equals(Object) - Method in class ds.funnel.node.compnt.NodeComponentKey
-
- equals(Object) - Method in class ds.funnel.node.NodeDetailsBase
-
- equals(Object) - Method in class ds.funnel.overlay.OverlayPathImpl
-
- equals(Object) - Method in class ds.funnel.peer.PeerDetailsImpl
-
- equals(Object) - Method in class ds.funnel.topic.StringTopic
-
- equals(Object) - Method in class ds.granules.scheduler.ExecutableTask
-
- errorMsg - Variable in class ds.funnel.data.msglink.event.MsgLinkAssocResp
-
- EVENT - Static variable in interface cgl.narada.event.Protocol
-
Deprecated.
- Event - Interface in ds.funnel.node.event
-
- EventDispatcher - Interface in ds.funnel.node.event
-
- EventDispatcherImpl - Class in ds.funnel.node.event
-
- EventDispatcherImpl() - Constructor for class ds.funnel.node.event.EventDispatcherImpl
-
- EventDispatcherImpl(boolean, String) - Constructor for class ds.funnel.node.event.EventDispatcherImpl
-
- EventDispatcherImpl(boolean, String, EventDispatcher) - Constructor for class ds.funnel.node.event.EventDispatcherImpl
-
- EventDispatchHandler<E extends Event> - Interface in ds.funnel.node.event
-
- EventHandler<E> - Interface in ds.funnel.node.event
-
- EventHeaders - Interface in cgl.narada.event
-
Deprecated.
- EventHeadersImpl - Class in cgl.narada.event
-
Deprecated.
- EventHeadersImpl() - Constructor for class cgl.narada.event.EventHeadersImpl
-
Deprecated.
- EventHeadersImpl(byte[]) - Constructor for class cgl.narada.event.EventHeadersImpl
-
Deprecated.
- EventID - Class in cgl.narada.event
-
Deprecated.
- EventID(byte[]) - Constructor for class cgl.narada.event.EventID
-
Deprecated.
This constructor provides for the unmarshalling of the eventID bytes
that are received over a link
- EventID(int, long, int) - Constructor for class cgl.narada.event.EventID
-
Deprecated.
Constructs a unique EventID based on the entityID, timeStamp,
sequenceNumber and the incarnation associated with the publishing
entity.
- EventIDGenerator - Class in cgl.narada.event
-
Deprecated.
- EventIDGenerator() - Constructor for class cgl.narada.event.EventIDGenerator
-
Deprecated.
- EventLimiter - Class in ds.funnel.node.event
-
- EventLimiter(ReentrantLock) - Constructor for class ds.funnel.node.event.EventLimiter
-
- EventLimiter.QueueSemaphore - Class in ds.funnel.node.event
-
- eventLogFile - Static variable in class ds.granules.interfere.streaming.GIStreamingNode
-
- eventLogPath - Static variable in class ds.granules.interfere.streaming.GIStreamingNode
-
- EventMethod - Annotation Type in ds.funnel.node.event
-
- EventProcessor<E> - Class in ds.funnel.node.event
-
- EventProcessor(EventHandler<? super E>) - Constructor for class ds.funnel.node.event.EventProcessor
-
- EventProperties - Interface in cgl.narada.event
-
Deprecated.
- EventPropertiesImpl - Class in cgl.narada.event
-
Deprecated.
- EventSequencer<E> - Class in ds.funnel.node.event
-
- EventSequencer() - Constructor for class ds.funnel.node.event.EventSequencer
-
- 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.
- ExchangeFactory() - Constructor for class ds.granules.exchange.ExchangeFactory
-
- 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.
- execute() - Method in class ds.granules.interfere.computation.GIComputation
-
- 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.uppercase.UpperCaseMap
-
- execute() - Method in class ds.granules.samples.wordcount.WordCountMap
-
- execute() - Method in class ds.granules.samples.wordcount.WordCountReduce
-
- 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.
- expectedBeginTime() - Method in interface ds.granules.scheduler.ResourceProfile
-
Retrieves the expect starting time for a given task's execution.
- expireSeconds - Variable in class ds.funnel.peer.event.MsgTopicAdvert
-