update content folder for 0.8.1 Author: manuzhang <[email protected]>
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 <[email protected]> Authored: Mon Aug 15 09:25:27 2016 +0800 Committer: manuzhang <[email protected]> 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>
