You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2016/08/12 04:30:45 UTC
[51/51] [partial] incubator-gearpump-site git commit: fix
GEARPUMP-187 update site to 0.8.1
fix GEARPUMP-187 update site to 0.8.1
Author: Kam Kasravi <ka...@yahoo.com>
Closes #4 from kkasravi/GEARPUMP-187.
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/commit/19769c76
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/tree/19769c76
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/diff/19769c76
Branch: refs/heads/asf-site
Commit: 19769c76978d387b5acc07043fdaa6d75ff9a1ab
Parents: b51cfea
Author: Kam Kasravi <ka...@yahoo.com>
Authored: Fri Aug 12 12:29:38 2016 +0800
Committer: manuzhang <ow...@gmail.com>
Committed: Fri Aug 12 12:29:38 2016 +0800
----------------------------------------------------------------------
downloads.md | 8 +-
overview.md | 2 +-
releases/0.8.1/api/java/allclasses-frame.html | 734 ++
releases/0.8.1/api/java/allclasses-noframe.html | 734 ++
releases/0.8.1/api/java/constant-values.html | 277 +
releases/0.8.1/api/java/deprecated-list.html | 122 +
releases/0.8.1/api/java/help-doc.html | 223 +
releases/0.8.1/api/java/index-all.html | 8372 +++++++++++++++++
releases/0.8.1/api/java/index.html | 74 +
.../api/java/org/apache/gearpump/Message.html | 325 +
.../apache/gearpump/cluster/AppDescription.html | 346 +
.../org/apache/gearpump/cluster/AppJar.html | 311 +
.../gearpump/cluster/AppMasterContext.html | 393 +
.../gearpump/cluster/AppMasterRegisterData.html | 169 +
.../AppMasterToMaster.ActivateAppMaster$.html | 306 +
.../AppMasterToMaster.ActivateAppMaster.html | 298 +
.../AppMasterToMaster.AppDataSaved$.html | 302 +
.../AppMasterToMaster.AppMasterSummary.html | 320 +
...MasterToMaster.GeneralAppMasterSummary$.html | 306 +
...pMasterToMaster.GeneralAppMasterSummary.html | 434 +
.../AppMasterToMaster.GetAllWorkers$.html | 302 +
.../cluster/AppMasterToMaster.GetAppData$.html | 306 +
.../cluster/AppMasterToMaster.GetAppData.html | 312 +
.../AppMasterToMaster.GetAppDataResult$.html | 306 +
.../AppMasterToMaster.GetAppDataResult.html | 312 +
.../AppMasterToMaster.GetMasterData$.html | 302 +
.../AppMasterToMaster.GetWorkerData$.html | 306 +
.../AppMasterToMaster.GetWorkerData.html | 297 +
.../AppMasterToMaster.InvalidAppMaster$.html | 306 +
.../AppMasterToMaster.InvalidAppMaster.html | 326 +
.../cluster/AppMasterToMaster.MasterData$.html | 306 +
.../cluster/AppMasterToMaster.MasterData.html | 297 +
.../AppMasterToMaster.RegisterAppMaster$.html | 306 +
.../AppMasterToMaster.RegisterAppMaster.html | 315 +
.../AppMasterToMaster.RequestResource$.html | 306 +
.../AppMasterToMaster.RequestResource.html | 311 +
.../cluster/AppMasterToMaster.SaveAppData$.html | 306 +
.../cluster/AppMasterToMaster.SaveAppData.html | 331 +
.../AppMasterToMaster.SaveAppDataFailed$.html | 302 +
.../cluster/AppMasterToMaster.WorkerData$.html | 306 +
.../cluster/AppMasterToMaster.WorkerData.html | 297 +
.../gearpump/cluster/AppMasterToMaster.html | 387 +
...pMasterToWorker.ChangeExecutorResource$.html | 306 +
...ppMasterToWorker.ChangeExecutorResource.html | 326 +
.../AppMasterToWorker.LaunchExecutor$.html | 306 +
.../AppMasterToWorker.LaunchExecutor.html | 341 +
.../AppMasterToWorker.ShutdownExecutor$.html | 306 +
.../AppMasterToWorker.ShutdownExecutor.html | 326 +
.../gearpump/cluster/AppMasterToWorker.html | 274 +
.../cluster/Application.DefaultApplication.html | 351 +
.../apache/gearpump/cluster/Application.html | 285 +
.../gearpump/cluster/ApplicationMaster.html | 267 +
.../cluster/ClientToMaster.AddMaster$.html | 301 +
.../cluster/ClientToMaster.AddWorker$.html | 306 +
.../cluster/ClientToMaster.AddWorker.html | 296 +
.../cluster/ClientToMaster.CommandResult$.html | 306 +
.../cluster/ClientToMaster.CommandResult.html | 329 +
.../ClientToMaster.GetJarStoreServer$.html | 302 +
.../cluster/ClientToMaster.GetLastFailure$.html | 306 +
.../cluster/ClientToMaster.GetLastFailure.html | 297 +
.../ClientToMaster.GetStallingTasks$.html | 306 +
.../ClientToMaster.GetStallingTasks.html | 299 +
.../ClientToMaster.JarStoreServerAddress$.html | 306 +
.../ClientToMaster.JarStoreServerAddress.html | 297 +
.../ClientToMaster.QueryAppMasterConfig$.html | 306 +
.../ClientToMaster.QueryAppMasterConfig.html | 297 +
.../ClientToMaster.QueryHistoryMetrics$.html | 306 +
.../ClientToMaster.QueryHistoryMetrics.html | 342 +
.../ClientToMaster.QueryMasterConfig$.html | 302 +
.../ClientToMaster.QueryWorkerConfig$.html | 306 +
.../ClientToMaster.QueryWorkerConfig.html | 297 +
.../cluster/ClientToMaster.ReadOption$.html | 367 +
.../cluster/ClientToMaster.RemoveMaster$.html | 306 +
.../cluster/ClientToMaster.RemoveMaster.html | 296 +
.../cluster/ClientToMaster.RemoveWorker$.html | 306 +
.../cluster/ClientToMaster.RemoveWorker.html | 296 +
.../cluster/ClientToMaster.ResolveAppId$.html | 306 +
.../cluster/ClientToMaster.ResolveAppId.html | 297 +
.../ClientToMaster.ResolveWorkerId$.html | 306 +
.../cluster/ClientToMaster.ResolveWorkerId.html | 297 +
.../ClientToMaster.RestartApplication$.html | 306 +
.../ClientToMaster.RestartApplication.html | 296 +
.../ClientToMaster.ShutdownApplication$.html | 306 +
.../ClientToMaster.ShutdownApplication.html | 296 +
.../ClientToMaster.SubmitApplication$.html | 306 +
.../ClientToMaster.SubmitApplication.html | 327 +
.../apache/gearpump/cluster/ClientToMaster.html | 412 +
...ClusterConfig.ConfigValidationException.html | 264 +
.../gearpump/cluster/ClusterConfig.Configs.html | 305 +
.../apache/gearpump/cluster/ClusterConfig.html | 478 +
...terConfigSource.ClusterConfigSourceImpl.html | 301 +
.../gearpump/cluster/ClusterConfigSource.html | 250 +
.../gearpump/cluster/ExecutorContext.html | 368 +
.../gearpump/cluster/ExecutorJVMConfig.html | 394 +
.../MasterToAppMaster.AppMasterActivated$.html | 306 +
.../MasterToAppMaster.AppMasterActivated.html | 297 +
.../MasterToAppMaster.AppMasterData$.html | 306 +
.../MasterToAppMaster.AppMasterData.html | 416 +
...ToAppMaster.AppMasterDataDetailRequest$.html | 306 +
...rToAppMaster.AppMasterDataDetailRequest.html | 296 +
...MasterToAppMaster.AppMasterDataRequest$.html | 306 +
.../MasterToAppMaster.AppMasterDataRequest.html | 311 +
...terToAppMaster.AppMasterMetricsRequest$.html | 306 +
...sterToAppMaster.AppMasterMetricsRequest.html | 296 +
.../MasterToAppMaster.AppMasterRegistered$.html | 306 +
.../MasterToAppMaster.AppMasterRegistered.html | 297 +
.../MasterToAppMaster.AppMastersData$.html | 306 +
.../MasterToAppMaster.AppMastersData.html | 296 +
...asterToAppMaster.AppMastersDataRequest$.html | 301 +
....ReplayFromTimestampWindowTrailingEdge$.html | 306 +
...r.ReplayFromTimestampWindowTrailingEdge.html | 296 +
.../MasterToAppMaster.ResourceAllocated$.html | 306 +
.../MasterToAppMaster.ResourceAllocated.html | 297 +
.../MasterToAppMaster.ShutdownAppMaster$.html | 302 +
.../MasterToAppMaster.StreamingType.html | 173 +
.../cluster/MasterToAppMaster.WorkerList$.html | 306 +
.../cluster/MasterToAppMaster.WorkerList.html | 296 +
.../gearpump/cluster/MasterToAppMaster.html | 423 +
.../MasterToClient.AppMasterConfig$.html | 306 +
.../cluster/MasterToClient.AppMasterConfig.html | 296 +
.../cluster/MasterToClient.HistoryMetrics$.html | 306 +
.../cluster/MasterToClient.HistoryMetrics.html | 319 +
.../MasterToClient.HistoryMetricsItem$.html | 306 +
.../MasterToClient.HistoryMetricsItem.html | 311 +
.../cluster/MasterToClient.LastFailure$.html | 306 +
.../cluster/MasterToClient.LastFailure.html | 312 +
.../cluster/MasterToClient.MasterConfig$.html | 306 +
.../cluster/MasterToClient.MasterConfig.html | 296 +
...MasterToClient.ReplayApplicationResult$.html | 306 +
.../MasterToClient.ReplayApplicationResult.html | 296 +
.../MasterToClient.ResolveAppIdResult$.html | 306 +
.../MasterToClient.ResolveAppIdResult.html | 297 +
.../MasterToClient.ResolveWorkerIdResult$.html | 306 +
.../MasterToClient.ResolveWorkerIdResult.html | 297 +
...sterToClient.ShutdownApplicationResult$.html | 306 +
...asterToClient.ShutdownApplicationResult.html | 296 +
...MasterToClient.SubmitApplicationResult$.html | 306 +
.../MasterToClient.SubmitApplicationResult.html | 297 +
...rToClient.SubmitApplicationResultValue$.html | 306 +
...erToClient.SubmitApplicationResultValue.html | 296 +
.../cluster/MasterToClient.WorkerConfig$.html | 306 +
.../cluster/MasterToClient.WorkerConfig.html | 296 +
.../apache/gearpump/cluster/MasterToClient.html | 356 +
.../org/apache/gearpump/cluster/UserConfig.html | 609 ++
...rkerToAppMaster.ExecutorLaunchRejected$.html | 306 +
...orkerToAppMaster.ExecutorLaunchRejected.html | 311 +
...rkerToAppMaster.ShutdownExecutorFailed$.html | 306 +
...orkerToAppMaster.ShutdownExecutorFailed.html | 311 +
...kerToAppMaster.ShutdownExecutorSucceed$.html | 306 +
...rkerToAppMaster.ShutdownExecutorSucceed.html | 311 +
.../gearpump/cluster/WorkerToAppMaster.html | 274 +
...rRuntimeEnvironment.LazyStartAppMaster$.html | 314 +
...erRuntimeEnvironment.LazyStartAppMaster.html | 359 +
...nment.MasterWithExecutorSystemProvider$.html | 314 +
...onment.MasterWithExecutorSystemProvider.html | 323 +
...asterRuntimeEnvironment.StartAppMaster$.html | 301 +
.../appmaster/AppMasterRuntimeEnvironment.html | 381 +
.../cluster/appmaster/AppMasterRuntimeInfo.html | 398 +
.../cluster/appmaster/ApplicationState.html | 419 +
.../cluster/appmaster/ExecutorSystem.html | 381 +
...torSystemLauncher.LaunchExecutorSystem$.html | 306 +
...utorSystemLauncher.LaunchExecutorSystem.html | 326 +
...mLauncher.LaunchExecutorSystemRejected$.html | 306 +
...emLauncher.LaunchExecutorSystemRejected.html | 326 +
...emLauncher.LaunchExecutorSystemSuccess$.html | 306 +
...temLauncher.LaunchExecutorSystemSuccess.html | 311 +
...emLauncher.LaunchExecutorSystemTimeout$.html | 306 +
...temLauncher.LaunchExecutorSystemTimeout.html | 296 +
.../appmaster/ExecutorSystemLauncher.html | 430 +
...ystemScheduler.ExecutorSystemJvmConfig$.html | 306 +
...SystemScheduler.ExecutorSystemJvmConfig.html | 356 +
...rSystemScheduler.ExecutorSystemStarted$.html | 306 +
...orSystemScheduler.ExecutorSystemStarted.html | 311 +
.../ExecutorSystemScheduler.ResourceAgent.html | 335 +
...mScheduler.ResourceAllocatedForSession$.html | 306 +
...emScheduler.ResourceAllocatedForSession.html | 311 +
...temScheduler.ResourceAllocationTimeOut$.html | 306 +
...stemScheduler.ResourceAllocationTimeOut.html | 296 +
.../ExecutorSystemScheduler.Session$.html | 306 +
.../ExecutorSystemScheduler.Session.html | 313 +
...emScheduler.StartExecutorSystemTimeout$.html | 301 +
...orSystemScheduler.StartExecutorSystems$.html | 306 +
...torSystemScheduler.StartExecutorSystems.html | 311 +
...utorSystemScheduler.StopExecutorSystem$.html | 306 +
...cutorSystemScheduler.StopExecutorSystem.html | 296 +
.../appmaster/ExecutorSystemScheduler.html | 475 +
...nectionKeeper.AppMasterRegisterTimeout$.html | 301 +
...MasterConnectionStatus$.MasterConnected.html | 262 +
...r.MasterConnectionStatus$.MasterStopped.html | 262 +
...onnectionKeeper.MasterConnectionStatus$.html | 301 +
.../appmaster/MasterConnectionKeeper.html | 364 +
.../gearpump/cluster/appmaster/WorkerInfo.html | 307 +
.../cluster/appmaster/package-frame.html | 58 +
.../cluster/appmaster/package-summary.html | 314 +
.../cluster/appmaster/package-tree.html | 191 +
.../gearpump/cluster/client/ClientContext.html | 520 ++
.../gearpump/cluster/client/MasterClient.html | 328 +
.../gearpump/cluster/client/package-frame.html | 21 +
.../cluster/client/package-summary.html | 148 +
.../gearpump/cluster/client/package-tree.html | 136 +
.../cluster/main/ArgumentsParser.Syntax$.html | 306 +
.../cluster/main/ArgumentsParser.Syntax.html | 326 +
.../gearpump/cluster/main/ArgumentsParser.html | 310 +
.../apache/gearpump/cluster/main/CLIOption.html | 322 +
.../gearpump/cluster/main/ParseResult.html | 323 +
.../gearpump/cluster/main/package-frame.html | 27 +
.../gearpump/cluster/main/package-summary.html | 169 +
.../gearpump/cluster/main/package-tree.html | 146 +
.../cluster/master/AppMasterLauncher.html | 451 +
.../master/AppMasterLauncherFactory.html | 231 +
.../gearpump/cluster/master/MasterActivity.html | 307 +
.../gearpump/cluster/master/MasterNode.html | 320 +
.../master/MasterProxy.MasterRestarted$.html | 301 +
.../master/MasterProxy.MasterStopped$.html | 301 +
.../master/MasterProxy.WatchMaster$.html | 306 +
.../cluster/master/MasterProxy.WatchMaster.html | 296 +
.../gearpump/cluster/master/MasterProxy.html | 472 +
.../gearpump/cluster/master/MasterStatus.html | 283 +
.../gearpump/cluster/master/MasterSummary.html | 428 +
.../gearpump/cluster/master/package-frame.html | 33 +
.../cluster/master/package-summary.html | 200 +
.../gearpump/cluster/master/package-tree.html | 152 +
.../apache/gearpump/cluster/package-frame.html | 166 +
.../gearpump/cluster/package-summary.html | 815 ++
.../apache/gearpump/cluster/package-tree.html | 318 +
.../gearpump/cluster/scheduler/Priority.html | 347 +
.../gearpump/cluster/scheduler/Relaxation.html | 347 +
.../gearpump/cluster/scheduler/Resource.html | 333 +
.../cluster/scheduler/ResourceAllocation.html | 322 +
.../cluster/scheduler/ResourceRequest.html | 352 +
.../cluster/scheduler/package-frame.html | 24 +
.../cluster/scheduler/package-summary.html | 162 +
.../cluster/scheduler/package-tree.html | 143 +
.../cluster/worker/ExecutorProcessLauncher.html | 290 +
.../gearpump/cluster/worker/ExecutorSlots.html | 322 +
.../gearpump/cluster/worker/WorkerId.html | 364 +
.../gearpump/cluster/worker/WorkerSummary.html | 471 +
.../gearpump/cluster/worker/package-frame.html | 26 +
.../cluster/worker/package-summary.html | 169 +
.../gearpump/cluster/worker/package-tree.html | 141 +
.../gearpump/external/hbase/HBaseSink.html | 543 ++
.../external/hbase/dsl/HBaseDSLSink.html | 310 +
.../external/hbase/dsl/package-frame.html | 20 +
.../external/hbase/dsl/package-summary.html | 142 +
.../external/hbase/dsl/package-tree.html | 135 +
.../gearpump/external/hbase/package-frame.html | 20 +
.../external/hbase/package-summary.html | 140 +
.../gearpump/external/hbase/package-tree.html | 135 +
.../org/apache/gearpump/jarstore/FilePath.html | 292 +
.../gearpump/jarstore/JarStoreService.html | 299 +
.../apache/gearpump/jarstore/package-frame.html | 24 +
.../gearpump/jarstore/package-summary.html | 158 +
.../apache/gearpump/jarstore/package-tree.html | 139 +
.../apache/gearpump/metrics/AkkaReporter.html | 281 +
.../org/apache/gearpump/metrics/Counter.html | 303 +
.../org/apache/gearpump/metrics/Histogram.html | 316 +
.../apache/gearpump/metrics/JvmMetricsSet.html | 278 +
.../java/org/apache/gearpump/metrics/Meter.html | 313 +
.../gearpump/metrics/Metrics.Counter$.html | 306 +
.../gearpump/metrics/Metrics.Counter.html | 315 +
.../metrics/Metrics.DemandMoreMetrics$.html | 306 +
.../metrics/Metrics.DemandMoreMetrics.html | 296 +
.../gearpump/metrics/Metrics.DummyMetrics.html | 359 +
.../apache/gearpump/metrics/Metrics.Gauge$.html | 306 +
.../apache/gearpump/metrics/Metrics.Gauge.html | 315 +
.../gearpump/metrics/Metrics.Histogram$.html | 306 +
.../gearpump/metrics/Metrics.Histogram.html | 390 +
.../apache/gearpump/metrics/Metrics.Meter$.html | 306 +
.../apache/gearpump/metrics/Metrics.Meter.html | 360 +
.../gearpump/metrics/Metrics.MetricType$.html | 333 +
.../gearpump/metrics/Metrics.MetricType.html | 227 +
.../metrics/Metrics.ReportMetrics$.html | 301 +
.../apache/gearpump/metrics/Metrics.Timer$.html | 306 +
.../apache/gearpump/metrics/Metrics.Timer.html | 555 ++
.../org/apache/gearpump/metrics/Metrics.html | 477 +
.../gearpump/metrics/MetricsAggregator.html | 229 +
.../MetricsReporterService.ReportTo.html | 228 +
.../metrics/MetricsReporterService.html | 381 +
.../apache/gearpump/metrics/package-frame.html | 47 +
.../gearpump/metrics/package-summary.html | 259 +
.../apache/gearpump/metrics/package-tree.html | 185 +
.../java/org/apache/gearpump/package-frame.html | 20 +
.../org/apache/gearpump/package-summary.html | 142 +
.../java/org/apache/gearpump/package-tree.html | 135 +
.../partitioner/BroadcastPartitioner.html | 306 +
.../partitioner/CoLocationPartitioner.html | 307 +
.../gearpump/partitioner/HashPartitioner.html | 308 +
.../partitioner/MulticastPartitioner.html | 260 +
.../gearpump/partitioner/Partitioner.html | 180 +
.../partitioner/PartitionerByClassName.html | 300 +
.../partitioner/PartitionerDescription.html | 293 +
.../partitioner/PartitionerFactory.html | 236 +
.../gearpump/partitioner/PartitionerObject.html | 300 +
.../partitioner/ShuffleGroupingPartitioner.html | 308 +
.../partitioner/ShufflePartitioner.html | 306 +
.../partitioner/UnicastPartitioner.html | 262 +
.../gearpump/partitioner/package-frame.html | 34 +
.../gearpump/partitioner/package-summary.html | 220 +
.../gearpump/partitioner/package-tree.html | 160 +
.../Authenticator.AuthenticationResult.html | 236 +
.../apache/gearpump/security/Authenticator.html | 250 +
.../security/ConfigFileBasedAuthenticator.html | 322 +
.../apache/gearpump/security/PasswordUtil.html | 326 +
.../apache/gearpump/security/package-frame.html | 26 +
.../gearpump/security/package-summary.html | 169 +
.../apache/gearpump/security/package-tree.html | 141 +
.../FastKryoSerializationFramework.html | 314 +
...oSerializer.KryoSerializationException$.html | 287 +
...yoSerializer.KryoSerializationException.html | 266 +
.../gearpump/serializer/FastKryoSerializer.html | 331 +
.../serializer/GearpumpSerialization.html | 269 +
.../serializer/SerializationFramework.html | 255 +
.../apache/gearpump/serializer/Serializer.html | 237 +
.../gearpump/serializer/package-frame.html | 32 +
.../gearpump/serializer/package-summary.html | 193 +
.../gearpump/serializer/package-tree.html | 152 +
.../streaming/AckRequestSerializer.html | 327 +
.../gearpump/streaming/AckSerializer.html | 327 +
.../AppMasterToExecutor.ChangeTask$.html | 306 +
.../AppMasterToExecutor.ChangeTask.html | 341 +
.../AppMasterToExecutor.ChangeTasks$.html | 306 +
.../AppMasterToExecutor.ChangeTasks.html | 342 +
.../AppMasterToExecutor.LaunchTasks$.html | 306 +
.../AppMasterToExecutor.LaunchTasks.html | 341 +
.../AppMasterToExecutor.MsgLostException.html | 264 +
...ppMasterToExecutor.RestartClockService$.html | 301 +
.../AppMasterToExecutor.StartAllTasks$.html | 306 +
.../AppMasterToExecutor.StartAllTasks.html | 296 +
.../AppMasterToExecutor.StartDynamicDag$.html | 306 +
.../AppMasterToExecutor.StartDynamicDag.html | 296 +
.../AppMasterToExecutor.StartTask$.html | 306 +
.../AppMasterToExecutor.StartTask.html | 296 +
.../AppMasterToExecutor.StopTask$.html | 306 +
.../streaming/AppMasterToExecutor.StopTask.html | 296 +
.../AppMasterToExecutor.TaskChanged$.html | 306 +
.../AppMasterToExecutor.TaskChanged.html | 311 +
...AppMasterToExecutor.TaskLocationsReady$.html | 306 +
.../AppMasterToExecutor.TaskLocationsReady.html | 311 +
...MasterToExecutor.TaskLocationsReceived$.html | 306 +
...pMasterToExecutor.TaskLocationsReceived.html | 311 +
...MasterToExecutor.TaskLocationsRejected$.html | 306 +
...pMasterToExecutor.TaskLocationsRejected.html | 341 +
.../AppMasterToExecutor.TaskRegistered$.html | 306 +
.../AppMasterToExecutor.TaskRegistered.html | 326 +
.../AppMasterToExecutor.TaskRejected$.html | 306 +
.../AppMasterToExecutor.TaskRejected.html | 296 +
.../AppMasterToExecutor.TasksChanged$.html | 306 +
.../AppMasterToExecutor.TasksChanged.html | 296 +
.../AppMasterToExecutor.TasksLaunched$.html | 301 +
.../gearpump/streaming/AppMasterToExecutor.html | 376 +
.../AppMasterToMaster.StallingTasks$.html | 306 +
.../AppMasterToMaster.StallingTasks.html | 296 +
.../gearpump/streaming/AppMasterToMaster.html | 258 +
.../apache/gearpump/streaming/Constants.html | 373 +
.../java/org/apache/gearpump/streaming/DAG.html | 390 +
.../ExecutorToAppMaster.MessageLoss$.html | 306 +
.../ExecutorToAppMaster.MessageLoss.html | 326 +
.../ExecutorToAppMaster.RegisterExecutor$.html | 306 +
.../ExecutorToAppMaster.RegisterExecutor.html | 341 +
.../ExecutorToAppMaster.RegisterTask$.html | 306 +
.../ExecutorToAppMaster.RegisterTask.html | 326 +
.../ExecutorToAppMaster.UnRegisterTask$.html | 306 +
.../ExecutorToAppMaster.UnRegisterTask.html | 311 +
.../gearpump/streaming/ExecutorToAppMaster.html | 282 +
.../streaming/InitialAckRequestSerializer.html | 327 +
.../streaming/LatencyProbeSerializer.html | 314 +
.../org/apache/gearpump/streaming/LifeTime.html | 350 +
.../streaming/Processor.DefaultProcessor$.html | 287 +
.../streaming/Processor.DefaultProcessor.html | 446 +
.../apache/gearpump/streaming/Processor.html | 330 +
.../streaming/ProcessorDescription.html | 389 +
.../gearpump/streaming/StreamApplication.html | 404 +
.../gearpump/streaming/TaskIdSerializer.html | 314 +
.../AppMaster.AllocateResourceTimeOut$.html | 302 +
.../appmaster/AppMaster.ExecutorBrief$.html | 306 +
.../appmaster/AppMaster.ExecutorBrief.html | 341 +
.../AppMaster.LookupTaskActorRef$.html | 306 +
.../appmaster/AppMaster.LookupTaskActorRef.html | 297 +
.../AppMaster.ServiceNotAvailableException.html | 264 +
.../appmaster/AppMaster.TaskActorRef$.html | 306 +
.../appmaster/AppMaster.TaskActorRef.html | 296 +
.../gearpump/streaming/appmaster/AppMaster.html | 429 +
.../appmaster/ClockService.ChangeToNewDAG$.html | 306 +
.../appmaster/ClockService.ChangeToNewDAG.html | 296 +
.../ClockService.ChangeToNewDAGSuccess$.html | 306 +
.../ClockService.ChangeToNewDAGSuccess.html | 296 +
.../appmaster/ClockService.HealthCheck$.html | 301 +
.../appmaster/ClockService.HealthChecker$.html | 278 +
.../ClockService.HealthChecker.ClockValue$.html | 306 +
.../ClockService.HealthChecker.ClockValue.html | 324 +
.../appmaster/ClockService.HealthChecker.html | 319 +
.../appmaster/ClockService.ProcessorClock$.html | 278 +
.../appmaster/ClockService.ProcessorClock.html | 374 +
.../ClockService.ProcessorClocks$.html | 312 +
.../appmaster/ClockService.Report$.html | 306 +
.../appmaster/ClockService.Report.html | 296 +
.../ClockService.SnapshotStartClock$.html | 301 +
.../ClockService.StoredStartClock$.html | 306 +
.../ClockService.StoredStartClock.html | 296 +
.../streaming/appmaster/ClockService.html | 467 +
.../appmaster/DagManager.DAGOperation.html | 173 +
.../DagManager.DAGOperationFailed$.html | 306 +
.../DagManager.DAGOperationFailed.html | 296 +
.../DagManager.DAGOperationResult.html | 173 +
.../DagManager.DAGOperationSuccess$.html | 301 +
.../appmaster/DagManager.DagInitiated$.html | 301 +
.../appmaster/DagManager.GetLatestDAG$.html | 301 +
.../DagManager.GetTaskLaunchData$.html | 306 +
.../appmaster/DagManager.GetTaskLaunchData.html | 326 +
.../appmaster/DagManager.LatestDAG$.html | 306 +
.../appmaster/DagManager.LatestDAG.html | 296 +
.../appmaster/DagManager.NewDAGDeployed$.html | 306 +
.../appmaster/DagManager.NewDAGDeployed.html | 296 +
.../appmaster/DagManager.ReplaceProcessor$.html | 306 +
.../appmaster/DagManager.ReplaceProcessor.html | 326 +
.../appmaster/DagManager.TaskLaunchData$.html | 306 +
.../appmaster/DagManager.TaskLaunchData.html | 326 +
.../appmaster/DagManager.WatchChange$.html | 306 +
.../appmaster/DagManager.WatchChange.html | 296 +
.../streaming/appmaster/DagManager.html | 443 +
.../appmaster/ExecutorManager.BroadCast$.html | 306 +
.../appmaster/ExecutorManager.BroadCast.html | 296 +
.../ExecutorManager.ExecutorInfo$.html | 306 +
.../appmaster/ExecutorManager.ExecutorInfo.html | 341 +
...orManager.ExecutorResourceUsageSummary$.html | 306 +
...torManager.ExecutorResourceUsageSummary.html | 296 +
.../ExecutorManager.ExecutorStarted$.html | 306 +
.../ExecutorManager.ExecutorStarted.html | 341 +
.../ExecutorManager.ExecutorStopped$.html | 306 +
.../ExecutorManager.ExecutorStopped.html | 296 +
.../ExecutorManager.GetExecutorInfo$.html | 301 +
.../ExecutorManager.SetTaskManager$.html | 306 +
.../ExecutorManager.SetTaskManager.html | 296 +
.../ExecutorManager.StartExecutors$.html | 306 +
.../ExecutorManager.StartExecutors.html | 311 +
.../ExecutorManager.StartExecutorsTimeOut$.html | 301 +
.../appmaster/ExecutorManager.UniCast$.html | 306 +
.../appmaster/ExecutorManager.UniCast.html | 311 +
.../streaming/appmaster/ExecutorManager.html | 466 +
.../appmaster/JarScheduler.ExecutorFailed$.html | 306 +
.../appmaster/JarScheduler.ExecutorFailed.html | 297 +
...JarScheduler.GetResourceRequestDetails$.html | 301 +
.../JarScheduler.JarSchedulerImpl.html | 341 +
.../appmaster/JarScheduler.NewDag$.html | 306 +
.../appmaster/JarScheduler.NewDag.html | 311 +
.../JarScheduler.ResourceRequestDetail$.html | 306 +
.../JarScheduler.ResourceRequestDetail.html | 311 +
.../appmaster/JarScheduler.ScheduleTask$.html | 306 +
.../appmaster/JarScheduler.ScheduleTask.html | 347 +
.../JarScheduler.TransitToNewDag$.html | 301 +
.../streaming/appmaster/JarScheduler.html | 422 +
.../streaming/appmaster/ProcessorSummary.html | 397 +
.../appmaster/StreamAppMasterSummary.html | 550 ++
.../gearpump/streaming/appmaster/TaskCount.html | 292 +
.../appmaster/TaskLocator.Localities$.html | 347 +
.../appmaster/TaskLocator.Localities.html | 297 +
.../appmaster/TaskLocator.Locality.html | 173 +
.../appmaster/TaskLocator.NonLocality$.html | 284 +
.../appmaster/TaskLocator.WorkerLocality$.html | 306 +
.../appmaster/TaskLocator.WorkerLocality.html | 297 +
.../streaming/appmaster/TaskLocator.html | 323 +
.../TaskManager.ApplicationReady$.html | 301 +
.../TaskManager.ChangeTasksOnExecutor$.html | 306 +
.../TaskManager.ChangeTasksOnExecutor.html | 312 +
.../appmaster/TaskManager.DAGDiff$.html | 306 +
.../appmaster/TaskManager.DAGDiff.html | 327 +
.../appmaster/TaskManager.DagReadyState$.html | 312 +
.../appmaster/TaskManager.DagReadyState.html | 289 +
.../appmaster/TaskManager.ExecutorRegistry.html | 287 +
.../appmaster/TaskManager.FailedToRecover$.html | 306 +
.../appmaster/TaskManager.FailedToRecover.html | 296 +
.../appmaster/TaskManager.GetTaskList$.html | 301 +
.../appmaster/TaskManager.SessionIdFactory.html | 281 +
.../appmaster/TaskManager.StartDagState$.html | 278 +
.../appmaster/TaskManager.StartDagState.html | 319 +
.../TaskManager.StartTasksOnExecutor$.html | 306 +
.../TaskManager.StartTasksOnExecutor.html | 312 +
.../TaskManager.TaskChangeRegistry$.html | 312 +
.../TaskManager.TaskChangeRegistry.html | 287 +
.../appmaster/TaskManager.TaskList$.html | 306 +
.../appmaster/TaskManager.TaskList.html | 296 +
.../streaming/appmaster/TaskManager.html | 539 ++
.../appmaster/TaskRegistry.Accept$.html | 301 +
.../TaskRegistry.RegisterTaskStatus.html | 173 +
.../appmaster/TaskRegistry.Reject$.html | 301 +
.../appmaster/TaskRegistry.TaskLocation$.html | 306 +
.../appmaster/TaskRegistry.TaskLocation.html | 311 +
.../appmaster/TaskRegistry.TaskLocations$.html | 306 +
.../appmaster/TaskRegistry.TaskLocations.html | 296 +
.../streaming/appmaster/TaskRegistry.html | 505 ++
.../appmaster/TaskScheduler.Location$.html | 306 +
.../appmaster/TaskScheduler.Location.html | 311 +
.../appmaster/TaskScheduler.TaskStatus.html | 303 +
.../streaming/appmaster/TaskScheduler.html | 361 +
.../streaming/appmaster/TaskSchedulerImpl.html | 416 +
.../streaming/appmaster/package-frame.html | 147 +
.../streaming/appmaster/package-summary.html | 698 ++
.../streaming/appmaster/package-tree.html | 287 +
.../streaming/dsl/CollectionDataSource.html | 343 +
.../apache/gearpump/streaming/dsl/KVStream.html | 307 +
.../gearpump/streaming/dsl/LoggerSink.html | 351 +
.../gearpump/streaming/dsl/Stream.Sink.html | 307 +
.../apache/gearpump/streaming/dsl/Stream.html | 552 ++
.../streaming/dsl/StreamApp.Source.html | 373 +
.../gearpump/streaming/dsl/StreamApp.html | 380 +
.../streaming/dsl/javaapi/JavaStream.html | 424 +
.../streaming/dsl/javaapi/JavaStreamApp.html | 311 +
.../streaming/dsl/javaapi/package-frame.html | 21 +
.../streaming/dsl/javaapi/package-summary.html | 146 +
.../streaming/dsl/javaapi/package-tree.html | 136 +
.../gearpump/streaming/dsl/op/DataSinkOp.html | 345 +
.../gearpump/streaming/dsl/op/DataSourceOp.html | 345 +
.../gearpump/streaming/dsl/op/Direct.html | 262 +
.../gearpump/streaming/dsl/op/FlatMapOp.html | 330 +
.../gearpump/streaming/dsl/op/GroupByOp.html | 345 +
.../gearpump/streaming/dsl/op/MasterOp.html | 199 +
.../gearpump/streaming/dsl/op/MergeOp.html | 315 +
.../apache/gearpump/streaming/dsl/op/Op.html | 241 +
.../gearpump/streaming/dsl/op/OpChain.html | 357 +
.../gearpump/streaming/dsl/op/OpEdge.html | 169 +
.../streaming/dsl/op/ParameterizedOp.html | 195 +
.../gearpump/streaming/dsl/op/ProcessorOp.html | 345 +
.../gearpump/streaming/dsl/op/ReduceOp.html | 330 +
.../gearpump/streaming/dsl/op/Shuffle.html | 262 +
.../gearpump/streaming/dsl/op/SlaveOp.html | 197 +
.../streaming/dsl/op/package-frame.html | 37 +
.../streaming/dsl/op/package-summary.html | 218 +
.../gearpump/streaming/dsl/op/package-tree.html | 158 +
.../gearpump/streaming/dsl/package-frame.html | 26 +
.../gearpump/streaming/dsl/package-summary.html | 168 +
.../gearpump/streaming/dsl/package-tree.html | 141 +
.../dsl/partitioner/GroupByPartitioner.html | 320 +
.../dsl/partitioner/package-frame.html | 20 +
.../dsl/partitioner/package-summary.html | 142 +
.../streaming/dsl/partitioner/package-tree.html | 135 +
.../dsl/plan/OpTranslator.AndThen.html | 314 +
.../plan/OpTranslator.DummyInputFunction.html | 322 +
.../dsl/plan/OpTranslator.FlatMapFunction.html | 314 +
.../dsl/plan/OpTranslator.GroupByTask.html | 347 +
.../dsl/plan/OpTranslator.ReduceFunction.html | 314 +
.../plan/OpTranslator.SingleInputFunction.html | 260 +
.../dsl/plan/OpTranslator.SinkTask.html | 372 +
.../dsl/plan/OpTranslator.SourceTask.html | 374 +
.../dsl/plan/OpTranslator.TransformTask.html | 347 +
.../streaming/dsl/plan/OpTranslator.html | 345 +
.../gearpump/streaming/dsl/plan/Planner.html | 271 +
.../streaming/dsl/plan/package-frame.html | 33 +
.../streaming/dsl/plan/package-summary.html | 193 +
.../streaming/dsl/plan/package-tree.html | 160 +
.../Executor.DagVersionMismatchException.html | 264 +
.../executor/Executor.ExecutorConfig$.html | 306 +
.../executor/Executor.ExecutorConfig.html | 296 +
.../executor/Executor.ExecutorSummary$.html | 321 +
.../executor/Executor.ExecutorSummary.html | 401 +
.../executor/Executor.GetExecutorSummary$.html | 306 +
.../executor/Executor.GetExecutorSummary.html | 296 +
.../executor/Executor.HealthCheck$.html | 278 +
.../executor/Executor.QueryExecutorConfig$.html | 306 +
.../executor/Executor.QueryExecutorConfig.html | 296 +
.../executor/Executor.RestartTasks$.html | 306 +
.../executor/Executor.RestartTasks.html | 296 +
.../streaming/executor/Executor.State$.html | 351 +
.../executor/Executor.TaskArgumentStore.html | 321 +
.../executor/Executor.TaskStopped$.html | 306 +
.../executor/Executor.TaskStopped.html | 296 +
.../gearpump/streaming/executor/Executor.html | 546 ++
.../executor/ExecutorRestartPolicy.html | 293 +
.../streaming/executor/ITaskLauncher.html | 234 +
.../executor/TaskLauncher.TaskArgument$.html | 306 +
.../executor/TaskLauncher.TaskArgument.html | 326 +
.../streaming/executor/TaskLauncher.html | 338 +
.../streaming/executor/package-frame.html | 47 +
.../streaming/executor/package-summary.html | 250 +
.../streaming/executor/package-tree.html | 175 +
.../streaming/hadoop/HadoopCheckpointStore.html | 425 +
.../hadoop/HadoopCheckpointStoreFactory.html | 303 +
.../streaming/hadoop/SequenceFileSink.html | 342 +
.../hadoop/lib/HadoopCheckpointStoreReader.html | 346 +
.../hadoop/lib/HadoopCheckpointStoreWriter.html | 286 +
.../streaming/hadoop/lib/HadoopUtil.html | 316 +
.../lib/format/DefaultSequenceFormatter.html | 333 +
.../hadoop/lib/format/OutputFormatter.html | 267 +
.../hadoop/lib/format/package-frame.html | 24 +
.../hadoop/lib/format/package-summary.html | 155 +
.../hadoop/lib/format/package-tree.html | 147 +
.../streaming/hadoop/lib/package-frame.html | 22 +
.../streaming/hadoop/lib/package-summary.html | 148 +
.../streaming/hadoop/lib/package-tree.html | 137 +
.../hadoop/lib/rotation/FileSizeRotation.html | 345 +
.../streaming/hadoop/lib/rotation/Rotation.html | 256 +
.../hadoop/lib/rotation/package-frame.html | 24 +
.../hadoop/lib/rotation/package-summary.html | 155 +
.../hadoop/lib/rotation/package-tree.html | 147 +
.../streaming/hadoop/package-frame.html | 22 +
.../streaming/hadoop/package-summary.html | 150 +
.../gearpump/streaming/hadoop/package-tree.html | 137 +
.../gearpump/streaming/javaapi/Graph.html | 273 +
.../gearpump/streaming/javaapi/Processor.html | 565 ++
.../streaming/javaapi/StreamApplication.html | 359 +
.../apache/gearpump/streaming/javaapi/Task.html | 421 +
.../javaapi/dsl/functions/FilterFunction.html | 231 +
.../javaapi/dsl/functions/FlatMapFunction.html | 232 +
.../javaapi/dsl/functions/GroupByFunction.html | 232 +
.../javaapi/dsl/functions/MapFunction.html | 232 +
.../javaapi/dsl/functions/ReduceFunction.html | 233 +
.../javaapi/dsl/functions/package-frame.html | 24 +
.../javaapi/dsl/functions/package-summary.html | 166 +
.../javaapi/dsl/functions/package-tree.html | 139 +
.../streaming/javaapi/package-frame.html | 23 +
.../streaming/javaapi/package-summary.html | 164 +
.../streaming/javaapi/package-tree.html | 146 +
.../gearpump/streaming/kafka/KafkaSink.html | 282 +
.../gearpump/streaming/kafka/KafkaSource.html | 313 +
.../streaming/kafka/KafkaStoreFactory.html | 265 +
.../gearpump/streaming/kafka/dsl/KafkaDSL.html | 380 +
.../streaming/kafka/dsl/package-frame.html | 20 +
.../streaming/kafka/dsl/package-summary.html | 140 +
.../streaming/kafka/dsl/package-tree.html | 135 +
.../AbstractKafkaSink.KafkaProducerFactory.html | 228 +
.../kafka/lib/sink/AbstractKafkaSink.html | 396 +
.../streaming/kafka/lib/sink/package-frame.html | 24 +
.../kafka/lib/sink/package-summary.html | 158 +
.../streaming/kafka/lib/sink/package-tree.html | 143 +
.../kafka/lib/source/AbstractKafkaSource.html | 420 +
.../kafka/lib/source/DefaultMessageDecoder.html | 289 +
.../kafka/lib/source/StringMessageDecoder.html | 289 +
.../consumer/ExponentialBackoffSleeper.html | 331 +
.../FetchThread.FetchThreadFactory.html | 284 +
.../kafka/lib/source/consumer/FetchThread.html | 435 +
.../lib/source/consumer/KafkaConsumer.html | 350 +
.../kafka/lib/source/consumer/KafkaMessage.html | 362 +
.../lib/source/consumer/package-frame.html | 24 +
.../lib/source/consumer/package-summary.html | 168 +
.../kafka/lib/source/consumer/package-tree.html | 143 +
.../source/grouper/DefaultPartitionGrouper.html | 289 +
.../lib/source/grouper/PartitionGrouper.html | 228 +
.../kafka/lib/source/grouper/package-frame.html | 24 +
.../lib/source/grouper/package-summary.html | 159 +
.../kafka/lib/source/grouper/package-tree.html | 139 +
.../kafka/lib/source/package-frame.html | 22 +
.../kafka/lib/source/package-summary.html | 151 +
.../kafka/lib/source/package-tree.html | 137 +
.../lib/store/AbstractKafkaStoreFactory.html | 307 +
.../streaming/kafka/lib/store/KafkaStore.html | 362 +
.../kafka/lib/store/package-frame.html | 21 +
.../kafka/lib/store/package-summary.html | 148 +
.../streaming/kafka/lib/store/package-tree.html | 136 +
.../util/KafkaClient.KafkaClientFactory.html | 282 +
.../streaming/kafka/lib/util/KafkaClient.html | 393 +
.../streaming/kafka/lib/util/package-frame.html | 21 +
.../kafka/lib/util/package-summary.html | 144 +
.../streaming/kafka/lib/util/package-tree.html | 136 +
.../gearpump/streaming/kafka/package-frame.html | 22 +
.../streaming/kafka/package-summary.html | 154 +
.../gearpump/streaming/kafka/package-tree.html | 149 +
.../util/KafkaConfig.KafkaConfigFactory.html | 282 +
.../streaming/kafka/util/KafkaConfig.html | 711 ++
.../streaming/kafka/util/package-frame.html | 21 +
.../streaming/kafka/util/package-summary.html | 146 +
.../streaming/kafka/util/package-tree.html | 140 +
.../metrics/ProcessorAggregator.Aggregator.html | 240 +
.../ProcessorAggregator.AggregatorFactory.html | 275 +
...ProcessorAggregator.HistogramAggregator.html | 403 +
.../ProcessorAggregator.MeterAggregator.html | 364 +
.../ProcessorAggregator.MultiLayerMap.html | 333 +
.../streaming/metrics/ProcessorAggregator.html | 381 +
.../metrics/TaskFilterAggregator.Options$.html | 334 +
.../metrics/TaskFilterAggregator.Options.html | 356 +
.../streaming/metrics/TaskFilterAggregator.html | 449 +
.../streaming/metrics/package-frame.html | 31 +
.../streaming/metrics/package-summary.html | 191 +
.../streaming/metrics/package-tree.html | 146 +
.../streaming/monoid/AlgebirdGroup.html | 324 +
.../streaming/monoid/AlgebirdMonoid.html | 303 +
.../streaming/monoid/package-frame.html | 21 +
.../streaming/monoid/package-summary.html | 144 +
.../gearpump/streaming/monoid/package-tree.html | 136 +
.../gearpump/streaming/package-frame.html | 82 +
.../gearpump/streaming/package-summary.html | 396 +
.../apache/gearpump/streaming/package-tree.html | 222 +
.../streaming/serializer/ChillSerializer.html | 301 +
.../streaming/serializer/package-frame.html | 20 +
.../streaming/serializer/package-summary.html | 140 +
.../streaming/serializer/package-tree.html | 135 +
.../gearpump/streaming/sink/DataSink.html | 295 +
.../streaming/sink/DataSinkProcessor.html | 288 +
.../gearpump/streaming/sink/DataSinkTask.html | 382 +
.../gearpump/streaming/sink/package-frame.html | 25 +
.../streaming/sink/package-summary.html | 167 +
.../gearpump/streaming/sink/package-tree.html | 148 +
.../gearpump/streaming/source/DataSource.html | 303 +
.../streaming/source/DataSourceConfig.html | 269 +
.../streaming/source/DataSourceProcessor.html | 288 +
.../streaming/source/DataSourceTask.html | 391 +
.../source/DefaultTimeStampFilter.html | 285 +
.../streaming/source/package-frame.html | 27 +
.../streaming/source/package-summary.html | 178 +
.../gearpump/streaming/source/package-tree.html | 150 +
.../gearpump/streaming/state/api/Group.html | 239 +
.../gearpump/streaming/state/api/Monoid.html | 249 +
.../streaming/state/api/MonoidState.html | 381 +
.../streaming/state/api/PersistentState.html | 331 +
.../streaming/state/api/PersistentTask.html | 496 +
.../streaming/state/api/Serializer.html | 243 +
.../streaming/state/api/package-frame.html | 28 +
.../streaming/state/api/package-summary.html | 177 +
.../streaming/state/api/package-tree.html | 154 +
.../streaming/state/impl/CheckpointManager.html | 352 +
.../state/impl/InMemoryCheckpointStore.html | 316 +
.../impl/InMemoryCheckpointStoreFactory.html | 286 +
.../gearpump/streaming/state/impl/Interval.html | 332 +
.../streaming/state/impl/NonWindowState.html | 365 +
.../state/impl/PersistentStateConfig.html | 321 +
.../gearpump/streaming/state/impl/Window.html | 363 +
.../streaming/state/impl/WindowConfig.html | 320 +
.../streaming/state/impl/WindowState.html | 443 +
.../streaming/state/impl/package-frame.html | 28 +
.../streaming/state/impl/package-summary.html | 187 +
.../streaming/state/impl/package-tree.html | 147 +
.../streaming/storage/AppDataStore.html | 239 +
.../storage/InMemoryAppStoreOnMaster.html | 313 +
.../streaming/storage/package-frame.html | 24 +
.../streaming/storage/package-summary.html | 159 +
.../streaming/storage/package-tree.html | 139 +
.../org/apache/gearpump/streaming/task/Ack.html | 341 +
.../gearpump/streaming/task/AckRequest.html | 322 +
.../streaming/task/CheckProcessorDeath.html | 292 +
.../streaming/task/CheckpointClock.html | 292 +
.../gearpump/streaming/task/ClockEvent.html | 169 +
.../streaming/task/ExpressTransport.html | 294 +
.../streaming/task/GetCheckpointClock.html | 258 +
.../apache/gearpump/streaming/task/GetDAG.html | 258 +
.../streaming/task/GetLatestMinClock.html | 240 +
.../gearpump/streaming/task/GetStartClock.html | 258 +
.../streaming/task/GetUpstreamMinClock.html | 292 +
.../streaming/task/InitialAckRequest.html | 307 +
.../gearpump/streaming/task/LatencyProbe.html | 293 +
.../gearpump/streaming/task/LatestMinClock.html | 292 +
.../streaming/task/SendMessageLoss.html | 258 +
.../streaming/task/SerializedMessage.html | 307 +
.../task/SerializedMessageSerializer.html | 314 +
.../task/SerializerResolver.Registration.html | 303 +
.../streaming/task/SerializerResolver.html | 316 +
.../gearpump/streaming/task/StartClock.html | 292 +
.../gearpump/streaming/task/StartTime.html | 293 +
.../task/StreamingTransportSerializer.html | 316 +
.../gearpump/streaming/task/Subscriber.html | 371 +
.../gearpump/streaming/task/Subscription.html | 427 +
.../apache/gearpump/streaming/task/Task.html | 426 +
.../streaming/task/TaskActor.FLUSH$.html | 301 +
.../task/TaskActor.MessageAndSender$.html | 306 +
.../task/TaskActor.MessageAndSender.html | 311 +
.../task/TaskActor.SecurityChecker.html | 307 +
.../streaming/task/TaskActor.SendAck$.html | 306 +
.../streaming/task/TaskActor.SendAck.html | 311 +
.../gearpump/streaming/task/TaskActor.html | 724 ++
.../gearpump/streaming/task/TaskContext.html | 512 ++
.../streaming/task/TaskContextData.html | 382 +
.../apache/gearpump/streaming/task/TaskId.html | 333 +
.../gearpump/streaming/task/TaskInterface.html | 293 +
.../streaming/task/TaskMessageSerializer.html | 255 +
.../gearpump/streaming/task/TaskUtil.html | 279 +
.../gearpump/streaming/task/TaskWrapper.html | 786 ++
.../streaming/task/UpdateCheckpointClock.html | 307 +
.../gearpump/streaming/task/UpdateClock.html | 307 +
.../streaming/task/UpstreamMinClock.html | 292 +
.../gearpump/streaming/task/package-frame.html | 64 +
.../streaming/task/package-summary.html | 336 +
.../gearpump/streaming/task/package-tree.html | 183 +
.../transaction/api/CheckpointStore.html | 254 +
.../transaction/api/CheckpointStoreFactory.html | 235 +
.../transaction/api/MessageDecoder.html | 239 +
.../transaction/api/TimeReplayableSource.html | 248 +
.../transaction/api/TimeStampFilter.html | 231 +
.../transaction/api/package-frame.html | 24 +
.../transaction/api/package-summary.html | 168 +
.../streaming/transaction/api/package-tree.html | 143 +
.../gearpump/streaming/util/ActorPathUtil.html | 312 +
.../gearpump/streaming/util/package-frame.html | 20 +
.../streaming/util/package-summary.html | 140 +
.../gearpump/streaming/util/package-tree.html | 135 +
.../gearpump/transport/ActorLookupById.html | 226 +
.../org/apache/gearpump/transport/Express.html | 543 ++
.../org/apache/gearpump/transport/HostPort.html | 333 +
.../netty/Client.ChannelFutureOps.html | 286 +
.../transport/netty/Client.ChannelReady$.html | 306 +
.../transport/netty/Client.ChannelReady.html | 296 +
.../netty/Client.ClientErrorHandler.html | 310 +
.../netty/Client.ClientPipelineFactory.html | 284 +
.../gearpump/transport/netty/Client.Close$.html | 301 +
.../Client.CompareAndReconnectIfEqual$.html | 306 +
.../Client.CompareAndReconnectIfEqual.html | 296 +
.../transport/netty/Client.Connect$.html | 306 +
.../transport/netty/Client.Connect.html | 296 +
.../gearpump/transport/netty/Client.Flush$.html | 306 +
.../gearpump/transport/netty/Client.Flush.html | 296 +
.../apache/gearpump/transport/netty/Client.html | 469 +
.../gearpump/transport/netty/Context.html | 370 +
.../gearpump/transport/netty/IContext.html | 279 +
.../netty/ITransportMessageSerializer.html | 253 +
.../gearpump/transport/netty/MessageBatch.html | 196 +
.../transport/netty/MessageDecoder.html | 335 +
.../transport/netty/MessageEncoder.html | 311 +
.../gearpump/transport/netty/NettyConfig.html | 347 +
.../netty/NettyRenameThreadFactory.html | 244 +
.../gearpump/transport/netty/NettyUtil.html | 309 +
.../transport/netty/Server.AddChannel$.html | 306 +
.../transport/netty/Server.AddChannel.html | 296 +
.../transport/netty/Server.CloseChannel$.html | 306 +
.../transport/netty/Server.CloseChannel.html | 296 +
.../transport/netty/Server.MsgBatch$.html | 306 +
.../transport/netty/Server.MsgBatch.html | 296 +
.../transport/netty/Server.ServerHandler.html | 361 +
.../netty/Server.ServerPipelineFactory.html | 284 +
.../netty/Server.TaskIdActorRefTranslation.html | 276 +
.../apache/gearpump/transport/netty/Server.html | 432 +
.../gearpump/transport/netty/TaskMessage.html | 314 +
.../transport/netty/WrappedChannelBuffer.html | 591 ++
.../gearpump/transport/netty/package-frame.html | 56 +
.../transport/netty/package-summary.html | 293 +
.../gearpump/transport/netty/package-tree.html | 187 +
.../gearpump/transport/package-frame.html | 25 +
.../gearpump/transport/package-summary.html | 161 +
.../apache/gearpump/transport/package-tree.html | 140 +
.../util/ActorSystemBooter.ActorCreated$.html | 306 +
.../util/ActorSystemBooter.ActorCreated.html | 311 +
...ctorSystemBooter.ActorSystemRegistered$.html | 306 +
...ActorSystemBooter.ActorSystemRegistered.html | 298 +
.../util/ActorSystemBooter.BindLifeCycle$.html | 306 +
.../util/ActorSystemBooter.BindLifeCycle.html | 296 +
.../util/ActorSystemBooter.CreateActor$.html | 306 +
.../util/ActorSystemBooter.CreateActor.html | 311 +
.../ActorSystemBooter.CreateActorFailed$.html | 306 +
.../ActorSystemBooter.CreateActorFailed.html | 311 +
.../gearpump/util/ActorSystemBooter.Daemon.html | 427 +
.../ActorSystemBooter.RegisterActorSystem$.html | 306 +
.../ActorSystemBooter.RegisterActorSystem.html | 296 +
...SystemBooter.RegisterActorSystemFailed$.html | 306 +
...rSystemBooter.RegisterActorSystemFailed.html | 296 +
...ystemBooter.RegisterActorSystemTimeOut$.html | 278 +
.../apache/gearpump/util/ActorSystemBooter.html | 383 +
.../org/apache/gearpump/util/ActorUtil.html | 460 +
.../java/org/apache/gearpump/util/AkkaApp.html | 261 +
.../org/apache/gearpump/util/AkkaHelper.html | 287 +
.../org/apache/gearpump/util/ConsoleOutput.html | 236 +
.../org/apache/gearpump/util/Constants.html | 1400 +++
.../org/apache/gearpump/util/FileUtils.html | 328 +
.../org/apache/gearpump/util/Graph.Node.html | 295 +
.../apache/gearpump/util/Graph.NodeList.html | 293 +
.../org/apache/gearpump/util/Graph.Path$.html | 314 +
.../org/apache/gearpump/util/Graph.Path.html | 294 +
.../java/org/apache/gearpump/util/Graph.html | 930 ++
.../gearpump/util/HadoopFSLogAppender.html | 324 +
...storyMetricsService.CounterMetricsStore.html | 338 +
...MetricsService.DummyHistoryMetricsStore.html | 350 +
...ryMetricsService.DummyMetricsAggregator.html | 284 +
...HistoryMetricsService.GaugeMetricsStore.html | 338 +
...oryMetricsService.HistogramMetricsStore.html | 338 +
...oryMetricsService.HistoryMetricsConfig$.html | 321 +
...toryMetricsService.HistoryMetricsConfig.html | 349 +
...toryMetricsService.HistoryMetricsStore$.html | 316 +
...storyMetricsService.HistoryMetricsStore.html | 272 +
...HistoryMetricsService.MeterMetricsStore.html | 338 +
.../HistoryMetricsService.MetricsStore.html | 259 +
...yMetricsService.SingleValueMetricsStore.html | 343 +
...HistoryMetricsService.SkipAllAggregator.html | 284 +
.../gearpump/util/HistoryMetricsService.html | 414 +
.../gearpump/util/LogUtil.ProcessType$.html | 406 +
.../java/org/apache/gearpump/util/LogUtil.html | 372 +
.../gearpump/util/ProcessLogRedirector.html | 383 +
.../util/RecreateRollingFileAppender.html | 416 +
.../apache/gearpump/util/ReferenceEqual.html | 249 +
.../org/apache/gearpump/util/RestartPolicy.html | 278 +
.../org/apache/gearpump/util/RichProcess.html | 311 +
.../apache/gearpump/util/TimeOutScheduler.html | 230 +
.../gearpump/util/Util.AppJvmSettings$.html | 306 +
.../gearpump/util/Util.AppJvmSettings.html | 311 +
.../apache/gearpump/util/Util.JvmSetting$.html | 306 +
.../apache/gearpump/util/Util.JvmSetting.html | 311 +
.../api/java/org/apache/gearpump/util/Util.html | 493 +
.../org/apache/gearpump/util/package-frame.html | 78 +
.../apache/gearpump/util/package-summary.html | 401 +
.../org/apache/gearpump/util/package-tree.html | 224 +
releases/0.8.1/api/java/overview-frame.html | 72 +
releases/0.8.1/api/java/overview-summary.html | 337 +
releases/0.8.1/api/java/overview-tree.html | 1044 +++
releases/0.8.1/api/java/package-list | 52 +
releases/0.8.1/api/java/script.js | 30 +
releases/0.8.1/api/java/serialized-form.html | 3907 ++++++++
releases/0.8.1/api/java/stylesheet.css | 574 ++
releases/0.8.1/api/scala/akka/package.html | 118 +
.../0.8.1/api/scala/akka/pattern/package.html | 359 +
releases/0.8.1/api/scala/index.html | 284 +
releases/0.8.1/api/scala/index.js | 1 +
releases/0.8.1/api/scala/index/index-_.html | 38 +
releases/0.8.1/api/scala/index/index-a.html | 401 +
releases/0.8.1/api/scala/index/index-b.html | 56 +
releases/0.8.1/api/scala/index/index-c.html | 323 +
releases/0.8.1/api/scala/index/index-d.html | 191 +
releases/0.8.1/api/scala/index/index-e.html | 179 +
releases/0.8.1/api/scala/index/index-f.html | 116 +
releases/0.8.1/api/scala/index/index-g.html | 488 +
releases/0.8.1/api/scala/index/index-h.html | 128 +
releases/0.8.1/api/scala/index/index-i.html | 95 +
releases/0.8.1/api/scala/index/index-j.html | 59 +
releases/0.8.1/api/scala/index/index-k.html | 62 +
releases/0.8.1/api/scala/index/index-l.html | 152 +
releases/0.8.1/api/scala/index/index-m.html | 251 +
releases/0.8.1/api/scala/index/index-n.html | 98 +
releases/0.8.1/api/scala/index/index-o.html | 95 +
releases/0.8.1/api/scala/index/index-p.html | 215 +
releases/0.8.1/api/scala/index/index-q.html | 29 +
releases/0.8.1/api/scala/index/index-r.html | 350 +
releases/0.8.1/api/scala/index/index-s.html | 467 +
releases/0.8.1/api/scala/index/index-t.html | 269 +
releases/0.8.1/api/scala/index/index-u.html | 101 +
releases/0.8.1/api/scala/index/index-v.html | 44 +
releases/0.8.1/api/scala/index/index-w.html | 173 +
releases/0.8.1/api/scala/index/index-z.html | 17 +
releases/0.8.1/api/scala/lib/arrow-down.png | Bin 0 -> 6232 bytes
releases/0.8.1/api/scala/lib/arrow-right.png | Bin 0 -> 6220 bytes
releases/0.8.1/api/scala/lib/class.png | Bin 0 -> 3357 bytes
releases/0.8.1/api/scala/lib/class_big.png | Bin 0 -> 7516 bytes
releases/0.8.1/api/scala/lib/class_diagram.png | Bin 0 -> 3910 bytes
.../0.8.1/api/scala/lib/class_to_object_big.png | Bin 0 -> 9006 bytes
releases/0.8.1/api/scala/lib/constructorsbg.gif | Bin 0 -> 1206 bytes
releases/0.8.1/api/scala/lib/conversionbg.gif | Bin 0 -> 167 bytes
releases/0.8.1/api/scala/lib/defbg-blue.gif | Bin 0 -> 1544 bytes
releases/0.8.1/api/scala/lib/defbg-green.gif | Bin 0 -> 1341 bytes
releases/0.8.1/api/scala/lib/diagrams.css | 143 +
releases/0.8.1/api/scala/lib/diagrams.js | 324 +
.../0.8.1/api/scala/lib/filter_box_left.png | Bin 0 -> 1692 bytes
.../0.8.1/api/scala/lib/filter_box_left2.gif | Bin 0 -> 1462 bytes
.../0.8.1/api/scala/lib/filter_box_right.png | Bin 0 -> 1803 bytes
releases/0.8.1/api/scala/lib/filterbg.gif | Bin 0 -> 1324 bytes
releases/0.8.1/api/scala/lib/filterboxbarbg.gif | Bin 0 -> 1104 bytes
releases/0.8.1/api/scala/lib/filterboxbarbg.png | Bin 0 -> 965 bytes
releases/0.8.1/api/scala/lib/filterboxbg.gif | Bin 0 -> 1366 bytes
.../0.8.1/api/scala/lib/fullcommenttopbg.gif | Bin 0 -> 1115 bytes
releases/0.8.1/api/scala/lib/index.css | 339 +
releases/0.8.1/api/scala/lib/index.js | 577 ++
releases/0.8.1/api/scala/lib/jquery-ui.js | 6 +
releases/0.8.1/api/scala/lib/jquery.js | 2 +
releases/0.8.1/api/scala/lib/jquery.layout.js | 5486 +++++++++++
.../0.8.1/api/scala/lib/modernizr.custom.js | 4 +
.../0.8.1/api/scala/lib/navigation-li-a.png | Bin 0 -> 1198 bytes
releases/0.8.1/api/scala/lib/navigation-li.png | Bin 0 -> 2441 bytes
releases/0.8.1/api/scala/lib/object.png | Bin 0 -> 3356 bytes
releases/0.8.1/api/scala/lib/object_big.png | Bin 0 -> 7653 bytes
releases/0.8.1/api/scala/lib/object_diagram.png | Bin 0 -> 3903 bytes
.../0.8.1/api/scala/lib/object_to_class_big.png | Bin 0 -> 9158 bytes
.../0.8.1/api/scala/lib/object_to_trait_big.png | Bin 0 -> 9200 bytes
.../0.8.1/api/scala/lib/object_to_type_big.png | Bin 0 -> 9158 bytes
releases/0.8.1/api/scala/lib/ownderbg2.gif | Bin 0 -> 1145 bytes
releases/0.8.1/api/scala/lib/ownerbg.gif | Bin 0 -> 1118 bytes
releases/0.8.1/api/scala/lib/ownerbg2.gif | Bin 0 -> 1145 bytes
releases/0.8.1/api/scala/lib/package.png | Bin 0 -> 3335 bytes
releases/0.8.1/api/scala/lib/package_big.png | Bin 0 -> 7312 bytes
releases/0.8.1/api/scala/lib/packagesbg.gif | Bin 0 -> 1201 bytes
releases/0.8.1/api/scala/lib/permalink.png | Bin 0 -> 943 bytes
releases/0.8.1/api/scala/lib/ref-index.css | 30 +
releases/0.8.1/api/scala/lib/remove.png | Bin 0 -> 3186 bytes
releases/0.8.1/api/scala/lib/scheduler.js | 71 +
.../0.8.1/api/scala/lib/selected-implicits.png | Bin 0 -> 1150 bytes
.../api/scala/lib/selected-right-implicits.png | Bin 0 -> 646 bytes
releases/0.8.1/api/scala/lib/selected-right.png | Bin 0 -> 1380 bytes
releases/0.8.1/api/scala/lib/selected.png | Bin 0 -> 1864 bytes
.../0.8.1/api/scala/lib/selected2-right.png | Bin 0 -> 1434 bytes
releases/0.8.1/api/scala/lib/selected2.png | Bin 0 -> 1965 bytes
releases/0.8.1/api/scala/lib/signaturebg.gif | Bin 0 -> 1214 bytes
releases/0.8.1/api/scala/lib/signaturebg2.gif | Bin 0 -> 1209 bytes
releases/0.8.1/api/scala/lib/template.css | 893 ++
releases/0.8.1/api/scala/lib/template.js | 500 +
releases/0.8.1/api/scala/lib/tools.tooltip.js | 14 +
releases/0.8.1/api/scala/lib/trait.png | Bin 0 -> 3374 bytes
releases/0.8.1/api/scala/lib/trait_big.png | Bin 0 -> 7410 bytes
releases/0.8.1/api/scala/lib/trait_diagram.png | Bin 0 -> 3882 bytes
.../0.8.1/api/scala/lib/trait_to_object_big.png | Bin 0 -> 8967 bytes
releases/0.8.1/api/scala/lib/type.png | Bin 0 -> 1445 bytes
releases/0.8.1/api/scala/lib/type_big.png | Bin 0 -> 4236 bytes
releases/0.8.1/api/scala/lib/type_diagram.png | Bin 0 -> 1841 bytes
.../0.8.1/api/scala/lib/type_to_object_big.png | Bin 0 -> 4969 bytes
releases/0.8.1/api/scala/lib/typebg.gif | Bin 0 -> 1206 bytes
releases/0.8.1/api/scala/lib/unselected.png | Bin 0 -> 1879 bytes
releases/0.8.1/api/scala/lib/valuemembersbg.gif | Bin 0 -> 1206 bytes
.../api/scala/org/apache/gearpump/Message$.html | 505 ++
.../api/scala/org/apache/gearpump/Message.html | 496 +
.../apache/gearpump/cluster/AppDescription.html | 538 ++
.../org/apache/gearpump/cluster/AppJar.html | 494 +
.../gearpump/cluster/AppMasterContext.html | 588 ++
.../gearpump/cluster/AppMasterRegisterData.html | 485 +
.../AppMasterToMaster$$ActivateAppMaster.html | 476 +
.../AppMasterToMaster$$AppDataSaved$.html | 456 +
.../AppMasterToMaster$$AppMasterSummary.html | 626 ++
...MasterToMaster$$GeneralAppMasterSummary.html | 597 ++
.../AppMasterToMaster$$GetAllWorkers$.html | 456 +
.../cluster/AppMasterToMaster$$GetAppData.html | 493 +
.../AppMasterToMaster$$GetAppDataResult.html | 493 +
.../AppMasterToMaster$$GetMasterData$.html | 456 +
.../AppMasterToMaster$$GetWorkerData.html | 476 +
.../AppMasterToMaster$$InvalidAppMaster.html | 510 ++
.../cluster/AppMasterToMaster$$MasterData.html | 476 +
.../AppMasterToMaster$$RegisterAppMaster.html | 499 +
.../AppMasterToMaster$$RequestResource.html | 493 +
.../cluster/AppMasterToMaster$$SaveAppData.html | 511 ++
.../AppMasterToMaster$$SaveAppDataFailed$.html | 456 +
.../cluster/AppMasterToMaster$$WorkerData.html | 476 +
.../gearpump/cluster/AppMasterToMaster$.html | 762 ++
...pMasterToWorker$$ChangeExecutorResource.html | 510 ++
.../AppMasterToWorker$$LaunchExecutor.html | 527 ++
.../AppMasterToWorker$$ShutdownExecutor.html | 510 ++
.../gearpump/cluster/AppMasterToWorker$.html | 536 ++
.../Application$$DefaultApplication.html | 559 ++
.../apache/gearpump/cluster/Application$.html | 538 ++
.../apache/gearpump/cluster/Application.html | 545 ++
.../gearpump/cluster/ApplicationMaster.html | 810 ++
.../cluster/ClientToMaster$$AddMaster$.html | 456 +
.../cluster/ClientToMaster$$AddWorker.html | 476 +
.../cluster/ClientToMaster$$CommandResult.html | 510 ++
.../ClientToMaster$$GetJarStoreServer$.html | 456 +
.../cluster/ClientToMaster$$GetLastFailure.html | 477 +
.../ClientToMaster$$GetStallingTasks.html | 479 +
.../ClientToMaster$$JarStoreServerAddress.html | 476 +
.../ClientToMaster$$QueryAppMasterConfig.html | 476 +
.../ClientToMaster$$QueryHistoryMetrics.html | 527 ++
.../ClientToMaster$$QueryMasterConfig$.html | 456 +
.../ClientToMaster$$QueryWorkerConfig.html | 476 +
.../cluster/ClientToMaster$$ReadOption$.html | 571 ++
.../cluster/ClientToMaster$$RemoveMaster.html | 476 +
.../cluster/ClientToMaster$$RemoveWorker.html | 476 +
.../cluster/ClientToMaster$$ResolveAppId.html | 476 +
.../ClientToMaster$$ResolveWorkerId.html | 476 +
.../ClientToMaster$$RestartApplication.html | 476 +
.../ClientToMaster$$ShutdownApplication.html | 476 +
.../ClientToMaster$$SubmitApplication.html | 510 ++
.../gearpump/cluster/ClientToMaster$.html | 811 ++
...lusterConfig$$ConfigValidationException.html | 712 ++
.../cluster/ClusterConfig$$Configs.html | 570 ++
.../apache/gearpump/cluster/ClusterConfig$.html | 718 ++
.../gearpump/cluster/ClusterConfigSource$.html | 523 ++
.../gearpump/cluster/ClusterConfigSource.html | 509 ++
.../gearpump/cluster/ExecutorContext.html | 562 ++
.../gearpump/cluster/ExecutorJVMConfig.html | 592 ++
.../MasterToAppMaster$$AppMasterActivated.html | 476 +
.../MasterToAppMaster$$AppMasterData.html | 612 ++
...ToAppMaster$$AppMasterDataDetailRequest.html | 476 +
...MasterToAppMaster$$AppMasterDataRequest.html | 493 +
...terToAppMaster$$AppMasterMetricsRequest.html | 478 +
.../MasterToAppMaster$$AppMasterRegistered.html | 476 +
.../MasterToAppMaster$$AppMastersData.html | 476 +
...sterToAppMaster$$AppMastersDataRequest$.html | 456 +
...$$ReplayFromTimestampWindowTrailingEdge.html | 476 +
.../MasterToAppMaster$$ResourceAllocated.html | 476 +
.../MasterToAppMaster$$ShutdownAppMaster$.html | 456 +
.../MasterToAppMaster$$StreamingType.html | 485 +
.../cluster/MasterToAppMaster$$WorkerList.html | 476 +
.../gearpump/cluster/MasterToAppMaster$.html | 791 ++
.../MasterToClient$$AppMasterConfig.html | 476 +
.../cluster/MasterToClient$$HistoryMetrics.html | 496 +
.../MasterToClient$$HistoryMetricsItem.html | 493 +
.../cluster/MasterToClient$$LastFailure.html | 493 +
.../cluster/MasterToClient$$MasterConfig.html | 476 +
...MasterToClient$$ReplayApplicationResult.html | 476 +
.../MasterToClient$$ResolveAppIdResult.html | 476 +
.../MasterToClient$$ResolveWorkerIdResult.html | 476 +
...sterToClient$$ShutdownApplicationResult.html | 476 +
...MasterToClient$$SubmitApplicationResult.html | 476 +
...rToClient$$SubmitApplicationResultValue.html | 476 +
.../cluster/MasterToClient$$WorkerConfig.html | 476 +
.../gearpump/cluster/MasterToClient$.html | 692 ++
.../apache/gearpump/cluster/UserConfig$.html | 539 ++
.../org/apache/gearpump/cluster/UserConfig.html | 840 ++
...rkerToAppMaster$$ExecutorLaunchRejected.html | 493 +
...rkerToAppMaster$$ShutdownExecutorFailed.html | 493 +
...kerToAppMaster$$ShutdownExecutorSucceed.html | 493 +
.../gearpump/cluster/WorkerToAppMaster$.html | 536 ++
.../appmaster/AppMasterRuntimeEnvironment$.html | 499 +
.../cluster/appmaster/AppMasterRuntimeInfo.html | 597 ++
.../cluster/appmaster/ApplicationState.html | 613 ++
.../cluster/appmaster/ExecutorSystem.html | 579 ++
...ystemScheduler$$ExecutorSystemJvmConfig.html | 544 ++
...rSystemScheduler$$ExecutorSystemStarted.html | 493 +
...mScheduler$$StartExecutorSystemTimeout$.html | 456 +
...orSystemScheduler$$StartExecutorSystems.html | 493 +
...utorSystemScheduler$$StopExecutorSystem.html | 476 +
.../appmaster/ExecutorSystemScheduler$.html | 570 ++
.../gearpump/cluster/appmaster/WorkerInfo.html | 493 +
.../gearpump/cluster/appmaster/package.html | 208 +
.../gearpump/cluster/client/ClientContext$.html | 569 ++
.../gearpump/cluster/client/ClientContext.html | 729 ++
.../gearpump/cluster/client/MasterClient.html | 588 ++
.../apache/gearpump/cluster/client/package.html | 157 +
.../cluster/main/ArgumentsParser$$Syntax.html | 510 ++
.../gearpump/cluster/main/ArgumentsParser$.html | 521 ++
.../gearpump/cluster/main/ArgumentsParser.html | 587 ++
.../apache/gearpump/cluster/main/CLIOption.html | 510 ++
.../gearpump/cluster/main/ParseResult.html | 587 ++
.../apache/gearpump/cluster/main/package.html | 173 +
.../cluster/master/AppMasterLauncher$.html | 503 ++
.../cluster/master/AppMasterLauncher.html | 943 ++
.../master/AppMasterLauncherFactory.html | 505 ++
.../gearpump/cluster/master/MasterActivity.html | 493 +
.../gearpump/cluster/master/MasterNode.html | 510 ++
.../master/MasterProxy$$MasterRestarted$.html | 456 +
.../master/MasterProxy$$MasterStopped$.html | 456 +
.../master/MasterProxy$$WatchMaster.html | 476 +
.../gearpump/cluster/master/MasterProxy$.html | 555 ++
.../gearpump/cluster/master/MasterProxy.html | 973 ++
.../gearpump/cluster/master/MasterStatus$.html | 536 ++
.../gearpump/cluster/master/MasterSummary.html | 630 ++
.../apache/gearpump/cluster/master/package.html | 261 +
.../org/apache/gearpump/cluster/package.html | 573 ++
.../gearpump/cluster/scheduler/Priority$.html | 805 ++
.../gearpump/cluster/scheduler/Relaxation$.html | 805 ++
.../gearpump/cluster/scheduler/Resource$.html | 522 ++
.../gearpump/cluster/scheduler/Resource.html | 597 ++
.../cluster/scheduler/ResourceAllocation.html | 510 ++
.../cluster/scheduler/ResourceRequest.html | 544 ++
.../gearpump/cluster/scheduler/package.html | 208 +
.../cluster/worker/ExecutorProcessLauncher.html | 539 ++
.../gearpump/cluster/worker/ExecutorSlots.html | 510 ++
.../gearpump/cluster/worker/WorkerId$.html | 556 ++
.../gearpump/cluster/worker/WorkerId.html | 499 +
.../gearpump/cluster/worker/WorkerSummary$.html | 505 ++
.../gearpump/cluster/worker/WorkerSummary.html | 666 ++
.../apache/gearpump/cluster/worker/package.html | 210 +
.../gearpump/external/hbase/HBaseSink$.html | 607 ++
.../gearpump/external/hbase/HBaseSink.html | 686 ++
.../external/hbase/dsl/HBaseDSLSink$.html | 501 +
.../external/hbase/dsl/HBaseDSLSink.html | 538 ++
.../gearpump/external/hbase/dsl/package.html | 138 +
.../apache/gearpump/external/hbase/package.html | 155 +
.../org/apache/gearpump/external/package.html | 118 +
.../org/apache/gearpump/jarstore/FilePath.html | 476 +
.../gearpump/jarstore/JarStoreService$.html | 503 ++
.../gearpump/jarstore/JarStoreService.html | 561 ++
.../org/apache/gearpump/jarstore/package.html | 156 +
.../apache/gearpump/metrics/AkkaReporter.html | 522 ++
.../org/apache/gearpump/metrics/Counter.html | 553 ++
.../org/apache/gearpump/metrics/Histogram.html | 570 ++
.../apache/gearpump/metrics/JvmMetricsSet.html | 523 ++
.../org/apache/gearpump/metrics/Meter.html | 570 ++
.../gearpump/metrics/Metrics$$Counter.html | 495 +
.../metrics/Metrics$$DemandMoreMetrics.html | 476 +
.../gearpump/metrics/Metrics$$DummyMetrics.html | 608 ++
.../apache/gearpump/metrics/Metrics$$Gauge.html | 495 +
.../gearpump/metrics/Metrics$$Histogram.html | 580 ++
.../apache/gearpump/metrics/Metrics$$Meter.html | 546 ++
.../gearpump/metrics/Metrics$$MetricType$.html | 518 ++
.../gearpump/metrics/Metrics$$MetricType.html | 507 ++
.../metrics/Metrics$$ReportMetrics$.html | 456 +
.../apache/gearpump/metrics/Metrics$$Timer.html | 767 ++
.../org/apache/gearpump/metrics/Metrics$.html | 746 ++
.../org/apache/gearpump/metrics/Metrics.html | 611 ++
.../gearpump/metrics/MetricsAggregator.html | 507 ++
.../MetricsReporterService$$ReportTo.html | 505 ++
.../metrics/MetricsReporterService$.html | 504 ++
.../metrics/MetricsReporterService.html | 891 ++
.../org/apache/gearpump/metrics/package.html | 277 +
.../api/scala/org/apache/gearpump/package.html | 369 +
.../partitioner/BroadcastPartitioner.html | 545 ++
.../partitioner/CoLocationPartitioner.html | 547 ++
.../gearpump/partitioner/HashPartitioner.html | 548 ++
.../partitioner/MulticastPartitioner.html | 529 ++
.../gearpump/partitioner/Partitioner$.html | 522 ++
.../gearpump/partitioner/Partitioner.html | 493 +
.../partitioner/PartitionerByClassName.html | 542 ++
.../partitioner/PartitionerDescription.html | 476 +
.../partitioner/PartitionerFactory.html | 522 ++
.../gearpump/partitioner/PartitionerObject.html | 542 ++
.../partitioner/ShuffleGroupingPartitioner.html | 548 ++
.../partitioner/ShufflePartitioner.html | 546 ++
.../partitioner/UnicastPartitioner.html | 531 ++
.../apache/gearpump/partitioner/package.html | 334 +
.../Authenticator$$AuthenticationResult.html | 519 ++
.../gearpump/security/Authenticator$.html | 572 ++
.../apache/gearpump/security/Authenticator.html | 509 ++
.../security/ConfigFileBasedAuthenticator$.html | 484 +
.../security/ConfigFileBasedAuthenticator.html | 531 ++
.../apache/gearpump/security/PasswordUtil$.html | 537 ++
.../org/apache/gearpump/security/package.html | 201 +
.../FastKryoSerializationFramework.html | 544 ++
...oSerializer$$KryoSerializationException.html | 712 ++
.../serializer/FastKryoSerializer$.html | 504 ++
.../gearpump/serializer/FastKryoSerializer.html | 557 ++
.../serializer/GearpumpSerialization.html | 519 ++
.../serializer/SerializationFramework.html | 529 ++
.../apache/gearpump/serializer/Serializer.html | 523 ++
.../org/apache/gearpump/serializer/package.html | 209 +
.../streaming/AckRequestSerializer.html | 572 ++
.../gearpump/streaming/AckSerializer.html | 572 ++
.../AppMasterToExecutor$$ChangeTask.html | 527 ++
.../AppMasterToExecutor$$ChangeTasks.html | 528 ++
.../AppMasterToExecutor$$LaunchTasks.html | 527 ++
.../AppMasterToExecutor$$MsgLostException.html | 712 ++
...pMasterToExecutor$$RestartClockService$.html | 456 +
.../AppMasterToExecutor$$StartAllTasks.html | 476 +
.../AppMasterToExecutor$$StartDynamicDag.html | 476 +
.../AppMasterToExecutor$$StartTask.html | 476 +
.../AppMasterToExecutor$$StopTask.html | 476 +
.../AppMasterToExecutor$$TaskChanged.html | 493 +
...AppMasterToExecutor$$TaskLocationsReady.html | 493 +
...MasterToExecutor$$TaskLocationsReceived.html | 493 +
...MasterToExecutor$$TaskLocationsRejected.html | 527 ++
.../AppMasterToExecutor$$TaskRegistered.html | 510 ++
.../AppMasterToExecutor$$TaskRejected.html | 476 +
.../AppMasterToExecutor$$TasksChanged.html | 476 +
.../AppMasterToExecutor$$TasksLaunched$.html | 456 +
.../streaming/AppMasterToExecutor$.html | 774 ++
.../AppMasterToMaster$$StallingTasks.html | 476 +
.../gearpump/streaming/AppMasterToMaster$.html | 502 ++
.../apache/gearpump/streaming/Constants$.html | 635 ++
.../org/apache/gearpump/streaming/DAG$.html | 522 ++
.../org/apache/gearpump/streaming/DAG.html | 564 ++
.../ExecutorToAppMaster$$MessageLoss.html | 510 ++
.../ExecutorToAppMaster$$RegisterExecutor.html | 527 ++
.../ExecutorToAppMaster$$RegisterTask.html | 510 ++
.../ExecutorToAppMaster$$UnRegisterTask.html | 493 +
.../streaming/ExecutorToAppMaster$.html | 553 ++
.../streaming/InitialAckRequestSerializer.html | 572 ++
.../streaming/LatencyProbeSerializer.html | 555 ++
.../apache/gearpump/streaming/LifeTime$.html | 505 ++
.../org/apache/gearpump/streaming/LifeTime.html | 531 ++
.../streaming/Processor$$DefaultProcessor.html | 622 ++
.../apache/gearpump/streaming/Processor$.html | 555 ++
.../apache/gearpump/streaming/Processor.html | 563 ++
.../streaming/ProcessorDescription.html | 614 ++
.../gearpump/streaming/StreamApplication$.html | 518 ++
.../gearpump/streaming/StreamApplication.html | 596 ++
.../gearpump/streaming/TaskIdSerializer.html | 555 ++
.../AppMaster$$AllocateResourceTimeOut$.html | 456 +
.../appmaster/AppMaster$$ExecutorBrief.html | 527 ++
.../AppMaster$$LookupTaskActorRef.html | 476 +
...AppMaster$$ServiceNotAvailableException.html | 712 ++
.../appmaster/AppMaster$$TaskActorRef.html | 476 +
.../streaming/appmaster/AppMaster$.html | 572 ++
.../gearpump/streaming/appmaster/AppMaster.html | 896 ++
.../appmaster/ClockService$$ChangeToNewDAG.html | 476 +
.../ClockService$$ChangeToNewDAGSuccess.html | 476 +
.../appmaster/ClockService$$HealthCheck$.html | 456 +
...ClockService$$HealthChecker$$ClockValue.html | 510 ++
.../appmaster/ClockService$$HealthChecker$.html | 504 ++
.../appmaster/ClockService$$HealthChecker.html | 539 ++
.../appmaster/ClockService$$ProcessorClock.html | 638 ++
.../ClockService$$ProcessorClocks$.html | 499 +
.../appmaster/ClockService$$Report.html | 476 +
.../ClockService$$SnapshotStartClock$.html | 456 +
.../ClockService$$StoredStartClock.html | 476 +
.../streaming/appmaster/ClockService$.html | 675 ++
.../streaming/appmaster/ClockService.html | 881 ++
.../appmaster/DagManager$$DAGOperation.html | 485 +
.../DagManager$$DAGOperationFailed.html | 478 +
.../DagManager$$DAGOperationResult.html | 485 +
.../DagManager$$DAGOperationSuccess$.html | 458 +
.../appmaster/DagManager$$DagInitiated$.html | 456 +
.../appmaster/DagManager$$GetLatestDAG$.html | 456 +
.../DagManager$$GetTaskLaunchData.html | 510 ++
.../appmaster/DagManager$$LatestDAG.html | 476 +
.../appmaster/DagManager$$NewDAGDeployed.html | 476 +
.../appmaster/DagManager$$ReplaceProcessor.html | 512 ++
.../appmaster/DagManager$$TaskLaunchData.html | 510 ++
.../appmaster/DagManager$$WatchChange.html | 476 +
.../streaming/appmaster/DagManager$.html | 691 ++
.../streaming/appmaster/DagManager.html | 865 ++
.../appmaster/JarScheduler$$ExecutorFailed.html | 476 +
...arScheduler$$GetResourceRequestDetails$.html | 456 +
.../JarScheduler$$JarSchedulerImpl.html | 867 ++
.../appmaster/JarScheduler$$NewDag.html | 493 +
.../JarScheduler$$ResourceRequestDetail.html | 493 +
.../appmaster/JarScheduler$$ScheduleTask.html | 528 ++
.../JarScheduler$$TransitToNewDag$.html | 456 +
.../streaming/appmaster/JarScheduler$.html | 607 ++
.../streaming/appmaster/JarScheduler.html | 578 ++
.../streaming/appmaster/ProcessorSummary.html | 595 ++
.../appmaster/StreamAppMasterSummary.html | 733 ++
.../gearpump/streaming/appmaster/TaskCount.html | 476 +
.../appmaster/TaskLocator$$Localities$.html | 539 ++
.../appmaster/TaskLocator$$Localities.html | 478 +
.../appmaster/TaskLocator$$Locality.html | 485 +
.../appmaster/TaskLocator$$NonLocality$.html | 484 +
.../appmaster/TaskLocator$$WorkerLocality.html | 478 +
.../streaming/appmaster/TaskLocator$.html | 572 ++
.../streaming/appmaster/TaskLocator.html | 523 ++
.../appmaster/TaskRegistry$$Accept$.html | 458 +
.../TaskRegistry$$RegisterTaskStatus.html | 485 +
.../appmaster/TaskRegistry$$Reject$.html | 458 +
.../appmaster/TaskRegistry$$TaskLocation.html | 493 +
.../appmaster/TaskRegistry$$TaskLocations.html | 476 +
.../streaming/appmaster/TaskRegistry$.html | 572 ++
.../streaming/appmaster/TaskRegistry.html | 730 ++
.../appmaster/TaskScheduler$$Location.html | 493 +
.../appmaster/TaskScheduler$$TaskStatus.html | 553 ++
.../streaming/appmaster/TaskScheduler$.html | 521 ++
.../streaming/appmaster/TaskScheduler.html | 588 ++
.../streaming/appmaster/TaskSchedulerImpl.html | 600 ++
.../gearpump/streaming/appmaster/package.html | 425 +
.../streaming/dsl/CollectionDataSource.html | 567 ++
.../apache/gearpump/streaming/dsl/KVStream.html | 537 ++
.../gearpump/streaming/dsl/LoggerSink.html | 582 ++
.../gearpump/streaming/dsl/Stream$$Sink.html | 538 ++
.../apache/gearpump/streaming/dsl/Stream$.html | 572 ++
.../apache/gearpump/streaming/dsl/Stream.html | 653 ++
.../streaming/dsl/StreamApp$$Source.html | 606 ++
.../gearpump/streaming/dsl/StreamApp$.html | 538 ++
.../gearpump/streaming/dsl/StreamApp.html | 580 ++
.../streaming/dsl/javaapi/JavaStream.html | 658 ++
.../streaming/dsl/javaapi/JavaStreamApp.html | 553 ++
.../gearpump/streaming/dsl/javaapi/package.html | 136 +
.../gearpump/streaming/dsl/op/DataSinkOp.html | 533 ++
.../gearpump/streaming/dsl/op/DataSourceOp.html | 533 ++
.../gearpump/streaming/dsl/op/Direct$.html | 460 +
.../gearpump/streaming/dsl/op/FlatMapOp.html | 514 ++
.../gearpump/streaming/dsl/op/GroupByOp.html | 533 ++
.../gearpump/streaming/dsl/op/MasterOp.html | 524 ++
.../gearpump/streaming/dsl/op/MergeOp.html | 497 +
.../apache/gearpump/streaming/dsl/op/Op.html | 523 ++
.../gearpump/streaming/dsl/op/OpChain.html | 547 ++
.../gearpump/streaming/dsl/op/OpEdge.html | 485 +
.../streaming/dsl/op/ParameterizedOp.html | 526 ++
.../gearpump/streaming/dsl/op/ProcessorOp.html | 533 ++
.../gearpump/streaming/dsl/op/ReduceOp.html | 514 ++
.../gearpump/streaming/dsl/op/Shuffle$.html | 460 +
.../gearpump/streaming/dsl/op/SlaveOp.html | 526 ++
.../gearpump/streaming/dsl/op/package.html | 366 +
.../apache/gearpump/streaming/dsl/package.html | 299 +
.../dsl/partitioner/GroupByPartitioner.html | 552 ++
.../streaming/dsl/partitioner/package.html | 124 +
.../dsl/plan/OpTranslator$$AndThen.html | 559 ++
.../plan/OpTranslator$$DummyInputFunction.html | 559 ++
.../dsl/plan/OpTranslator$$FlatMapFunction.html | 559 ++
.../dsl/plan/OpTranslator$$GroupByTask.html | 667 ++
.../dsl/plan/OpTranslator$$ReduceFunction.html | 559 ++
.../plan/OpTranslator$$SingleInputFunction.html | 543 ++
.../dsl/plan/OpTranslator$$SinkTask.html | 667 ++
.../dsl/plan/OpTranslator$$SourceTask.html | 667 ++
.../dsl/plan/OpTranslator$$TransformTask.html | 667 ++
.../streaming/dsl/plan/OpTranslator$.html | 644 ++
.../streaming/dsl/plan/OpTranslator.html | 541 ++
.../gearpump/streaming/dsl/plan/Planner.html | 519 ++
.../gearpump/streaming/dsl/plan/package.html | 156 +
.../Executor$$DagVersionMismatchException.html | 712 ++
.../executor/Executor$$ExecutorConfig.html | 476 +
.../executor/Executor$$ExecutorSummary$.html | 505 ++
.../executor/Executor$$ExecutorSummary.html | 597 ++
.../executor/Executor$$GetExecutorSummary.html | 476 +
.../executor/Executor$$HealthCheck$.html | 482 +
.../executor/Executor$$QueryExecutorConfig.html | 476 +
.../executor/Executor$$RestartTasks.html | 476 +
.../streaming/executor/Executor$$State$.html | 550 ++
.../executor/Executor$$TaskArgumentStore.html | 571 ++
.../executor/Executor$$TaskStopped.html | 476 +
.../gearpump/streaming/executor/Executor$.html | 674 ++
.../gearpump/streaming/executor/Executor.html | 996 ++
.../executor/ExecutorRestartPolicy.html | 540 ++
.../streaming/executor/ITaskLauncher.html | 505 ++
.../executor/TaskLauncher$$TaskArgument.html | 510 ++
.../streaming/executor/TaskLauncher$.html | 521 ++
.../streaming/executor/TaskLauncher.html | 523 ++
.../gearpump/streaming/executor/package.html | 208 +
.../hadoop/HadoopCheckpointStore$.html | 501 +
.../streaming/hadoop/HadoopCheckpointStore.html | 573 ++
.../hadoop/HadoopCheckpointStoreFactory$.html | 505 ++
.../hadoop/HadoopCheckpointStoreFactory.html | 525 ++
.../streaming/hadoop/SequenceFileSink.html | 559 ++
.../hadoop/lib/HadoopCheckpointStoreReader.html | 2027 +++++
.../hadoop/lib/HadoopCheckpointStoreWriter.html | 536 ++
.../lib/format/DefaultSequenceFormatter.html | 576 ++
.../hadoop/lib/format/OutputFormatter.html | 560 ++
.../streaming/hadoop/lib/format/package.html | 135 +
.../gearpump/streaming/hadoop/lib/package.html | 172 +
.../hadoop/lib/rotation/FileSizeRotation.html | 529 ++
.../streaming/hadoop/lib/rotation/Rotation.html | 543 ++
.../streaming/hadoop/lib/rotation/package.html | 135 +
.../gearpump/streaming/hadoop/package.html | 209 +
.../gearpump/streaming/javaapi/Graph.html | 950 ++
.../gearpump/streaming/javaapi/Processor.html | 682 ++
.../streaming/javaapi/StreamApplication.html | 579 ++
.../apache/gearpump/streaming/javaapi/Task.html | 650 ++
.../javaapi/dsl/functions/FilterFunction.html | 504 ++
.../javaapi/dsl/functions/FlatMapFunction.html | 504 ++
.../javaapi/dsl/functions/GroupByFunction.html | 504 ++
.../javaapi/dsl/functions/MapFunction.html | 504 ++
.../javaapi/dsl/functions/ReduceFunction.html | 504 ++
.../javaapi/dsl/functions/package.html | 186 +
.../gearpump/streaming/javaapi/dsl/package.html | 118 +
.../gearpump/streaming/javaapi/package.html | 189 +
.../gearpump/streaming/kafka/KafkaSink.html | 567 ++
.../gearpump/streaming/kafka/KafkaSource.html | 624 ++
.../streaming/kafka/KafkaStoreFactory.html | 525 ++
.../gearpump/streaming/kafka/dsl/KafkaDSL$.html | 535 ++
.../gearpump/streaming/kafka/dsl/KafkaDSL.html | 521 ++
.../gearpump/streaming/kafka/dsl/package.html | 138 +
.../gearpump/streaming/kafka/lib/package.html | 169 +
...AbstractKafkaSink$$KafkaProducerFactory.html | 504 ++
.../kafka/lib/sink/AbstractKafkaSink$.html | 525 ++
.../kafka/lib/sink/AbstractKafkaSink.html | 572 ++
.../streaming/kafka/lib/sink/package.html | 140 +
.../kafka/lib/source/AbstractKafkaSource$.html | 488 +
.../kafka/lib/source/AbstractKafkaSource.html | 637 ++
.../kafka/lib/source/DefaultMessageDecoder.html | 523 ++
.../kafka/lib/source/StringMessageDecoder.html | 523 ++
.../FetchThread$$FetchThreadFactory.html | 521 ++
.../kafka/lib/source/consumer/FetchThread$.html | 536 ++
.../lib/source/consumer/KafkaConsumer$.html | 501 +
.../lib/source/consumer/KafkaConsumer.html | 591 ++
.../kafka/lib/source/consumer/KafkaMessage.html | 544 ++
.../kafka/lib/source/consumer/package.html | 173 +
.../source/grouper/DefaultPartitionGrouper.html | 524 ++
.../lib/source/grouper/PartitionGrouper.html | 506 ++
.../kafka/lib/source/grouper/package.html | 139 +
.../streaming/kafka/lib/source/package.html | 217 +
.../lib/store/AbstractKafkaStoreFactory.html | 544 ++
.../streaming/kafka/lib/store/KafkaStore$.html | 484 +
.../streaming/kafka/lib/store/KafkaStore.html | 589 ++
.../streaming/kafka/lib/store/package.html | 157 +
.../util/KafkaClient$$KafkaClientFactory.html | 521 ++
.../streaming/kafka/lib/util/KafkaClient$.html | 521 ++
.../streaming/kafka/lib/util/KafkaClient.html | 608 ++
.../streaming/kafka/lib/util/package.html | 138 +
.../gearpump/streaming/kafka/package.html | 206 +
.../streaming/kafka/util/KafkaConfig.html | 795 ++
.../gearpump/streaming/kafka/util/package.html | 118 +
.../ProcessorAggregator$$Aggregator.html | 522 ++
.../ProcessorAggregator$$AggregatorFactory.html | 519 ++
...rocessorAggregator$$HistogramAggregator.html | 674 ++
.../ProcessorAggregator$$MeterAggregator.html | 623 ++
.../ProcessorAggregator$$MultiLayerMap.html | 572 ++
.../streaming/metrics/ProcessorAggregator$.html | 591 ++
.../streaming/metrics/ProcessorAggregator.html | 566 ++
.../metrics/TaskFilterAggregator$$Options$.html | 522 ++
.../metrics/TaskFilterAggregator$$Options.html | 546 ++
.../metrics/TaskFilterAggregator$.html | 674 ++
.../streaming/metrics/TaskFilterAggregator.html | 559 ++
.../gearpump/streaming/metrics/package.html | 178 +
.../streaming/monoid/AlgebirdGroup.html | 559 ++
.../streaming/monoid/AlgebirdMonoid.html | 540 ++
.../gearpump/streaming/monoid/package.html | 135 +
.../org/apache/gearpump/streaming/package.html | 762 ++
.../streaming/serializer/ChillSerializer.html | 540 ++
.../gearpump/streaming/serializer/package.html | 118 +
.../gearpump/streaming/sink/DataSink.html | 558 ++
.../streaming/sink/DataSinkProcessor$.html | 504 ++
.../gearpump/streaming/sink/DataSinkTask$.html | 501 +
.../gearpump/streaming/sink/DataSinkTask.html | 653 ++
.../apache/gearpump/streaming/sink/package.html | 191 +
.../gearpump/streaming/source/DataSource.html | 562 ++
.../streaming/source/DataSourceConfig$.html | 499 +
.../streaming/source/DataSourceProcessor$.html | 504 ++
.../streaming/source/DataSourceTask$.html | 501 +
.../streaming/source/DataSourceTask.html | 655 ++
.../source/DefaultTimeStampFilter.html | 524 ++
.../gearpump/streaming/source/package.html | 230 +
.../gearpump/streaming/state/api/Group.html | 543 ++
.../gearpump/streaming/state/api/Monoid.html | 524 ++
.../streaming/state/api/MonoidState.html | 650 ++
.../streaming/state/api/PersistentState.html | 585 ++
.../streaming/state/api/PersistentTask$.html | 518 ++
.../streaming/state/api/PersistentTask.html | 779 ++
.../streaming/state/api/Serializer.html | 524 ++
.../gearpump/streaming/state/api/package.html | 231 +
.../streaming/state/impl/CheckpointManager.html | 604 ++
.../state/impl/InMemoryCheckpointStore.html | 557 ++
.../impl/InMemoryCheckpointStoreFactory.html | 523 ++
.../gearpump/streaming/state/impl/Interval.html | 600 ++
.../streaming/state/impl/NonWindowState$.html | 501 +
.../streaming/state/impl/NonWindowState.html | 646 ++
.../state/impl/PersistentStateConfig$.html | 567 ++
.../gearpump/streaming/state/impl/Window.html | 640 ++
.../streaming/state/impl/WindowConfig$.html | 505 ++
.../streaming/state/impl/WindowConfig.html | 495 +
.../streaming/state/impl/WindowState$.html | 501 +
.../streaming/state/impl/WindowState.html | 649 ++
.../gearpump/streaming/state/impl/package.html | 319 +
.../gearpump/streaming/state/package.html | 135 +
.../streaming/storage/AppDataStore.html | 523 ++
.../storage/InMemoryAppStoreOnMaster.html | 556 ++
.../gearpump/streaming/storage/package.html | 136 +
.../org/apache/gearpump/streaming/task/Ack.html | 531 ++
.../gearpump/streaming/task/AckRequest.html | 510 ++
.../streaming/task/CheckProcessorDeath.html | 476 +
.../streaming/task/CheckpointClock.html | 476 +
.../gearpump/streaming/task/ClockEvent.html | 485 +
.../streaming/task/ExpressTransport.html | 589 ++
.../streaming/task/GetCheckpointClock$.html | 458 +
.../apache/gearpump/streaming/task/GetDAG$.html | 456 +
.../streaming/task/GetLatestMinClock$.html | 484 +
.../gearpump/streaming/task/GetStartClock$.html | 456 +
.../streaming/task/GetUpstreamMinClock.html | 478 +
.../streaming/task/InitialAckRequest.html | 493 +
.../gearpump/streaming/task/LatencyProbe.html | 476 +
.../gearpump/streaming/task/LatestMinClock.html | 476 +
.../streaming/task/SendMessageLoss.html | 459 +
.../streaming/task/SerializedMessage.html | 493 +
.../task/SerializedMessageSerializer.html | 555 ++
.../task/SerializerResolver$$Registration.html | 553 ++
.../streaming/task/SerializerResolver$.html | 502 ++
.../gearpump/streaming/task/StartClock.html | 476 +
.../gearpump/streaming/task/StartTime.html | 476 +
.../task/StreamingTransportSerializer.html | 555 ++
.../gearpump/streaming/task/Subscriber$.html | 507 ++
.../gearpump/streaming/task/Subscriber.html | 531 ++
.../gearpump/streaming/task/Subscription$.html | 518 ++
.../gearpump/streaming/task/Subscription.html | 645 ++
.../apache/gearpump/streaming/task/Task.html | 651 ++
.../streaming/task/TaskActor$$FLUSH$.html | 456 +
.../task/TaskActor$$MessageAndSender.html | 493 +
.../task/TaskActor$$SecurityChecker.html | 553 ++
.../streaming/task/TaskActor$$SendAck.html | 493 +
.../gearpump/streaming/task/TaskActor$.html | 589 ++
.../gearpump/streaming/task/TaskActor.html | 1276 +++
.../gearpump/streaming/task/TaskContext.html | 775 ++
.../streaming/task/TaskContextData.html | 578 ++
.../apache/gearpump/streaming/task/TaskId$.html | 522 ++
.../apache/gearpump/streaming/task/TaskId.html | 495 +
.../gearpump/streaming/task/TaskInterface.html | 563 ++
.../streaming/task/TaskMessageSerializer.html | 539 ++
.../gearpump/streaming/task/TaskUtil$.html | 500 +
.../gearpump/streaming/task/TaskWrapper.html | 924 ++
.../streaming/task/UpdateCheckpointClock.html | 495 +
.../gearpump/streaming/task/UpdateClock.html | 495 +
.../streaming/task/UpstreamMinClock.html | 476 +
.../apache/gearpump/streaming/task/package.html | 778 ++
.../transaction/api/CheckpointStore.html | 542 ++
.../transaction/api/CheckpointStoreFactory.html | 508 ++
.../transaction/api/MessageDecoder.html | 509 ++
.../transaction/api/TimeReplayableSource.html | 574 ++
.../transaction/api/TimeStampFilter.html | 508 ++
.../streaming/transaction/api/package.html | 194 +
.../gearpump/streaming/transaction/package.html | 118 +
.../gearpump/streaming/util/ActorPathUtil$.html | 550 ++
.../apache/gearpump/streaming/util/package.html | 118 +
.../gearpump/transport/ActorLookupById.html | 505 ++
.../org/apache/gearpump/transport/Express$.html | 573 ++
.../org/apache/gearpump/transport/Express.html | 782 ++
.../apache/gearpump/transport/HostPort$.html | 505 ++
.../org/apache/gearpump/transport/HostPort.html | 512 ++
.../netty/Client$$ChannelFutureOps.html | 536 ++
.../transport/netty/Client$$ChannelReady.html | 476 +
.../netty/Client$$ClientErrorHandler.html | 801 ++
.../netty/Client$$ClientPipelineFactory.html | 521 ++
.../transport/netty/Client$$Close$.html | 456 +
.../Client$$CompareAndReconnectIfEqual.html | 476 +
.../transport/netty/Client$$Connect.html | 476 +
.../gearpump/transport/netty/Client$$Flush.html | 476 +
.../gearpump/transport/netty/Client$.html | 657 ++
.../apache/gearpump/transport/netty/Client.html | 886 ++
.../gearpump/transport/netty/Context$.html | 484 +
.../gearpump/transport/netty/Context.html | 596 ++
.../gearpump/transport/netty/IContext.html | 541 ++
.../netty/ITransportMessageSerializer.html | 539 ++
.../gearpump/transport/netty/MessageBatch.html | 482 +
.../transport/netty/MessageDecoder.html | 1204 +++
.../transport/netty/MessageEncoder.html | 571 ++
.../gearpump/transport/netty/NettyConfig.html | 621 ++
.../netty/NettyRenameThreadFactory.html | 501 +
.../gearpump/transport/netty/NettyUtil$.html | 533 ++
.../transport/netty/Server$$AddChannel.html | 476 +
.../transport/netty/Server$$CloseChannel.html | 476 +
.../transport/netty/Server$$MsgBatch.html | 476 +
.../transport/netty/Server$$ServerHandler.html | 789 ++
.../netty/Server$$ServerPipelineFactory.html | 521 ++
.../Server$$TaskIdActorRefTranslation.html | 519 ++
.../gearpump/transport/netty/Server$.html | 589 ++
.../apache/gearpump/transport/netty/Server.html | 867 ++
.../gearpump/transport/netty/TaskMessage.html | 570 ++
.../transport/netty/WrappedChannelBuffer.html | 793 ++
.../gearpump/transport/netty/package.html | 378 +
.../org/apache/gearpump/transport/package.html | 208 +
.../util/ActorSystemBooter$$ActorCreated.html | 493 +
...ctorSystemBooter$$ActorSystemRegistered.html | 478 +
.../util/ActorSystemBooter$$BindLifeCycle.html | 476 +
.../util/ActorSystemBooter$$CreateActor.html | 493 +
.../ActorSystemBooter$$CreateActorFailed.html | 493 +
.../util/ActorSystemBooter$$Daemon.html | 933 ++
.../ActorSystemBooter$$RegisterActorSystem.html | 476 +
...SystemBooter$$RegisterActorSystemFailed.html | 476 +
...stemBooter$$RegisterActorSystemTimeOut$.html | 482 +
.../gearpump/util/ActorSystemBooter$.html | 676 ++
.../apache/gearpump/util/ActorSystemBooter.html | 523 ++
.../org/apache/gearpump/util/ActorUtil$.html | 703 ++
.../scala/org/apache/gearpump/util/AkkaApp.html | 574 ++
.../org/apache/gearpump/util/AkkaHelper.html | 502 ++
.../org/apache/gearpump/util/ConsoleOutput.html | 522 ++
.../org/apache/gearpump/util/Constants$.html | 1978 ++++
.../org/apache/gearpump/util/FileUtils$.html | 567 ++
.../org/apache/gearpump/util/Graph$$Node.html | 555 ++
.../apache/gearpump/util/Graph$$NodeList.html | 555 ++
.../org/apache/gearpump/util/Graph$$Path$.html | 501 +
.../org/apache/gearpump/util/Graph$$Path.html | 558 ++
.../scala/org/apache/gearpump/util/Graph$.html | 634 ++
.../scala/org/apache/gearpump/util/Graph.html | 925 ++
.../gearpump/util/HadoopFSLogAppender.html | 1330 +++
...toryMetricsService$$CounterMetricsStore.html | 572 ++
...etricsService$$DummyHistoryMetricsStore.html | 589 ++
...yMetricsService$$DummyMetricsAggregator.html | 521 ++
...istoryMetricsService$$GaugeMetricsStore.html | 572 ++
...ryMetricsService$$HistogramMetricsStore.html | 572 ++
...ryMetricsService$$HistoryMetricsConfig$.html | 505 ++
...oryMetricsService$$HistoryMetricsConfig.html | 536 ++
...oryMetricsService$$HistoryMetricsStore$.html | 501 +
...toryMetricsService$$HistoryMetricsStore.html | 558 ++
...istoryMetricsService$$MeterMetricsStore.html | 572 ++
.../HistoryMetricsService$$MetricsStore.html | 539 ++
...MetricsService$$SingleValueMetricsStore.html | 574 ++
...istoryMetricsService$$SkipAllAggregator.html | 521 ++
.../gearpump/util/HistoryMetricsService$.html | 712 ++
.../gearpump/util/HistoryMetricsService.html | 859 ++
.../gearpump/util/LogUtil$$ProcessType$.html | 837 ++
.../org/apache/gearpump/util/LogUtil$.html | 601 ++
.../gearpump/util/ProcessLogRedirector.html | 631 ++
.../util/RecreateRollingFileAppender.html | 1364 +++
.../apache/gearpump/util/ReferenceEqual.html | 486 +
.../org/apache/gearpump/util/RestartPolicy.html | 523 ++
.../org/apache/gearpump/util/RichProcess.html | 555 ++
.../apache/gearpump/util/TimeOutScheduler.html | 502 ++
.../gearpump/util/Util$$AppJvmSettings.html | 493 +
.../apache/gearpump/util/Util$$JvmSetting.html | 493 +
.../scala/org/apache/gearpump/util/Util$.html | 740 ++
.../scala/org/apache/gearpump/util/package.html | 468 +
.../0.8.1/api/scala/org/apache/package.html | 118 +
releases/0.8.1/api/scala/org/package.html | 118 +
releases/0.8.1/api/scala/package.html | 135 +
releases/0.8.1/basic-concepts.html | 218 +
releases/0.8.1/coding-style.html | 176 +
releases/0.8.1/commandline.html | 238 +
releases/0.8.1/css/api-docs.css | 35 +
releases/0.8.1/css/api-javadocs.css | 52 +
releases/0.8.1/css/bootstrap-3.3.5.min.css | 5 +
releases/0.8.1/css/main.css | 127 +
releases/0.8.1/css/pygments-default.css | 76 +
releases/0.8.1/deployment-configuration.html | 399 +
releases/0.8.1/deployment-docker.html | 174 +
releases/0.8.1/deployment-ha.html | 230 +
releases/0.8.1/deployment-local.html | 202 +
releases/0.8.1/deployment-msg-delivery.html | 234 +
.../0.8.1/deployment-resource-isolation.html | 301 +
releases/0.8.1/deployment-security.html | 256 +
releases/0.8.1/deployment-standalone.html | 246 +
.../0.8.1/deployment-ui-authentication.html | 554 ++
releases/0.8.1/deployment-yarn.html | 320 +
releases/0.8.1/dev-connectors.html | 523 ++
releases/0.8.1/dev-custom-serializer.html | 293 +
releases/0.8.1/dev-ide-setup.html | 201 +
releases/0.8.1/dev-non-streaming-example.html | 296 +
releases/0.8.1/dev-rest-api.html | 1204 +++
releases/0.8.1/dev-storm.html | 472 +
releases/0.8.1/dev-write-1st-app.html | 560 ++
releases/0.8.1/faq.html | 208 +
releases/0.8.1/features.html | 239 +
.../fonts/glyphicons-halflings-regular.eot | Bin 0 -> 20127 bytes
.../fonts/glyphicons-halflings-regular.svg | 288 +
.../fonts/glyphicons-halflings-regular.ttf | Bin 0 -> 45404 bytes
.../fonts/glyphicons-halflings-regular.woff | Bin 0 -> 23424 bytes
.../fonts/glyphicons-halflings-regular.woff2 | Bin 0 -> 18028 bytes
releases/0.8.1/gearpump-internals.html | 402 +
releases/0.8.1/get-gearpump-distribution.html | 261 +
releases/0.8.1/hardware-requirement.html | 252 +
releases/0.8.1/img/actor_hierarchy.png | Bin 0 -> 109855 bytes
releases/0.8.1/img/checkpoint_equation.png | Bin 0 -> 1663 bytes
.../0.8.1/img/checkpoint_interval_equation.png | Bin 0 -> 16637 bytes
releases/0.8.1/img/checkpointing.png | Bin 0 -> 104471 bytes
releases/0.8.1/img/checkpointing_interval.png | Bin 0 -> 44284 bytes
releases/0.8.1/img/clock.png | Bin 0 -> 33147 bytes
releases/0.8.1/img/dag.png | Bin 0 -> 18263 bytes
releases/0.8.1/img/dashboard.gif | Bin 0 -> 152314 bytes
releases/0.8.1/img/dashboard.png | Bin 0 -> 29434 bytes
releases/0.8.1/img/dashboard_3.png | Bin 0 -> 42684 bytes
releases/0.8.1/img/download.jpg | Bin 0 -> 3999 bytes
releases/0.8.1/img/dynamic.png | Bin 0 -> 40091 bytes
releases/0.8.1/img/exact.png | Bin 0 -> 104471 bytes
releases/0.8.1/img/failures.png | Bin 0 -> 95078 bytes
releases/0.8.1/img/flow_control.png | Bin 0 -> 61928 bytes
releases/0.8.1/img/flowcontrol.png | Bin 0 -> 61928 bytes
releases/0.8.1/img/ha.png | Bin 0 -> 47152 bytes
releases/0.8.1/img/kafka_wordcount.png | Bin 0 -> 14520 bytes
releases/0.8.1/img/layout.png | Bin 0 -> 126947 bytes
releases/0.8.1/img/logo.png | Bin 0 -> 2053 bytes
releases/0.8.1/img/logo.svg | 71 +
releases/0.8.1/img/logo2.png | Bin 0 -> 7970 bytes
releases/0.8.1/img/messageLoss.png | Bin 0 -> 37166 bytes
releases/0.8.1/img/netty_transport.png | Bin 0 -> 65010 bytes
releases/0.8.1/img/replay.png | Bin 0 -> 37255 bytes
releases/0.8.1/img/shuffle.png | Bin 0 -> 23550 bytes
releases/0.8.1/img/storm_gearpump_cluster.png | Bin 0 -> 30930 bytes
releases/0.8.1/img/storm_gearpump_dag.png | Bin 0 -> 54000 bytes
releases/0.8.1/img/submit.png | Bin 0 -> 32954 bytes
releases/0.8.1/img/submit2.png | Bin 0 -> 51933 bytes
releases/0.8.1/img/through_vs_message_size.png | Bin 0 -> 20965 bytes
releases/0.8.1/index.html | 204 +
releases/0.8.1/js/api-docs.js | 43 +
releases/0.8.1/js/api-javadocs.js | 60 +
releases/0.8.1/js/main.js | 108 +
releases/0.8.1/js/vendor/anchor-1.1.1.min.js | 6 +
releases/0.8.1/js/vendor/bootstrap-3.3.5.min.js | 7 +
releases/0.8.1/js/vendor/jquery-2.1.4.min.js | 5 +
.../vendor/modernizr-2.6.1-respond-1.1.0.min.js | 11 +
releases/0.8.1/maven-setting.html | 264 +
releases/0.8.1/message-delivery.html | 218 +
releases/0.8.1/performance-report.html | 204 +
releases/0.8.1/submit-your-1st-application.html | 209 +
releases/latest/about.html | 190 -
releases/latest/api/java/allclasses-frame.html | 1104 ++-
.../latest/api/java/allclasses-noframe.html | 1104 ++-
releases/latest/api/java/constant-values.html | 159 +-
releases/latest/api/java/deprecated-list.html | 4 +-
releases/latest/api/java/help-doc.html | 4 +-
releases/latest/api/java/index-all.html | 8521 +++++++++++++-----
releases/latest/api/java/index.html | 2 +-
.../streaming/AckRequestSerializer.html | 327 -
.../io/gearpump/streaming/AckSerializer.html | 327 -
.../streaming/AppMasterToExecutor$.html | 274 -
.../AppMasterToExecutor.ChangeTask$.html | 306 -
.../AppMasterToExecutor.ChangeTask.html | 341 -
.../AppMasterToExecutor.ChangeTasks$.html | 306 -
.../AppMasterToExecutor.ChangeTasks.html | 342 -
.../AppMasterToExecutor.LaunchTasks$.html | 306 -
.../AppMasterToExecutor.LaunchTasks.html | 341 -
.../AppMasterToExecutor.MsgLostException.html | 264 -
...ppMasterToExecutor.RestartClockService$.html | 301 -
.../AppMasterToExecutor.StartAllTasks$.html | 306 -
.../AppMasterToExecutor.StartAllTasks.html | 296 -
.../AppMasterToExecutor.StartDynamicDag$.html | 306 -
.../AppMasterToExecutor.StartDynamicDag.html | 296 -
.../AppMasterToExecutor.StartTask$.html | 306 -
.../AppMasterToExecutor.StartTask.html | 296 -
.../AppMasterToExecutor.StopTask$.html | 306 -
.../streaming/AppMasterToExecutor.StopTask.html | 296 -
.../AppMasterToExecutor.TaskChanged$.html | 306 -
.../AppMasterToExecutor.TaskChanged.html | 311 -
...AppMasterToExecutor.TaskLocationsReady$.html | 306 -
.../AppMasterToExecutor.TaskLocationsReady.html | 311 -
...MasterToExecutor.TaskLocationsReceived$.html | 306 -
...pMasterToExecutor.TaskLocationsReceived.html | 311 -
...MasterToExecutor.TaskLocationsRejected$.html | 306 -
...pMasterToExecutor.TaskLocationsRejected.html | 341 -
.../AppMasterToExecutor.TaskRegistered$.html | 306 -
.../AppMasterToExecutor.TaskRegistered.html | 326 -
.../AppMasterToExecutor.TaskRejected$.html | 306 -
.../AppMasterToExecutor.TaskRejected.html | 296 -
.../AppMasterToExecutor.TasksChanged$.html | 306 -
.../AppMasterToExecutor.TasksChanged.html | 296 -
.../AppMasterToExecutor.TasksLaunched$.html | 301 -
.../gearpump/streaming/AppMasterToExecutor.html | 376 -
.../gearpump/streaming/AppMasterToMaster$.html | 274 -
.../AppMasterToMaster.StallingTasks$.html | 306 -
.../AppMasterToMaster.StallingTasks.html | 296 -
.../gearpump/streaming/AppMasterToMaster.html | 258 -
.../java/io/gearpump/streaming/Constants$.html | 399 -
.../java/io/gearpump/streaming/Constants.html | 360 -
.../api/java/io/gearpump/streaming/DAG$.html | 332 -
.../api/java/io/gearpump/streaming/DAG.html | 390 -
.../streaming/ExecutorToAppMaster$.html | 274 -
.../ExecutorToAppMaster.MessageLoss$.html | 306 -
.../ExecutorToAppMaster.MessageLoss.html | 326 -
.../ExecutorToAppMaster.RegisterExecutor$.html | 306 -
.../ExecutorToAppMaster.RegisterExecutor.html | 341 -
.../ExecutorToAppMaster.RegisterTask$.html | 306 -
.../ExecutorToAppMaster.RegisterTask.html | 326 -
.../ExecutorToAppMaster.UnRegisterTask$.html | 306 -
.../ExecutorToAppMaster.UnRegisterTask.html | 311 -
.../gearpump/streaming/ExecutorToAppMaster.html | 282 -
.../streaming/InitialAckRequestSerializer.html | 327 -
.../streaming/LatencyProbeSerializer.html | 314 -
.../java/io/gearpump/streaming/LifeTime$.html | 317 -
.../java/io/gearpump/streaming/LifeTime.html | 351 -
.../java/io/gearpump/streaming/Processor$.html | 348 -
.../streaming/Processor.DefaultProcessor$.html | 287 -
.../streaming/Processor.DefaultProcessor.html | 436 -
.../java/io/gearpump/streaming/Processor.html | 313 -
.../streaming/ProcessorDescription$.html | 302 -
.../streaming/ProcessorDescription.html | 389 -
.../gearpump/streaming/StreamApplication$.html | 325 -
.../gearpump/streaming/StreamApplication.html | 388 -
.../io/gearpump/streaming/TaskIdSerializer.html | 314 -
.../streaming/appmaster/AppMaster$.html | 274 -
.../AppMaster.AllocateResourceTimeOut$.html | 301 -
.../appmaster/AppMaster.ExecutorBrief$.html | 306 -
.../appmaster/AppMaster.ExecutorBrief.html | 341 -
.../AppMaster.LookupTaskActorRef$.html | 306 -
.../appmaster/AppMaster.LookupTaskActorRef.html | 296 -
.../AppMaster.ServiceNotAvailableException.html | 264 -
.../appmaster/AppMaster.TaskActorRef$.html | 306 -
.../appmaster/AppMaster.TaskActorRef.html | 296 -
.../gearpump/streaming/appmaster/AppMaster.html | 466 -
.../streaming/appmaster/ClockService$.html | 308 -
.../appmaster/ClockService.ChangeToNewDAG$.html | 306 -
.../appmaster/ClockService.ChangeToNewDAG.html | 296 -
.../ClockService.ChangeToNewDAGSuccess$.html | 306 -
.../ClockService.ChangeToNewDAGSuccess.html | 296 -
.../appmaster/ClockService.HealthCheck$.html | 301 -
.../appmaster/ClockService.HealthChecker$.html | 278 -
.../ClockService.HealthChecker.ClockValue$.html | 306 -
.../ClockService.HealthChecker.ClockValue.html | 324 -
.../appmaster/ClockService.HealthChecker.html | 316 -
.../appmaster/ClockService.ProcessorClock$.html | 278 -
.../appmaster/ClockService.ProcessorClock.html | 374 -
.../ClockService.ProcessorClocks$.html | 312 -
.../appmaster/ClockService.Report$.html | 306 -
.../appmaster/ClockService.Report.html | 296 -
.../ClockService.SnapshotStartClock$.html | 301 -
.../ClockService.StoredStartClock$.html | 306 -
.../ClockService.StoredStartClock.html | 296 -
.../streaming/appmaster/ClockService.html | 480 -
.../streaming/appmaster/DagManager$.html | 274 -
.../appmaster/DagManager.DAGOperation.html | 173 -
.../DagManager.DAGOperationFailed$.html | 306 -
.../DagManager.DAGOperationFailed.html | 296 -
.../DagManager.DAGOperationResult.html | 173 -
.../DagManager.DAGOperationSuccess$.html | 301 -
.../appmaster/DagManager.DagInitiated$.html | 301 -
.../appmaster/DagManager.GetLatestDAG$.html | 301 -
.../DagManager.GetTaskLaunchData$.html | 306 -
.../appmaster/DagManager.GetTaskLaunchData.html | 326 -
.../appmaster/DagManager.LatestDAG$.html | 306 -
.../appmaster/DagManager.LatestDAG.html | 296 -
.../appmaster/DagManager.NewDAGDeployed$.html | 306 -
.../appmaster/DagManager.NewDAGDeployed.html | 296 -
.../appmaster/DagManager.ReplaceProcessor$.html | 306 -
.../appmaster/DagManager.ReplaceProcessor.html | 311 -
.../appmaster/DagManager.TaskLaunchData$.html | 306 -
.../appmaster/DagManager.TaskLaunchData.html | 326 -
.../appmaster/DagManager.WatchChange$.html | 306 -
.../appmaster/DagManager.WatchChange.html | 296 -
.../streaming/appmaster/DagManager.html | 453 -
.../streaming/appmaster/ExecutorManager$.html | 314 -
.../streaming/appmaster/JarScheduler$.html | 274 -
.../appmaster/JarScheduler.ExecutorFailed$.html | 306 -
.../appmaster/JarScheduler.ExecutorFailed.html | 296 -
.../JarScheduler.GetRequestDetails$.html | 301 -
.../JarScheduler.JarSchedulerImpl.html | 341 -
.../appmaster/JarScheduler.NewDag$.html | 306 -
.../appmaster/JarScheduler.NewDag.html | 311 -
.../JarScheduler.ResourceRequestDetail$.html | 306 -
.../JarScheduler.ResourceRequestDetail.html | 311 -
.../appmaster/JarScheduler.ScheduleTask$.html | 306 -
.../appmaster/JarScheduler.ScheduleTask.html | 341 -
.../JarScheduler.TransitToNewDag$.html | 301 -
.../streaming/appmaster/JarScheduler.html | 384 -
.../streaming/appmaster/ProcessorSummary$.html | 302 -
.../streaming/appmaster/ProcessorSummary.html | 397 -
.../appmaster/StreamAppMasterSummary$.html | 302 -
.../appmaster/StreamAppMasterSummary.html | 549 --
.../streaming/appmaster/TaskCount$.html | 302 -
.../gearpump/streaming/appmaster/TaskCount.html | 292 -
.../streaming/appmaster/TaskLocator$.html | 274 -
.../appmaster/TaskLocator.Localities$.html | 347 -
.../appmaster/TaskLocator.Localities.html | 296 -
.../appmaster/TaskLocator.Locality.html | 173 -
.../appmaster/TaskLocator.NonLocality$.html | 283 -
.../appmaster/TaskLocator.WorkerLocality$.html | 306 -
.../appmaster/TaskLocator.WorkerLocality.html | 296 -
.../streaming/appmaster/TaskLocator.html | 314 -
.../streaming/appmaster/TaskManager$.html | 313 -
.../streaming/appmaster/TaskRegistry$.html | 274 -
.../appmaster/TaskRegistry.Accept$.html | 301 -
.../TaskRegistry.RegisterTaskStatus.html | 173 -
.../appmaster/TaskRegistry.Reject$.html | 301 -
.../appmaster/TaskRegistry.TaskLocation$.html | 306 -
.../appmaster/TaskRegistry.TaskLocation.html | 311 -
.../appmaster/TaskRegistry.TaskLocations$.html | 306 -
.../appmaster/TaskRegistry.TaskLocations.html | 296 -
.../streaming/appmaster/TaskRegistry.html | 485 -
.../streaming/appmaster/TaskScheduler$.html | 274 -
.../appmaster/TaskScheduler.Location$.html | 306 -
.../appmaster/TaskScheduler.Location.html | 311 -
.../appmaster/TaskScheduler.TaskStatus.html | 303 -
.../streaming/appmaster/TaskScheduler.html | 354 -
.../streaming/appmaster/TaskSchedulerImpl.html | 413 -
.../streaming/appmaster/package-frame.html | 119 -
.../streaming/appmaster/package-summary.html | 552 --
.../streaming/appmaster/package-tree.html | 267 -
.../streaming/dsl/CollectionDataSource.html | 380 -
.../io/gearpump/streaming/dsl/KVStream.html | 308 -
.../io/gearpump/streaming/dsl/LoggerSink.html | 356 -
.../java/io/gearpump/streaming/dsl/Stream$.html | 351 -
.../io/gearpump/streaming/dsl/Stream.Sink.html | 307 -
.../java/io/gearpump/streaming/dsl/Stream.html | 548 --
.../io/gearpump/streaming/dsl/StreamApp$.html | 325 -
.../streaming/dsl/StreamApp.Source.html | 373 -
.../io/gearpump/streaming/dsl/StreamApp.html | 378 -
.../streaming/dsl/javaapi/JavaStream.html | 394 -
.../streaming/dsl/javaapi/JavaStreamApp.html | 311 -
.../streaming/dsl/javaapi/package-frame.html | 21 -
.../streaming/dsl/javaapi/package-summary.html | 146 -
.../streaming/dsl/javaapi/package-tree.html | 136 -
.../gearpump/streaming/dsl/op/DataSinkOp$.html | 283 -
.../gearpump/streaming/dsl/op/DataSinkOp.html | 345 -
.../streaming/dsl/op/DataSourceOp$.html | 283 -
.../gearpump/streaming/dsl/op/DataSourceOp.html | 345 -
.../io/gearpump/streaming/dsl/op/Direct$.html | 302 -
.../io/gearpump/streaming/dsl/op/Direct.html | 263 -
.../gearpump/streaming/dsl/op/FlatMapOp$.html | 283 -
.../io/gearpump/streaming/dsl/op/FlatMapOp.html | 330 -
.../gearpump/streaming/dsl/op/GroupByOp$.html | 283 -
.../io/gearpump/streaming/dsl/op/GroupByOp.html | 345 -
.../io/gearpump/streaming/dsl/op/MasterOp.html | 199 -
.../io/gearpump/streaming/dsl/op/MergeOp$.html | 302 -
.../io/gearpump/streaming/dsl/op/MergeOp.html | 315 -
.../java/io/gearpump/streaming/dsl/op/Op.html | 241 -
.../io/gearpump/streaming/dsl/op/OpChain$.html | 302 -
.../io/gearpump/streaming/dsl/op/OpChain.html | 356 -
.../io/gearpump/streaming/dsl/op/OpEdge.html | 169 -
.../streaming/dsl/op/ParameterizedOp.html | 195 -
.../gearpump/streaming/dsl/op/ProcessorOp$.html | 283 -
.../gearpump/streaming/dsl/op/ProcessorOp.html | 345 -
.../io/gearpump/streaming/dsl/op/ReduceOp$.html | 283 -
.../io/gearpump/streaming/dsl/op/ReduceOp.html | 330 -
.../io/gearpump/streaming/dsl/op/Shuffle$.html | 302 -
.../io/gearpump/streaming/dsl/op/Shuffle.html | 263 -
.../io/gearpump/streaming/dsl/op/SlaveOp.html | 198 -
.../streaming/dsl/op/package-frame.html | 47 -
.../streaming/dsl/op/package-summary.html | 262 -
.../gearpump/streaming/dsl/op/package-tree.html | 176 -
.../gearpump/streaming/dsl/package-frame.html | 28 -
.../gearpump/streaming/dsl/package-summary.html | 176 -
.../io/gearpump/streaming/dsl/package-tree.html | 143 -
.../dsl/partitioner/GroupByPartitioner$.html | 283 -
.../dsl/partitioner/GroupByPartitioner.html | 295 -
.../dsl/partitioner/package-frame.html | 21 -
.../dsl/partitioner/package-summary.html | 146 -
.../streaming/dsl/partitioner/package-tree.html | 136 -
.../streaming/dsl/plan/OpTranslator$.html | 283 -
.../dsl/plan/OpTranslator.AndThen.html | 314 -
.../plan/OpTranslator.DummyInputFunction.html | 322 -
.../dsl/plan/OpTranslator.FlatMapFunction.html | 314 -
.../dsl/plan/OpTranslator.GroupByTask.html | 344 -
.../dsl/plan/OpTranslator.ReduceFunction.html | 314 -
.../plan/OpTranslator.SingleInputFunction.html | 260 -
.../dsl/plan/OpTranslator.SinkTask.html | 368 -
.../dsl/plan/OpTranslator.SourceTask.html | 370 -
.../dsl/plan/OpTranslator.TransformTask.html | 344 -
.../streaming/dsl/plan/OpTranslator.html | 345 -
.../io/gearpump/streaming/dsl/plan/Planner.html | 271 -
.../streaming/dsl/plan/package-frame.html | 34 -
.../streaming/dsl/plan/package-summary.html | 197 -
.../streaming/dsl/plan/package-tree.html | 161 -
.../gearpump/streaming/executor/Executor$.html | 274 -
.../Executor.DagVersionMismatchException.html | 264 -
.../executor/Executor.ExecutorConfig$.html | 306 -
.../executor/Executor.ExecutorConfig.html | 296 -
.../executor/Executor.ExecutorSummary$.html | 321 -
.../executor/Executor.ExecutorSummary.html | 401 -
.../executor/Executor.GetExecutorSummary$.html | 306 -
.../executor/Executor.GetExecutorSummary.html | 296 -
.../executor/Executor.HealthCheck$.html | 278 -
.../executor/Executor.QueryExecutorConfig$.html | 306 -
.../executor/Executor.QueryExecutorConfig.html | 296 -
.../executor/Executor.RestartTasks$.html | 306 -
.../executor/Executor.RestartTasks.html | 296 -
.../streaming/executor/Executor.State$.html | 351 -
.../executor/Executor.TaskArgumentStore.html | 319 -
.../executor/Executor.TaskStopped$.html | 306 -
.../executor/Executor.TaskStopped.html | 296 -
.../gearpump/streaming/executor/Executor.html | 559 --
.../executor/ExecutorRestartPolicy.html | 286 -
.../streaming/executor/ITaskLauncher.html | 231 -
.../streaming/executor/TaskLauncher$.html | 310 -
.../executor/TaskLauncher.TaskArgument$.html | 306 -
.../executor/TaskLauncher.TaskArgument.html | 326 -
.../streaming/executor/TaskLauncher.html | 334 -
.../streaming/executor/package-frame.html | 49 -
.../streaming/executor/package-summary.html | 256 -
.../streaming/executor/package-tree.html | 177 -
.../io/gearpump/streaming/javaapi/Graph.html | 270 -
.../gearpump/streaming/javaapi/Processor.html | 545 --
.../streaming/javaapi/StreamApplication.html | 340 -
.../io/gearpump/streaming/javaapi/Task.html | 414 -
.../javaapi/dsl/functions/FilterFunction.html | 227 -
.../javaapi/dsl/functions/FlatMapFunction.html | 227 -
.../javaapi/dsl/functions/GroupByFunction.html | 227 -
.../javaapi/dsl/functions/MapFunction.html | 227 -
.../javaapi/dsl/functions/ReduceFunction.html | 229 -
.../javaapi/dsl/functions/package-frame.html | 24 -
.../javaapi/dsl/functions/package-summary.html | 166 -
.../javaapi/dsl/functions/package-tree.html | 139 -
.../streaming/javaapi/package-frame.html | 23 -
.../streaming/javaapi/package-summary.html | 152 -
.../streaming/javaapi/package-tree.html | 146 -
.../streaming/metrics/ProcessorAggregator$.html | 308 -
.../metrics/ProcessorAggregator.Aggregator.html | 240 -
.../ProcessorAggregator.AggregatorFactory.html | 275 -
...ProcessorAggregator.HistogramAggregator.html | 403 -
.../ProcessorAggregator.MeterAggregator.html | 364 -
.../ProcessorAggregator.MultiLayerMap.html | 333 -
.../streaming/metrics/ProcessorAggregator.html | 378 -
.../metrics/TaskFilterAggregator$.html | 412 -
.../metrics/TaskFilterAggregator.Options$.html | 334 -
.../metrics/TaskFilterAggregator.Options.html | 356 -
.../streaming/metrics/TaskFilterAggregator.html | 449 -
.../streaming/metrics/package-frame.html | 33 -
.../streaming/metrics/package-summary.html | 199 -
.../streaming/metrics/package-tree.html | 148 -
.../io/gearpump/streaming/package-frame.html | 91 -
.../io/gearpump/streaming/package-summary.html | 432 -
.../io/gearpump/streaming/package-tree.html | 235 -
.../io/gearpump/streaming/sink/DataSink.html | 297 -
.../streaming/sink/DataSinkProcessor$.html | 327 -
.../streaming/sink/DataSinkProcessor.html | 288 -
.../gearpump/streaming/sink/DataSinkTask$.html | 308 -
.../gearpump/streaming/sink/DataSinkTask.html | 362 -
.../gearpump/streaming/sink/package-frame.html | 27 -
.../streaming/sink/package-summary.html | 178 -
.../gearpump/streaming/sink/package-tree.html | 150 -
.../gearpump/streaming/source/DataSource.html | 302 -
.../streaming/source/DataSourceConfig$.html | 321 -
.../streaming/source/DataSourceConfig.html | 282 -
.../streaming/source/DataSourceProcessor$.html | 327 -
.../streaming/source/DataSourceProcessor.html | 288 -
.../streaming/source/DataSourceTask$.html | 308 -
.../streaming/source/DataSourceTask.html | 369 -
.../source/DefaultTimeStampFilter.html | 285 -
.../streaming/source/package-frame.html | 30 -
.../streaming/source/package-summary.html | 192 -
.../gearpump/streaming/source/package-tree.html | 153 -
.../io/gearpump/streaming/state/api/Group.html | 235 -
.../io/gearpump/streaming/state/api/Monoid.html | 245 -
.../streaming/state/api/MonoidState.html | 377 -
.../streaming/state/api/PersistentState.html | 309 -
.../streaming/state/api/PersistentTask$.html | 321 -
.../streaming/state/api/PersistentTask.html | 488 -
.../streaming/state/api/Serializer.html | 239 -
.../streaming/state/api/package-frame.html | 29 -
.../streaming/state/api/package-summary.html | 181 -
.../streaming/state/api/package-tree.html | 155 -
.../streaming/state/impl/CheckpointManager.html | 338 -
.../state/impl/InMemoryCheckpointStore.html | 316 -
.../impl/InMemoryCheckpointStoreFactory.html | 284 -
.../streaming/state/impl/Interval$.html | 302 -
.../gearpump/streaming/state/impl/Interval.html | 332 -
.../streaming/state/impl/NonWindowState$.html | 308 -
.../streaming/state/impl/NonWindowState.html | 351 -
.../state/impl/PersistentStateConfig$.html | 360 -
.../state/impl/PersistentStateConfig.html | 321 -
.../gearpump/streaming/state/impl/Window.html | 363 -
.../streaming/state/impl/WindowConfig$.html | 317 -
.../streaming/state/impl/WindowConfig.html | 320 -
.../streaming/state/impl/WindowState$.html | 308 -
.../streaming/state/impl/WindowState.html | 360 -
.../streaming/state/impl/package-frame.html | 33 -
.../streaming/state/impl/package-summary.html | 205 -
.../streaming/state/impl/package-tree.html | 156 -
.../streaming/storage/AppDataStore.html | 240 -
.../storage/InMemoryAppStoreOnMaster.html | 313 -
.../streaming/storage/package-frame.html | 24 -
.../streaming/storage/package-summary.html | 159 -
.../streaming/storage/package-tree.html | 139 -
.../java/io/gearpump/streaming/task/Ack$.html | 302 -
.../java/io/gearpump/streaming/task/Ack.html | 337 -
.../io/gearpump/streaming/task/AckRequest$.html | 302 -
.../io/gearpump/streaming/task/AckRequest.html | 322 -
.../streaming/task/CheckProcessorDeath$.html | 302 -
.../streaming/task/CheckProcessorDeath.html | 292 -
.../streaming/task/CheckpointClock$.html | 302 -
.../streaming/task/CheckpointClock.html | 292 -
.../io/gearpump/streaming/task/ClockEvent.html | 169 -
.../streaming/task/ExpressTransport.html | 295 -
.../streaming/task/GetCheckpointClock$.html | 297 -
.../streaming/task/GetCheckpointClock.html | 258 -
.../io/gearpump/streaming/task/GetDAG$.html | 297 -
.../java/io/gearpump/streaming/task/GetDAG.html | 258 -
.../streaming/task/GetLatestMinClock$.html | 279 -
.../streaming/task/GetLatestMinClock.html | 240 -
.../gearpump/streaming/task/GetStartClock$.html | 297 -
.../gearpump/streaming/task/GetStartClock.html | 258 -
.../streaming/task/GetUpstreamMinClock$.html | 302 -
.../streaming/task/GetUpstreamMinClock.html | 292 -
.../streaming/task/InitialAckRequest$.html | 302 -
.../streaming/task/InitialAckRequest.html | 307 -
.../gearpump/streaming/task/LatencyProbe$.html | 302 -
.../gearpump/streaming/task/LatencyProbe.html | 292 -
.../streaming/task/LatestMinClock$.html | 302 -
.../gearpump/streaming/task/LatestMinClock.html | 292 -
.../streaming/task/ReportCheckpointClock$.html | 302 -
.../streaming/task/ReportCheckpointClock.html | 307 -
.../streaming/task/SendMessageLoss$.html | 302 -
.../streaming/task/SendMessageLoss.html | 258 -
.../streaming/task/SerializedMessage$.html | 302 -
.../streaming/task/SerializedMessage.html | 307 -
.../task/SerializedMessageSerializer.html | 314 -
.../streaming/task/SerializerResolver$.html | 274 -
.../io/gearpump/streaming/task/StartClock$.html | 302 -
.../io/gearpump/streaming/task/StartClock.html | 292 -
.../io/gearpump/streaming/task/StartTime$.html | 302 -
.../io/gearpump/streaming/task/StartTime.html | 292 -
.../task/StreamingTransportSerializer.html | 316 -
.../io/gearpump/streaming/task/Subscriber$.html | 331 -
.../io/gearpump/streaming/task/Subscriber.html | 369 -
.../gearpump/streaming/task/Subscription$.html | 321 -
.../gearpump/streaming/task/Subscription.html | 461 -
.../java/io/gearpump/streaming/task/Task.html | 421 -
.../io/gearpump/streaming/task/TaskActor$.html | 321 -
.../streaming/task/TaskActor.FLUSH$.html | 301 -
.../task/TaskActor.MessageAndSender$.html | 306 -
.../task/TaskActor.MessageAndSender.html | 311 -
.../task/TaskActor.SecurityChecker.html | 307 -
.../streaming/task/TaskActor.SendAck$.html | 306 -
.../streaming/task/TaskActor.SendAck.html | 311 -
.../io/gearpump/streaming/task/TaskActor.html | 719 --
.../io/gearpump/streaming/task/TaskContext.html | 508 --
.../streaming/task/TaskContextData$.html | 302 -
.../streaming/task/TaskContextData.html | 382 -
.../io/gearpump/streaming/task/TaskId$.html | 330 -
.../java/io/gearpump/streaming/task/TaskId.html | 333 -
.../gearpump/streaming/task/TaskInterface.html | 288 -
.../streaming/task/TaskMessageSerializer.html | 255 -
.../io/gearpump/streaming/task/TaskUtil$.html | 317 -
.../io/gearpump/streaming/task/TaskUtil.html | 278 -
.../io/gearpump/streaming/task/TaskWrapper.html | 768 --
.../gearpump/streaming/task/UpdateClock$.html | 302 -
.../io/gearpump/streaming/task/UpdateClock.html | 307 -
.../streaming/task/UpstreamMinClock$.html | 302 -
.../streaming/task/UpstreamMinClock.html | 292 -
.../gearpump/streaming/task/package-frame.html | 88 -
.../streaming/task/package-summary.html | 426 -
.../gearpump/streaming/task/package-tree.html | 227 -
.../transaction/api/CheckpointStore.html | 254 -
.../transaction/api/CheckpointStoreFactory.html | 230 -
.../transaction/api/MessageDecoder.html | 227 -
.../transaction/api/MessageFilter.html | 224 -
.../transaction/api/OffsetManager.html | 239 -
.../transaction/api/OffsetStorage$.html | 274 -
.../api/OffsetStorage.Overflow$.html | 306 -
.../transaction/api/OffsetStorage.Overflow.html | 310 -
.../api/OffsetStorage.StorageEmpty$.html | 314 -
.../api/OffsetStorage.Underflow$.html | 306 -
.../api/OffsetStorage.Underflow.html | 310 -
.../transaction/api/OffsetStorage.html | 306 -
.../transaction/api/OffsetStorageFactory.html | 224 -
.../api/OffsetTimeStampResolver.html | 224 -
.../transaction/api/TimeReplayableSource.html | 195 -
.../transaction/api/TimeStampFilter.html | 231 -
.../transaction/api/package-frame.html | 38 -
.../transaction/api/package-summary.html | 239 -
.../streaming/transaction/api/package-tree.html | 176 -
.../gearpump/streaming/util/ActorPathUtil$.html | 351 -
.../gearpump/streaming/util/ActorPathUtil.html | 312 -
.../gearpump/streaming/util/package-frame.html | 21 -
.../streaming/util/package-summary.html | 144 -
.../gearpump/streaming/util/package-tree.html | 136 -
.../netty/ITransportMessageSerializer.html | 253 -
.../gearpump/transport/netty/MessageBatch.html | 195 -
.../transport/netty/MessageDecoder.html | 335 -
.../transport/netty/MessageEncoder.html | 311 -
.../netty/NettyRenameThreadFactory.html | 244 -
.../gearpump/transport/netty/TaskMessage.html | 314 -
.../transport/netty/WrappedChannelBuffer.html | 590 --
.../gearpump/transport/netty/package-frame.html | 29 -
.../transport/netty/package-summary.html | 175 -
.../gearpump/transport/netty/package-tree.html | 156 -
.../api/java/io/gearpump/util/AkkaHelper.html | 280 -
.../io/gearpump/util/HadoopFSLogAppender.html | 324 -
.../util/RecreateRollingFileAppender.html | 415 -
.../java/io/gearpump/util/package-frame.html | 22 -
.../java/io/gearpump/util/package-summary.html | 150 -
.../api/java/io/gearpump/util/package-tree.html | 153 -
.../api/java/org/apache/gearpump/Message.html | 325 +
.../apache/gearpump/cluster/AppDescription.html | 346 +
.../org/apache/gearpump/cluster/AppJar.html | 311 +
.../gearpump/cluster/AppMasterContext.html | 393 +
.../gearpump/cluster/AppMasterRegisterData.html | 169 +
.../AppMasterToMaster.ActivateAppMaster$.html | 306 +
.../AppMasterToMaster.ActivateAppMaster.html | 298 +
.../AppMasterToMaster.AppDataSaved$.html | 302 +
.../AppMasterToMaster.AppMasterSummary.html | 320 +
...MasterToMaster.GeneralAppMasterSummary$.html | 306 +
...pMasterToMaster.GeneralAppMasterSummary.html | 434 +
.../AppMasterToMaster.GetAllWorkers$.html | 302 +
.../cluster/AppMasterToMaster.GetAppData$.html | 306 +
.../cluster/AppMasterToMaster.GetAppData.html | 312 +
.../AppMasterToMaster.GetAppDataResult$.html | 306 +
.../AppMasterToMaster.GetAppDataResult.html | 312 +
.../AppMasterToMaster.GetMasterData$.html | 302 +
.../AppMasterToMaster.GetWorkerData$.html | 306 +
.../AppMasterToMaster.GetWorkerData.html | 297 +
.../AppMasterToMaster.InvalidAppMaster$.html | 306 +
.../AppMasterToMaster.InvalidAppMaster.html | 326 +
.../cluster/AppMasterToMaster.MasterData$.html | 306 +
.../cluster/AppMasterToMaster.MasterData.html | 297 +
.../AppMasterToMaster.RegisterAppMaster$.html | 306 +
.../AppMasterToMaster.RegisterAppMaster.html | 315 +
.../AppMasterToMaster.RequestResource$.html | 306 +
.../AppMasterToMaster.RequestResource.html | 311 +
.../cluster/AppMasterToMaster.SaveAppData$.html | 306 +
.../cluster/AppMasterToMaster.SaveAppData.html | 331 +
.../AppMasterToMaster.SaveAppDataFailed$.html | 302 +
.../cluster/AppMasterToMaster.WorkerData$.html | 306 +
.../cluster/AppMasterToMaster.WorkerData.html | 297 +
.../gearpump/cluster/AppMasterToMaster.html | 387 +
...pMasterToWorker.ChangeExecutorResource$.html | 306 +
...ppMasterToWorker.ChangeExecutorResource.html | 326 +
.../AppMasterToWorker.LaunchExecutor$.html | 306 +
.../AppMasterToWorker.LaunchExecutor.html | 341 +
.../AppMasterToWorker.ShutdownExecutor$.html | 306 +
.../AppMasterToWorker.ShutdownExecutor.html | 326 +
.../gearpump/cluster/AppMasterToWorker.html | 274 +
.../cluster/Application.DefaultApplication.html | 351 +
.../apache/gearpump/cluster/Application.html | 285 +
.../gearpump/cluster/ApplicationMaster.html | 267 +
.../cluster/ClientToMaster.AddMaster$.html | 301 +
.../cluster/ClientToMaster.AddWorker$.html | 306 +
.../cluster/ClientToMaster.AddWorker.html | 296 +
.../cluster/ClientToMaster.CommandResult$.html | 306 +
.../cluster/ClientToMaster.CommandResult.html | 329 +
.../ClientToMaster.GetJarStoreServer$.html | 302 +
.../cluster/ClientToMaster.GetLastFailure$.html | 306 +
.../cluster/ClientToMaster.GetLastFailure.html | 297 +
.../ClientToMaster.GetStallingTasks$.html | 306 +
.../ClientToMaster.GetStallingTasks.html | 299 +
.../ClientToMaster.JarStoreServerAddress$.html | 306 +
.../ClientToMaster.JarStoreServerAddress.html | 297 +
.../ClientToMaster.QueryAppMasterConfig$.html | 306 +
.../ClientToMaster.QueryAppMasterConfig.html | 297 +
.../ClientToMaster.QueryHistoryMetrics$.html | 306 +
.../ClientToMaster.QueryHistoryMetrics.html | 342 +
.../ClientToMaster.QueryMasterConfig$.html | 302 +
.../ClientToMaster.QueryWorkerConfig$.html | 306 +
.../ClientToMaster.QueryWorkerConfig.html | 297 +
.../cluster/ClientToMaster.ReadOption$.html | 367 +
.../cluster/ClientToMaster.RemoveMaster$.html | 306 +
.../cluster/ClientToMaster.RemoveMaster.html | 296 +
.../cluster/ClientToMaster.RemoveWorker$.html | 306 +
.../cluster/ClientToMaster.RemoveWorker.html | 296 +
.../cluster/ClientToMaster.ResolveAppId$.html | 306 +
.../cluster/ClientToMaster.ResolveAppId.html | 297 +
.../ClientToMaster.ResolveWorkerId$.html | 306 +
.../cluster/ClientToMaster.ResolveWorkerId.html | 297 +
.../ClientToMaster.RestartApplication$.html | 306 +
.../ClientToMaster.RestartApplication.html | 296 +
.../ClientToMaster.ShutdownApplication$.html | 306 +
.../ClientToMaster.ShutdownApplication.html | 296 +
.../ClientToMaster.SubmitApplication$.html | 306 +
.../ClientToMaster.SubmitApplication.html | 327 +
.../apache/gearpump/cluster/ClientToMaster.html | 412 +
...ClusterConfig.ConfigValidationException.html | 264 +
.../gearpump/cluster/ClusterConfig.Configs.html | 305 +
.../apache/gearpump/cluster/ClusterConfig.html | 478 +
...terConfigSource.ClusterConfigSourceImpl.html | 301 +
.../gearpump/cluster/ClusterConfigSource.html | 250 +
.../gearpump/cluster/ExecutorContext.html | 368 +
.../gearpump/cluster/ExecutorJVMConfig.html | 394 +
.../MasterToAppMaster.AppMasterActivated$.html | 306 +
.../MasterToAppMaster.AppMasterActivated.html | 297 +
.../MasterToAppMaster.AppMasterData$.html | 306 +
.../MasterToAppMaster.AppMasterData.html | 416 +
...ToAppMaster.AppMasterDataDetailRequest$.html | 306 +
...rToAppMaster.AppMasterDataDetailRequest.html | 296 +
...MasterToAppMaster.AppMasterDataRequest$.html | 306 +
.../MasterToAppMaster.AppMasterDataRequest.html | 311 +
...terToAppMaster.AppMasterMetricsRequest$.html | 306 +
...sterToAppMaster.AppMasterMetricsRequest.html | 296 +
.../MasterToAppMaster.AppMasterRegistered$.html | 306 +
.../MasterToAppMaster.AppMasterRegistered.html | 297 +
.../MasterToAppMaster.AppMastersData$.html | 306 +
.../MasterToAppMaster.AppMastersData.html | 296 +
...asterToAppMaster.AppMastersDataRequest$.html | 301 +
....ReplayFromTimestampWindowTrailingEdge$.html | 306 +
...r.ReplayFromTimestampWindowTrailingEdge.html | 296 +
.../MasterToAppMaster.ResourceAllocated$.html | 306 +
.../MasterToAppMaster.ResourceAllocated.html | 297 +
.../MasterToAppMaster.ShutdownAppMaster$.html | 302 +
.../MasterToAppMaster.StreamingType.html | 173 +
.../cluster/MasterToAppMaster.WorkerList$.html | 306 +
.../cluster/MasterToAppMaster.WorkerList.html | 296 +
.../gearpump/cluster/MasterToAppMaster.html | 423 +
.../MasterToClient.AppMasterConfig$.html | 306 +
.../cluster/MasterToClient.AppMasterConfig.html | 296 +
.../cluster/MasterToClient.HistoryMetrics$.html | 306 +
.../cluster/MasterToClient.HistoryMetrics.html | 319 +
.../MasterToClient.HistoryMetricsItem$.html | 306 +
.../MasterToClient.HistoryMetricsItem.html | 311 +
.../cluster/MasterToClient.LastFailure$.html | 306 +
.../cluster/MasterToClient.LastFailure.html | 312 +
.../cluster/MasterToClient.MasterConfig$.html | 306 +
.../cluster/MasterToClient.MasterConfig.html | 296 +
...MasterToClient.ReplayApplicationResult$.html | 306 +
.../MasterToClient.ReplayApplicationResult.html | 296 +
.../MasterToClient.ResolveAppIdResult$.html | 306 +
.../MasterToClient.ResolveAppIdResult.html | 297 +
.../MasterToClient.ResolveWorkerIdResult$.html | 306 +
.../MasterToClient.ResolveWorkerIdResult.html | 297 +
...sterToClient.ShutdownApplicationResult$.html | 306 +
...asterToClient.ShutdownApplicationResult.html | 296 +
...MasterToClient.SubmitApplicationResult$.html | 306 +
.../MasterToClient.SubmitApplicationResult.html | 297 +
...rToClient.SubmitApplicationResultValue$.html | 306 +
...erToClient.SubmitApplicationResultValue.html | 296 +
.../cluster/MasterToClient.WorkerConfig$.html | 306 +
.../cluster/MasterToClient.WorkerConfig.html | 296 +
.../apache/gearpump/cluster/MasterToClient.html | 356 +
.../org/apache/gearpump/cluster/UserConfig.html | 609 ++
...rkerToAppMaster.ExecutorLaunchRejected$.html | 306 +
...orkerToAppMaster.ExecutorLaunchRejected.html | 311 +
...rkerToAppMaster.ShutdownExecutorFailed$.html | 306 +
...orkerToAppMaster.ShutdownExecutorFailed.html | 311 +
...kerToAppMaster.ShutdownExecutorSucceed$.html | 306 +
...rkerToAppMaster.ShutdownExecutorSucceed.html | 311 +
.../gearpump/cluster/WorkerToAppMaster.html | 274 +
...rRuntimeEnvironment.LazyStartAppMaster$.html | 314 +
...erRuntimeEnvironment.LazyStartAppMaster.html | 359 +
...nment.MasterWithExecutorSystemProvider$.html | 314 +
...onment.MasterWithExecutorSystemProvider.html | 323 +
...asterRuntimeEnvironment.StartAppMaster$.html | 301 +
.../appmaster/AppMasterRuntimeEnvironment.html | 381 +
.../cluster/appmaster/AppMasterRuntimeInfo.html | 398 +
.../cluster/appmaster/ApplicationState.html | 419 +
.../cluster/appmaster/ExecutorSystem.html | 381 +
...torSystemLauncher.LaunchExecutorSystem$.html | 306 +
...utorSystemLauncher.LaunchExecutorSystem.html | 326 +
...mLauncher.LaunchExecutorSystemRejected$.html | 306 +
...emLauncher.LaunchExecutorSystemRejected.html | 326 +
...emLauncher.LaunchExecutorSystemSuccess$.html | 306 +
...temLauncher.LaunchExecutorSystemSuccess.html | 311 +
...emLauncher.LaunchExecutorSystemTimeout$.html | 306 +
...temLauncher.LaunchExecutorSystemTimeout.html | 296 +
.../appmaster/ExecutorSystemLauncher.html | 430 +
...ystemScheduler.ExecutorSystemJvmConfig$.html | 306 +
...SystemScheduler.ExecutorSystemJvmConfig.html | 356 +
...rSystemScheduler.ExecutorSystemStarted$.html | 306 +
...orSystemScheduler.ExecutorSystemStarted.html | 311 +
.../ExecutorSystemScheduler.ResourceAgent.html | 335 +
...mScheduler.ResourceAllocatedForSession$.html | 306 +
...emScheduler.ResourceAllocatedForSession.html | 311 +
...temScheduler.ResourceAllocationTimeOut$.html | 306 +
...stemScheduler.ResourceAllocationTimeOut.html | 296 +
.../ExecutorSystemScheduler.Session$.html | 306 +
.../ExecutorSystemScheduler.Session.html | 313 +
...emScheduler.StartExecutorSystemTimeout$.html | 301 +
...orSystemScheduler.StartExecutorSystems$.html | 306 +
...torSystemScheduler.StartExecutorSystems.html | 311 +
...utorSystemScheduler.StopExecutorSystem$.html | 306 +
...cutorSystemScheduler.StopExecutorSystem.html | 296 +
.../appmaster/ExecutorSystemScheduler.html | 475 +
...nectionKeeper.AppMasterRegisterTimeout$.html | 301 +
...MasterConnectionStatus$.MasterConnected.html | 262 +
...r.MasterConnectionStatus$.MasterStopped.html | 262 +
...onnectionKeeper.MasterConnectionStatus$.html | 301 +
.../appmaster/MasterConnectionKeeper.html | 364 +
.../gearpump/cluster/appmaster/WorkerInfo.html | 307 +
.../cluster/appmaster/package-frame.html | 58 +
.../cluster/appmaster/package-summary.html | 314 +
.../cluster/appmaster/package-tree.html | 191 +
.../gearpump/cluster/client/ClientContext.html | 520 ++
.../gearpump/cluster/client/MasterClient.html | 328 +
.../gearpump/cluster/client/package-frame.html | 21 +
.../cluster/client/package-summary.html | 148 +
.../gearpump/cluster/client/package-tree.html | 136 +
.../cluster/main/ArgumentsParser.Syntax$.html | 306 +
.../cluster/main/ArgumentsParser.Syntax.html | 326 +
.../gearpump/cluster/main/ArgumentsParser.html | 310 +
.../apache/gearpump/cluster/main/CLIOption.html | 322 +
.../gearpump/cluster/main/ParseResult.html | 323 +
.../gearpump/cluster/main/package-frame.html | 27 +
.../gearpump/cluster/main/package-summary.html | 169 +
.../gearpump/cluster/main/package-tree.html | 146 +
.../cluster/master/AppMasterLauncher.html | 451 +
.../master/AppMasterLauncherFactory.html | 231 +
.../gearpump/cluster/master/MasterActivity.html | 307 +
.../gearpump/cluster/master/MasterNode.html | 320 +
.../master/MasterProxy.MasterRestarted$.html | 301 +
.../master/MasterProxy.MasterStopped$.html | 301 +
.../master/MasterProxy.WatchMaster$.html | 306 +
.../cluster/master/MasterProxy.WatchMaster.html | 296 +
.../gearpump/cluster/master/MasterProxy.html | 472 +
.../gearpump/cluster/master/MasterStatus.html | 283 +
.../gearpump/cluster/master/MasterSummary.html | 428 +
.../gearpump/cluster/master/package-frame.html | 33 +
.../cluster/master/package-summary.html | 200 +
.../gearpump/cluster/master/package-tree.html | 152 +
.../apache/gearpump/cluster/package-frame.html | 166 +
.../gearpump/cluster/package-summary.html | 815 ++
.../apache/gearpump/cluster/package-tree.html | 318 +
.../gearpump/cluster/scheduler/Priority.html | 347 +
.../gearpump/cluster/scheduler/Relaxation.html | 347 +
.../gearpump/cluster/scheduler/Resource.html | 333 +
.../cluster/scheduler/ResourceAllocation.html | 322 +
.../cluster/scheduler/ResourceRequest.html | 352 +
.../cluster/scheduler/package-frame.html | 24 +
.../cluster/scheduler/package-summary.html | 162 +
.../cluster/scheduler/package-tree.html | 143 +
.../cluster/worker/ExecutorProcessLauncher.html | 290 +
.../gearpump/cluster/worker/ExecutorSlots.html | 322 +
.../gearpump/cluster/worker/WorkerId.html | 364 +
.../gearpump/cluster/worker/WorkerSummary.html | 471 +
.../gearpump/cluster/worker/package-frame.html | 26 +
.../cluster/worker/package-summary.html | 169 +
.../gearpump/cluster/worker/package-tree.html | 141 +
.../gearpump/external/hbase/HBaseSink.html | 543 ++
.../external/hbase/dsl/HBaseDSLSink.html | 310 +
.../external/hbase/dsl/package-frame.html | 20 +
.../external/hbase/dsl/package-summary.html | 142 +
.../external/hbase/dsl/package-tree.html | 135 +
.../gearpump/external/hbase/package-frame.html | 20 +
.../external/hbase/package-summary.html | 140 +
.../gearpump/external/hbase/package-tree.html | 135 +
.../org/apache/gearpump/jarstore/FilePath.html | 292 +
.../gearpump/jarstore/JarStoreService.html | 299 +
.../apache/gearpump/jarstore/package-frame.html | 24 +
.../gearpump/jarstore/package-summary.html | 158 +
.../apache/gearpump/jarstore/package-tree.html | 139 +
.../apache/gearpump/metrics/AkkaReporter.html | 281 +
.../org/apache/gearpump/metrics/Counter.html | 303 +
.../org/apache/gearpump/metrics/Histogram.html | 316 +
.../apache/gearpump/metrics/JvmMetricsSet.html | 278 +
.../java/org/apache/gearpump/metrics/Meter.html | 313 +
.../gearpump/metrics/Metrics.Counter$.html | 306 +
.../gearpump/metrics/Metrics.Counter.html | 315 +
.../metrics/Metrics.DemandMoreMetrics$.html | 306 +
.../metrics/Metrics.DemandMoreMetrics.html | 296 +
.../gearpump/metrics/Metrics.DummyMetrics.html | 359 +
.../apache/gearpump/metrics/Metrics.Gauge$.html | 306 +
.../apache/gearpump/metrics/Metrics.Gauge.html | 315 +
.../gearpump/metrics/Metrics.Histogram$.html | 306 +
.../gearpump/metrics/Metrics.Histogram.html | 390 +
.../apache/gearpump/metrics/Metrics.Meter$.html | 306 +
.../apache/gearpump/metrics/Metrics.Meter.html | 360 +
.../gearpump/metrics/Metrics.MetricType$.html | 333 +
.../gearpump/metrics/Metrics.MetricType.html | 227 +
.../metrics/Metrics.ReportMetrics$.html | 301 +
.../apache/gearpump/metrics/Metrics.Timer$.html | 306 +
.../apache/gearpump/metrics/Metrics.Timer.html | 555 ++
.../org/apache/gearpump/metrics/Metrics.html | 477 +
.../gearpump/metrics/MetricsAggregator.html | 229 +
.../MetricsReporterService.ReportTo.html | 228 +
.../metrics/MetricsReporterService.html | 381 +
.../apache/gearpump/metrics/package-frame.html | 47 +
.../gearpump/metrics/package-summary.html | 259 +
.../apache/gearpump/metrics/package-tree.html | 185 +
.../java/org/apache/gearpump/package-frame.html | 20 +
.../org/apache/gearpump/package-summary.html | 142 +
.../java/org/apache/gearpump/package-tree.html | 135 +
.../partitioner/BroadcastPartitioner.html | 306 +
.../partitioner/CoLocationPartitioner.html | 307 +
.../gearpump/partitioner/HashPartitioner.html | 308 +
.../partitioner/MulticastPartitioner.html | 260 +
.../gearpump/partitioner/Partitioner.html | 180 +
.../partitioner/PartitionerByClassName.html | 300 +
.../partitioner/PartitionerDescription.html | 293 +
.../partitioner/PartitionerFactory.html | 236 +
.../gearpump/partitioner/PartitionerObject.html | 300 +
.../partitioner/ShuffleGroupingPartitioner.html | 308 +
.../partitioner/ShufflePartitioner.html | 306 +
.../partitioner/UnicastPartitioner.html | 262 +
.../gearpump/partitioner/package-frame.html | 34 +
.../gearpump/partitioner/package-summary.html | 220 +
.../gearpump/partitioner/package-tree.html | 160 +
.../Authenticator.AuthenticationResult.html | 236 +
.../apache/gearpump/security/Authenticator.html | 250 +
.../security/ConfigFileBasedAuthenticator.html | 322 +
.../apache/gearpump/security/PasswordUtil.html | 326 +
.../apache/gearpump/security/package-frame.html | 26 +
.../gearpump/security/package-summary.html | 169 +
.../apache/gearpump/security/package-tree.html | 141 +
.../FastKryoSerializationFramework.html | 314 +
...oSerializer.KryoSerializationException$.html | 287 +
...yoSerializer.KryoSerializationException.html | 266 +
.../gearpump/serializer/FastKryoSerializer.html | 331 +
.../serializer/GearpumpSerialization.html | 269 +
.../serializer/SerializationFramework.html | 255 +
.../apache/gearpump/serializer/Serializer.html | 237 +
.../gearpump/serializer/package-frame.html | 32 +
.../gearpump/serializer/package-summary.html | 193 +
.../gearpump/serializer/package-tree.html | 152 +
.../streaming/AckRequestSerializer.html | 327 +
.../gearpump/streaming/AckSerializer.html | 327 +
.../AppMasterToExecutor.ChangeTask$.html | 306 +
.../AppMasterToExecutor.ChangeTask.html | 341 +
.../AppMasterToExecutor.ChangeTasks$.html | 306 +
.../AppMasterToExecutor.ChangeTasks.html | 342 +
.../AppMasterToExecutor.LaunchTasks$.html | 306 +
.../AppMasterToExecutor.LaunchTasks.html | 341 +
.../AppMasterToExecutor.MsgLostException.html | 264 +
...ppMasterToExecutor.RestartClockService$.html | 301 +
.../AppMasterToExecutor.StartAllTasks$.html | 306 +
.../AppMasterToExecutor.StartAllTasks.html | 296 +
.../AppMasterToExecutor.StartDynamicDag$.html | 306 +
.../AppMasterToExecutor.StartDynamicDag.html | 296 +
.../AppMasterToExecutor.StartTask$.html | 306 +
.../AppMasterToExecutor.StartTask.html | 296 +
.../AppMasterToExecutor.StopTask$.html | 306 +
.../streaming/AppMasterToExecutor.StopTask.html | 296 +
.../AppMasterToExecutor.TaskChanged$.html | 306 +
.../AppMasterToExecutor.TaskChanged.html | 311 +
...AppMasterToExecutor.TaskLocationsReady$.html | 306 +
.../AppMasterToExecutor.TaskLocationsReady.html | 311 +
...MasterToExecutor.TaskLocationsReceived$.html | 306 +
...pMasterToExecutor.TaskLocationsReceived.html | 311 +
...MasterToExecutor.TaskLocationsRejected$.html | 306 +
...pMasterToExecutor.TaskLocationsRejected.html | 341 +
.../AppMasterToExecutor.TaskRegistered$.html | 306 +
.../AppMasterToExecutor.TaskRegistered.html | 326 +
.../AppMasterToExecutor.TaskRejected$.html | 306 +
.../AppMasterToExecutor.TaskRejected.html | 296 +
.../AppMasterToExecutor.TasksChanged$.html | 306 +
.../AppMasterToExecutor.TasksChanged.html | 296 +
.../AppMasterToExecutor.TasksLaunched$.html | 301 +
.../gearpump/streaming/AppMasterToExecutor.html | 376 +
.../AppMasterToMaster.StallingTasks$.html | 306 +
.../AppMasterToMaster.StallingTasks.html | 296 +
.../gearpump/streaming/AppMasterToMaster.html | 258 +
.../apache/gearpump/streaming/Constants.html | 373 +
.../java/org/apache/gearpump/streaming/DAG.html | 390 +
.../ExecutorToAppMaster.MessageLoss$.html | 306 +
.../ExecutorToAppMaster.MessageLoss.html | 326 +
.../ExecutorToAppMaster.RegisterExecutor$.html | 306 +
.../ExecutorToAppMaster.RegisterExecutor.html | 341 +
.../ExecutorToAppMaster.RegisterTask$.html | 306 +
.../ExecutorToAppMaster.RegisterTask.html | 326 +
.../ExecutorToAppMaster.UnRegisterTask$.html | 306 +
.../ExecutorToAppMaster.UnRegisterTask.html | 311 +
.../gearpump/streaming/ExecutorToAppMaster.html | 282 +
.../streaming/InitialAckRequestSerializer.html | 327 +
.../streaming/LatencyProbeSerializer.html | 314 +
.../org/apache/gearpump/streaming/LifeTime.html | 350 +
.../streaming/Processor.DefaultProcessor$.html | 287 +
.../streaming/Processor.DefaultProcessor.html | 446 +
.../apache/gearpump/streaming/Processor.html | 330 +
.../streaming/ProcessorDescription.html | 389 +
.../gearpump/streaming/StreamApplication.html | 404 +
.../gearpump/streaming/TaskIdSerializer.html | 314 +
.../AppMaster.AllocateResourceTimeOut$.html | 302 +
.../appmaster/AppMaster.ExecutorBrief$.html | 306 +
.../appmaster/AppMaster.ExecutorBrief.html | 341 +
.../AppMaster.LookupTaskActorRef$.html | 306 +
.../appmaster/AppMaster.LookupTaskActorRef.html | 297 +
.../AppMaster.ServiceNotAvailableException.html | 264 +
.../appmaster/AppMaster.TaskActorRef$.html | 306 +
.../appmaster/AppMaster.TaskActorRef.html | 296 +
.../gearpump/streaming/appmaster/AppMaster.html | 429 +
.../appmaster/ClockService.ChangeToNewDAG$.html | 306 +
.../appmaster/ClockService.ChangeToNewDAG.html | 296 +
.../ClockService.ChangeToNewDAGSuccess$.html | 306 +
.../ClockService.ChangeToNewDAGSuccess.html | 296 +
.../appmaster/ClockService.HealthCheck$.html | 301 +
.../appmaster/ClockService.HealthChecker$.html | 278 +
.../ClockService.HealthChecker.ClockValue$.html | 306 +
.../ClockService.HealthChecker.ClockValue.html | 324 +
.../appmaster/ClockService.HealthChecker.html | 319 +
.../appmaster/ClockService.ProcessorClock$.html | 278 +
.../appmaster/ClockService.ProcessorClock.html | 374 +
.../ClockService.ProcessorClocks$.html | 312 +
.../appmaster/ClockService.Report$.html | 306 +
.../appmaster/ClockService.Report.html | 296 +
.../ClockService.SnapshotStartClock$.html | 301 +
.../ClockService.StoredStartClock$.html | 306 +
.../ClockService.StoredStartClock.html | 296 +
.../streaming/appmaster/ClockService.html | 467 +
.../appmaster/DagManager.DAGOperation.html | 173 +
.../DagManager.DAGOperationFailed$.html | 306 +
.../DagManager.DAGOperationFailed.html | 296 +
.../DagManager.DAGOperationResult.html | 173 +
.../DagManager.DAGOperationSuccess$.html | 301 +
.../appmaster/DagManager.DagInitiated$.html | 301 +
.../appmaster/DagManager.GetLatestDAG$.html | 301 +
.../DagManager.GetTaskLaunchData$.html | 306 +
.../appmaster/DagManager.GetTaskLaunchData.html | 326 +
.../appmaster/DagManager.LatestDAG$.html | 306 +
.../appmaster/DagManager.LatestDAG.html | 296 +
.../appmaster/DagManager.NewDAGDeployed$.html | 306 +
.../appmaster/DagManager.NewDAGDeployed.html | 296 +
.../appmaster/DagManager.ReplaceProcessor$.html | 306 +
.../appmaster/DagManager.ReplaceProcessor.html | 326 +
.../appmaster/DagManager.TaskLaunchData$.html | 306 +
.../appmaster/DagManager.TaskLaunchData.html | 326 +
.../appmaster/DagManager.WatchChange$.html | 306 +
.../appmaster/DagManager.WatchChange.html | 296 +
.../streaming/appmaster/DagManager.html | 443 +
.../appmaster/ExecutorManager.BroadCast$.html | 306 +
.../appmaster/ExecutorManager.BroadCast.html | 296 +
.../ExecutorManager.ExecutorInfo$.html | 306 +
.../appmaster/ExecutorManager.ExecutorInfo.html | 341 +
...orManager.ExecutorResourceUsageSummary$.html | 306 +
...torManager.ExecutorResourceUsageSummary.html | 296 +
.../ExecutorManager.ExecutorStarted$.html | 306 +
.../ExecutorManager.ExecutorStarted.html | 341 +
.../ExecutorManager.ExecutorStopped$.html | 306 +
.../ExecutorManager.ExecutorStopped.html | 296 +
.../ExecutorManager.GetExecutorInfo$.html | 301 +
.../ExecutorManager.SetTaskManager$.html | 306 +
.../ExecutorManager.SetTaskManager.html | 296 +
.../ExecutorManager.StartExecutors$.html | 306 +
.../ExecutorManager.StartExecutors.html | 311 +
.../ExecutorManager.StartExecutorsTimeOut$.html | 301 +
.../appmaster/ExecutorManager.UniCast$.html | 306 +
.../appmaster/ExecutorManager.UniCast.html | 311 +
.../streaming/appmaster/ExecutorManager.html | 466 +
.../appmaster/JarScheduler.ExecutorFailed$.html | 306 +
.../appmaster/JarScheduler.ExecutorFailed.html | 297 +
...JarScheduler.GetResourceRequestDetails$.html | 301 +
.../JarScheduler.JarSchedulerImpl.html | 341 +
.../appmaster/JarScheduler.NewDag$.html | 306 +
.../appmaster/JarScheduler.NewDag.html | 311 +
.../JarScheduler.ResourceRequestDetail$.html | 306 +
.../JarScheduler.ResourceRequestDetail.html | 311 +
.../appmaster/JarScheduler.ScheduleTask$.html | 306 +
.../appmaster/JarScheduler.ScheduleTask.html | 347 +
.../JarScheduler.TransitToNewDag$.html | 301 +
.../streaming/appmaster/JarScheduler.html | 422 +
.../streaming/appmaster/ProcessorSummary.html | 397 +
.../appmaster/StreamAppMasterSummary.html | 550 ++
.../gearpump/streaming/appmaster/TaskCount.html | 292 +
.../appmaster/TaskLocator.Localities$.html | 347 +
.../appmaster/TaskLocator.Localities.html | 297 +
.../appmaster/TaskLocator.Locality.html | 173 +
.../appmaster/TaskLocator.NonLocality$.html | 284 +
.../appmaster/TaskLocator.WorkerLocality$.html | 306 +
.../appmaster/TaskLocator.WorkerLocality.html | 297 +
.../streaming/appmaster/TaskLocator.html | 323 +
.../TaskManager.ApplicationReady$.html | 301 +
.../TaskManager.ChangeTasksOnExecutor$.html | 306 +
.../TaskManager.ChangeTasksOnExecutor.html | 312 +
.../appmaster/TaskManager.DAGDiff$.html | 306 +
.../appmaster/TaskManager.DAGDiff.html | 327 +
.../appmaster/TaskManager.DagReadyState$.html | 312 +
.../appmaster/TaskManager.DagReadyState.html | 289 +
.../appmaster/TaskManager.ExecutorRegistry.html | 287 +
.../appmaster/TaskManager.FailedToRecover$.html | 306 +
.../appmaster/TaskManager.FailedToRecover.html | 296 +
.../appmaster/TaskManager.GetTaskList$.html | 301 +
.../appmaster/TaskManager.SessionIdFactory.html | 281 +
.../appmaster/TaskManager.StartDagState$.html | 278 +
.../appmaster/TaskManager.StartDagState.html | 319 +
.../TaskManager.StartTasksOnExecutor$.html | 306 +
.../TaskManager.StartTasksOnExecutor.html | 312 +
.../TaskManager.TaskChangeRegistry$.html | 312 +
.../TaskManager.TaskChangeRegistry.html | 287 +
.../appmaster/TaskManager.TaskList$.html | 306 +
.../appmaster/TaskManager.TaskList.html | 296 +
.../streaming/appmaster/TaskManager.html | 539 ++
.../appmaster/TaskRegistry.Accept$.html | 301 +
.../TaskRegistry.RegisterTaskStatus.html | 173 +
.../appmaster/TaskRegistry.Reject$.html | 301 +
.../appmaster/TaskRegistry.TaskLocation$.html | 306 +
.../appmaster/TaskRegistry.TaskLocation.html | 311 +
.../appmaster/TaskRegistry.TaskLocations$.html | 306 +
.../appmaster/TaskRegistry.TaskLocations.html | 296 +
.../streaming/appmaster/TaskRegistry.html | 505 ++
.../appmaster/TaskScheduler.Location$.html | 306 +
.../appmaster/TaskScheduler.Location.html | 311 +
.../appmaster/TaskScheduler.TaskStatus.html | 303 +
.../streaming/appmaster/TaskScheduler.html | 361 +
.../streaming/appmaster/TaskSchedulerImpl.html | 416 +
.../streaming/appmaster/package-frame.html | 147 +
.../streaming/appmaster/package-summary.html | 698 ++
.../streaming/appmaster/package-tree.html | 287 +
.../streaming/dsl/CollectionDataSource.html | 343 +
.../apache/gearpump/streaming/dsl/KVStream.html | 307 +
.../gearpump/streaming/dsl/LoggerSink.html | 351 +
.../gearpump/streaming/dsl/Stream.Sink.html | 307 +
.../apache/gearpump/streaming/dsl/Stream.html | 552 ++
.../streaming/dsl/StreamApp.Source.html | 373 +
.../gearpump/streaming/dsl/StreamApp.html | 380 +
.../streaming/dsl/javaapi/JavaStream.html | 424 +
.../streaming/dsl/javaapi/JavaStreamApp.html | 311 +
.../streaming/dsl/javaapi/package-frame.html | 21 +
.../streaming/dsl/javaapi/package-summary.html | 146 +
.../streaming/dsl/javaapi/package-tree.html | 136 +
.../gearpump/streaming/dsl/op/DataSinkOp.html | 345 +
.../gearpump/streaming/dsl/op/DataSourceOp.html | 345 +
.../gearpump/streaming/dsl/op/Direct.html | 262 +
.../gearpump/streaming/dsl/op/FlatMapOp.html | 330 +
.../gearpump/streaming/dsl/op/GroupByOp.html | 345 +
.../gearpump/streaming/dsl/op/MasterOp.html | 199 +
.../gearpump/streaming/dsl/op/MergeOp.html | 315 +
.../apache/gearpump/streaming/dsl/op/Op.html | 241 +
.../gearpump/streaming/dsl/op/OpChain.html | 357 +
.../gearpump/streaming/dsl/op/OpEdge.html | 169 +
.../streaming/dsl/op/ParameterizedOp.html | 195 +
.../gearpump/streaming/dsl/op/ProcessorOp.html | 345 +
.../gearpump/streaming/dsl/op/ReduceOp.html | 330 +
.../gearpump/streaming/dsl/op/Shuffle.html | 262 +
.../gearpump/streaming/dsl/op/SlaveOp.html | 197 +
.../streaming/dsl/op/package-frame.html | 37 +
.../streaming/dsl/op/package-summary.html | 218 +
.../gearpump/streaming/dsl/op/package-tree.html | 158 +
.../gearpump/streaming/dsl/package-frame.html | 26 +
.../gearpump/streaming/dsl/package-summary.html | 168 +
.../gearpump/streaming/dsl/package-tree.html | 141 +
.../dsl/partitioner/GroupByPartitioner.html | 320 +
.../dsl/partitioner/package-frame.html | 20 +
.../dsl/partitioner/package-summary.html | 142 +
.../streaming/dsl/partitioner/package-tree.html | 135 +
.../dsl/plan/OpTranslator.AndThen.html | 314 +
.../plan/OpTranslator.DummyInputFunction.html | 322 +
.../dsl/plan/OpTranslator.FlatMapFunction.html | 314 +
.../dsl/plan/OpTranslator.GroupByTask.html | 347 +
.../dsl/plan/OpTranslator.ReduceFunction.html | 314 +
.../plan/OpTranslator.SingleInputFunction.html | 260 +
.../dsl/plan/OpTranslator.SinkTask.html | 372 +
.../dsl/plan/OpTranslator.SourceTask.html | 374 +
.../dsl/plan/OpTranslator.TransformTask.html | 347 +
.../streaming/dsl/plan/OpTranslator.html | 345 +
.../gearpump/streaming/dsl/plan/Planner.html | 271 +
.../streaming/dsl/plan/package-frame.html | 33 +
.../streaming/dsl/plan/package-summary.html | 193 +
.../streaming/dsl/plan/package-tree.html | 160 +
.../Executor.DagVersionMismatchException.html | 264 +
.../executor/Executor.ExecutorConfig$.html | 306 +
.../executor/Executor.ExecutorConfig.html | 296 +
.../executor/Executor.ExecutorSummary$.html | 321 +
.../executor/Executor.ExecutorSummary.html | 401 +
.../executor/Executor.GetExecutorSummary$.html | 306 +
.../executor/Executor.GetExecutorSummary.html | 296 +
.../executor/Executor.HealthCheck$.html | 278 +
.../executor/Executor.QueryExecutorConfig$.html | 306 +
.../executor/Executor.QueryExecutorConfig.html | 296 +
.../executor/Executor.RestartTasks$.html | 306 +
.../executor/Executor.RestartTasks.html | 296 +
.../streaming/executor/Executor.State$.html | 351 +
.../executor/Executor.TaskArgumentStore.html | 321 +
.../executor/Executor.TaskStopped$.html | 306 +
.../executor/Executor.TaskStopped.html | 296 +
.../gearpump/streaming/executor/Executor.html | 546 ++
.../executor/ExecutorRestartPolicy.html | 293 +
.../streaming/executor/ITaskLauncher.html | 234 +
.../executor/TaskLauncher.TaskArgument$.html | 306 +
.../executor/TaskLauncher.TaskArgument.html | 326 +
.../streaming/executor/TaskLauncher.html | 338 +
.../streaming/executor/package-frame.html | 47 +
.../streaming/executor/package-summary.html | 250 +
.../streaming/executor/package-tree.html | 175 +
.../streaming/hadoop/HadoopCheckpointStore.html | 425 +
.../hadoop/HadoopCheckpointStoreFactory.html | 303 +
.../streaming/hadoop/SequenceFileSink.html | 342 +
.../hadoop/lib/HadoopCheckpointStoreReader.html | 346 +
.../hadoop/lib/HadoopCheckpointStoreWriter.html | 286 +
.../streaming/hadoop/lib/HadoopUtil.html | 316 +
.../lib/format/DefaultSequenceFormatter.html | 333 +
.../hadoop/lib/format/OutputFormatter.html | 267 +
.../hadoop/lib/format/package-frame.html | 24 +
.../hadoop/lib/format/package-summary.html | 155 +
.../hadoop/lib/format/package-tree.html | 147 +
.../streaming/hadoop/lib/package-frame.html | 22 +
.../streaming/hadoop/lib/package-summary.html | 148 +
.../streaming/hadoop/lib/package-tree.html | 137 +
.../hadoop/lib/rotation/FileSizeRotation.html | 345 +
.../streaming/hadoop/lib/rotation/Rotation.html | 256 +
.../hadoop/lib/rotation/package-frame.html | 24 +
.../hadoop/lib/rotation/package-summary.html | 155 +
.../hadoop/lib/rotation/package-tree.html | 147 +
.../streaming/hadoop/package-frame.html | 22 +
.../streaming/hadoop/package-summary.html | 150 +
.../gearpump/streaming/hadoop/package-tree.html | 137 +
.../gearpump/streaming/javaapi/Graph.html | 273 +
.../gearpump/streaming/javaapi/Processor.html | 565 ++
.../streaming/javaapi/StreamApplication.html | 359 +
.../apache/gearpump/streaming/javaapi/Task.html | 421 +
.../javaapi/dsl/functions/FilterFunction.html | 231 +
.../javaapi/dsl/functions/FlatMapFunction.html | 232 +
.../javaapi/dsl/functions/GroupByFunction.html | 232 +
.../javaapi/dsl/functions/MapFunction.html | 232 +
.../javaapi/dsl/functions/ReduceFunction.html | 233 +
.../javaapi/dsl/functions/package-frame.html | 24 +
.../javaapi/dsl/functions/package-summary.html | 166 +
.../javaapi/dsl/functions/package-tree.html | 139 +
.../streaming/javaapi/package-frame.html | 23 +
.../streaming/javaapi/package-summary.html | 164 +
.../streaming/javaapi/package-tree.html | 146 +
.../gearpump/streaming/kafka/KafkaSink.html | 282 +
.../gearpump/streaming/kafka/KafkaSource.html | 313 +
.../streaming/kafka/KafkaStoreFactory.html | 265 +
.../gearpump/streaming/kafka/dsl/KafkaDSL.html | 380 +
.../streaming/kafka/dsl/package-frame.html | 20 +
.../streaming/kafka/dsl/package-summary.html | 140 +
.../streaming/kafka/dsl/package-tree.html | 135 +
.../AbstractKafkaSink.KafkaProducerFactory.html | 228 +
.../kafka/lib/sink/AbstractKafkaSink.html | 396 +
.../streaming/kafka/lib/sink/package-frame.html | 24 +
.../kafka/lib/sink/package-summary.html | 158 +
.../streaming/kafka/lib/sink/package-tree.html | 143 +
.../kafka/lib/source/AbstractKafkaSource.html | 420 +
.../kafka/lib/source/DefaultMessageDecoder.html | 289 +
.../kafka/lib/source/StringMessageDecoder.html | 289 +
.../consumer/ExponentialBackoffSleeper.html | 331 +
.../FetchThread.FetchThreadFactory.html | 284 +
.../kafka/lib/source/consumer/FetchThread.html | 435 +
.../lib/source/consumer/KafkaConsumer.html | 350 +
.../kafka/lib/source/consumer/KafkaMessage.html | 362 +
.../lib/source/consumer/package-frame.html | 24 +
.../lib/source/consumer/package-summary.html | 168 +
.../kafka/lib/source/consumer/package-tree.html | 143 +
.../source/grouper/DefaultPartitionGrouper.html | 289 +
.../lib/source/grouper/PartitionGrouper.html | 228 +
.../kafka/lib/source/grouper/package-frame.html | 24 +
.../lib/source/grouper/package-summary.html | 159 +
.../kafka/lib/source/grouper/package-tree.html | 139 +
.../kafka/lib/source/package-frame.html | 22 +
.../kafka/lib/source/package-summary.html | 151 +
.../kafka/lib/source/package-tree.html | 137 +
.../lib/store/AbstractKafkaStoreFactory.html | 307 +
.../streaming/kafka/lib/store/KafkaStore.html | 362 +
.../kafka/lib/store/package-frame.html | 21 +
.../kafka/lib/store/package-summary.html | 148 +
.../streaming/kafka/lib/store/package-tree.html | 136 +
.../util/KafkaClient.KafkaClientFactory.html | 282 +
.../streaming/kafka/lib/util/KafkaClient.html | 393 +
.../streaming/kafka/lib/util/package-frame.html | 21 +
.../kafka/lib/util/package-summary.html | 144 +
.../streaming/kafka/lib/util/package-tree.html | 136 +
.../gearpump/streaming/kafka/package-frame.html | 22 +
.../streaming/kafka/package-summary.html | 154 +
.../gearpump/streaming/kafka/package-tree.html | 149 +
.../util/KafkaConfig.KafkaConfigFactory.html | 282 +
.../streaming/kafka/util/KafkaConfig.html | 711 ++
.../streaming/kafka/util/package-frame.html | 21 +
.../streaming/kafka/util/package-summary.html | 146 +
.../streaming/kafka/util/package-tree.html | 140 +
.../metrics/ProcessorAggregator.Aggregator.html | 240 +
.../ProcessorAggregator.AggregatorFactory.html | 275 +
...ProcessorAggregator.HistogramAggregator.html | 403 +
.../ProcessorAggregator.MeterAggregator.html | 364 +
.../ProcessorAggregator.MultiLayerMap.html | 333 +
.../streaming/metrics/ProcessorAggregator.html | 381 +
.../metrics/TaskFilterAggregator.Options$.html | 334 +
.../metrics/TaskFilterAggregator.Options.html | 356 +
.../streaming/metrics/TaskFilterAggregator.html | 449 +
.../streaming/metrics/package-frame.html | 31 +
.../streaming/metrics/package-summary.html | 191 +
.../streaming/metrics/package-tree.html | 146 +
.../streaming/monoid/AlgebirdGroup.html | 324 +
.../streaming/monoid/AlgebirdMonoid.html | 303 +
.../streaming/monoid/package-frame.html | 21 +
.../streaming/monoid/package-summary.html | 144 +
.../gearpump/streaming/monoid/package-tree.html | 136 +
.../gearpump/streaming/package-frame.html | 82 +
.../gearpump/streaming/package-summary.html | 396 +
.../apache/gearpump/streaming/package-tree.html | 222 +
.../streaming/serializer/ChillSerializer.html | 301 +
.../streaming/serializer/package-frame.html | 20 +
.../streaming/serializer/package-summary.html | 140 +
.../streaming/serializer/package-tree.html | 135 +
.../gearpump/streaming/sink/DataSink.html | 295 +
.../streaming/sink/DataSinkProcessor.html | 288 +
.../gearpump/streaming/sink/DataSinkTask.html | 382 +
.../gearpump/streaming/sink/package-frame.html | 25 +
.../streaming/sink/package-summary.html | 167 +
.../gearpump/streaming/sink/package-tree.html | 148 +
.../gearpump/streaming/source/DataSource.html | 303 +
.../streaming/source/DataSourceConfig.html | 269 +
.../streaming/source/DataSourceProcessor.html | 288 +
.../streaming/source/DataSourceTask.html | 391 +
.../source/DefaultTimeStampFilter.html | 285 +
.../streaming/source/package-frame.html | 27 +
.../streaming/source/package-summary.html | 178 +
.../gearpump/streaming/source/package-tree.html | 150 +
.../gearpump/streaming/state/api/Group.html | 239 +
.../gearpump/streaming/state/api/Monoid.html | 249 +
.../streaming/state/api/MonoidState.html | 381 +
.../streaming/state/api/PersistentState.html | 331 +
.../streaming/state/api/PersistentTask.html | 496 +
.../streaming/state/api/Serializer.html | 243 +
.../streaming/state/api/package-frame.html | 28 +
.../streaming/state/api/package-summary.html | 177 +
.../streaming/state/api/package-tree.html | 154 +
.../streaming/state/impl/CheckpointManager.html | 352 +
.../state/impl/InMemoryCheckpointStore.html | 316 +
.../impl/InMemoryCheckpointStoreFactory.html | 286 +
.../gearpump/streaming/state/impl/Interval.html | 332 +
.../streaming/state/impl/NonWindowState.html | 365 +
.../state/impl/PersistentStateConfig.html | 321 +
.../gearpump/streaming/state/impl/Window.html | 363 +
.../streaming/state/impl/WindowConfig.html | 320 +
.../streaming/state/impl/WindowState.html | 443 +
.../streaming/state/impl/package-frame.html | 28 +
.../streaming/state/impl/package-summary.html | 187 +
.../streaming/state/impl/package-tree.html | 147 +
.../streaming/storage/AppDataStore.html | 239 +
.../storage/InMemoryAppStoreOnMaster.html | 313 +
.../streaming/storage/package-frame.html | 24 +
.../streaming/storage/package-summary.html | 159 +
.../streaming/storage/package-tree.html | 139 +
.../org/apache/gearpump/streaming/task/Ack.html | 341 +
.../gearpump/streaming/task/AckRequest.html | 322 +
.../streaming/task/CheckProcessorDeath.html | 292 +
.../streaming/task/CheckpointClock.html | 292 +
.../gearpump/streaming/task/ClockEvent.html | 169 +
.../streaming/task/ExpressTransport.html | 294 +
.../streaming/task/GetCheckpointClock.html | 258 +
.../apache/gearpump/streaming/task/GetDAG.html | 258 +
.../streaming/task/GetLatestMinClock.html | 240 +
.../gearpump/streaming/task/GetStartClock.html | 258 +
.../streaming/task/GetUpstreamMinClock.html | 292 +
.../streaming/task/InitialAckRequest.html | 307 +
.../gearpump/streaming/task/LatencyProbe.html | 293 +
.../gearpump/streaming/task/LatestMinClock.html | 292 +
.../streaming/task/SendMessageLoss.html | 258 +
.../streaming/task/SerializedMessage.html | 307 +
.../task/SerializedMessageSerializer.html | 314 +
.../task/SerializerResolver.Registration.html | 303 +
.../streaming/task/SerializerResolver.html | 316 +
.../gearpump/streaming/task/StartClock.html | 292 +
.../gearpump/streaming/task/StartTime.html | 293 +
.../task/StreamingTransportSerializer.html | 316 +
.../gearpump/streaming/task/Subscriber.html | 371 +
.../gearpump/streaming/task/Subscription.html | 427 +
.../apache/gearpump/streaming/task/Task.html | 426 +
.../streaming/task/TaskActor.FLUSH$.html | 301 +
.../task/TaskActor.MessageAndSender$.html | 306 +
.../task/TaskActor.MessageAndSender.html | 311 +
.../task/TaskActor.SecurityChecker.html | 307 +
.../streaming/task/TaskActor.SendAck$.html | 306 +
.../streaming/task/TaskActor.SendAck.html | 311 +
.../gearpump/streaming/task/TaskActor.html | 724 ++
.../gearpump/streaming/task/TaskContext.html | 512 ++
.../streaming/task/TaskContextData.html | 382 +
.../apache/gearpump/streaming/task/TaskId.html | 333 +
.../gearpump/streaming/task/TaskInterface.html | 293 +
.../streaming/task/TaskMessageSerializer.html | 255 +
.../gearpump/streaming/task/TaskUtil.html | 279 +
.../gearpump/streaming/task/TaskWrapper.html | 786 ++
.../streaming/task/UpdateCheckpointClock.html | 307 +
.../gearpump/streaming/task/UpdateClock.html | 307 +
.../streaming/task/UpstreamMinClock.html | 292 +
.../gearpump/streaming/task/package-frame.html | 64 +
.../streaming/task/package-summary.html | 336 +
.../gearpump/streaming/task/package-tree.html | 183 +
.../transaction/api/CheckpointStore.html | 254 +
.../transaction/api/CheckpointStoreFactory.html | 235 +
.../transaction/api/MessageDecoder.html | 239 +
.../transaction/api/TimeReplayableSource.html | 248 +
.../transaction/api/TimeStampFilter.html | 231 +
.../transaction/api/package-frame.html | 24 +
.../transaction/api/package-summary.html | 168 +
.../streaming/transaction/api/package-tree.html | 143 +
.../gearpump/streaming/util/ActorPathUtil.html | 312 +
.../gearpump/streaming/util/package-frame.html | 20 +
.../streaming/util/package-summary.html | 140 +
.../gearpump/streaming/util/package-tree.html | 135 +
.../gearpump/transport/ActorLookupById.html | 226 +
.../org/apache/gearpump/transport/Express.html | 543 ++
.../org/apache/gearpump/transport/HostPort.html | 333 +
.../netty/Client.ChannelFutureOps.html | 286 +
.../transport/netty/Client.ChannelReady$.html | 306 +
.../transport/netty/Client.ChannelReady.html | 296 +
.../netty/Client.ClientErrorHandler.html | 310 +
.../netty/Client.ClientPipelineFactory.html | 284 +
.../gearpump/transport/netty/Client.Close$.html | 301 +
.../Client.CompareAndReconnectIfEqual$.html | 306 +
.../Client.CompareAndReconnectIfEqual.html | 296 +
.../transport/netty/Client.Connect$.html | 306 +
.../transport/netty/Client.Connect.html | 296 +
.../gearpump/transport/netty/Client.Flush$.html | 306 +
.../gearpump/transport/netty/Client.Flush.html | 296 +
.../apache/gearpump/transport/netty/Client.html | 469 +
.../gearpump/transport/netty/Context.html | 370 +
.../gearpump/transport/netty/IContext.html | 279 +
.../netty/ITransportMessageSerializer.html | 253 +
.../gearpump/transport/netty/MessageBatch.html | 196 +
.../transport/netty/MessageDecoder.html | 335 +
.../transport/netty/MessageEncoder.html | 311 +
.../gearpump/transport/netty/NettyConfig.html | 347 +
.../netty/NettyRenameThreadFactory.html | 244 +
.../gearpump/transport/netty/NettyUtil.html | 309 +
.../transport/netty/Server.AddChannel$.html | 306 +
.../transport/netty/Server.AddChannel.html | 296 +
.../transport/netty/Server.CloseChannel$.html | 306 +
.../transport/netty/Server.CloseChannel.html | 296 +
.../transport/netty/Server.MsgBatch$.html | 306 +
.../transport/netty/Server.MsgBatch.html | 296 +
.../transport/netty/Server.ServerHandler.html | 361 +
.../netty/Server.ServerPipelineFactory.html | 284 +
.../netty/Server.TaskIdActorRefTranslation.html | 276 +
.../apache/gearpump/transport/netty/Server.html | 432 +
.../gearpump/transport/netty/TaskMessage.html | 314 +
.../transport/netty/WrappedChannelBuffer.html | 591 ++
.../gearpump/transport/netty/package-frame.html | 56 +
.../transport/netty/package-summary.html | 293 +
.../gearpump/transport/netty/package-tree.html | 187 +
.../gearpump/transport/package-frame.html | 25 +
.../gearpump/transport/package-summary.html | 161 +
.../apache/gearpump/transport/package-tree.html | 140 +
.../util/ActorSystemBooter.ActorCreated$.html | 306 +
.../util/ActorSystemBooter.ActorCreated.html | 311 +
...ctorSystemBooter.ActorSystemRegistered$.html | 306 +
...ActorSystemBooter.ActorSystemRegistered.html | 298 +
.../util/ActorSystemBooter.BindLifeCycle$.html | 306 +
.../util/ActorSystemBooter.BindLifeCycle.html | 296 +
.../util/ActorSystemBooter.CreateActor$.html | 306 +
.../util/ActorSystemBooter.CreateActor.html | 311 +
.../ActorSystemBooter.CreateActorFailed$.html | 306 +
.../ActorSystemBooter.CreateActorFailed.html | 311 +
.../gearpump/util/ActorSystemBooter.Daemon.html | 427 +
.../ActorSystemBooter.RegisterActorSystem$.html | 306 +
.../ActorSystemBooter.RegisterActorSystem.html | 296 +
...SystemBooter.RegisterActorSystemFailed$.html | 306 +
...rSystemBooter.RegisterActorSystemFailed.html | 296 +
...ystemBooter.RegisterActorSystemTimeOut$.html | 278 +
.../apache/gearpump/util/ActorSystemBooter.html | 383 +
.../org/apache/gearpump/util/ActorUtil.html | 460 +
.../java/org/apache/gearpump/util/AkkaApp.html | 261 +
.../org/apache/gearpump/util/AkkaHelper.html | 287 +
.../org/apache/gearpump/util/ConsoleOutput.html | 236 +
.../org/apache/gearpump/util/Constants.html | 1400 +++
.../org/apache/gearpump/util/FileUtils.html | 328 +
.../org/apache/gearpump/util/Graph.Node.html | 295 +
.../apache/gearpump/util/Graph.NodeList.html | 293 +
.../org/apache/gearpump/util/Graph.Path$.html | 314 +
.../org/apache/gearpump/util/Graph.Path.html | 294 +
.../java/org/apache/gearpump/util/Graph.html | 930 ++
.../gearpump/util/HadoopFSLogAppender.html | 324 +
...storyMetricsService.CounterMetricsStore.html | 338 +
...MetricsService.DummyHistoryMetricsStore.html | 350 +
...ryMetricsService.DummyMetricsAggregator.html | 284 +
...HistoryMetricsService.GaugeMetricsStore.html | 338 +
...oryMetricsService.HistogramMetricsStore.html | 338 +
...oryMetricsService.HistoryMetricsConfig$.html | 321 +
...toryMetricsService.HistoryMetricsConfig.html | 349 +
...toryMetricsService.HistoryMetricsStore$.html | 316 +
...storyMetricsService.HistoryMetricsStore.html | 272 +
...HistoryMetricsService.MeterMetricsStore.html | 338 +
.../HistoryMetricsService.MetricsStore.html | 259 +
...yMetricsService.SingleValueMetricsStore.html | 343 +
...HistoryMetricsService.SkipAllAggregator.html | 284 +
.../gearpump/util/HistoryMetricsService.html | 414 +
.../gearpump/util/LogUtil.ProcessType$.html | 406 +
.../java/org/apache/gearpump/util/LogUtil.html | 372 +
.../gearpump/util/ProcessLogRedirector.html | 383 +
.../util/RecreateRollingFileAppender.html | 416 +
.../apache/gearpump/util/ReferenceEqual.html | 249 +
.../org/apache/gearpump/util/RestartPolicy.html | 278 +
.../org/apache/gearpump/util/RichProcess.html | 311 +
.../apache/gearpump/util/TimeOutScheduler.html | 230 +
.../gearpump/util/Util.AppJvmSettings$.html | 306 +
.../gearpump/util/Util.AppJvmSettings.html | 311 +
.../apache/gearpump/util/Util.JvmSetting$.html | 306 +
.../apache/gearpump/util/Util.JvmSetting.html | 311 +
.../api/java/org/apache/gearpump/util/Util.html | 493 +
.../org/apache/gearpump/util/package-frame.html | 78 +
.../apache/gearpump/util/package-summary.html | 401 +
.../org/apache/gearpump/util/package-tree.html | 224 +
releases/latest/api/java/overview-frame.html | 77 +-
releases/latest/api/java/overview-summary.html | 170 +-
releases/latest/api/java/overview-tree.html | 1287 ++-
releases/latest/api/java/package-list | 73 +-
releases/latest/api/java/serialized-form.html | 3531 ++++++--
.../latest/api/scala/akka/pattern/package.html | 2 +-
releases/latest/api/scala/index.html | 378 +-
releases/latest/api/scala/index.js | 2 +-
releases/latest/api/scala/index/index-_.html | 16 +-
releases/latest/api/scala/index/index-a.html | 288 +-
releases/latest/api/scala/index/index-b.html | 34 +-
releases/latest/api/scala/index/index-c.html | 237 +-
releases/latest/api/scala/index/index-d.html | 146 +-
releases/latest/api/scala/index/index-e.html | 122 +-
releases/latest/api/scala/index/index-f.html | 96 +-
releases/latest/api/scala/index/index-g.html | 369 +-
releases/latest/api/scala/index/index-h.html | 83 +-
releases/latest/api/scala/index/index-i.html | 64 +-
releases/latest/api/scala/index/index-j.html | 30 +-
releases/latest/api/scala/index/index-k.html | 60 +-
releases/latest/api/scala/index/index-l.html | 116 +-
releases/latest/api/scala/index/index-m.html | 209 +-
releases/latest/api/scala/index/index-n.html | 65 +-
releases/latest/api/scala/index/index-o.html | 75 +-
releases/latest/api/scala/index/index-p.html | 158 +-
releases/latest/api/scala/index/index-q.html | 13 +-
releases/latest/api/scala/index/index-r.html | 260 +-
releases/latest/api/scala/index/index-s.html | 332 +-
releases/latest/api/scala/index/index-t.html | 181 +-
releases/latest/api/scala/index/index-u.html | 83 +-
releases/latest/api/scala/index/index-v.html | 26 +-
releases/latest/api/scala/index/index-w.html | 145 +-
releases/latest/api/scala/index/index-z.html | 5 +-
.../latest/api/scala/io/gearpump/Message$.html | 505 --
.../latest/api/scala/io/gearpump/Message.html | 496 -
.../io/gearpump/cluster/AppDescription.html | 528 --
.../api/scala/io/gearpump/cluster/AppJar.html | 494 -
.../io/gearpump/cluster/AppMasterContext.html | 579 --
.../gearpump/cluster/AppMasterRegisterData.html | 485 -
.../AppMasterToMaster$$AppDataSaved$.html | 456 -
.../AppMasterToMaster$$AppMasterSummary.html | 624 --
...MasterToMaster$$GeneralAppMasterSummary.html | 597 --
.../AppMasterToMaster$$GetAllWorkers$.html | 456 -
.../cluster/AppMasterToMaster$$GetAppData.html | 493 -
.../AppMasterToMaster$$GetAppDataResult.html | 493 -
.../AppMasterToMaster$$GetMasterData$.html | 456 -
.../AppMasterToMaster$$GetWorkerData.html | 476 -
.../AppMasterToMaster$$InvalidAppMaster.html | 510 --
.../cluster/AppMasterToMaster$$MasterData.html | 476 -
.../AppMasterToMaster$$RegisterAppMaster.html | 493 -
.../AppMasterToMaster$$RequestResource.html | 493 -
.../cluster/AppMasterToMaster$$SaveAppData.html | 510 --
.../AppMasterToMaster$$SaveAppDataFailed$.html | 456 -
.../cluster/AppMasterToMaster$$WorkerData.html | 476 -
.../io/gearpump/cluster/AppMasterToMaster$.html | 740 --
...pMasterToWorker$$ChangeExecutorResource.html | 510 --
.../AppMasterToWorker$$LaunchExecutor.html | 527 --
.../AppMasterToWorker$$ShutdownExecutor.html | 510 --
.../io/gearpump/cluster/AppMasterToWorker$.html | 536 --
.../Application$$DefaultApplication.html | 555 --
.../scala/io/gearpump/cluster/Application$.html | 538 --
.../scala/io/gearpump/cluster/Application.html | 541 --
.../io/gearpump/cluster/ApplicationMaster.html | 810 --
.../cluster/ClientToMaster$$AddMaster$.html | 456 -
.../cluster/ClientToMaster$$AddWorker.html | 476 -
.../cluster/ClientToMaster$$CommandResult.html | 510 --
.../ClientToMaster$$GetJarStoreServer$.html | 456 -
.../cluster/ClientToMaster$$GetLastFailure.html | 476 -
.../ClientToMaster$$GetStallingTasks.html | 476 -
.../ClientToMaster$$JarStoreServerAddress.html | 476 -
.../ClientToMaster$$QueryAppMasterConfig.html | 476 -
.../ClientToMaster$$QueryHistoryMetrics.html | 527 --
.../ClientToMaster$$QueryMasterConfig$.html | 456 -
.../ClientToMaster$$QueryWorkerConfig.html | 476 -
.../cluster/ClientToMaster$$ReadOption$.html | 570 --
.../cluster/ClientToMaster$$RemoveMaster.html | 476 -
.../cluster/ClientToMaster$$RemoveWorker.html | 476 -
.../cluster/ClientToMaster$$ResolveAppId.html | 476 -
.../ClientToMaster$$ResolveWorkerId.html | 476 -
.../ClientToMaster$$RestartApplication.html | 476 -
.../ClientToMaster$$ShutdownApplication.html | 476 -
.../ClientToMaster$$SubmitApplication.html | 510 --
.../io/gearpump/cluster/ClientToMaster$.html | 809 --
...lusterConfig$$ConfigValidationException.html | 712 --
.../cluster/ClusterConfig$$Configs.html | 570 --
.../io/gearpump/cluster/ClusterConfig$.html | 715 --
.../gearpump/cluster/ClusterConfigSource$.html | 523 --
.../gearpump/cluster/ClusterConfigSource.html | 509 --
.../io/gearpump/cluster/ExecutorContext.html | 563 --
.../io/gearpump/cluster/ExecutorJVMConfig.html | 584 --
.../MasterToAppMaster$$AppMasterData.html | 612 --
...ToAppMaster$$AppMasterDataDetailRequest.html | 476 -
...MasterToAppMaster$$AppMasterDataRequest.html | 493 -
...terToAppMaster$$AppMasterMetricsRequest.html | 478 -
.../MasterToAppMaster$$AppMasterRegistered.html | 476 -
.../MasterToAppMaster$$AppMastersData.html | 476 -
...sterToAppMaster$$AppMastersDataRequest$.html | 456 -
...$$ReplayFromTimestampWindowTrailingEdge.html | 476 -
.../MasterToAppMaster$$ResourceAllocated.html | 493 -
.../MasterToAppMaster$$ShutdownAppMaster$.html | 456 -
.../MasterToAppMaster$$StreamingType.html | 485 -
.../cluster/MasterToAppMaster$$WorkerList.html | 476 -
.../io/gearpump/cluster/MasterToAppMaster$.html | 757 --
.../MasterToClient$$AppMasterConfig.html | 476 -
.../cluster/MasterToClient$$HistoryMetrics.html | 493 -
.../MasterToClient$$HistoryMetricsItem.html | 493 -
.../cluster/MasterToClient$$LastFailure.html | 493 -
.../cluster/MasterToClient$$MasterConfig.html | 476 -
...MasterToClient$$ReplayApplicationResult.html | 476 -
.../MasterToClient$$ResolveAppIdResult.html | 476 -
.../MasterToClient$$ResolveWorkerIdResult.html | 476 -
...sterToClient$$ShutdownApplicationResult.html | 476 -
...MasterToClient$$SubmitApplicationResult.html | 476 -
...rToClient$$SubmitApplicationResultValue.html | 476 -
.../cluster/MasterToClient$$WorkerConfig.html | 476 -
.../io/gearpump/cluster/MasterToClient$.html | 689 --
.../MasterToWorker$$UpdateResourceFailed.html | 493 -
.../MasterToWorker$$UpdateResourceSucceed$.html | 456 -
.../MasterToWorker$$WorkerRegistered.html | 493 -
.../io/gearpump/cluster/MasterToWorker$.html | 536 --
.../scala/io/gearpump/cluster/UserConfig$.html | 539 --
.../scala/io/gearpump/cluster/UserConfig.html | 838 --
...rkerToAppMaster$$ExecutorLaunchRejected.html | 493 -
...rkerToAppMaster$$ShutdownExecutorFailed.html | 493 -
...kerToAppMaster$$ShutdownExecutorSucceed.html | 493 -
.../io/gearpump/cluster/WorkerToAppMaster$.html | 536 --
.../WorkerToMaster$$RegisterNewWorker$.html | 456 -
.../cluster/WorkerToMaster$$RegisterWorker.html | 476 -
.../cluster/WorkerToMaster$$ResourceUpdate.html | 510 --
.../io/gearpump/cluster/WorkerToMaster$.html | 537 --
.../appmaster/AppMasterRuntimeEnvironment$.html | 499 -
.../cluster/appmaster/AppMasterRuntimeInfo.html | 597 --
.../cluster/appmaster/ApplicationState.html | 613 --
.../cluster/appmaster/ExecutorSystem.html | 579 --
...ystemScheduler$$ExecutorSystemJvmConfig.html | 544 --
...rSystemScheduler$$ExecutorSystemStarted.html | 493 -
...mScheduler$$StartExecutorSystemTimeout$.html | 456 -
...orSystemScheduler$$StartExecutorSystems.html | 493 -
...utorSystemScheduler$$StopExecutorSystem.html | 476 -
.../appmaster/ExecutorSystemScheduler$.html | 570 --
.../gearpump/cluster/appmaster/WorkerInfo.html | 493 -
.../io/gearpump/cluster/appmaster/package.html | 207 -
.../gearpump/cluster/client/ClientContext$.html | 569 --
.../gearpump/cluster/client/ClientContext.html | 729 --
.../gearpump/cluster/client/MasterClient.html | 589 --
.../io/gearpump/cluster/client/package.html | 157 -
.../cluster/embedded/EmbeddedCluster$.html | 501 -
.../cluster/embedded/EmbeddedCluster.html | 556 --
.../io/gearpump/cluster/embedded/package.html | 139 -
.../io/gearpump/cluster/main/AppSubmitter$.html | 676 --
.../cluster/main/ArgumentsParser$$Syntax.html | 510 --
.../gearpump/cluster/main/ArgumentsParser$.html | 521 --
.../gearpump/cluster/main/ArgumentsParser.html | 591 --
.../io/gearpump/cluster/main/CLIOption.html | 510 --
.../scala/io/gearpump/cluster/main/Gear$.html | 567 --
.../scala/io/gearpump/cluster/main/Info$.html | 659 --
.../scala/io/gearpump/cluster/main/Kill$.html | 659 --
.../scala/io/gearpump/cluster/main/Local$.html | 693 --
.../io/gearpump/cluster/main/MainRunner$.html | 659 --
.../scala/io/gearpump/cluster/main/Master$.html | 693 --
.../cluster/main/MasterWatcher$$Shutdown$.html | 482 -
.../gearpump/cluster/main/MasterWatcher$.html | 501 -
.../io/gearpump/cluster/main/MasterWatcher.html | 999 --
.../io/gearpump/cluster/main/ParseResult.html | 587 --
.../scala/io/gearpump/cluster/main/Replay$.html | 659 --
.../scala/io/gearpump/cluster/main/Worker$.html | 693 --
.../scala/io/gearpump/cluster/main/package.html | 360 -
.../cluster/master/AppManager$$MasterState.html | 510 --
.../io/gearpump/cluster/master/AppManager$.html | 536 --
.../cluster/master/AppMasterLauncher$.html | 503 --
.../cluster/master/AppMasterLauncher.html | 943 --
.../master/AppMasterLauncherFactory.html | 505 --
.../InMemoryKVService$$DeleteKVGroup.html | 476 -
.../master/InMemoryKVService$$GetKV.html | 494 -
.../master/InMemoryKVService$$GetKVFailed.html | 478 -
.../master/InMemoryKVService$$GetKVResult.html | 485 -
.../master/InMemoryKVService$$GetKVSuccess.html | 495 -
.../master/InMemoryKVService$$GroupDeleted.html | 480 -
.../master/InMemoryKVService$$PutKV.html | 510 --
.../master/InMemoryKVService$$PutKVFailed.html | 495 -
.../master/InMemoryKVService$$PutKVResult.html | 485 -
.../InMemoryKVService$$PutKVSuccess$.html | 458 -
.../master/InMemoryKVService$$Request.html | 493 -
.../cluster/master/InMemoryKVService$.html | 675 --
.../cluster/master/InMemoryKVService.html | 853 --
.../cluster/master/Master$$MasterInfo$.html | 505 --
.../cluster/master/Master$$MasterInfo.html | 495 -
.../cluster/master/Master$$SlotStatus.html | 493 -
.../master/Master$$WorkerTerminated.html | 476 -
.../io/gearpump/cluster/master/Master$.html | 587 --
.../gearpump/cluster/master/MasterActivity.html | 493 -
.../io/gearpump/cluster/master/MasterNode.html | 510 --
.../master/MasterProxy$$MasterRestarted$.html | 456 -
.../master/MasterProxy$$MasterStopped$.html | 456 -
.../master/MasterProxy$$WatchMaster.html | 476 -
.../gearpump/cluster/master/MasterProxy$.html | 555 --
.../io/gearpump/cluster/master/MasterProxy.html | 972 --
.../gearpump/cluster/master/MasterStatus$.html | 536 --
.../gearpump/cluster/master/MasterSummary.html | 630 --
.../io/gearpump/cluster/master/package.html | 328 -
.../api/scala/io/gearpump/cluster/package.html | 616 --
.../gearpump/cluster/scheduler/Priority$.html | 803 --
.../cluster/scheduler/PriorityScheduler.html | 924 --
.../gearpump/cluster/scheduler/Relaxation$.html | 803 --
.../gearpump/cluster/scheduler/Resource$.html | 522 --
.../io/gearpump/cluster/scheduler/Resource.html | 614 --
.../cluster/scheduler/ResourceAllocation.html | 510 --
.../cluster/scheduler/ResourceRequest.html | 544 --
.../Scheduler$$ApplicationFinished.html | 476 -
.../scheduler/Scheduler$$PendingRequest.html | 527 --
.../gearpump/cluster/scheduler/Scheduler$.html | 521 --
.../gearpump/cluster/scheduler/Scheduler.html | 897 --
.../io/gearpump/cluster/scheduler/package.html | 257 -
.../worker/DefaultExecutorProcessLauncher.html | 555 --
.../cluster/worker/ExecutorProcessLauncher.html | 542 --
.../gearpump/cluster/worker/ExecutorSlots.html | 510 --
.../gearpump/cluster/worker/WorkerSummary$.html | 505 --
.../gearpump/cluster/worker/WorkerSummary.html | 666 --
.../io/gearpump/cluster/worker/package.html | 192 -
.../io/gearpump/external/hbase/HBaseSink$.html | 590 --
.../io/gearpump/external/hbase/HBaseSink.html | 686 --
.../external/hbase/dsl/HBaseDSLSink$.html | 501 -
.../external/hbase/dsl/HBaseDSLSink.html | 538 --
.../io/gearpump/external/hbase/dsl/package.html | 138 -
.../io/gearpump/external/hbase/package.html | 155 -
.../api/scala/io/gearpump/external/package.html | 118 -
.../scala/io/gearpump/jarstore/FilePath.html | 476 -
.../io/gearpump/jarstore/JarStoreService$.html | 504 --
.../io/gearpump/jarstore/JarStoreService.html | 563 --
.../jarstore/dfs/DFSJarStoreService.html | 577 --
.../scala/io/gearpump/jarstore/dfs/package.html | 119 -
.../gearpump/jarstore/local/LocalJarStore.html | 936 --
.../jarstore/local/LocalJarStoreService.html | 577 --
.../io/gearpump/jarstore/local/package.html | 135 -
.../api/scala/io/gearpump/jarstore/package.html | 190 -
.../scala/io/gearpump/metrics/AkkaReporter.html | 522 --
.../api/scala/io/gearpump/metrics/Counter.html | 554 --
.../scala/io/gearpump/metrics/Histogram.html | 571 --
.../io/gearpump/metrics/JvmMetricsSet.html | 523 --
.../api/scala/io/gearpump/metrics/Meter.html | 570 --
.../io/gearpump/metrics/Metrics$$Counter.html | 495 -
.../metrics/Metrics$$DemandMoreMetrics.html | 476 -
.../gearpump/metrics/Metrics$$DummyMetrics.html | 608 --
.../io/gearpump/metrics/Metrics$$Gauge.html | 495 -
.../io/gearpump/metrics/Metrics$$Histogram.html | 580 --
.../io/gearpump/metrics/Metrics$$Meter.html | 546 --
.../gearpump/metrics/Metrics$$MetricType$.html | 518 --
.../gearpump/metrics/Metrics$$MetricType.html | 507 --
.../metrics/Metrics$$ReportMetrics$.html | 456 -
.../io/gearpump/metrics/Metrics$$Timer.html | 767 --
.../api/scala/io/gearpump/metrics/Metrics$.html | 746 --
.../api/scala/io/gearpump/metrics/Metrics.html | 611 --
.../io/gearpump/metrics/MetricsAggregator.html | 506 --
.../MetricsReporterService$$ReportTo.html | 505 --
.../metrics/MetricsReporterService$.html | 504 --
.../metrics/MetricsReporterService.html | 890 --
.../api/scala/io/gearpump/metrics/package.html | 276 -
.../scala/io/gearpump/package$$WorkerId$.html | 556 --
.../scala/io/gearpump/package$$WorkerId.html | 499 -
.../latest/api/scala/io/gearpump/package.html | 405 -
.../partitioner/BroadcastPartitioner.html | 544 --
.../partitioner/CoLocationPartitioner.html | 546 --
.../gearpump/partitioner/HashPartitioner.html | 547 --
.../partitioner/MulticastPartitioner.html | 528 --
.../io/gearpump/partitioner/Partitioner$.html | 522 --
.../io/gearpump/partitioner/Partitioner.html | 491 -
.../partitioner/PartitionerByClassName.html | 542 --
.../partitioner/PartitionerDescription.html | 476 -
.../partitioner/PartitionerFactory.html | 522 --
.../gearpump/partitioner/PartitionerObject.html | 542 --
.../partitioner/ShuffleGroupingPartitioner.html | 547 --
.../partitioner/ShufflePartitioner.html | 562 --
.../partitioner/UnicastPartitioner.html | 528 --
.../scala/io/gearpump/partitioner/package.html | 332 -
.../Authenticator$$AuthenticationResult.html | 519 --
.../io/gearpump/security/Authenticator$.html | 572 --
.../io/gearpump/security/Authenticator.html | 508 --
.../security/ConfigFileBasedAuthenticator$.html | 484 -
.../security/ConfigFileBasedAuthenticator.html | 532 --
.../io/gearpump/security/PasswordUtil$.html | 539 --
.../api/scala/io/gearpump/security/package.html | 201 -
.../FastKryoSerializationFramework.html | 543 --
...oSerializer$$KryoSerializationException.html | 712 --
.../serializer/FastKryoSerializer$.html | 504 --
.../gearpump/serializer/FastKryoSerializer.html | 557 --
.../serializer/GearpumpSerialization.html | 519 --
.../serializer/SerializationFramework.html | 528 --
.../io/gearpump/serializer/Serializer.html | 523 --
.../scala/io/gearpump/serializer/package.html | 208 -
.../streaming/AckRequestSerializer.html | 572 --
.../io/gearpump/streaming/AckSerializer.html | 572 --
.../AppMasterToExecutor$$ChangeTask.html | 527 --
.../AppMasterToExecutor$$ChangeTasks.html | 528 --
.../AppMasterToExecutor$$LaunchTasks.html | 527 --
.../AppMasterToExecutor$$MsgLostException.html | 712 --
...pMasterToExecutor$$RestartClockService$.html | 456 -
.../AppMasterToExecutor$$StartAllTasks.html | 476 -
.../AppMasterToExecutor$$StartDynamicDag.html | 476 -
.../AppMasterToExecutor$$StartTask.html | 476 -
.../AppMasterToExecutor$$StopTask.html | 476 -
.../AppMasterToExecutor$$TaskChanged.html | 493 -
...AppMasterToExecutor$$TaskLocationsReady.html | 493 -
...MasterToExecutor$$TaskLocationsReceived.html | 493 -
...MasterToExecutor$$TaskLocationsRejected.html | 527 --
.../AppMasterToExecutor$$TaskRegistered.html | 510 --
.../AppMasterToExecutor$$TaskRejected.html | 476 -
.../AppMasterToExecutor$$TasksChanged.html | 476 -
.../AppMasterToExecutor$$TasksLaunched$.html | 456 -
.../streaming/AppMasterToExecutor$.html | 774 --
.../AppMasterToMaster$$StallingTasks.html | 476 -
.../gearpump/streaming/AppMasterToMaster$.html | 502 --
.../scala/io/gearpump/streaming/Constants$.html | 618 --
.../api/scala/io/gearpump/streaming/DAG$.html | 522 --
.../api/scala/io/gearpump/streaming/DAG.html | 564 --
.../ExecutorToAppMaster$$MessageLoss.html | 510 --
.../ExecutorToAppMaster$$RegisterExecutor.html | 527 --
.../ExecutorToAppMaster$$RegisterTask.html | 510 --
.../ExecutorToAppMaster$$UnRegisterTask.html | 493 -
.../streaming/ExecutorToAppMaster$.html | 553 --
.../streaming/InitialAckRequestSerializer.html | 572 --
.../streaming/LatencyProbeSerializer.html | 555 --
.../scala/io/gearpump/streaming/LifeTime$.html | 505 --
.../scala/io/gearpump/streaming/LifeTime.html | 530 --
.../streaming/Processor$$DefaultProcessor.html | 603 --
.../scala/io/gearpump/streaming/Processor$.html | 555 --
.../scala/io/gearpump/streaming/Processor.html | 561 --
.../streaming/ProcessorDescription.html | 597 --
.../gearpump/streaming/StreamApplication$.html | 518 --
.../gearpump/streaming/StreamApplication.html | 592 --
.../io/gearpump/streaming/TaskIdSerializer.html | 555 --
.../AppMaster$$AllocateResourceTimeOut$.html | 456 -
.../appmaster/AppMaster$$ExecutorBrief.html | 527 --
.../AppMaster$$LookupTaskActorRef.html | 476 -
...AppMaster$$ServiceNotAvailableException.html | 712 --
.../appmaster/AppMaster$$TaskActorRef.html | 476 -
.../streaming/appmaster/AppMaster$.html | 572 --
.../gearpump/streaming/appmaster/AppMaster.html | 964 --
.../appmaster/ClockService$$ChangeToNewDAG.html | 476 -
.../ClockService$$ChangeToNewDAGSuccess.html | 476 -
.../appmaster/ClockService$$HealthCheck$.html | 456 -
...ClockService$$HealthChecker$$ClockValue.html | 510 --
.../appmaster/ClockService$$HealthChecker$.html | 504 --
.../appmaster/ClockService$$HealthChecker.html | 539 --
.../appmaster/ClockService$$ProcessorClock.html | 638 --
.../ClockService$$ProcessorClocks$.html | 499 -
.../appmaster/ClockService$$Report.html | 476 -
.../ClockService$$SnapshotStartClock$.html | 456 -
.../ClockService$$StoredStartClock.html | 476 -
.../streaming/appmaster/ClockService$.html | 675 --
.../streaming/appmaster/ClockService.html | 898 --
.../appmaster/DagManager$$DAGOperation.html | 485 -
.../DagManager$$DAGOperationFailed.html | 478 -
.../DagManager$$DAGOperationResult.html | 485 -
.../DagManager$$DAGOperationSuccess$.html | 458 -
.../appmaster/DagManager$$DagInitiated$.html | 456 -
.../appmaster/DagManager$$GetLatestDAG$.html | 456 -
.../DagManager$$GetTaskLaunchData.html | 510 --
.../appmaster/DagManager$$LatestDAG.html | 476 -
.../appmaster/DagManager$$NewDAGDeployed.html | 476 -
.../appmaster/DagManager$$ReplaceProcessor.html | 495 -
.../appmaster/DagManager$$TaskLaunchData.html | 510 --
.../appmaster/DagManager$$WatchChange.html | 476 -
.../streaming/appmaster/DagManager$.html | 691 --
.../streaming/appmaster/DagManager.html | 881 --
.../appmaster/JarScheduler$$ExecutorFailed.html | 476 -
.../JarScheduler$$GetRequestDetails$.html | 456 -
.../JarScheduler$$JarSchedulerImpl.html | 867 --
.../appmaster/JarScheduler$$NewDag.html | 493 -
.../JarScheduler$$ResourceRequestDetail.html | 493 -
.../appmaster/JarScheduler$$ScheduleTask.html | 527 --
.../JarScheduler$$TransitToNewDag$.html | 456 -
.../streaming/appmaster/JarScheduler$.html | 606 --
.../streaming/appmaster/JarScheduler.html | 573 --
.../streaming/appmaster/ProcessorSummary.html | 595 --
.../appmaster/StreamAppMasterSummary.html | 733 --
.../gearpump/streaming/appmaster/TaskCount.html | 476 -
.../appmaster/TaskLocator$$Localities$.html | 539 --
.../appmaster/TaskLocator$$Localities.html | 478 -
.../appmaster/TaskLocator$$Locality.html | 485 -
.../appmaster/TaskLocator$$NonLocality$.html | 484 -
.../appmaster/TaskLocator$$WorkerLocality.html | 478 -
.../streaming/appmaster/TaskLocator$.html | 572 --
.../streaming/appmaster/TaskLocator.html | 523 --
.../appmaster/TaskRegistry$$Accept$.html | 458 -
.../TaskRegistry$$RegisterTaskStatus.html | 485 -
.../appmaster/TaskRegistry$$Reject$.html | 458 -
.../appmaster/TaskRegistry$$TaskLocation.html | 493 -
.../appmaster/TaskRegistry$$TaskLocations.html | 476 -
.../streaming/appmaster/TaskRegistry$.html | 572 --
.../streaming/appmaster/TaskRegistry.html | 728 --
.../appmaster/TaskScheduler$$Location.html | 493 -
.../appmaster/TaskScheduler$$TaskStatus.html | 553 --
.../streaming/appmaster/TaskScheduler$.html | 521 --
.../streaming/appmaster/TaskScheduler.html | 586 --
.../streaming/appmaster/TaskSchedulerImpl.html | 600 --
.../gearpump/streaming/appmaster/package.html | 420 -
.../streaming/dsl/CollectionDataSource.html | 613 --
.../io/gearpump/streaming/dsl/KVStream.html | 540 --
.../io/gearpump/streaming/dsl/LoggerSink.html | 582 --
.../io/gearpump/streaming/dsl/Stream$$Sink.html | 538 --
.../io/gearpump/streaming/dsl/Stream$.html | 572 --
.../scala/io/gearpump/streaming/dsl/Stream.html | 643 --
.../streaming/dsl/StreamApp$$Source.html | 606 --
.../io/gearpump/streaming/dsl/StreamApp$.html | 538 --
.../io/gearpump/streaming/dsl/StreamApp.html | 579 --
.../streaming/dsl/javaapi/JavaStream.html | 656 --
.../streaming/dsl/javaapi/JavaStreamApp.html | 553 --
.../gearpump/streaming/dsl/javaapi/package.html | 136 -
.../gearpump/streaming/dsl/op/DataSinkOp.html | 533 --
.../gearpump/streaming/dsl/op/DataSourceOp.html | 533 --
.../io/gearpump/streaming/dsl/op/Direct$.html | 459 -
.../io/gearpump/streaming/dsl/op/FlatMapOp.html | 514 --
.../io/gearpump/streaming/dsl/op/GroupByOp.html | 533 --
.../io/gearpump/streaming/dsl/op/MasterOp.html | 524 --
.../io/gearpump/streaming/dsl/op/MergeOp.html | 497 -
.../scala/io/gearpump/streaming/dsl/op/Op.html | 523 --
.../io/gearpump/streaming/dsl/op/OpChain.html | 547 --
.../io/gearpump/streaming/dsl/op/OpEdge.html | 485 -
.../streaming/dsl/op/ParameterizedOp.html | 526 --
.../gearpump/streaming/dsl/op/ProcessorOp.html | 533 --
.../io/gearpump/streaming/dsl/op/ReduceOp.html | 514 --
.../io/gearpump/streaming/dsl/op/Shuffle$.html | 459 -
.../io/gearpump/streaming/dsl/op/SlaveOp.html | 525 --
.../io/gearpump/streaming/dsl/op/package.html | 364 -
.../io/gearpump/streaming/dsl/package.html | 298 -
.../dsl/partitioner/GroupByPartitioner.html | 553 --
.../streaming/dsl/partitioner/package.html | 118 -
.../dsl/plan/OpTranslator$$AndThen.html | 559 --
.../plan/OpTranslator$$DummyInputFunction.html | 559 --
.../dsl/plan/OpTranslator$$FlatMapFunction.html | 559 --
.../dsl/plan/OpTranslator$$GroupByTask.html | 663 --
.../dsl/plan/OpTranslator$$ReduceFunction.html | 559 --
.../plan/OpTranslator$$SingleInputFunction.html | 543 --
.../dsl/plan/OpTranslator$$SinkTask.html | 663 --
.../dsl/plan/OpTranslator$$SourceTask.html | 663 --
.../dsl/plan/OpTranslator$$TransformTask.html | 663 --
.../streaming/dsl/plan/OpTranslator$.html | 644 --
.../streaming/dsl/plan/OpTranslator.html | 541 --
.../io/gearpump/streaming/dsl/plan/Planner.html | 519 --
.../io/gearpump/streaming/dsl/plan/package.html | 156 -
.../Executor$$DagVersionMismatchException.html | 712 --
.../executor/Executor$$ExecutorConfig.html | 476 -
.../executor/Executor$$ExecutorSummary$.html | 505 --
.../executor/Executor$$ExecutorSummary.html | 597 --
.../executor/Executor$$GetExecutorSummary.html | 476 -
.../executor/Executor$$HealthCheck$.html | 482 -
.../executor/Executor$$QueryExecutorConfig.html | 476 -
.../executor/Executor$$RestartTasks.html | 476 -
.../streaming/executor/Executor$$State$.html | 550 --
.../executor/Executor$$TaskArgumentStore.html | 570 --
.../executor/Executor$$TaskStopped.html | 476 -
.../gearpump/streaming/executor/Executor$.html | 674 --
.../gearpump/streaming/executor/Executor.html | 1013 ---
.../executor/ExecutorRestartPolicy.html | 537 --
.../streaming/executor/ITaskLauncher.html | 505 --
.../executor/TaskLauncher$$TaskArgument.html | 510 --
.../streaming/executor/TaskLauncher$.html | 521 --
.../streaming/executor/TaskLauncher.html | 523 --
.../io/gearpump/streaming/executor/package.html | 208 -
.../hadoop/HadoopCheckpointStore$.html | 501 -
.../streaming/hadoop/HadoopCheckpointStore.html | 576 --
.../hadoop/HadoopCheckpointStoreFactory$.html | 505 --
.../hadoop/HadoopCheckpointStoreFactory.html | 525 --
.../streaming/hadoop/SequenceFileSink.html | 565 --
.../hadoop/lib/HadoopCheckpointStoreReader.html | 2027 -----
.../hadoop/lib/HadoopCheckpointStoreWriter.html | 536 --
.../lib/format/DefaultSequenceFormatter.html | 576 --
.../hadoop/lib/format/OutputFormatter.html | 560 --
.../streaming/hadoop/lib/format/package.html | 135 -
.../gearpump/streaming/hadoop/lib/package.html | 172 -
.../hadoop/lib/rotation/FileSizeRotation.html | 529 --
.../streaming/hadoop/lib/rotation/Rotation.html | 543 --
.../streaming/hadoop/lib/rotation/package.html | 135 -
.../io/gearpump/streaming/hadoop/package.html | 216 -
.../io/gearpump/streaming/javaapi/Graph.html | 954 --
.../gearpump/streaming/javaapi/Processor.html | 680 --
.../streaming/javaapi/StreamApplication.html | 575 --
.../io/gearpump/streaming/javaapi/Task.html | 646 --
.../javaapi/dsl/functions/FilterFunction.html | 504 --
.../javaapi/dsl/functions/FlatMapFunction.html | 504 --
.../javaapi/dsl/functions/GroupByFunction.html | 504 --
.../javaapi/dsl/functions/MapFunction.html | 504 --
.../javaapi/dsl/functions/ReduceFunction.html | 504 --
.../javaapi/dsl/functions/package.html | 186 -
.../gearpump/streaming/javaapi/dsl/package.html | 118 -
.../io/gearpump/streaming/javaapi/package.html | 189 -
.../io/gearpump/streaming/kafka/KafkaSink.html | 585 --
.../gearpump/streaming/kafka/KafkaSource$.html | 488 -
.../gearpump/streaming/kafka/KafkaSource.html | 644 --
.../gearpump/streaming/kafka/KafkaStorage$.html | 484 -
.../gearpump/streaming/kafka/KafkaStorage.html | 543 --
.../streaming/kafka/KafkaStorageFactory.html | 543 --
.../streaming/kafka/dsl/KafkaDSLSink$.html | 501 -
.../streaming/kafka/dsl/KafkaDSLSink.html | 538 --
.../streaming/kafka/dsl/KafkaDSLUtil$.html | 567 --
.../gearpump/streaming/kafka/dsl/package.html | 155 -
.../kafka/lib/DefaultMessageDecoder.html | 523 --
.../kafka/lib/KafkaOffsetManager$.html | 482 -
.../streaming/kafka/lib/KafkaSourceConfig$.html | 641 --
.../streaming/kafka/lib/KafkaSourceConfig.html | 728 --
.../streaming/kafka/lib/KafkaUtil$.html | 654 --
.../kafka/lib/StringMessageDecoder.html | 523 --
.../kafka/lib/consumer/FetchThread$.html | 499 -
.../kafka/lib/consumer/KafkaConsumer$.html | 501 -
.../kafka/lib/consumer/KafkaConsumer.html | 590 --
.../kafka/lib/consumer/KafkaMessage.html | 544 --
.../streaming/kafka/lib/consumer/package.html | 172 -
.../kafka/lib/grouper/KafkaDefaultGrouper.html | 524 --
.../kafka/lib/grouper/KafkaGrouper.html | 506 --
.../streaming/kafka/lib/grouper/package.html | 139 -
.../gearpump/streaming/kafka/lib/package.html | 241 -
.../io/gearpump/streaming/kafka/package.html | 249 -
.../ProcessorAggregator$$Aggregator.html | 522 --
.../ProcessorAggregator$$AggregatorFactory.html | 519 --
...rocessorAggregator$$HistogramAggregator.html | 674 --
.../ProcessorAggregator$$MeterAggregator.html | 623 --
.../ProcessorAggregator$$MultiLayerMap.html | 571 --
.../streaming/metrics/ProcessorAggregator$.html | 590 --
.../streaming/metrics/ProcessorAggregator.html | 564 --
.../metrics/TaskFilterAggregator$$Options$.html | 522 --
.../metrics/TaskFilterAggregator$$Options.html | 546 --
.../metrics/TaskFilterAggregator$.html | 674 --
.../streaming/metrics/TaskFilterAggregator.html | 559 --
.../io/gearpump/streaming/metrics/package.html | 179 -
.../streaming/monoid/AlgebirdGroup.html | 559 --
.../streaming/monoid/AlgebirdMonoid.html | 540 --
.../io/gearpump/streaming/monoid/package.html | 135 -
.../scala/io/gearpump/streaming/package.html | 761 --
.../streaming/serializer/ChillSerializer.html | 540 --
.../gearpump/streaming/serializer/package.html | 118 -
.../io/gearpump/streaming/sink/DataSink.html | 558 --
.../streaming/sink/DataSinkProcessor$.html | 504 --
.../gearpump/streaming/sink/DataSinkTask$.html | 501 -
.../gearpump/streaming/sink/DataSinkTask.html | 649 --
.../io/gearpump/streaming/sink/package.html | 191 -
.../gearpump/streaming/source/DataSource.html | 557 --
.../streaming/source/DataSourceConfig$.html | 516 --
.../streaming/source/DataSourceProcessor$.html | 504 --
.../streaming/source/DataSourceTask$.html | 501 -
.../streaming/source/DataSourceTask.html | 651 --
.../source/DefaultTimeStampFilter.html | 524 --
.../io/gearpump/streaming/source/package.html | 228 -
.../io/gearpump/streaming/state/api/Group.html | 543 --
.../io/gearpump/streaming/state/api/Monoid.html | 524 --
.../streaming/state/api/MonoidState.html | 650 --
.../streaming/state/api/PersistentState.html | 585 --
.../streaming/state/api/PersistentTask$.html | 518 --
.../streaming/state/api/PersistentTask.html | 779 --
.../streaming/state/api/Serializer.html | 524 --
.../gearpump/streaming/state/api/package.html | 231 -
.../streaming/state/impl/CheckpointManager.html | 604 --
.../state/impl/InMemoryCheckpointStore.html | 557 --
.../impl/InMemoryCheckpointStoreFactory.html | 523 --
.../gearpump/streaming/state/impl/Interval.html | 600 --
.../streaming/state/impl/NonWindowState$.html | 501 -
.../streaming/state/impl/NonWindowState.html | 646 --
.../state/impl/PersistentStateConfig$.html | 567 --
.../gearpump/streaming/state/impl/Window.html | 640 --
.../streaming/state/impl/WindowConfig$.html | 505 --
.../streaming/state/impl/WindowConfig.html | 495 -
.../streaming/state/impl/WindowState$.html | 501 -
.../streaming/state/impl/WindowState.html | 649 --
.../gearpump/streaming/state/impl/package.html | 319 -
.../io/gearpump/streaming/state/package.html | 135 -
.../streaming/storage/AppDataStore.html | 522 --
.../storage/InMemoryAppStoreOnMaster.html | 556 --
.../io/gearpump/streaming/storage/package.html | 136 -
.../scala/io/gearpump/streaming/task/Ack.html | 527 --
.../io/gearpump/streaming/task/AckRequest.html | 510 --
.../streaming/task/CheckProcessorDeath.html | 476 -
.../streaming/task/CheckpointClock.html | 476 -
.../io/gearpump/streaming/task/ClockEvent.html | 485 -
.../streaming/task/ExpressTransport.html | 588 --
.../streaming/task/GetCheckpointClock$.html | 456 -
.../io/gearpump/streaming/task/GetDAG$.html | 456 -
.../streaming/task/GetLatestMinClock$.html | 484 -
.../gearpump/streaming/task/GetStartClock$.html | 456 -
.../streaming/task/GetUpstreamMinClock.html | 478 -
.../streaming/task/InitialAckRequest.html | 493 -
.../gearpump/streaming/task/LatencyProbe.html | 476 -
.../gearpump/streaming/task/LatestMinClock.html | 476 -
.../streaming/task/ReportCheckpointClock.html | 493 -
.../streaming/task/SendMessageLoss.html | 459 -
.../streaming/task/SerializedMessage.html | 493 -
.../task/SerializedMessageSerializer.html | 555 --
.../task/SerializerResolver$$Registration.html | 510 --
.../streaming/task/SerializerResolver$.html | 502 --
.../io/gearpump/streaming/task/StartClock.html | 476 -
.../io/gearpump/streaming/task/StartTime.html | 476 -
.../task/StreamingTransportSerializer.html | 555 --
.../io/gearpump/streaming/task/Subscriber$.html | 507 --
.../io/gearpump/streaming/task/Subscriber.html | 531 --
.../gearpump/streaming/task/Subscription$.html | 518 --
.../gearpump/streaming/task/Subscription.html | 693 --
.../scala/io/gearpump/streaming/task/Task.html | 647 --
.../streaming/task/TaskActor$$FLUSH$.html | 456 -
.../task/TaskActor$$MessageAndSender.html | 493 -
.../task/TaskActor$$SecurityChecker.html | 553 --
.../streaming/task/TaskActor$$SendAck.html | 493 -
.../io/gearpump/streaming/task/TaskActor$.html | 589 --
.../io/gearpump/streaming/task/TaskActor.html | 1275 ---
.../io/gearpump/streaming/task/TaskContext.html | 770 --
.../streaming/task/TaskContextData.html | 578 --
.../io/gearpump/streaming/task/TaskId$.html | 522 --
.../io/gearpump/streaming/task/TaskId.html | 495 -
.../gearpump/streaming/task/TaskInterface.html | 559 --
.../streaming/task/TaskMessageSerializer.html | 539 --
.../io/gearpump/streaming/task/TaskUtil$.html | 499 -
.../io/gearpump/streaming/task/TaskWrapper.html | 909 --
.../io/gearpump/streaming/task/UpdateClock.html | 495 -
.../streaming/task/UpstreamMinClock.html | 476 -
.../io/gearpump/streaming/task/package.html | 775 --
.../transaction/api/CheckpointStore.html | 542 --
.../transaction/api/CheckpointStoreFactory.html | 507 --
.../transaction/api/MessageDecoder.html | 510 --
.../transaction/api/MessageFilter.html | 506 --
.../transaction/api/OffsetManager.html | 541 --
.../api/OffsetStorage$$Overflow.html | 701 --
.../api/OffsetStorage$$StorageEmpty$.html | 680 --
.../api/OffsetStorage$$Underflow.html | 701 --
.../transaction/api/OffsetStorage$.html | 543 --
.../transaction/api/OffsetStorage.html | 548 --
.../transaction/api/OffsetStorageFactory.html | 507 --
.../api/OffsetTimeStampResolver.html | 506 --
.../transaction/api/TimeReplayableSource.html | 550 --
.../transaction/api/TimeStampFilter.html | 508 --
.../streaming/transaction/api/package.html | 303 -
.../gearpump/streaming/transaction/package.html | 118 -
.../gearpump/streaming/util/ActorPathUtil$.html | 550 --
.../io/gearpump/streaming/util/package.html | 118 -
.../io/gearpump/transport/ActorLookupById.html | 505 --
.../scala/io/gearpump/transport/Express$.html | 573 --
.../scala/io/gearpump/transport/Express.html | 782 --
.../scala/io/gearpump/transport/HostPort$.html | 505 --
.../scala/io/gearpump/transport/HostPort.html | 512 --
.../netty/Client$$ChannelFutureOps.html | 536 --
.../transport/netty/Client$$ChannelReady.html | 476 -
.../netty/Client$$ClientErrorHandler.html | 801 --
.../netty/Client$$ClientPipelineFactory.html | 521 --
.../transport/netty/Client$$Close$.html | 456 -
.../Client$$CompareAndReconnectIfEqual.html | 476 -
.../transport/netty/Client$$Connect.html | 476 -
.../gearpump/transport/netty/Client$$Flush.html | 476 -
.../io/gearpump/transport/netty/Client$.html | 657 --
.../io/gearpump/transport/netty/Client.html | 884 --
.../io/gearpump/transport/netty/Context$.html | 501 -
.../io/gearpump/transport/netty/Context.html | 598 --
.../io/gearpump/transport/netty/IContext.html | 542 --
.../netty/ITransportMessageSerializer.html | 539 --
.../gearpump/transport/netty/MessageBatch.html | 482 -
.../transport/netty/MessageDecoder.html | 1204 ---
.../transport/netty/MessageEncoder.html | 571 --
.../gearpump/transport/netty/NettyConfig.html | 621 --
.../netty/NettyRenameThreadFactory.html | 501 -
.../io/gearpump/transport/netty/NettyUtil$.html | 533 --
.../transport/netty/Server$$AddChannel.html | 476 -
.../transport/netty/Server$$CloseChannel.html | 476 -
.../transport/netty/Server$$MsgBatch.html | 476 -
.../transport/netty/Server$$ServerHandler.html | 789 --
.../netty/Server$$ServerPipelineFactory.html | 521 --
.../Server$$TaskIdActorRefTranslation.html | 519 --
.../io/gearpump/transport/netty/Server$.html | 589 --
.../io/gearpump/transport/netty/Server.html | 867 --
.../gearpump/transport/netty/TaskMessage.html | 570 --
.../transport/netty/WrappedChannelBuffer.html | 793 --
.../io/gearpump/transport/netty/package.html | 376 -
.../scala/io/gearpump/transport/package.html | 208 -
.../util/ActorSystemBooter$$ActorCreated.html | 493 -
...ctorSystemBooter$$ActorSystemRegistered.html | 478 -
.../util/ActorSystemBooter$$BindLifeCycle.html | 476 -
.../util/ActorSystemBooter$$CreateActor.html | 493 -
.../ActorSystemBooter$$CreateActorFailed.html | 493 -
.../util/ActorSystemBooter$$Daemon.html | 933 --
.../ActorSystemBooter$$RegisterActorSystem.html | 476 -
...SystemBooter$$RegisterActorSystemFailed.html | 476 -
...stemBooter$$RegisterActorSystemTimeOut$.html | 482 -
.../io/gearpump/util/ActorSystemBooter$.html | 676 --
.../io/gearpump/util/ActorSystemBooter.html | 523 --
.../api/scala/io/gearpump/util/ActorUtil$.html | 688 --
.../api/scala/io/gearpump/util/AkkaApp.html | 577 --
.../api/scala/io/gearpump/util/AkkaHelper.html | 502 --
.../scala/io/gearpump/util/ConsoleOutput.html | 522 --
.../api/scala/io/gearpump/util/Constants$.html | 1961 ----
.../gearpump/util/FileDirective$$FileInfo.html | 511 --
.../io/gearpump/util/FileDirective$$Form.html | 553 --
.../scala/io/gearpump/util/FileDirective$.html | 627 --
.../io/gearpump/util/FileServer$$Client.html | 588 --
.../io/gearpump/util/FileServer$$Port.html | 476 -
.../api/scala/io/gearpump/util/FileServer$.html | 539 --
.../api/scala/io/gearpump/util/FileServer.html | 608 --
.../api/scala/io/gearpump/util/FileUtils$.html | 567 --
.../api/scala/io/gearpump/util/Graph$$Node.html | 555 --
.../scala/io/gearpump/util/Graph$$NodeList.html | 555 --
.../scala/io/gearpump/util/Graph$$Path$.html | 501 -
.../api/scala/io/gearpump/util/Graph$$Path.html | 558 --
.../api/scala/io/gearpump/util/Graph$.html | 635 --
.../api/scala/io/gearpump/util/Graph.html | 927 --
.../io/gearpump/util/HadoopFSLogAppender.html | 1330 ---
...toryMetricsService$$CounterMetricsStore.html | 572 --
...etricsService$$DummyHistoryMetricsStore.html | 589 --
...yMetricsService$$DummyMetricsAggregator.html | 521 --
...istoryMetricsService$$GaugeMetricsStore.html | 572 --
...ryMetricsService$$HistogramMetricsStore.html | 572 --
...ryMetricsService$$HistoryMetricsConfig$.html | 505 --
...oryMetricsService$$HistoryMetricsConfig.html | 529 --
...oryMetricsService$$HistoryMetricsStore$.html | 501 -
...toryMetricsService$$HistoryMetricsStore.html | 558 --
...istoryMetricsService$$MeterMetricsStore.html | 572 --
.../HistoryMetricsService$$MetricsStore.html | 539 --
...MetricsService$$SingleValueMetricsStore.html | 574 --
...istoryMetricsService$$SkipAllAggregator.html | 521 --
.../gearpump/util/HistoryMetricsService$.html | 709 --
.../io/gearpump/util/HistoryMetricsService.html | 875 --
.../io/gearpump/util/LogUtil$$ProcessType$.html | 837 --
.../api/scala/io/gearpump/util/LogUtil$.html | 601 --
.../io/gearpump/util/ProcessLogRedirector.html | 631 --
.../util/RecreateRollingFileAppender.html | 1364 ---
.../scala/io/gearpump/util/ReferenceEqual.html | 486 -
.../scala/io/gearpump/util/RestartPolicy.html | 520 --
.../api/scala/io/gearpump/util/RichProcess.html | 555 --
.../io/gearpump/util/TimeOutScheduler.html | 502 --
.../io/gearpump/util/Util$$AppJvmSettings.html | 493 -
.../io/gearpump/util/Util$$JvmSetting.html | 493 -
.../api/scala/io/gearpump/util/Util$.html | 740 --
.../api/scala/io/gearpump/util/package.html | 518 --
releases/latest/api/scala/io/package.html | 118 -
.../api/scala/org/apache/gearpump/Message$.html | 505 ++
.../api/scala/org/apache/gearpump/Message.html | 496 +
.../apache/gearpump/cluster/AppDescription.html | 538 ++
.../org/apache/gearpump/cluster/AppJar.html | 494 +
.../gearpump/cluster/AppMasterContext.html | 588 ++
.../gearpump/cluster/AppMasterRegisterData.html | 485 +
.../AppMasterToMaster$$ActivateAppMaster.html | 476 +
.../AppMasterToMaster$$AppDataSaved$.html | 456 +
.../AppMasterToMaster$$AppMasterSummary.html | 626 ++
...MasterToMaster$$GeneralAppMasterSummary.html | 597 ++
.../AppMasterToMaster$$GetAllWorkers$.html | 456 +
.../cluster/AppMasterToMaster$$GetAppData.html | 493 +
.../AppMasterToMaster$$GetAppDataResult.html | 493 +
.../AppMasterToMaster$$GetMasterData$.html | 456 +
.../AppMasterToMaster$$GetWorkerData.html | 476 +
.../AppMasterToMaster$$InvalidAppMaster.html | 510 ++
.../cluster/AppMasterToMaster$$MasterData.html | 476 +
.../AppMasterToMaster$$RegisterAppMaster.html | 499 +
.../AppMasterToMaster$$RequestResource.html | 493 +
.../cluster/AppMasterToMaster$$SaveAppData.html | 511 ++
.../AppMasterToMaster$$SaveAppDataFailed$.html | 456 +
.../cluster/AppMasterToMaster$$WorkerData.html | 476 +
.../gearpump/cluster/AppMasterToMaster$.html | 762 ++
...pMasterToWorker$$ChangeExecutorResource.html | 510 ++
.../AppMasterToWorker$$LaunchExecutor.html | 527 ++
.../AppMasterToWorker$$ShutdownExecutor.html | 510 ++
.../gearpump/cluster/AppMasterToWorker$.html | 536 ++
.../Application$$DefaultApplication.html | 559 ++
.../apache/gearpump/cluster/Application$.html | 538 ++
.../apache/gearpump/cluster/Application.html | 545 ++
.../gearpump/cluster/ApplicationMaster.html | 810 ++
.../cluster/ClientToMaster$$AddMaster$.html | 456 +
.../cluster/ClientToMaster$$AddWorker.html | 476 +
.../cluster/ClientToMaster$$CommandResult.html | 510 ++
.../ClientToMaster$$GetJarStoreServer$.html | 456 +
.../cluster/ClientToMaster$$GetLastFailure.html | 477 +
.../ClientToMaster$$GetStallingTasks.html | 479 +
.../ClientToMaster$$JarStoreServerAddress.html | 476 +
.../ClientToMaster$$QueryAppMasterConfig.html | 476 +
.../ClientToMaster$$QueryHistoryMetrics.html | 527 ++
.../ClientToMaster$$QueryMasterConfig$.html | 456 +
.../ClientToMaster$$QueryWorkerConfig.html | 476 +
.../cluster/ClientToMaster$$ReadOption$.html | 571 ++
.../cluster/ClientToMaster$$RemoveMaster.html | 476 +
.../cluster/ClientToMaster$$RemoveWorker.html | 476 +
.../cluster/ClientToMaster$$ResolveAppId.html | 476 +
.../ClientToMaster$$ResolveWorkerId.html | 476 +
.../ClientToMaster$$RestartApplication.html | 476 +
.../ClientToMaster$$ShutdownApplication.html | 476 +
.../ClientToMaster$$SubmitApplication.html | 510 ++
.../gearpump/cluster/ClientToMaster$.html | 811 ++
...lusterConfig$$ConfigValidationException.html | 712 ++
.../cluster/ClusterConfig$$Configs.html | 570 ++
.../apache/gearpump/cluster/ClusterConfig$.html | 718 ++
.../gearpump/cluster/ClusterConfigSource$.html | 523 ++
.../gearpump/cluster/ClusterConfigSource.html | 509 ++
.../gearpump/cluster/ExecutorContext.html | 562 ++
.../gearpump/cluster/ExecutorJVMConfig.html | 592 ++
.../MasterToAppMaster$$AppMasterActivated.html | 476 +
.../MasterToAppMaster$$AppMasterData.html | 612 ++
...ToAppMaster$$AppMasterDataDetailRequest.html | 476 +
...MasterToAppMaster$$AppMasterDataRequest.html | 493 +
...terToAppMaster$$AppMasterMetricsRequest.html | 478 +
.../MasterToAppMaster$$AppMasterRegistered.html | 476 +
.../MasterToAppMaster$$AppMastersData.html | 476 +
...sterToAppMaster$$AppMastersDataRequest$.html | 456 +
...$$ReplayFromTimestampWindowTrailingEdge.html | 476 +
.../MasterToAppMaster$$ResourceAllocated.html | 476 +
.../MasterToAppMaster$$ShutdownAppMaster$.html | 456 +
.../MasterToAppMaster$$StreamingType.html | 485 +
.../cluster/MasterToAppMaster$$WorkerList.html | 476 +
.../gearpump/cluster/MasterToAppMaster$.html | 791 ++
.../MasterToClient$$AppMasterConfig.html | 476 +
.../cluster/MasterToClient$$HistoryMetrics.html | 496 +
.../MasterToClient$$HistoryMetricsItem.html | 493 +
.../cluster/MasterToClient$$LastFailure.html | 493 +
.../cluster/MasterToClient$$MasterConfig.html | 476 +
...MasterToClient$$ReplayApplicationResult.html | 476 +
.../MasterToClient$$ResolveAppIdResult.html | 476 +
.../MasterToClient$$ResolveWorkerIdResult.html | 476 +
...sterToClient$$ShutdownApplicationResult.html | 476 +
...MasterToClient$$SubmitApplicationResult.html | 476 +
...rToClient$$SubmitApplicationResultValue.html | 476 +
.../cluster/MasterToClient$$WorkerConfig.html | 476 +
.../gearpump/cluster/MasterToClient$.html | 692 ++
.../apache/gearpump/cluster/UserConfig$.html | 539 ++
.../org/apache/gearpump/cluster/UserConfig.html | 840 ++
...rkerToAppMaster$$ExecutorLaunchRejected.html | 493 +
...rkerToAppMaster$$ShutdownExecutorFailed.html | 493 +
...kerToAppMaster$$ShutdownExecutorSucceed.html | 493 +
.../gearpump/cluster/WorkerToAppMaster$.html | 536 ++
.../appmaster/AppMasterRuntimeEnvironment$.html | 499 +
.../cluster/appmaster/AppMasterRuntimeInfo.html | 597 ++
.../cluster/appmaster/ApplicationState.html | 613 ++
.../cluster/appmaster/ExecutorSystem.html | 579 ++
...ystemScheduler$$ExecutorSystemJvmConfig.html | 544 ++
...rSystemScheduler$$ExecutorSystemStarted.html | 493 +
...mScheduler$$StartExecutorSystemTimeout$.html | 456 +
...orSystemScheduler$$StartExecutorSystems.html | 493 +
...utorSystemScheduler$$StopExecutorSystem.html | 476 +
.../appmaster/ExecutorSystemScheduler$.html | 570 ++
.../gearpump/cluster/appmaster/WorkerInfo.html | 493 +
.../gearpump/cluster/appmaster/package.html | 208 +
.../gearpump/cluster/client/ClientContext$.html | 569 ++
.../gearpump/cluster/client/ClientContext.html | 729 ++
.../gearpump/cluster/client/MasterClient.html | 588 ++
.../apache/gearpump/cluster/client/package.html | 157 +
.../cluster/main/ArgumentsParser$$Syntax.html | 510 ++
.../gearpump/cluster/main/ArgumentsParser$.html | 521 ++
.../gearpump/cluster/main/ArgumentsParser.html | 587 ++
.../apache/gearpump/cluster/main/CLIOption.html | 510 ++
.../gearpump/cluster/main/ParseResult.html | 587 ++
.../apache/gearpump/cluster/main/package.html | 173 +
.../cluster/master/AppMasterLauncher$.html | 503 ++
.../cluster/master/AppMasterLauncher.html | 943 ++
.../master/AppMasterLauncherFactory.html | 505 ++
.../gearpump/cluster/master/MasterActivity.html | 493 +
.../gearpump/cluster/master/MasterNode.html | 510 ++
.../master/MasterProxy$$MasterRestarted$.html | 456 +
.../master/MasterProxy$$MasterStopped$.html | 456 +
.../master/MasterProxy$$WatchMaster.html | 476 +
.../gearpump/cluster/master/MasterProxy$.html | 555 ++
.../gearpump/cluster/master/MasterProxy.html | 973 ++
.../gearpump/cluster/master/MasterStatus$.html | 536 ++
.../gearpump/cluster/master/MasterSummary.html | 630 ++
.../apache/gearpump/cluster/master/package.html | 261 +
.../org/apache/gearpump/cluster/package.html | 573 ++
.../gearpump/cluster/scheduler/Priority$.html | 805 ++
.../gearpump/cluster/scheduler/Relaxation$.html | 805 ++
.../gearpump/cluster/scheduler/Resource$.html | 522 ++
.../gearpump/cluster/scheduler/Resource.html | 597 ++
.../cluster/scheduler/ResourceAllocation.html | 510 ++
.../cluster/scheduler/ResourceRequest.html | 544 ++
.../gearpump/cluster/scheduler/package.html | 208 +
.../cluster/worker/ExecutorProcessLauncher.html | 539 ++
.../gearpump/cluster/worker/ExecutorSlots.html | 510 ++
.../gearpump/cluster/worker/WorkerId$.html | 556 ++
.../gearpump/cluster/worker/WorkerId.html | 499 +
.../gearpump/cluster/worker/WorkerSummary$.html | 505 ++
.../gearpump/cluster/worker/WorkerSummary.html | 666 ++
.../apache/gearpump/cluster/worker/package.html | 210 +
.../gearpump/external/hbase/HBaseSink$.html | 607 ++
.../gearpump/external/hbase/HBaseSink.html | 686 ++
.../external/hbase/dsl/HBaseDSLSink$.html | 501 +
.../external/hbase/dsl/HBaseDSLSink.html | 538 ++
.../gearpump/external/hbase/dsl/package.html | 138 +
.../apache/gearpump/external/hbase/package.html | 155 +
.../org/apache/gearpump/external/package.html | 118 +
.../org/apache/gearpump/jarstore/FilePath.html | 476 +
.../gearpump/jarstore/JarStoreService$.html | 503 ++
.../gearpump/jarstore/JarStoreService.html | 561 ++
.../org/apache/gearpump/jarstore/package.html | 156 +
.../apache/gearpump/metrics/AkkaReporter.html | 522 ++
.../org/apache/gearpump/metrics/Counter.html | 553 ++
.../org/apache/gearpump/metrics/Histogram.html | 570 ++
.../apache/gearpump/metrics/JvmMetricsSet.html | 523 ++
.../org/apache/gearpump/metrics/Meter.html | 570 ++
.../gearpump/metrics/Metrics$$Counter.html | 495 +
.../metrics/Metrics$$DemandMoreMetrics.html | 476 +
.../gearpump/metrics/Metrics$$DummyMetrics.html | 608 ++
.../apache/gearpump/metrics/Metrics$$Gauge.html | 495 +
.../gearpump/metrics/Metrics$$Histogram.html | 580 ++
.../apache/gearpump/metrics/Metrics$$Meter.html | 546 ++
.../gearpump/metrics/Metrics$$MetricType$.html | 518 ++
.../gearpump/metrics/Metrics$$MetricType.html | 507 ++
.../metrics/Metrics$$ReportMetrics$.html | 456 +
.../apache/gearpump/metrics/Metrics$$Timer.html | 767 ++
.../org/apache/gearpump/metrics/Metrics$.html | 746 ++
.../org/apache/gearpump/metrics/Metrics.html | 611 ++
.../gearpump/metrics/MetricsAggregator.html | 507 ++
.../MetricsReporterService$$ReportTo.html | 505 ++
.../metrics/MetricsReporterService$.html | 504 ++
.../metrics/MetricsReporterService.html | 891 ++
.../org/apache/gearpump/metrics/package.html | 277 +
.../api/scala/org/apache/gearpump/package.html | 369 +
.../partitioner/BroadcastPartitioner.html | 545 ++
.../partitioner/CoLocationPartitioner.html | 547 ++
.../gearpump/partitioner/HashPartitioner.html | 548 ++
.../partitioner/MulticastPartitioner.html | 529 ++
.../gearpump/partitioner/Partitioner$.html | 522 ++
.../gearpump/partitioner/Partitioner.html | 493 +
.../partitioner/PartitionerByClassName.html | 542 ++
.../partitioner/PartitionerDescription.html | 476 +
.../partitioner/PartitionerFactory.html | 522 ++
.../gearpump/partitioner/PartitionerObject.html | 542 ++
.../partitioner/ShuffleGroupingPartitioner.html | 548 ++
.../partitioner/ShufflePartitioner.html | 546 ++
.../partitioner/UnicastPartitioner.html | 531 ++
.../apache/gearpump/partitioner/package.html | 334 +
.../Authenticator$$AuthenticationResult.html | 519 ++
.../gearpump/security/Authenticator$.html | 572 ++
.../apache/gearpump/security/Authenticator.html | 509 ++
.../security/ConfigFileBasedAuthenticator$.html | 484 +
.../security/ConfigFileBasedAuthenticator.html | 531 ++
.../apache/gearpump/security/PasswordUtil$.html | 537 ++
.../org/apache/gearpump/security/package.html | 201 +
.../FastKryoSerializationFramework.html | 544 ++
...oSerializer$$KryoSerializationException.html | 712 ++
.../serializer/FastKryoSerializer$.html | 504 ++
.../gearpump/serializer/FastKryoSerializer.html | 557 ++
.../serializer/GearpumpSerialization.html | 519 ++
.../serializer/SerializationFramework.html | 529 ++
.../apache/gearpump/serializer/Serializer.html | 523 ++
.../org/apache/gearpump/serializer/package.html | 209 +
.../streaming/AckRequestSerializer.html | 572 ++
.../gearpump/streaming/AckSerializer.html | 572 ++
.../AppMasterToExecutor$$ChangeTask.html | 527 ++
.../AppMasterToExecutor$$ChangeTasks.html | 528 ++
.../AppMasterToExecutor$$LaunchTasks.html | 527 ++
.../AppMasterToExecutor$$MsgLostException.html | 712 ++
...pMasterToExecutor$$RestartClockService$.html | 456 +
.../AppMasterToExecutor$$StartAllTasks.html | 476 +
.../AppMasterToExecutor$$StartDynamicDag.html | 476 +
.../AppMasterToExecutor$$StartTask.html | 476 +
.../AppMasterToExecutor$$StopTask.html | 476 +
.../AppMasterToExecutor$$TaskChanged.html | 493 +
...AppMasterToExecutor$$TaskLocationsReady.html | 493 +
...MasterToExecutor$$TaskLocationsReceived.html | 493 +
...MasterToExecutor$$TaskLocationsRejected.html | 527 ++
.../AppMasterToExecutor$$TaskRegistered.html | 510 ++
.../AppMasterToExecutor$$TaskRejected.html | 476 +
.../AppMasterToExecutor$$TasksChanged.html | 476 +
.../AppMasterToExecutor$$TasksLaunched$.html | 456 +
.../streaming/AppMasterToExecutor$.html | 774 ++
.../AppMasterToMaster$$StallingTasks.html | 476 +
.../gearpump/streaming/AppMasterToMaster$.html | 502 ++
.../apache/gearpump/streaming/Constants$.html | 635 ++
.../org/apache/gearpump/streaming/DAG$.html | 522 ++
.../org/apache/gearpump/streaming/DAG.html | 564 ++
.../ExecutorToAppMaster$$MessageLoss.html | 510 ++
.../ExecutorToAppMaster$$RegisterExecutor.html | 527 ++
.../ExecutorToAppMaster$$RegisterTask.html | 510 ++
.../ExecutorToAppMaster$$UnRegisterTask.html | 493 +
.../streaming/ExecutorToAppMaster$.html | 553 ++
.../streaming/InitialAckRequestSerializer.html | 572 ++
.../streaming/LatencyProbeSerializer.html | 555 ++
.../apache/gearpump/streaming/LifeTime$.html | 505 ++
.../org/apache/gearpump/streaming/LifeTime.html | 531 ++
.../streaming/Processor$$DefaultProcessor.html | 622 ++
.../apache/gearpump/streaming/Processor$.html | 555 ++
.../apache/gearpump/streaming/Processor.html | 563 ++
.../streaming/ProcessorDescription.html | 614 ++
.../gearpump/streaming/StreamApplication$.html | 518 ++
.../gearpump/streaming/StreamApplication.html | 596 ++
.../gearpump/streaming/TaskIdSerializer.html | 555 ++
.../AppMaster$$AllocateResourceTimeOut$.html | 456 +
.../appmaster/AppMaster$$ExecutorBrief.html | 527 ++
.../AppMaster$$LookupTaskActorRef.html | 476 +
...AppMaster$$ServiceNotAvailableException.html | 712 ++
.../appmaster/AppMaster$$TaskActorRef.html | 476 +
.../streaming/appmaster/AppMaster$.html | 572 ++
.../gearpump/streaming/appmaster/AppMaster.html | 896 ++
.../appmaster/ClockService$$ChangeToNewDAG.html | 476 +
.../ClockService$$ChangeToNewDAGSuccess.html | 476 +
.../appmaster/ClockService$$HealthCheck$.html | 456 +
...ClockService$$HealthChecker$$ClockValue.html | 510 ++
.../appmaster/ClockService$$HealthChecker$.html | 504 ++
.../appmaster/ClockService$$HealthChecker.html | 539 ++
.../appmaster/ClockService$$ProcessorClock.html | 638 ++
.../ClockService$$ProcessorClocks$.html | 499 +
.../appmaster/ClockService$$Report.html | 476 +
.../ClockService$$SnapshotStartClock$.html | 456 +
.../ClockService$$StoredStartClock.html | 476 +
.../streaming/appmaster/ClockService$.html | 675 ++
.../streaming/appmaster/ClockService.html | 881 ++
.../appmaster/DagManager$$DAGOperation.html | 485 +
.../DagManager$$DAGOperationFailed.html | 478 +
.../DagManager$$DAGOperationResult.html | 485 +
.../DagManager$$DAGOperationSuccess$.html | 458 +
.../appmaster/DagManager$$DagInitiated$.html | 456 +
.../appmaster/DagManager$$GetLatestDAG$.html | 456 +
.../DagManager$$GetTaskLaunchData.html | 510 ++
.../appmaster/DagManager$$LatestDAG.html | 476 +
.../appmaster/DagManager$$NewDAGDeployed.html | 476 +
.../appmaster/DagManager$$ReplaceProcessor.html | 512 ++
.../appmaster/DagManager$$TaskLaunchData.html | 510 ++
.../appmaster/DagManager$$WatchChange.html | 476 +
.../streaming/appmaster/DagManager$.html | 691 ++
.../streaming/appmaster/DagManager.html | 865 ++
.../appmaster/JarScheduler$$ExecutorFailed.html | 476 +
...arScheduler$$GetResourceRequestDetails$.html | 456 +
.../JarScheduler$$JarSchedulerImpl.html | 867 ++
.../appmaster/JarScheduler$$NewDag.html | 493 +
.../JarScheduler$$ResourceRequestDetail.html | 493 +
.../appmaster/JarScheduler$$ScheduleTask.html | 528 ++
.../JarScheduler$$TransitToNewDag$.html | 456 +
.../streaming/appmaster/JarScheduler$.html | 607 ++
.../streaming/appmaster/JarScheduler.html | 578 ++
.../streaming/appmaster/ProcessorSummary.html | 595 ++
.../appmaster/StreamAppMasterSummary.html | 733 ++
.../gearpump/streaming/appmaster/TaskCount.html | 476 +
.../appmaster/TaskLocator$$Localities$.html | 539 ++
.../appmaster/TaskLocator$$Localities.html | 478 +
.../appmaster/TaskLocator$$Locality.html | 485 +
.../appmaster/TaskLocator$$NonLocality$.html | 484 +
.../appmaster/TaskLocator$$WorkerLocality.html | 478 +
.../streaming/appmaster/TaskLocator$.html | 572 ++
.../streaming/appmaster/TaskLocator.html | 523 ++
.../appmaster/TaskRegistry$$Accept$.html | 458 +
.../TaskRegistry$$RegisterTaskStatus.html | 485 +
.../appmaster/TaskRegistry$$Reject$.html | 458 +
.../appmaster/TaskRegistry$$TaskLocation.html | 493 +
.../appmaster/TaskRegistry$$TaskLocations.html | 476 +
.../streaming/appmaster/TaskRegistry$.html | 572 ++
.../streaming/appmaster/TaskRegistry.html | 730 ++
.../appmaster/TaskScheduler$$Location.html | 493 +
.../appmaster/TaskScheduler$$TaskStatus.html | 553 ++
.../streaming/appmaster/TaskScheduler$.html | 521 ++
.../streaming/appmaster/TaskScheduler.html | 588 ++
.../streaming/appmaster/TaskSchedulerImpl.html | 600 ++
.../gearpump/streaming/appmaster/package.html | 425 +
.../streaming/dsl/CollectionDataSource.html | 567 ++
.../apache/gearpump/streaming/dsl/KVStream.html | 537 ++
.../gearpump/streaming/dsl/LoggerSink.html | 582 ++
.../gearpump/streaming/dsl/Stream$$Sink.html | 538 ++
.../apache/gearpump/streaming/dsl/Stream$.html | 572 ++
.../apache/gearpump/streaming/dsl/Stream.html | 653 ++
.../streaming/dsl/StreamApp$$Source.html | 606 ++
.../gearpump/streaming/dsl/StreamApp$.html | 538 ++
.../gearpump/streaming/dsl/StreamApp.html | 580 ++
.../streaming/dsl/javaapi/JavaStream.html | 658 ++
.../streaming/dsl/javaapi/JavaStreamApp.html | 553 ++
.../gearpump/streaming/dsl/javaapi/package.html | 136 +
.../gearpump/streaming/dsl/op/DataSinkOp.html | 533 ++
.../gearpump/streaming/dsl/op/DataSourceOp.html | 533 ++
.../gearpump/streaming/dsl/op/Direct$.html | 460 +
.../gearpump/streaming/dsl/op/FlatMapOp.html | 514 ++
.../gearpump/streaming/dsl/op/GroupByOp.html | 533 ++
.../gearpump/streaming/dsl/op/MasterOp.html | 524 ++
.../gearpump/streaming/dsl/op/MergeOp.html | 497 +
.../apache/gearpump/streaming/dsl/op/Op.html | 523 ++
.../gearpump/streaming/dsl/op/OpChain.html | 547 ++
.../gearpump/streaming/dsl/op/OpEdge.html | 485 +
.../streaming/dsl/op/ParameterizedOp.html | 526 ++
.../gearpump/streaming/dsl/op/ProcessorOp.html | 533 ++
.../gearpump/streaming/dsl/op/ReduceOp.html | 514 ++
.../gearpump/streaming/dsl/op/Shuffle$.html | 460 +
.../gearpump/streaming/dsl/op/SlaveOp.html | 526 ++
.../gearpump/streaming/dsl/op/package.html | 366 +
.../apache/gearpump/streaming/dsl/package.html | 299 +
.../dsl/partitioner/GroupByPartitioner.html | 552 ++
.../streaming/dsl/partitioner/package.html | 124 +
.../dsl/plan/OpTranslator$$AndThen.html | 559 ++
.../plan/OpTranslator$$DummyInputFunction.html | 559 ++
.../dsl/plan/OpTranslator$$FlatMapFunction.html | 559 ++
.../dsl/plan/OpTranslator$$GroupByTask.html | 667 ++
.../dsl/plan/OpTranslator$$ReduceFunction.html | 559 ++
.../plan/OpTranslator$$SingleInputFunction.html | 543 ++
.../dsl/plan/OpTranslator$$SinkTask.html | 667 ++
.../dsl/plan/OpTranslator$$SourceTask.html | 667 ++
.../dsl/plan/OpTranslator$$TransformTask.html | 667 ++
.../streaming/dsl/plan/OpTranslator$.html | 644 ++
.../streaming/dsl/plan/OpTranslator.html | 541 ++
.../gearpump/streaming/dsl/plan/Planner.html | 519 ++
.../gearpump/streaming/dsl/plan/package.html | 156 +
.../Executor$$DagVersionMismatchException.html | 712 ++
.../executor/Executor$$ExecutorConfig.html | 476 +
.../executor/Executor$$ExecutorSummary$.html | 505 ++
.../executor/Executor$$ExecutorSummary.html | 597 ++
.../executor/Executor$$GetExecutorSummary.html | 476 +
.../executor/Executor$$HealthCheck$.html | 482 +
.../executor/Executor$$QueryExecutorConfig.html | 476 +
.../executor/Executor$$RestartTasks.html | 476 +
.../streaming/executor/Executor$$State$.html | 550 ++
.../executor/Executor$$TaskArgumentStore.html | 571 ++
.../executor/Executor$$TaskStopped.html | 476 +
.../gearpump/streaming/executor/Executor$.html | 674 ++
.../gearpump/streaming/executor/Executor.html | 996 ++
.../executor/ExecutorRestartPolicy.html | 540 ++
.../streaming/executor/ITaskLauncher.html | 505 ++
.../executor/TaskLauncher$$TaskArgument.html | 510 ++
.../streaming/executor/TaskLauncher$.html | 521 ++
.../streaming/executor/TaskLauncher.html | 523 ++
.../gearpump/streaming/executor/package.html | 208 +
.../hadoop/HadoopCheckpointStore$.html | 501 +
.../streaming/hadoop/HadoopCheckpointStore.html | 573 ++
.../hadoop/HadoopCheckpointStoreFactory$.html | 505 ++
.../hadoop/HadoopCheckpointStoreFactory.html | 525 ++
.../streaming/hadoop/SequenceFileSink.html | 559 ++
.../hadoop/lib/HadoopCheckpointStoreReader.html | 2027 +++++
.../hadoop/lib/HadoopCheckpointStoreWriter.html | 536 ++
.../lib/format/DefaultSequenceFormatter.html | 576 ++
.../hadoop/lib/format/OutputFormatter.html | 560 ++
.../streaming/hadoop/lib/format/package.html | 135 +
.../gearpump/streaming/hadoop/lib/package.html | 172 +
.../hadoop/lib/rotation/FileSizeRotation.html | 529 ++
.../streaming/hadoop/lib/rotation/Rotation.html | 543 ++
.../streaming/hadoop/lib/rotation/package.html | 135 +
.../gearpump/streaming/hadoop/package.html | 209 +
.../gearpump/streaming/javaapi/Graph.html | 950 ++
.../gearpump/streaming/javaapi/Processor.html | 682 ++
.../streaming/javaapi/StreamApplication.html | 579 ++
.../apache/gearpump/streaming/javaapi/Task.html | 650 ++
.../javaapi/dsl/functions/FilterFunction.html | 504 ++
.../javaapi/dsl/functions/FlatMapFunction.html | 504 ++
.../javaapi/dsl/functions/GroupByFunction.html | 504 ++
.../javaapi/dsl/functions/MapFunction.html | 504 ++
.../javaapi/dsl/functions/ReduceFunction.html | 504 ++
.../javaapi/dsl/functions/package.html | 186 +
.../gearpump/streaming/javaapi/dsl/package.html | 118 +
.../gearpump/streaming/javaapi/package.html | 189 +
.../gearpump/streaming/kafka/KafkaSink.html | 567 ++
.../gearpump/streaming/kafka/KafkaSource.html | 624 ++
.../streaming/kafka/KafkaStoreFactory.html | 525 ++
.../gearpump/streaming/kafka/dsl/KafkaDSL$.html | 535 ++
.../gearpump/streaming/kafka/dsl/KafkaDSL.html | 521 ++
.../gearpump/streaming/kafka/dsl/package.html | 138 +
.../gearpump/streaming/kafka/lib/package.html | 169 +
...AbstractKafkaSink$$KafkaProducerFactory.html | 504 ++
.../kafka/lib/sink/AbstractKafkaSink$.html | 525 ++
.../kafka/lib/sink/AbstractKafkaSink.html | 572 ++
.../streaming/kafka/lib/sink/package.html | 140 +
.../kafka/lib/source/AbstractKafkaSource$.html | 488 +
.../kafka/lib/source/AbstractKafkaSource.html | 637 ++
.../kafka/lib/source/DefaultMessageDecoder.html | 523 ++
.../kafka/lib/source/StringMessageDecoder.html | 523 ++
.../FetchThread$$FetchThreadFactory.html | 521 ++
.../kafka/lib/source/consumer/FetchThread$.html | 536 ++
.../lib/source/consumer/KafkaConsumer$.html | 501 +
.../lib/source/consumer/KafkaConsumer.html | 591 ++
.../kafka/lib/source/consumer/KafkaMessage.html | 544 ++
.../kafka/lib/source/consumer/package.html | 173 +
.../source/grouper/DefaultPartitionGrouper.html | 524 ++
.../lib/source/grouper/PartitionGrouper.html | 506 ++
.../kafka/lib/source/grouper/package.html | 139 +
.../streaming/kafka/lib/source/package.html | 217 +
.../lib/store/AbstractKafkaStoreFactory.html | 544 ++
.../streaming/kafka/lib/store/KafkaStore$.html | 484 +
.../streaming/kafka/lib/store/KafkaStore.html | 589 ++
.../streaming/kafka/lib/store/package.html | 157 +
.../util/KafkaClient$$KafkaClientFactory.html | 521 ++
.../streaming/kafka/lib/util/KafkaClient$.html | 521 ++
.../streaming/kafka/lib/util/KafkaClient.html | 608 ++
.../streaming/kafka/lib/util/package.html | 138 +
.../gearpump/streaming/kafka/package.html | 206 +
.../streaming/kafka/util/KafkaConfig.html | 795 ++
.../gearpump/streaming/kafka/util/package.html | 118 +
.../ProcessorAggregator$$Aggregator.html | 522 ++
.../ProcessorAggregator$$AggregatorFactory.html | 519 ++
...rocessorAggregator$$HistogramAggregator.html | 674 ++
.../ProcessorAggregator$$MeterAggregator.html | 623 ++
.../ProcessorAggregator$$MultiLayerMap.html | 572 ++
.../streaming/metrics/ProcessorAggregator$.html | 591 ++
.../streaming/metrics/ProcessorAggregator.html | 566 ++
.../metrics/TaskFilterAggregator$$Options$.html | 522 ++
.../metrics/TaskFilterAggregator$$Options.html | 546 ++
.../metrics/TaskFilterAggregator$.html | 674 ++
.../streaming/metrics/TaskFilterAggregator.html | 559 ++
.../gearpump/streaming/metrics/package.html | 178 +
.../streaming/monoid/AlgebirdGroup.html | 559 ++
.../streaming/monoid/AlgebirdMonoid.html | 540 ++
.../gearpump/streaming/monoid/package.html | 135 +
.../org/apache/gearpump/streaming/package.html | 762 ++
.../streaming/serializer/ChillSerializer.html | 540 ++
.../gearpump/streaming/serializer/package.html | 118 +
.../gearpump/streaming/sink/DataSink.html | 558 ++
.../streaming/sink/DataSinkProcessor$.html | 504 ++
.../gearpump/streaming/sink/DataSinkTask$.html | 501 +
.../gearpump/streaming/sink/DataSinkTask.html | 653 ++
.../apache/gearpump/streaming/sink/package.html | 191 +
.../gearpump/streaming/source/DataSource.html | 562 ++
.../streaming/source/DataSourceConfig$.html | 499 +
.../streaming/source/DataSourceProcessor$.html | 504 ++
.../streaming/source/DataSourceTask$.html | 501 +
.../streaming/source/DataSourceTask.html | 655 ++
.../source/DefaultTimeStampFilter.html | 524 ++
.../gearpump/streaming/source/package.html | 230 +
.../gearpump/streaming/state/api/Group.html | 543 ++
.../gearpump/streaming/state/api/Monoid.html | 524 ++
.../streaming/state/api/MonoidState.html | 650 ++
.../streaming/state/api/PersistentState.html | 585 ++
.../streaming/state/api/PersistentTask$.html | 518 ++
.../streaming/state/api/PersistentTask.html | 779 ++
.../streaming/state/api/Serializer.html | 524 ++
.../gearpump/streaming/state/api/package.html | 231 +
.../streaming/state/impl/CheckpointManager.html | 604 ++
.../state/impl/InMemoryCheckpointStore.html | 557 ++
.../impl/InMemoryCheckpointStoreFactory.html | 523 ++
.../gearpump/streaming/state/impl/Interval.html | 600 ++
.../streaming/state/impl/NonWindowState$.html | 501 +
.../streaming/state/impl/NonWindowState.html | 646 ++
.../state/impl/PersistentStateConfig$.html | 567 ++
.../gearpump/streaming/state/impl/Window.html | 640 ++
.../streaming/state/impl/WindowConfig$.html | 505 ++
.../streaming/state/impl/WindowConfig.html | 495 +
.../streaming/state/impl/WindowState$.html | 501 +
.../streaming/state/impl/WindowState.html | 649 ++
.../gearpump/streaming/state/impl/package.html | 319 +
.../gearpump/streaming/state/package.html | 135 +
.../streaming/storage/AppDataStore.html | 523 ++
.../storage/InMemoryAppStoreOnMaster.html | 556 ++
.../gearpump/streaming/storage/package.html | 136 +
.../org/apache/gearpump/streaming/task/Ack.html | 531 ++
.../gearpump/streaming/task/AckRequest.html | 510 ++
.../streaming/task/CheckProcessorDeath.html | 476 +
.../streaming/task/CheckpointClock.html | 476 +
.../gearpump/streaming/task/ClockEvent.html | 485 +
.../streaming/task/ExpressTransport.html | 589 ++
.../streaming/task/GetCheckpointClock$.html | 458 +
.../apache/gearpump/streaming/task/GetDAG$.html | 456 +
.../streaming/task/GetLatestMinClock$.html | 484 +
.../gearpump/streaming/task/GetStartClock$.html | 456 +
.../streaming/task/GetUpstreamMinClock.html | 478 +
.../streaming/task/InitialAckRequest.html | 493 +
.../gearpump/streaming/task/LatencyProbe.html | 476 +
.../gearpump/streaming/task/LatestMinClock.html | 476 +
.../streaming/task/SendMessageLoss.html | 459 +
.../streaming/task/SerializedMessage.html | 493 +
.../task/SerializedMessageSerializer.html | 555 ++
.../task/SerializerResolver$$Registration.html | 553 ++
.../streaming/task/SerializerResolver$.html | 502 ++
.../gearpump/streaming/task/StartClock.html | 476 +
.../gearpump/streaming/task/StartTime.html | 476 +
.../task/StreamingTransportSerializer.html | 555 ++
.../gearpump/streaming/task/Subscriber$.html | 507 ++
.../gearpump/streaming/task/Subscriber.html | 531 ++
.../gearpump/streaming/task/Subscription$.html | 518 ++
.../gearpump/streaming/task/Subscription.html | 645 ++
.../apache/gearpump/streaming/task/Task.html | 651 ++
.../streaming/task/TaskActor$$FLUSH$.html | 456 +
.../task/TaskActor$$MessageAndSender.html | 493 +
.../task/TaskActor$$SecurityChecker.html | 553 ++
.../streaming/task/TaskActor$$SendAck.html | 493 +
.../gearpump/streaming/task/TaskActor$.html | 589 ++
.../gearpump/streaming/task/TaskActor.html | 1276 +++
.../gearpump/streaming/task/TaskContext.html | 775 ++
.../streaming/task/TaskContextData.html | 578 ++
.../apache/gearpump/streaming/task/TaskId$.html | 522 ++
.../apache/gearpump/streaming/task/TaskId.html | 495 +
.../gearpump/streaming/task/TaskInterface.html | 563 ++
.../streaming/task/TaskMessageSerializer.html | 539 ++
.../gearpump/streaming/task/TaskUtil$.html | 500 +
.../gearpump/streaming/task/TaskWrapper.html | 924 ++
.../streaming/task/UpdateCheckpointClock.html | 495 +
.../gearpump/streaming/task/UpdateClock.html | 495 +
.../streaming/task/UpstreamMinClock.html | 476 +
.../apache/gearpump/streaming/task/package.html | 778 ++
.../transaction/api/CheckpointStore.html | 542 ++
.../transaction/api/CheckpointStoreFactory.html | 508 ++
.../transaction/api/MessageDecoder.html | 509 ++
.../transaction/api/TimeReplayableSource.html | 574 ++
.../transaction/api/TimeStampFilter.html | 508 ++
.../streaming/transaction/api/package.html | 194 +
.../gearpump/streaming/transaction/package.html | 118 +
.../gearpump/streaming/util/ActorPathUtil$.html | 550 ++
.../apache/gearpump/streaming/util/package.html | 118 +
.../gearpump/transport/ActorLookupById.html | 505 ++
.../org/apache/gearpump/transport/Express$.html | 573 ++
.../org/apache/gearpump/transport/Express.html | 782 ++
.../apache/gearpump/transport/HostPort$.html | 505 ++
.../org/apache/gearpump/transport/HostPort.html | 512 ++
.../netty/Client$$ChannelFutureOps.html | 536 ++
.../transport/netty/Client$$ChannelReady.html | 476 +
.../netty/Client$$ClientErrorHandler.html | 801 ++
.../netty/Client$$ClientPipelineFactory.html | 521 ++
.../transport/netty/Client$$Close$.html | 456 +
.../Client$$CompareAndReconnectIfEqual.html | 476 +
.../transport/netty/Client$$Connect.html | 476 +
.../gearpump/transport/netty/Client$$Flush.html | 476 +
.../gearpump/transport/netty/Client$.html | 657 ++
.../apache/gearpump/transport/netty/Client.html | 886 ++
.../gearpump/transport/netty/Context$.html | 484 +
.../gearpump/transport/netty/Context.html | 596 ++
.../gearpump/transport/netty/IContext.html | 541 ++
.../netty/ITransportMessageSerializer.html | 539 ++
.../gearpump/transport/netty/MessageBatch.html | 482 +
.../transport/netty/MessageDecoder.html | 1204 +++
.../transport/netty/MessageEncoder.html | 571 ++
.../gearpump/transport/netty/NettyConfig.html | 621 ++
.../netty/NettyRenameThreadFactory.html | 501 +
.../gearpump/transport/netty/NettyUtil$.html | 533 ++
.../transport/netty/Server$$AddChannel.html | 476 +
.../transport/netty/Server$$CloseChannel.html | 476 +
.../transport/netty/Server$$MsgBatch.html | 476 +
.../transport/netty/Server$$ServerHandler.html | 789 ++
.../netty/Server$$ServerPipelineFactory.html | 521 ++
.../Server$$TaskIdActorRefTranslation.html | 519 ++
.../gearpump/transport/netty/Server$.html | 589 ++
.../apache/gearpump/transport/netty/Server.html | 867 ++
.../gearpump/transport/netty/TaskMessage.html | 570 ++
.../transport/netty/WrappedChannelBuffer.html | 793 ++
.../gearpump/transport/netty/package.html | 378 +
.../org/apache/gearpump/transport/package.html | 208 +
.../util/ActorSystemBooter$$ActorCreated.html | 493 +
...ctorSystemBooter$$ActorSystemRegistered.html | 478 +
.../util/ActorSystemBooter$$BindLifeCycle.html | 476 +
.../util/ActorSystemBooter$$CreateActor.html | 493 +
.../ActorSystemBooter$$CreateActorFailed.html | 493 +
.../util/ActorSystemBooter$$Daemon.html | 933 ++
.../ActorSystemBooter$$RegisterActorSystem.html | 476 +
...SystemBooter$$RegisterActorSystemFailed.html | 476 +
...stemBooter$$RegisterActorSystemTimeOut$.html | 482 +
.../gearpump/util/ActorSystemBooter$.html | 676 ++
.../apache/gearpump/util/ActorSystemBooter.html | 523 ++
.../org/apache/gearpump/util/ActorUtil$.html | 703 ++
.../scala/org/apache/gearpump/util/AkkaApp.html | 574 ++
.../org/apache/gearpump/util/AkkaHelper.html | 502 ++
.../org/apache/gearpump/util/ConsoleOutput.html | 522 ++
.../org/apache/gearpump/util/Constants$.html | 1978 ++++
.../org/apache/gearpump/util/FileUtils$.html | 567 ++
.../org/apache/gearpump/util/Graph$$Node.html | 555 ++
.../apache/gearpump/util/Graph$$NodeList.html | 555 ++
.../org/apache/gearpump/util/Graph$$Path$.html | 501 +
.../org/apache/gearpump/util/Graph$$Path.html | 558 ++
.../scala/org/apache/gearpump/util/Graph$.html | 634 ++
.../scala/org/apache/gearpump/util/Graph.html | 925 ++
.../gearpump/util/HadoopFSLogAppender.html | 1330 +++
...toryMetricsService$$CounterMetricsStore.html | 572 ++
...etricsService$$DummyHistoryMetricsStore.html | 589 ++
...yMetricsService$$DummyMetricsAggregator.html | 521 ++
...istoryMetricsService$$GaugeMetricsStore.html | 572 ++
...ryMetricsService$$HistogramMetricsStore.html | 572 ++
...ryMetricsService$$HistoryMetricsConfig$.html | 505 ++
...oryMetricsService$$HistoryMetricsConfig.html | 536 ++
...oryMetricsService$$HistoryMetricsStore$.html | 501 +
...toryMetricsService$$HistoryMetricsStore.html | 558 ++
...istoryMetricsService$$MeterMetricsStore.html | 572 ++
.../HistoryMetricsService$$MetricsStore.html | 539 ++
...MetricsService$$SingleValueMetricsStore.html | 574 ++
...istoryMetricsService$$SkipAllAggregator.html | 521 ++
.../gearpump/util/HistoryMetricsService$.html | 712 ++
.../gearpump/util/HistoryMetricsService.html | 859 ++
.../gearpump/util/LogUtil$$ProcessType$.html | 837 ++
.../org/apache/gearpump/util/LogUtil$.html | 601 ++
.../gearpump/util/ProcessLogRedirector.html | 631 ++
.../util/RecreateRollingFileAppender.html | 1364 +++
.../apache/gearpump/util/ReferenceEqual.html | 486 +
.../org/apache/gearpump/util/RestartPolicy.html | 523 ++
.../org/apache/gearpump/util/RichProcess.html | 555 ++
.../apache/gearpump/util/TimeOutScheduler.html | 502 ++
.../gearpump/util/Util$$AppJvmSettings.html | 493 +
.../apache/gearpump/util/Util$$JvmSetting.html | 493 +
.../scala/org/apache/gearpump/util/Util$.html | 740 ++
.../scala/org/apache/gearpump/util/package.html | 468 +
.../latest/api/scala/org/apache/package.html | 118 +
releases/latest/api/scala/org/package.html | 118 +
releases/latest/api/scala/package.html | 10 +-
releases/latest/basic-concepts.html | 266 +-
releases/latest/coding-style.html | 263 +-
releases/latest/commandline.html | 270 +-
releases/latest/css/api-javadocs.css | 4 +-
releases/latest/css/main.css | 29 +-
releases/latest/deployment-configuration.html | 283 +-
releases/latest/deployment-docker.html | 263 +-
releases/latest/deployment-ha.html | 279 +-
releases/latest/deployment-local.html | 266 +-
releases/latest/deployment-msg-delivery.html | 265 +-
.../latest/deployment-resource-isolation.html | 280 +-
releases/latest/deployment-security.html | 274 +-
releases/latest/deployment-standalone.html | 277 +-
.../latest/deployment-ui-authentication.html | 279 +-
releases/latest/deployment-yarn.html | 273 +-
releases/latest/dev-connectors.html | 505 +-
releases/latest/dev-custom-serializer.html | 289 +-
releases/latest/dev-ide-setup.html | 263 +-
releases/latest/dev-non-streaming-example.html | 263 +-
releases/latest/dev-rest-api.html | 365 +-
releases/latest/dev-storm.html | 280 +-
releases/latest/dev-write-1st-app.html | 541 +-
releases/latest/faq.html | 266 +-
releases/latest/features.html | 268 +-
releases/latest/gearpump-internals.html | 276 +-
releases/latest/get-gearpump-distribution.html | 276 +-
releases/latest/hardware-requirement.html | 266 +-
releases/latest/how-to-contribute.html | 224 -
releases/latest/img/logo.png | Bin 39969 -> 2053 bytes
releases/latest/img/logo.svg | 71 +
releases/latest/index.html | 268 +-
releases/latest/js/api-docs.js | 4 +-
releases/latest/js/api-javadocs.js | 18 +-
releases/latest/js/main.js | 29 +-
releases/latest/maven-setting.html | 272 +-
releases/latest/message-delivery.html | 269 +-
releases/latest/performance-report.html | 268 +-
.../latest/submit-your-1st-application.html | 268 +-
4430 files changed, 1234025 insertions(+), 511848 deletions(-)
----------------------------------------------------------------------