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/15 01:26:30 UTC
[51/51] [partial] incubator-gearpump-site git commit: update content
folder for 0.8.1
update content folder for 0.8.1
Author: manuzhang <ow...@gmail.com>
Closes #6 from manuzhang/update_content.
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/c330442c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/tree/c330442c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/diff/c330442c
Branch: refs/heads/asf-site
Commit: c330442c4020cb6b95d7016dd14a1fef9be8ca72
Parents: b5f0e57
Author: manuzhang <ow...@gmail.com>
Authored: Mon Aug 15 09:25:27 2016 +0800
Committer: manuzhang <ow...@gmail.com>
Committed: Mon Aug 15 09:25:27 2016 +0800
----------------------------------------------------------------------
content/downloads.html | 8 +-
content/overview.html | 2 +-
content/releases/latest/about.html | 190 -
.../latest/api/java/allclasses-frame.html | 1104 ++-
.../latest/api/java/allclasses-noframe.html | 1104 ++-
.../latest/api/java/constant-values.html | 159 +-
.../latest/api/java/deprecated-list.html | 4 +-
content/releases/latest/api/java/help-doc.html | 4 +-
content/releases/latest/api/java/index-all.html | 8521 +++++++++++++-----
content/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 -
.../latest/api/java/overview-frame.html | 77 +-
.../latest/api/java/overview-summary.html | 170 +-
.../releases/latest/api/java/overview-tree.html | 1287 ++-
content/releases/latest/api/java/package-list | 73 +-
.../latest/api/java/serialized-form.html | 3531 ++++++--
.../latest/api/scala/akka/pattern/package.html | 2 +-
content/releases/latest/api/scala/index.html | 378 +-
content/releases/latest/api/scala/index.js | 2 +-
.../latest/api/scala/index/index-_.html | 16 +-
.../latest/api/scala/index/index-a.html | 288 +-
.../latest/api/scala/index/index-b.html | 34 +-
.../latest/api/scala/index/index-c.html | 237 +-
.../latest/api/scala/index/index-d.html | 146 +-
.../latest/api/scala/index/index-e.html | 122 +-
.../latest/api/scala/index/index-f.html | 96 +-
.../latest/api/scala/index/index-g.html | 369 +-
.../latest/api/scala/index/index-h.html | 83 +-
.../latest/api/scala/index/index-i.html | 64 +-
.../latest/api/scala/index/index-j.html | 30 +-
.../latest/api/scala/index/index-k.html | 60 +-
.../latest/api/scala/index/index-l.html | 116 +-
.../latest/api/scala/index/index-m.html | 209 +-
.../latest/api/scala/index/index-n.html | 65 +-
.../latest/api/scala/index/index-o.html | 75 +-
.../latest/api/scala/index/index-p.html | 158 +-
.../latest/api/scala/index/index-q.html | 13 +-
.../latest/api/scala/index/index-r.html | 260 +-
.../latest/api/scala/index/index-s.html | 332 +-
.../latest/api/scala/index/index-t.html | 181 +-
.../latest/api/scala/index/index-u.html | 83 +-
.../latest/api/scala/index/index-v.html | 26 +-
.../latest/api/scala/index/index-w.html | 145 +-
.../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 -
content/releases/latest/api/scala/package.html | 10 +-
content/releases/latest/basic-concepts.html | 266 +-
content/releases/latest/coding-style.html | 263 +-
content/releases/latest/commandline.html | 270 +-
content/releases/latest/css/api-javadocs.css | 4 +-
content/releases/latest/css/main.css | 29 +-
.../latest/deployment-configuration.html | 283 +-
content/releases/latest/deployment-docker.html | 263 +-
content/releases/latest/deployment-ha.html | 279 +-
content/releases/latest/deployment-local.html | 266 +-
.../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 +-
content/releases/latest/deployment-yarn.html | 273 +-
content/releases/latest/dev-connectors.html | 505 +-
.../releases/latest/dev-custom-serializer.html | 289 +-
content/releases/latest/dev-ide-setup.html | 263 +-
.../latest/dev-non-streaming-example.html | 263 +-
content/releases/latest/dev-rest-api.html | 365 +-
content/releases/latest/dev-storm.html | 280 +-
content/releases/latest/dev-write-1st-app.html | 541 +-
content/releases/latest/faq.html | 266 +-
content/releases/latest/features.html | 268 +-
content/releases/latest/gearpump-internals.html | 276 +-
.../latest/get-gearpump-distribution.html | 276 +-
.../releases/latest/hardware-requirement.html | 266 +-
content/releases/latest/how-to-contribute.html | 224 -
content/releases/latest/img/logo.png | Bin 39969 -> 2053 bytes
content/releases/latest/index.html | 268 +-
content/releases/latest/js/api-docs.js | 4 +-
content/releases/latest/js/api-javadocs.js | 18 +-
content/releases/latest/js/main.js | 29 +-
content/releases/latest/maven-setting.html | 272 +-
content/releases/latest/message-delivery.html | 269 +-
content/releases/latest/performance-report.html | 268 +-
.../latest/submit-your-1st-application.html | 268 +-
1221 files changed, 17991 insertions(+), 511848 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/c330442c/content/downloads.html
----------------------------------------------------------------------
diff --git a/content/downloads.html b/content/downloads.html
index dfa5341..c4b9317 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -97,14 +97,12 @@
<h2 id="downloads">Downloads</h2>
-<h3 id="latest-stable-release-v081-this-is-not-an-apache-release">Latest Stable Release (v0.8.1) (This is not an Apache release)</h3>
+<h3 id="latest-stable-release-v081">Latest Stable Release (v0.8.1)</h3>
-<p><a href="https://github.com/gearpump/gearpump/releases">Release Notes</a></p>
+<p><a href="https://git-wip-us.apache.org/repos/asf?p=incubator-gearpump.git;a=blob;f=CHANGELOG.md;h=564899ef23176c304f03c4decb2266c19d88d46f;hb=9063ae8c447b711b4b512e79ce8d7aff66924e79">Release Notes</a></p>
<ul>
- <li><a href="https://github.com/gearpump/gearpump/releases/download/0.8.1/gearpump-2.11-0.8.1.zip">Binary (for Scala 2.11)</a></li>
- <li><a href="https://github.com/gearpump/gearpump/archive/0.8.1.zip">Source code (.zip)</a></li>
- <li><a href="https://github.com/gearpump/gearpump/archive/0.8.1.tar.gz">Source code (.tar.gz)</a></li>
+ <li><a href="https://dist.apache.org/repos/dist/release/incubator/gearpump/0.8.1-incubating/">The source tarball, including signatures, digests, etc.</a></li>
</ul>
<p><em>Note that as we have upgraded the Akka library to 2.4.x, which has dropped the Scala 2.10 support, we do NOT provide Gearpump build for Scala 2.10 since Gearpump 0.8.0.</em></p>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/c330442c/content/overview.html
----------------------------------------------------------------------
diff --git a/content/overview.html b/content/overview.html
index d462e57..127507a 100644
--- a/content/overview.html
+++ b/content/overview.html
@@ -98,7 +98,7 @@
<p><img src="/favicon.ico" alt="gearpump-logo" />
-<a href="http://www.gearpump.io/downloads.html"><img src="https://img.shields.io/badge/Latest%20Release-v0.8.1-blue.svg" alt="Release" /></a></p>
+<a href="https://dist.apache.org/repos/dist/release/incubator/gearpump/0.8.1-incubating/"><img src="https://img.shields.io/badge/Latest%20Release-v0.8.1-blue.svg" alt="Release" /></a></p>
<p><strong>Apache Gearpump</strong> is a real-time big data streaming engine. The name Gearpump is a reference to the engineering term “gear pump” which is a super simple pump that consists of only two gears, but is very powerful at streaming water. Different to other streaming engines, Gearpump’s engine is event/message based. Per initial benchmarks we are able to process 18 million messages per second (message length is 100 bytes) with a 8ms latency on a 4-node cluster.</p>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/c330442c/content/releases/latest/about.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/about.html b/content/releases/latest/about.html
deleted file mode 100644
index dbaa605..0000000
--- a/content/releases/latest/about.html
+++ /dev/null
@@ -1,190 +0,0 @@
-<!DOCTYPE html>
-<!--[if lt IE 7]> <html class="no-js lt-ie9 lt-ie8 lt-ie7"> <![endif]-->
-<!--[if IE 7]> <html class="no-js lt-ie9 lt-ie8"> <![endif]-->
-<!--[if IE 8]> <html class="no-js lt-ie9"> <![endif]-->
-<!--[if gt IE 8]><!--> <html class="no-js"> <!--<![endif]-->
-<head>
- <meta charset="utf-8">
- <meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1">
- <meta name="viewport" content="width=device-width,initial-scale=1,maximum-scale=1"/>
- <title>About - Gearpump 0.8.0 Documentation</title>
-
-
-
-
- <link rel="stylesheet" href="css/bootstrap-3.3.5.min.css">
- <style>
- body {
- padding-top: 60px;
- padding-bottom: 40px;
- }
- </style>
- <link rel="stylesheet" href="css/main.css">
- <link rel="stylesheet" href="css/pygments-default.css">
- <script src="js/vendor/modernizr-2.6.1-respond-1.1.0.min.js"></script>
-</head>
-<body>
- <!--[if lt IE 7]>
- <p class="chromeframe">You are using an outdated browser. <a href="http://browsehappy.com/">Upgrade your browser today</a> or <a href="http://www.google.com/chromeframe/?redirect=true">install Google Chrome Frame</a> to better experience this site.</p>
- <![endif]-->
-
- <div class="navbar navbar-inverse navbar-fixed-top" id="topbar">
- <div class="container">
- <div class="navbar-header">
- <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#navbar" aria-expanded="false" aria-controls="navbar">
- <span class="sr-only">Toggle navigation</span>
- <span class="icon-bar"></span>
- <span class="icon-bar"></span>
- <span class="icon-bar"></span>
- </button>
- <a class="navbar-brand" href="http://gearpump.io">Gearpump
- <span class="label label-primary" style="font-size: .6em">0.8.0</span>
- </a>
- </div>
- <div id="navbar" class="collapse navbar-collapse">
- <ul class="nav navbar-nav">
- <li><a href="index.html">Overview</a></li>
-
- <li class="dropdown">
- <a href="#" class="dropdown-toggle" data-toggle="dropdown">Introduction<b class="caret"></b></a>
- <ul class="dropdown-menu">
- <li><a href="submit-your-1st-application.html">Submit Your 1st Application</a></li>
- <li><a href="commandline.html">Client Command Line</a></li>
- <li class="divider"></li>
- <li><a href="basic-concepts.html">Basic Concepts</a></li>
- <li><a href="features.html">Technical Highlights</a></li>
- <li><a href="message-delivery.html">Reliable Message Delivery</a></li>
- <li><a href="performance-report.html">Performance</a></li>
- <li><a href="gearpump-internals.html">Gearpump Internals</a></li>
- </ul>
- </li>
-
- <li class="dropdown">
- <a href="#" class="dropdown-toggle" data-toggle="dropdown">Deploying<b class="caret"></b></a>
- <ul class="dropdown-menu">
- <li class="dropdown-header">Deployment</li>
- <li><a href="deployment-local.html">Local Mode</a><li>
- <li><a href="deployment-standalone.html">Standalone Mode</a></li>
- <li><a href="deployment-yarn.html">YARN Mode</a></li>
- <li><a href="deployment-docker.html">Docker Mode</a><li>
- <li class="divider"></li>
- <li><a href="deployment-ui-authentication.html">UI Authentication</a></li>
- <li><a href="deployment-ha.html">High Availability</a></li>
- <li><a href="deployment-msg-delivery.html">Reliable Message Delivery</a></li>
- <li><a href="deployment-configuration.html">Configuration</a></li>
- <li><a href="deployment-resource-isolation.html">Resource Isolation</a></li>
- <li class="divider"></li>
- <li><a href="deployment-security.html">YARN Security Guide</a></li>
- </ul>
- </li>
-
- <li class="dropdown">
- <a href="#" class="dropdown-toggle" data-toggle="dropdown">Programming Guide<b class="caret"></b></a>
- <ul class="dropdown-menu">
- <li><a href="dev-write-1st-app.html">Write Your 1st App</a></li>
- <li><a href="dev-custom-serializer.html">Customized Message Passing</a></li>
- <li class="divider"></li>
- <li><a href="api/scala/index.html">Scala API</a></li>
- <li><a href="api/java/index.html">Java API</a></li>
- <li><a href="dev-rest-api.html">RESTful API</a></li>
- <li class="divider"></li>
- <li><a href="dev-connectors.html">Gearpump Connectors</a></li>
- <li class="divider"></li>
- <li><a href="dev-storm.html">Storm Compatibility</a></li>
- <!--
- <li><a href="dev-samoa.html">Samoa Compatibility</a></li>
- <li class="divider"></li>
- <li><a href="dev-iot.html">Gearpump with IoT</a></li>
- -->
- </ul>
- </li>
-
- <li class="dropdown">
- <a href="#" class="dropdown-toggle" data-toggle="dropdown">More<b class="caret"></b></a>
- <ul class="dropdown-menu">
- <li><a href="how-to-contribute.html">How to Contribute</a></li>
- <li><a href="coding-style.html">Coding Style</a></li>
- <li class="divider"></li>
- <li><a href="faq.html">FAQ</a><li>
- <li><a href="about.html">About</a></li>
- </ul>
- </li>
- </ul>
- </div>
- </div>
- </div>
-
- <div class="container" id="content">
-
- <h1 class="title">About</h1>
-
-
- <h3 id="who-are-we">Who are we?</h3>
-
-<p>We are a group of streaming guys from Intel.</p>
-
-<h3 id="user-list">User List</h3>
-
-<p>We have a user mail list at: <a href="https://groups.google.com/forum/#!forum/gearpump-user">User Mail List</a></p>
-
-<h3 id="submit-an-issue">Submit an issue</h3>
-
-<p>Please submit new issue to <a href="https://github.com/gearpump/gearpump/issues">https://github.com/gearpump/gearpump/issues</a></p>
-
-<h3 id="make-code-contribution">Make code contribution</h3>
-
-<p>Contributions are warmly welcome! To contribute to Gearpump source code, please make a PR against <a href="https://github.com/gearpump/gearpump/pulls">https://github.com/gearpump/gearpump/pulls</a></p>
-
-<p>To contribute to the contents in this site, make a PR to <a href="https://github.com/gearpump/gearpump.github.io">https://github.com/gearpump/gearpump.github.io</a></p>
-
-<h3 id="more-technical-support">More Technical Support</h3>
-
-<p>For business cooperation and support, please contact <a href="mailto:xiang.zhong@intel.com">xiang.zhong@intel.com</a> <a href="mailto:kam.d.kasravi@intel.com">kam.d.kasravi@intel.com</a> <a href="mailto:weihua.jiang@intel.com">weihua.jiang@intel.co&
#109;</a></p>
-
-<h3 id="license">License</h3>
-
-<p>The source tree under <a href="http://github.com/gearpump/gearpump">http://github.com/gearpump/gearpump</a> is
-Licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0</p>
-
-<h3 id="acknowledgement">Acknowledgement</h3>
-
-<p>The netty transport code work is based on <a href="http://storm.apache.org/">Apache Storm</a>. Thanks Apache Storm contributors.</p>
-
-
- </div> <!-- /container -->
-
- <script src="js/vendor/jquery-2.1.4.min.js"></script>
- <script src="js/vendor/bootstrap-3.3.5.min.js"></script>
- <script src="js/vendor/anchor-1.1.1.min.js"></script>
- <script src="js/main.js"></script>
-
- <!-- MathJax Section -->
- <script type="text/x-mathjax-config">
- MathJax.Hub.Config({
- TeX: { equationNumbers: { autoNumber: "AMS" } }
- });
- </script>
- <script>
- // Note that we load MathJax this way to work with local file (file://), HTTP and HTTPS.
- // We could use "//cdn.mathjax...", but that won't support "file://".
- (function(d, script) {
- script = d.createElement('script');
- script.type = 'text/javascript';
- script.async = true;
- script.onload = function(){
- MathJax.Hub.Config({
- tex2jax: {
- inlineMath: [ ["$", "$"], ["\\\\(","\\\\)"] ],
- displayMath: [ ["$$","$$"], ["\\[", "\\]"] ],
- processEscapes: true,
- skipTags: ['script', 'noscript', 'style', 'textarea', 'pre']
- }
- });
- };
- script.src = ('https:' == document.location.protocol ? 'https://' : 'http://') +
- 'cdn.mathjax.org/mathjax/latest/MathJax.js?config=TeX-AMS-MML_HTMLorMML';
- d.getElementsByTagName('head')[0].appendChild(script);
- }(document));
- </script>
-</body>
-</html>