JavaScript is disabled on your browser.
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Hierarchy For All Packages
Package Hierarchies:
ds.granules
,
ds.granules.communication
,
ds.granules.communication.direct
,
ds.granules.communication.direct.netty.client
,
ds.granules.communication.direct.netty.server
,
ds.granules.communication.direct.nio.client
,
ds.granules.communication.direct.nio.server
,
ds.granules.communication.direct.util
,
ds.granules.communication.funnel
,
ds.granules.dataset
,
ds.granules.exception
,
ds.granules.exchange
,
ds.granules.operation
,
ds.granules.results
,
ds.granules.scheduler
,
ds.granules.streaming.core
,
ds.granules.streaming.core.datatype
,
ds.granules.streaming.core.exception
,
ds.granules.streaming.core.partition
,
ds.granules.streaming.core.partition.scheme
,
ds.granules.util
Class Hierarchy
java.lang.
Object
ds.granules.communication.direct.nio.server.
ChannelAcceptor
(implements java.lang.
Runnable
)
io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
io.netty.handler.codec.ByteToMessageDecoder
ds.granules.communication.direct.netty.server.
MessageReceiver
io.netty.channel.SimpleChannelInboundHandler<I>
ds.granules.communication.direct.netty.server.
ServerHandler
io.netty.channel.ChannelOutboundHandlerAdapter (implements io.netty.channel.ChannelOutboundHandler)
io.netty.handler.codec.MessageToByteEncoder<I>
ds.granules.communication.direct.netty.client.
DataLengthEncoder
ds.granules.communication.direct.nio.server.
ChannelReaderDataHolder
ds.granules.communication.direct.
ChannelToStreamDeMultiplexer
ds.granules.communication.direct.
ChannelWriterCache
ds.granules.communication.direct.nio.client.
ChannelWriterDataHolder
(implements ds.granules.communication.direct.
ChannelWriter
)
ds.granules.util.
Checksum
ds.granules.communication.
CommFrameworkLauncherFactory
ds.granules.util.
Constants
ds.granules.util.
Constants.PartitionSchemes
ds.granules.dataset.
DatasetCollectionManagement
(implements ds.granules.dataset.
DataAvailabilityObserver
, ds.granules.dataset.
DatasetCollection
)
ds.granules.dataset.
DatasetFactory
ds.granules.dataset.
DatasetNotifier
(implements ds.granules.dataset.
DataAvailabilityNotifier
)
ds.granules.scheduler.
Diagnostics
ds.granules.communication.direct.
DirectCommFrameworkLauncher
(implements ds.granules.communication.
CommFrameworkLauncher
)
ds.granules.communication.direct.netty.server.
NettyServerLauncher
ds.granules.communication.direct.nio.server.
NIOServerLauncher
ds.granules.communication.direct.
DirectCommStreamDatasetImpl
(implements ds.granules.dataset.
StreamDataset
)
ds.granules.exchange.
Exchange
ds.granules.exchange.
DeploymentMessage
ds.granules.exchange.
ExecutionStatus
ds.granules.exchange.
ResourceDiscovery
ds.granules.exchange.
ExchangeFactory
ds.granules.scheduler.
ExchangeProcessor
ds.granules.scheduler.
ExecutableTask
(implements ds.granules.dataset.
DatasetCollectionObserver
, java.lang.
Runnable
)
ds.granules.operation.
ExecutionProfileSetup
(implements ds.granules.operation.
ExecutionProfile
)
ds.granules.streaming.core.partition.scheme.
FieldPartitioner
(implements ds.granules.streaming.core.partition.
Partitioner
)
ds.granules.dataset.
FileDatasetImpl
(implements ds.granules.dataset.
FileDataset
)
ds.granules.dataset.
FileDatasetImplLegacy
(implements ds.granules.dataset.
FileAccess
)
ds.granules.communication.funnel.
FunnelLauncher
(implements ds.granules.communication.
CommFrameworkLauncher
)
ds.granules.communication.funnel.
FunnelStreamDatasetImpl
(implements ds.granules.dataset.
StreamDataset
)
ds.granules.
Granules
ds.granules.util.
GranulesStaticConfig
ds.granules.operation.
InstanceDeployer
(implements ds.granules.operation.
Deployer
, ds.granules.operation.
JobLifecycleObserver
)
ds.granules.communication.direct.nio.client.
IOReactor
(implements java.lang.
Runnable
)
ds.granules.communication.direct.nio.server.
IOReactor
(implements java.lang.
Runnable
)
ds.granules.streaming.core.
Job
ds.granules.communication.direct.
JobDeployer
(implements ds.granules.operation.
Deployer
)
ds.granules.operation.
JobSubmission
ds.granules.util.
MarshallingUtil
ds.granules.util.
Matrix
ds.granules.util.
MatrixColumnMajor
ds.granules.util.
MatrixFactory
ds.granules.util.
MD5Checksum
ds.granules.communication.direct.netty.client.
NettyChannelConnector
(implements ds.granules.communication.direct.
ChannelConnector
)
ds.granules.communication.direct.netty.client.
NettyChannelWriter
(implements ds.granules.communication.direct.
ChannelWriter
)
ds.granules.communication.direct.nio.client.
NIOChannelConnector
(implements ds.granules.communication.direct.
ChannelConnector
, java.lang.
Runnable
)
ds.granules.communication.direct.
NIOTopicDataEvent
(implements ds.funnel.topic.TopicDataEvent)
ds.granules.operation.
OperationBase
(implements ds.granules.operation.
Operation
, ds.granules.operation.
OperationConfiguration
)
ds.granules.operation.
MapReduceBase
(implements ds.granules.operation.
Map
, ds.granules.operation.
Reduce
)
ds.granules.streaming.core.
StreamBase
ds.granules.streaming.core.
StreamProcessor
ds.granules.streaming.core.
StreamSource
ds.granules.util.
ParamsReader
ds.granules.streaming.core.partition.
PartitionerFactory
ds.granules.operation.
ProgressTrackerWidget
(implements ds.granules.operation.
ProgressTracker
)
ds.granules.scheduler.
Resource
ds.granules.scheduler.
ResourceMetrics
ds.granules.results.
ResultPayload
ds.granules.results.
ResultsFactory
ds.granules.results.
ResultsWidget
(implements ds.granules.results.
Results
)
ds.granules.streaming.core.partition.scheme.
SendToAllPartitioner
(implements ds.granules.streaming.core.partition.
Partitioner
)
ds.granules.streaming.core.partition.scheme.
SendToOnePartitioner
(implements ds.granules.streaming.core.partition.
Partitioner
)
ds.granules.streaming.core.partition.scheme.
SendToRandomPartitioner
(implements ds.granules.streaming.core.partition.
Partitioner
)
ds.granules.results.
SequencingWidget
(implements ds.granules.results.
SequencingInfo
)
ds.granules.communication.direct.util.
StatCollector
ds.granules.dataset.
StreamDatasetImplLegacy
(implements ds.granules.dataset.
StreamingAccess
)
ds.granules.dataset.
StreamEvent
ds.granules.streaming.core.datatype.
AbstractStreamEvent
ds.granules.streaming.core.datatype.
StreamingString
ds.granules.scheduler.
StreamingService
ds.granules.util.
StreamPublisher
ds.granules.streaming.core.
StreamUtil
ds.granules.util.
SystemCommand
ds.granules.exchange.
TaskLifecycleMetricsReader
(implements ds.granules.scheduler.
TaskLifecycleMetrics
)
ds.granules.scheduler.
TaskManagement
(implements java.util.concurrent.
RejectedExecutionHandler
, ds.granules.scheduler.
TaskLifecycleObserver
)
java.lang.
Throwable
(implements java.io.
Serializable
)
java.lang.
Exception
ds.granules.exception.
CommunicationsException
ds.granules.dataset.
DatasetException
ds.granules.exception.
DeploymentException
ds.granules.exception.
DirectivesException
ds.granules.exception.
GranulesConfigurationException
ds.granules.scheduler.
LibraryException
ds.granules.operation.
MapReduceException
ds.granules.exception.
MarshallingException
ds.granules.operation.
ProcessingException
java.lang.
RuntimeException
ds.granules.results.
IllegalModificationException
ds.granules.scheduler.
SchedulingException
ds.granules.streaming.core.exception.
StreamingDatasetException
ds.granules.streaming.core.exception.
StreamingGraphConfigurationException
ds.granules.scheduler.
SuppressedException
ds.granules.util.
UUIDRetriever
ds.granules.util.
Version
ds.granules.communication.direct.
ZooKeeperAgent
(implements org.apache.zookeeper.Watcher)
ds.granules.util.
ZooKeeperUtils
Interface Hierarchy
ds.granules.communication.direct.
ChannelConnector
ds.granules.communication.direct.
ChannelReaderCallback
ds.granules.communication.direct.
ChannelWriter
ds.granules.communication.
CommFrameworkLauncher
ds.granules.exchange.
ConditionFlag
ds.granules.scheduler.
Controller
ds.granules.dataset.
DataAvailabilityNotifier
ds.granules.dataset.
DataAvailabilityObserver
ds.granules.dataset.
DatasetCollectionObserver
ds.granules.operation.
Deployer
ds.granules.exchange.
ExchangeType
ds.granules.operation.
ExecutionProfile
ds.funnel.data.format.FormatMarshaller
ds.granules.dataset.
Dataset
ds.granules.dataset.
FileAccess
ds.granules.dataset.
FileDataset
ds.granules.dataset.
StreamDataset
ds.granules.dataset.
StreamingAccess
ds.granules.dataset.
DatasetCollection
ds.granules.dataset.
FileAccess
ds.granules.dataset.
FileDataset
ds.granules.operation.
Map
ds.granules.operation.
MapReduce
ds.granules.operation.
Map
ds.granules.operation.
Reduce
ds.granules.operation.
Operation
ds.granules.operation.
Map
ds.granules.operation.
MapReduce
ds.granules.operation.
Map
ds.granules.operation.
Reduce
ds.granules.operation.
Reduce
ds.granules.operation.
Reduce
ds.granules.results.
Results
ds.granules.results.
SequencingInfo
ds.granules.dataset.
StreamDataset
ds.granules.dataset.
StreamingAccess
ds.granules.operation.
JobLifecycleObserver
ds.granules.scheduler.
LibraryManager
ds.granules.operation.
OperationConfiguration
ds.granules.streaming.core.partition.
Partitioner
ds.granules.operation.
ProgressTracker
ds.granules.scheduler.
ResourceProfile
ds.granules.scheduler.
TaskLifecycleMetrics
ds.granules.scheduler.
TaskLifecycleObserver
Enum Hierarchy
java.lang.
Object
java.lang.
Enum
<E> (implements java.lang.
Comparable
<T>, java.io.
Serializable
)
ds.granules.dataset.
Dataset.DatasetType
(implements ds.funnel.data.format.FormatUnmarshaller<T>)
ds.granules.operation.
Operation.OperationType
(implements ds.funnel.data.format.FormatUnmarshaller<T>)
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2015. All rights reserved.