http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/content/releases/latest/api/java/allclasses-noframe.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/allclasses-noframe.html b/content/releases/latest/api/java/allclasses-noframe.html index 4a13e819..aa3ccdc 100644 --- a/content/releases/latest/api/java/allclasses-noframe.html +++ b/content/releases/latest/api/java/allclasses-noframe.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_25) on Thu Aug 11 09:54:18 PDT 2016 --> +<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:22 PST 2016 --> <title>All Classes</title> -<meta name="date" content="2016-08-11"> +<meta name="date" content="2016-11-28"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -16,6 +16,8 @@ <li><a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html" title="interface in org.apache.gearpump.streaming.kafka.lib.sink"><span class="interfaceName">AbstractKafkaSink.KafkaProducerFactory</span></a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">AbstractKafkaSource</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.store">AbstractKafkaStoreFactory</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/Accumulating.html" title="class in org.apache.gearpump.streaming.dsl.window.api">Accumulating</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html" title="interface in org.apache.gearpump.streaming.dsl.window.api"><span class="interfaceName">AccumulationMode</span></a></li> <li><a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task">Ack</a></li> <li><a href="org/apache/gearpump/streaming/task/AckRequest.html" title="class in org.apache.gearpump.streaming.task">AckRequest</a></li> <li><a href="org/apache/gearpump/streaming/AckRequestSerializer.html" title="class in org.apache.gearpump.streaming">AckRequestSerializer</a></li> @@ -39,12 +41,18 @@ <li><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed.html" title="class in org.apache.gearpump.util">ActorSystemBooter.RegisterActorSystemFailed</a></li> <li><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed$.html" title="class in org.apache.gearpump.util">ActorSystemBooter.RegisterActorSystemFailed$</a></li> <li><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemTimeOut$.html" title="class in org.apache.gearpump.util">ActorSystemBooter.RegisterActorSystemTimeOut$</a></li> +<li><a href="org/apache/gearpump/util/ActorSystemBooterSpec.html" title="class in org.apache.gearpump.util">ActorSystemBooterSpec</a></li> +<li><a href="org/apache/gearpump/util/ActorSystemBooterSpec.AcceptThreeArguments.html" title="class in org.apache.gearpump.util">ActorSystemBooterSpec.AcceptThreeArguments</a></li> +<li><a href="org/apache/gearpump/util/ActorSystemBooterSpec.AcceptZeroArguments.html" title="class in org.apache.gearpump.util">ActorSystemBooterSpec.AcceptZeroArguments</a></li> +<li><a href="org/apache/gearpump/util/ActorSystemBooterSpec.Dummy.html" title="class in org.apache.gearpump.util">ActorSystemBooterSpec.Dummy</a></li> <li><a href="org/apache/gearpump/util/ActorUtil.html" title="class in org.apache.gearpump.util">ActorUtil</a></li> +<li><a href="org/apache/gearpump/util/ActorUtilSpec.html" title="class in org.apache.gearpump.util">ActorUtilSpec</a></li> <li><a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util"><span class="interfaceName">AkkaApp</span></a></li> <li><a href="org/apache/gearpump/util/AkkaHelper.html" title="class in org.apache.gearpump.util">AkkaHelper</a></li> <li><a href="org/apache/gearpump/metrics/AkkaReporter.html" title="class in org.apache.gearpump.metrics">AkkaReporter</a></li> <li><a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" title="class in org.apache.gearpump.streaming.monoid">AlgebirdGroup</a></li> <li><a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" title="class in org.apache.gearpump.streaming.monoid">AlgebirdMonoid</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">AndThen</a></li> <li><a href="org/apache/gearpump/streaming/storage/AppDataStore.html" title="interface in org.apache.gearpump.streaming.storage"><span class="interfaceName">AppDataStore</span></a></li> <li><a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster">AppDescription</a></li> <li><a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a></li> @@ -52,6 +60,11 @@ <li><a href="org/apache/gearpump/cluster/Application.DefaultApplication.html" title="class in org.apache.gearpump.cluster">Application.DefaultApplication</a></li> <li><a href="org/apache/gearpump/cluster/ApplicationMaster.html" title="class in org.apache.gearpump.cluster">ApplicationMaster</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationState</a></li> +<li><a href="org/apache/gearpump/cluster/master/ApplicationStateSpec.html" title="class in org.apache.gearpump.cluster.master">ApplicationStateSpec</a></li> +<li><a href="org/apache/gearpump/cluster/master/AppManager.html" title="class in org.apache.gearpump.cluster.master">AppManager</a></li> +<li><a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState</a></li> +<li><a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/AppManagerSpec.html" title="class in org.apache.gearpump.cluster.appmaster">AppManagerSpec</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/AppMaster.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.AllocateResourceTimeOut$</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.ExecutorBrief</a></li> @@ -64,6 +77,7 @@ <li><a href="org/apache/gearpump/cluster/AppMasterContext.html" title="class in org.apache.gearpump.cluster">AppMasterContext</a></li> <li><a href="org/apache/gearpump/cluster/master/AppMasterLauncher.html" title="class in org.apache.gearpump.cluster.master">AppMasterLauncher</a></li> <li><a href="org/apache/gearpump/cluster/master/AppMasterLauncherFactory.html" title="interface in org.apache.gearpump.cluster.master"><span class="interfaceName">AppMasterLauncherFactory</span></a></li> +<li><a href="org/apache/gearpump/cluster/master/AppMasterLauncherSpec.html" title="class in org.apache.gearpump.cluster.master">AppMasterLauncherSpec</a></li> <li><a href="org/apache/gearpump/cluster/AppMasterRegisterData.html" title="interface in org.apache.gearpump.cluster"><span class="interfaceName">AppMasterRegisterData</span></a></li> <li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironment</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.LazyStartAppMaster.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironment.LazyStartAppMaster</a></li> @@ -71,7 +85,12 @@ <li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.MasterWithExecutorSystemProvider.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironment.MasterWithExecutorSystemProvider</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.MasterWithExecutorSystemProvider$.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironment.MasterWithExecutorSystemProvider$</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.StartAppMaster$.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironment.StartAppMaster$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeInfo</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/AppMasterSpec.html" title="class in org.apache.gearpump.streaming.appmaster">AppMasterSpec</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/AppMasterSpec.TaskStarted$.html" title="class in org.apache.gearpump.streaming.appmaster">AppMasterSpec.TaskStarted$</a></li> <li><a href="org/apache/gearpump/streaming/AppMasterToExecutor.html" title="class in org.apache.gearpump.streaming">AppMasterToExecutor</a></li> <li><a href="org/apache/gearpump/streaming/AppMasterToExecutor.ChangeTask.html" title="class in org.apache.gearpump.streaming">AppMasterToExecutor.ChangeTask</a></li> <li><a href="org/apache/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html" title="class in org.apache.gearpump.streaming">AppMasterToExecutor.ChangeTask$</a></li> @@ -142,18 +161,22 @@ <li><a href="org/apache/gearpump/cluster/AppMasterToWorker.LaunchExecutor$.html" title="class in org.apache.gearpump.cluster">AppMasterToWorker.LaunchExecutor$</a></li> <li><a href="org/apache/gearpump/cluster/AppMasterToWorker.ShutdownExecutor.html" title="class in org.apache.gearpump.cluster">AppMasterToWorker.ShutdownExecutor</a></li> <li><a href="org/apache/gearpump/cluster/AppMasterToWorker.ShutdownExecutor$.html" title="class in org.apache.gearpump.cluster">AppMasterToWorker.ShutdownExecutor$</a></li> +<li><a href="org/apache/gearpump/cluster/main/AppSubmitter.html" title="class in org.apache.gearpump.cluster.main">AppSubmitter</a></li> +<li><a href="org/apache/gearpump/cluster/main/ArgumentParserSpec.html" title="class in org.apache.gearpump.cluster.main">ArgumentParserSpec</a></li> <li><a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main"><span class="interfaceName">ArgumentsParser</span></a></li> <li><a href="org/apache/gearpump/cluster/main/ArgumentsParser.Syntax.html" title="class in org.apache.gearpump.cluster.main">ArgumentsParser.Syntax</a></li> <li><a href="org/apache/gearpump/cluster/main/ArgumentsParser.Syntax$.html" title="class in org.apache.gearpump.cluster.main">ArgumentsParser.Syntax$</a></li> <li><a href="org/apache/gearpump/security/Authenticator.html" title="interface in org.apache.gearpump.security"><span class="interfaceName">Authenticator</span></a></li> <li><a href="org/apache/gearpump/security/Authenticator.AuthenticationResult.html" title="interface in org.apache.gearpump.security"><span class="interfaceName">Authenticator.AuthenticationResult</span></a></li> -<li><a href="org/apache/gearpump/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.partitioner">BroadcastPartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">BroadcastPartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/impl/Bucket.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">Bucket</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">ChainableOp</a></li> <li><a href="org/apache/gearpump/streaming/task/CheckpointClock.html" title="class in org.apache.gearpump.streaming.task">CheckpointClock</a></li> <li><a href="org/apache/gearpump/streaming/state/impl/CheckpointManager.html" title="class in org.apache.gearpump.streaming.state.impl">CheckpointManager</a></li> +<li><a href="org/apache/gearpump/streaming/state/impl/CheckpointManagerSpec.html" title="class in org.apache.gearpump.streaming.state.impl">CheckpointManagerSpec</a></li> <li><a href="org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in org.apache.gearpump.streaming.transaction.api"><span class="interfaceName">CheckpointStore</span></a></li> <li><a href="org/apache/gearpump/streaming/transaction/api/CheckpointStoreFactory.html" title="interface in org.apache.gearpump.streaming.transaction.api"><span class="interfaceName">CheckpointStoreFactory</span></a></li> <li><a href="org/apache/gearpump/streaming/task/CheckProcessorDeath.html" title="class in org.apache.gearpump.streaming.task">CheckProcessorDeath</a></li> -<li><a href="org/apache/gearpump/streaming/serializer/ChillSerializer.html" title="class in org.apache.gearpump.streaming.serializer">ChillSerializer</a></li> <li><a href="org/apache/gearpump/transport/netty/Client.html" title="class in org.apache.gearpump.transport.netty">Client</a></li> <li><a href="org/apache/gearpump/transport/netty/Client.ChannelFutureOps.html" title="class in org.apache.gearpump.transport.netty">Client.ChannelFutureOps</a></li> <li><a href="org/apache/gearpump/transport/netty/Client.ChannelReady.html" title="class in org.apache.gearpump.transport.netty">Client.ChannelReady</a></li> @@ -223,19 +246,30 @@ <li><a href="org/apache/gearpump/streaming/appmaster/ClockService.SnapshotStartClock$.html" title="class in org.apache.gearpump.streaming.appmaster">ClockService.SnapshotStartClock$</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in org.apache.gearpump.streaming.appmaster">ClockService.StoredStartClock</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html" title="class in org.apache.gearpump.streaming.appmaster">ClockService.StoredStartClock$</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/ClockServiceSpec.html" title="class in org.apache.gearpump.streaming.appmaster">ClockServiceSpec</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/ClockServiceSpec.Store.html" title="class in org.apache.gearpump.streaming.appmaster">ClockServiceSpec.Store</a></li> <li><a href="org/apache/gearpump/cluster/ClusterConfig.html" title="class in org.apache.gearpump.cluster">ClusterConfig</a></li> <li><a href="org/apache/gearpump/cluster/ClusterConfig.Configs.html" title="class in org.apache.gearpump.cluster">ClusterConfig.Configs</a></li> <li><a href="org/apache/gearpump/cluster/ClusterConfig.ConfigValidationException.html" title="class in org.apache.gearpump.cluster">ClusterConfig.ConfigValidationException</a></li> <li><a href="org/apache/gearpump/cluster/ClusterConfigSource.html" title="interface in org.apache.gearpump.cluster"><span class="interfaceName">ClusterConfigSource</span></a></li> <li><a href="org/apache/gearpump/cluster/ClusterConfigSource.ClusterConfigSourceImpl.html" title="class in org.apache.gearpump.cluster">ClusterConfigSource.ClusterConfigSourceImpl</a></li> <li><a href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl">CollectionDataSource</a></li> -<li><a href="org/apache/gearpump/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.partitioner">CoLocationPartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">CoLocationPartitioner</a></li> <li><a href="org/apache/gearpump/security/ConfigFileBasedAuthenticator.html" title="class in org.apache.gearpump.security">ConfigFileBasedAuthenticator</a></li> +<li><a href="org/apache/gearpump/security/ConfigFileBasedAuthenticatorSpec.html" title="class in org.apache.gearpump.security">ConfigFileBasedAuthenticatorSpec</a></li> +<li><a href="org/apache/gearpump/util/ConfigsSpec.html" title="class in org.apache.gearpump.util">ConfigsSpec</a></li> +<li><a href="org/apache/gearpump/util/ConfigsSpec.Data.html" title="class in org.apache.gearpump.util">ConfigsSpec.Data</a></li> +<li><a href="org/apache/gearpump/util/ConfigsSpec.Data$.html" title="class in org.apache.gearpump.util">ConfigsSpec.Data$</a></li> <li><a href="org/apache/gearpump/util/ConsoleOutput.html" title="interface in org.apache.gearpump.util"><span class="interfaceName">ConsoleOutput</span></a></li> <li><a href="org/apache/gearpump/streaming/Constants.html" title="class in org.apache.gearpump.streaming">Constants</a></li> <li><a href="org/apache/gearpump/util/Constants.html" title="class in org.apache.gearpump.util">Constants</a></li> <li><a href="org/apache/gearpump/transport/netty/Context.html" title="class in org.apache.gearpump.transport.netty">Context</a></li> <li><a href="org/apache/gearpump/metrics/Counter.html" title="class in org.apache.gearpump.metrics">Counter</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">CountTrigger</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" title="class in org.apache.gearpump.streaming.dsl.task">CountTriggerTask</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task">CountTriggerTaskSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.api">CountWindow</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">CountWindowFn</a></li> <li><a href="org/apache/gearpump/streaming/DAG.html" title="class in org.apache.gearpump.streaming">DAG</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/DagManager.html" title="class in org.apache.gearpump.streaming.appmaster">DagManager</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/DagManager.DagInitiated$.html" title="class in org.apache.gearpump.streaming.appmaster">DagManager.DagInitiated$</a></li> @@ -257,20 +291,37 @@ <li><a href="org/apache/gearpump/streaming/appmaster/DagManager.TaskLaunchData$.html" title="class in org.apache.gearpump.streaming.appmaster">DagManager.TaskLaunchData$</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/DagManager.WatchChange.html" title="class in org.apache.gearpump.streaming.appmaster">DagManager.WatchChange</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/DagManager.WatchChange$.html" title="class in org.apache.gearpump.streaming.appmaster">DagManager.WatchChange$</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/DagManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">DagManagerSpec</a></li> +<li><a href="org/apache/gearpump/streaming/DAGSpec.html" title="class in org.apache.gearpump.streaming">DAGSpec</a></li> <li><a href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink"><span class="interfaceName">DataSink</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.op">DataSinkOp</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a></li> <li><a href="org/apache/gearpump/streaming/sink/DataSinkProcessor.html" title="class in org.apache.gearpump.streaming.sink">DataSinkProcessor</a></li> <li><a href="org/apache/gearpump/streaming/sink/DataSinkTask.html" title="class in org.apache.gearpump.streaming.sink">DataSinkTask</a></li> +<li><a href="org/apache/gearpump/streaming/sink/DataSinkTaskSpec.html" title="class in org.apache.gearpump.streaming.sink">DataSinkTaskSpec</a></li> <li><a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source"><span class="interfaceName">DataSource</span></a></li> <li><a href="org/apache/gearpump/streaming/source/DataSourceConfig.html" title="class in org.apache.gearpump.streaming.source">DataSourceConfig</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.op">DataSourceOp</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSourceOp</a></li> <li><a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source">DataSourceProcessor</a></li> <li><a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source">DataSourceTask</a></li> -<li><a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">DefaultMessageDecoder</a></li> +<li><a href="org/apache/gearpump/streaming/source/DataSourceTaskSpec.html" title="class in org.apache.gearpump.streaming.source">DataSourceTaskSpec</a></li> +<li><a href="org/apache/gearpump/cluster/worker/DefaultExecutorProcessLauncher.html" title="class in org.apache.gearpump.cluster.worker">DefaultExecutorProcessLauncher</a></li> +<li><a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">DefaultKafkaMessageDecoder</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.grouper">DefaultPartitionGrouper</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/format/DefaultSequenceFormatter.html" title="class in org.apache.gearpump.streaming.hadoop.lib.format">DefaultSequenceFormatter</a></li> -<li><a href="org/apache/gearpump/streaming/source/DefaultTimeStampFilter.html" title="class in org.apache.gearpump.streaming.source">DefaultTimeStampFilter</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/Direct.html" title="class in org.apache.gearpump.streaming.dsl.op">Direct</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">DefaultWindowRunner</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">DefaultWindowRunner.WindowGroup</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup$.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">DefaultWindowRunner.WindowGroup$</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/Direct.html" title="class in org.apache.gearpump.streaming.dsl.plan">Direct</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/Discarding.html" title="class in org.apache.gearpump.streaming.dsl.window.api">Discarding</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncher.html" title="class in org.apache.gearpump.cluster.appmaster">DummyAppMasterLauncher</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncherFactory.html" title="class in org.apache.gearpump.cluster.appmaster">DummyAppMasterLauncherFactory</a></li> +<li><a href="org/apache/gearpump/util/Echo.html" title="class in org.apache.gearpump.util">Echo</a></li> +<li><a href="org/apache/gearpump/util/EchoActor.html" title="class in org.apache.gearpump.util">EchoActor</a></li> +<li><a href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html" title="class in org.apache.gearpump.cluster.embedded">EmbeddedCluster</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/EmitFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">EmitFunction</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">EventTimeTrigger</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" title="class in org.apache.gearpump.streaming.dsl.task">EventTimeTriggerTask</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task">EventTimeTriggerTaskSpec</a></li> <li><a href="org/apache/gearpump/streaming/executor/Executor.html" title="class in org.apache.gearpump.streaming.executor">Executor</a></li> <li><a href="org/apache/gearpump/streaming/executor/Executor.DagVersionMismatchException.html" title="class in org.apache.gearpump.streaming.executor">Executor.DagVersionMismatchException</a></li> <li><a href="org/apache/gearpump/streaming/executor/Executor.ExecutorConfig.html" title="class in org.apache.gearpump.streaming.executor">Executor.ExecutorConfig</a></li> @@ -309,9 +360,13 @@ <li><a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.StartExecutorsTimeOut$.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorManager.StartExecutorsTimeOut$</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.UniCast.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorManager.UniCast</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.UniCast$.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorManager.UniCast$</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorManagerSpec</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.StartExecutorActorPlease$.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorManagerSpec.StartExecutorActorPlease$</a></li> <li><a href="org/apache/gearpump/cluster/worker/ExecutorProcessLauncher.html" title="interface in org.apache.gearpump.cluster.worker"><span class="interfaceName">ExecutorProcessLauncher</span></a></li> <li><a href="org/apache/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in org.apache.gearpump.streaming.executor">ExecutorRestartPolicy</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/ExecutorRestartPolicySpec.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorRestartPolicySpec</a></li> <li><a href="org/apache/gearpump/cluster/worker/ExecutorSlots.html" title="class in org.apache.gearpump.cluster.worker">ExecutorSlots</a></li> +<li><a href="org/apache/gearpump/streaming/executor/ExecutorSpec.html" title="class in org.apache.gearpump.streaming.executor">ExecutorSpec</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystem</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemLauncher</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemLauncher.LaunchExecutorSystem</a></li> @@ -322,6 +377,7 @@ <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystemSuccess$.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemLauncher.LaunchExecutorSystemSuccess$</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystemTimeout.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemLauncher.LaunchExecutorSystemTimeout</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystemTimeout$.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemLauncher.LaunchExecutorSystemTimeout$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncherSpec.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemLauncherSpec</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.ExecutorSystemJvmConfig.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.ExecutorSystemJvmConfig</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.ExecutorSystemJvmConfig$.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.ExecutorSystemJvmConfig$</a></li> @@ -339,6 +395,10 @@ <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StartExecutorSystemTimeout$.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.StartExecutorSystemTimeout$</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StopExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.StopExecutorSystem</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StopExecutorSystem$.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.StopExecutorSystem$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemSchedulerSpec</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted$.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.MockExecutorSystemLauncher.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemSchedulerSpec.MockExecutorSystemLauncher</a></li> <li><a href="org/apache/gearpump/streaming/ExecutorToAppMaster.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster</a></li> <li><a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a></li> <li><a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss$</a></li> @@ -357,12 +417,24 @@ <li><a href="org/apache/gearpump/serializer/FastKryoSerializer.KryoSerializationException$.html" title="class in org.apache.gearpump.serializer">FastKryoSerializer.KryoSerializationException$</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer">FetchThread</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer">FetchThread.FetchThreadFactory</a></li> +<li><a href="org/apache/gearpump/jarstore/FileDirective.html" title="class in org.apache.gearpump.jarstore">FileDirective</a></li> +<li><a href="org/apache/gearpump/jarstore/FileDirective.FileInfo.html" title="class in org.apache.gearpump.jarstore">FileDirective.FileInfo</a></li> +<li><a href="org/apache/gearpump/jarstore/FileDirective.FileInfo$.html" title="class in org.apache.gearpump.jarstore">FileDirective.FileInfo$</a></li> +<li><a href="org/apache/gearpump/jarstore/FileDirective.Form.html" title="class in org.apache.gearpump.jarstore">FileDirective.Form</a></li> <li><a href="org/apache/gearpump/jarstore/FilePath.html" title="class in org.apache.gearpump.jarstore">FilePath</a></li> +<li><a href="org/apache/gearpump/jarstore/FileServer.html" title="class in org.apache.gearpump.jarstore">FileServer</a></li> +<li><a href="org/apache/gearpump/jarstore/FileServer.Client.html" title="class in org.apache.gearpump.jarstore">FileServer.Client</a></li> +<li><a href="org/apache/gearpump/jarstore/FileServer.Port.html" title="class in org.apache.gearpump.jarstore">FileServer.Port</a></li> +<li><a href="org/apache/gearpump/jarstore/FileServer.Port$.html" title="class in org.apache.gearpump.jarstore">FileServer.Port$</a></li> +<li><a href="org/apache/gearpump/jarstore/FileServerSpec.html" title="class in org.apache.gearpump.jarstore">FileServerSpec</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html" title="class in org.apache.gearpump.streaming.hadoop.lib.rotation">FileSizeRotation</a></li> <li><a href="org/apache/gearpump/util/FileUtils.html" title="class in org.apache.gearpump.util">FileUtils</a></li> +<li><a href="org/apache/gearpump/util/FileUtilsSpec.html" title="class in org.apache.gearpump.util">FileUtilsSpec</a></li> <li><a href="org/apache/gearpump/streaming/javaapi/dsl/functions/FilterFunction.html" title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span class="interfaceName">FilterFunction</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/FixedWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.api">FixedWindow</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">FlatMapFunction</a></li> <li><a href="org/apache/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html" title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span class="interfaceName">FlatMapFunction</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/FlatMapOp.html" title="class in org.apache.gearpump.streaming.dsl.op">FlatMapOp</a></li> +<li><a href="org/apache/gearpump/cluster/main/Gear.html" title="class in org.apache.gearpump.cluster.main">Gear</a></li> <li><a href="org/apache/gearpump/serializer/GearpumpSerialization.html" title="class in org.apache.gearpump.serializer">GearpumpSerialization</a></li> <li><a href="org/apache/gearpump/streaming/task/GetCheckpointClock.html" title="class in org.apache.gearpump.streaming.task">GetCheckpointClock</a></li> <li><a href="org/apache/gearpump/streaming/task/GetDAG.html" title="class in org.apache.gearpump.streaming.task">GetDAG</a></li> @@ -375,17 +447,23 @@ <li><a href="org/apache/gearpump/util/Graph.NodeList.html" title="class in org.apache.gearpump.util">Graph.NodeList</a></li> <li><a href="org/apache/gearpump/util/Graph.Path.html" title="class in org.apache.gearpump.util">Graph.Path</a></li> <li><a href="org/apache/gearpump/util/Graph.Path$.html" title="class in org.apache.gearpump.util">Graph.Path$</a></li> +<li><a href="org/apache/gearpump/util/GraphSpec.html" title="class in org.apache.gearpump.util">GraphSpec</a></li> <li><a href="org/apache/gearpump/streaming/state/api/Group.html" title="interface in org.apache.gearpump.streaming.state.api"><span class="interfaceName">Group</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">GroupAlsoByWindow</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/GroupByFn.html" title="interface in org.apache.gearpump.streaming.dsl.window.api"><span class="interfaceName">GroupByFn</span></a></li> <li><a href="org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html" title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span class="interfaceName">GroupByFunction</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/GroupByOp.html" title="class in org.apache.gearpump.streaming.dsl.op">GroupByOp</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">GroupByOp</a></li> <li><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">GroupByPartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">GroupByPartitionerSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">GroupByPartitionerSpec.People</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People$.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">GroupByPartitionerSpec.People$</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/HadoopCheckpointStore.html" title="class in org.apache.gearpump.streaming.hadoop">HadoopCheckpointStore</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/HadoopCheckpointStoreFactory.html" title="class in org.apache.gearpump.streaming.hadoop">HadoopCheckpointStoreFactory</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/HadoopCheckpointStoreReader.html" title="class in org.apache.gearpump.streaming.hadoop.lib">HadoopCheckpointStoreReader</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/HadoopCheckpointStoreWriter.html" title="class in org.apache.gearpump.streaming.hadoop.lib">HadoopCheckpointStoreWriter</a></li> <li><a href="org/apache/gearpump/util/HadoopFSLogAppender.html" title="class in org.apache.gearpump.util">HadoopFSLogAppender</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/HadoopUtil.html" title="class in org.apache.gearpump.streaming.hadoop.lib">HadoopUtil</a></li> -<li><a href="org/apache/gearpump/partitioner/HashPartitioner.html" title="class in org.apache.gearpump.partitioner">HashPartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/HashPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">HashPartitioner</a></li> <li><a href="org/apache/gearpump/external/hbase/dsl/HBaseDSLSink.html" title="class in org.apache.gearpump.external.hbase.dsl">HBaseDSLSink</a></li> <li><a href="org/apache/gearpump/external/hbase/HBaseSink.html" title="class in org.apache.gearpump.external.hbase">HBaseSink</a></li> <li><a href="org/apache/gearpump/metrics/Histogram.html" title="class in org.apache.gearpump.metrics">Histogram</a></li> @@ -403,13 +481,38 @@ <li><a href="org/apache/gearpump/util/HistoryMetricsService.MetricsStore.html" title="interface in org.apache.gearpump.util"><span class="interfaceName">HistoryMetricsService.MetricsStore</span></a></li> <li><a href="org/apache/gearpump/util/HistoryMetricsService.SingleValueMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.SingleValueMetricsStore</a></li> <li><a href="org/apache/gearpump/util/HistoryMetricsService.SkipAllAggregator.html" title="class in org.apache.gearpump.util">HistoryMetricsService.SkipAllAggregator</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/HistoryMetricsServiceSpec.html" title="class in org.apache.gearpump.streaming.appmaster">HistoryMetricsServiceSpec</a></li> <li><a href="org/apache/gearpump/transport/HostPort.html" title="class in org.apache.gearpump.transport">HostPort</a></li> <li><a href="org/apache/gearpump/transport/netty/IContext.html" title="interface in org.apache.gearpump.transport.netty"><span class="interfaceName">IContext</span></a></li> +<li><a href="org/apache/gearpump/cluster/main/Info.html" title="class in org.apache.gearpump.cluster.main">Info</a></li> <li><a href="org/apache/gearpump/streaming/task/InitialAckRequest.html" title="class in org.apache.gearpump.streaming.task">InitialAckRequest</a></li> <li><a href="org/apache/gearpump/streaming/InitialAckRequestSerializer.html" title="class in org.apache.gearpump.streaming">InitialAckRequestSerializer</a></li> <li><a href="org/apache/gearpump/streaming/storage/InMemoryAppStoreOnMaster.html" title="class in org.apache.gearpump.streaming.storage">InMemoryAppStoreOnMaster</a></li> +<li><a href="org/apache/gearpump/streaming/storage/InMemoryAppStoreOnMasterSpec.html" title="class in org.apache.gearpump.streaming.storage">InMemoryAppStoreOnMasterSpec</a></li> <li><a href="org/apache/gearpump/streaming/state/impl/InMemoryCheckpointStore.html" title="class in org.apache.gearpump.streaming.state.impl">InMemoryCheckpointStore</a></li> <li><a href="org/apache/gearpump/streaming/state/impl/InMemoryCheckpointStoreFactory.html" title="class in org.apache.gearpump.streaming.state.impl">InMemoryCheckpointStoreFactory</a></li> +<li><a href="org/apache/gearpump/streaming/state/impl/InMemoryCheckpointStoreSpec.html" title="class in org.apache.gearpump.streaming.state.impl">InMemoryCheckpointStoreSpec</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.DeleteKVGroup</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.DeleteKVGroup$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKV</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKV$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVFailed</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVFailed$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVResult.html" title="interface in org.apache.gearpump.cluster.master"><span class="interfaceName">InMemoryKVService.GetKVResult</span></a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVSuccess</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVSuccess$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GroupDeleted</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GroupDeleted$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKV.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKV</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKV$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKV$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKVFailed</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKVFailed$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVResult.html" title="interface in org.apache.gearpump.cluster.master"><span class="interfaceName">InMemoryKVService.PutKVResult</span></a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVSuccess$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKVSuccess$</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.Request.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.Request</a></li> +<li><a href="org/apache/gearpump/cluster/master/InMemoryKVService.Request$.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.Request$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/InMemoryKVServiceSpec.html" title="class in org.apache.gearpump.cluster.appmaster">InMemoryKVServiceSpec</a></li> <li><a href="org/apache/gearpump/streaming/state/impl/Interval.html" title="class in org.apache.gearpump.streaming.state.impl">Interval</a></li> <li><a href="org/apache/gearpump/streaming/executor/ITaskLauncher.html" title="interface in org.apache.gearpump.streaming.executor"><span class="interfaceName">ITaskLauncher</span></a></li> <li><a href="org/apache/gearpump/transport/netty/ITransportMessageSerializer.html" title="interface in org.apache.gearpump.transport.netty"><span class="interfaceName">ITransportMessageSerializer</span></a></li> @@ -425,9 +528,13 @@ <li><a href="org/apache/gearpump/streaming/appmaster/JarScheduler.ScheduleTask.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ScheduleTask</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/JarScheduler.ScheduleTask$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ScheduleTask$</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/JarScheduler.TransitToNewDag$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.TransitToNewDag$</a></li> -<li><a href="org/apache/gearpump/jarstore/JarStoreService.html" title="interface in org.apache.gearpump.jarstore"><span class="interfaceName">JarStoreService</span></a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/JarSchedulerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">JarSchedulerSpec</a></li> +<li><a href="org/apache/gearpump/jarstore/JarStore.html" title="interface in org.apache.gearpump.jarstore"><span class="interfaceName">JarStore</span></a></li> +<li><a href="org/apache/gearpump/jarstore/JarStoreClient.html" title="class in org.apache.gearpump.jarstore">JarStoreClient</a></li> +<li><a href="org/apache/gearpump/jarstore/JarStoreServer.html" title="class in org.apache.gearpump.jarstore">JarStoreServer</a></li> <li><a href="org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" title="class in org.apache.gearpump.streaming.dsl.javaapi">JavaStream</a></li> <li><a href="org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.html" title="class in org.apache.gearpump.streaming.dsl.javaapi">JavaStreamApp</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/javaapi/JavaWindowStream.html" title="class in org.apache.gearpump.streaming.dsl.javaapi">JavaWindowStream</a></li> <li><a href="org/apache/gearpump/metrics/JvmMetricsSet.html" title="class in org.apache.gearpump.metrics">JvmMetricsSet</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html" title="class in org.apache.gearpump.streaming.kafka.lib.util">KafkaClient</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.util">KafkaClient.KafkaClientFactory</a></li> @@ -436,31 +543,54 @@ <li><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer">KafkaConsumer</a></li> <li><a href="org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" title="class in org.apache.gearpump.streaming.kafka.dsl">KafkaDSL</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer">KafkaMessage</a></li> +<li><a href="org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html" title="interface in org.apache.gearpump.streaming.kafka.lib"><span class="interfaceName">KafkaMessageDecoder</span></a></li> <li><a href="org/apache/gearpump/streaming/kafka/KafkaSink.html" title="class in org.apache.gearpump.streaming.kafka">KafkaSink</a></li> <li><a href="org/apache/gearpump/streaming/kafka/KafkaSource.html" title="class in org.apache.gearpump.streaming.kafka">KafkaSource</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html" title="class in org.apache.gearpump.streaming.kafka.lib.store">KafkaStore</a></li> <li><a href="org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html" title="class in org.apache.gearpump.streaming.kafka">KafkaStoreFactory</a></li> +<li><a href="org/apache/gearpump/cluster/main/Kill.html" title="class in org.apache.gearpump.cluster.main">Kill</a></li> <li><a href="org/apache/gearpump/streaming/dsl/KVStream.html" title="class in org.apache.gearpump.streaming.dsl">KVStream</a></li> <li><a href="org/apache/gearpump/streaming/task/LatencyProbe.html" title="class in org.apache.gearpump.streaming.task">LatencyProbe</a></li> <li><a href="org/apache/gearpump/streaming/LatencyProbeSerializer.html" title="class in org.apache.gearpump.streaming">LatencyProbeSerializer</a></li> <li><a href="org/apache/gearpump/streaming/task/LatestMinClock.html" title="class in org.apache.gearpump.streaming.task">LatestMinClock</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/LauncherStarted.html" title="class in org.apache.gearpump.cluster.appmaster">LauncherStarted</a></li> <li><a href="org/apache/gearpump/streaming/LifeTime.html" title="class in org.apache.gearpump.streaming">LifeTime</a></li> +<li><a href="org/apache/gearpump/cluster/main/Local.html" title="class in org.apache.gearpump.cluster.main">Local</a></li> +<li><a href="org/apache/gearpump/jarstore/local/LocalJarStore.html" title="class in org.apache.gearpump.jarstore.local">LocalJarStore</a></li> <li><a href="org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl">LoggerSink</a></li> <li><a href="org/apache/gearpump/util/LogUtil.html" title="class in org.apache.gearpump.util">LogUtil</a></li> <li><a href="org/apache/gearpump/util/LogUtil.ProcessType$.html" title="class in org.apache.gearpump.util">LogUtil.ProcessType$</a></li> +<li><a href="org/apache/gearpump/cluster/main/MainRunner.html" title="class in org.apache.gearpump.cluster.main">MainRunner</a></li> +<li><a href="org/apache/gearpump/cluster/main/MainSpec.html" title="class in org.apache.gearpump.cluster.main">MainSpec</a></li> <li><a href="org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html" title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span class="interfaceName">MapFunction</span></a></li> +<li><a href="org/apache/gearpump/cluster/main/Master.html" title="class in org.apache.gearpump.cluster.main">Master</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.html" title="class in org.apache.gearpump.cluster.master">Master</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.MasterInfo.html" title="class in org.apache.gearpump.cluster.master">Master.MasterInfo</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.MasterInfo$.html" title="class in org.apache.gearpump.cluster.master">Master.MasterInfo$</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.MasterListUpdated.html" title="class in org.apache.gearpump.cluster.master">Master.MasterListUpdated</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.MasterListUpdated$.html" title="class in org.apache.gearpump.cluster.master">Master.MasterListUpdated$</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.SlotStatus.html" title="class in org.apache.gearpump.cluster.master">Master.SlotStatus</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.SlotStatus$.html" title="class in org.apache.gearpump.cluster.master">Master.SlotStatus$</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated.html" title="class in org.apache.gearpump.cluster.master">Master.WorkerTerminated</a></li> +<li><a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated$.html" title="class in org.apache.gearpump.cluster.master">Master.WorkerTerminated$</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterActivity.html" title="class in org.apache.gearpump.cluster.master">MasterActivity</a></li> <li><a href="org/apache/gearpump/cluster/client/MasterClient.html" title="class in org.apache.gearpump.cluster.client">MasterClient</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeper</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.AppMasterRegisterTimeout$.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeper.AppMasterRegisterTimeout$</a></li> <li><a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.MasterConnectionStatus$.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeper.MasterConnectionStatus$</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeperSpec</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.ConnectionKeeperTestEnv.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeperSpec.ConnectionKeeperTestEnv</a></li> +<li><a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.ConnectionKeeperTestEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeperSpec.ConnectionKeeperTestEnv$</a></li> +<li><a href="org/apache/gearpump/cluster/MasterHarness.html" title="interface in org.apache.gearpump.cluster"><span class="interfaceName">MasterHarness</span></a></li> +<li><a href="org/apache/gearpump/cluster/MasterHarness.MockMaster.html" title="class in org.apache.gearpump.cluster">MasterHarness.MockMaster</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterNode.html" title="class in org.apache.gearpump.cluster.master">MasterNode</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/MasterOp.html" title="interface in org.apache.gearpump.streaming.dsl.op"><span class="interfaceName">MasterOp</span></a></li> <li><a href="org/apache/gearpump/cluster/master/MasterProxy.html" title="class in org.apache.gearpump.cluster.master">MasterProxy</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterProxy.MasterRestarted$.html" title="class in org.apache.gearpump.cluster.master">MasterProxy.MasterRestarted$</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterProxy.MasterStopped$.html" title="class in org.apache.gearpump.cluster.master">MasterProxy.MasterStopped$</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterProxy.WatchMaster.html" title="class in org.apache.gearpump.cluster.master">MasterProxy.WatchMaster</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterProxy.WatchMaster$.html" title="class in org.apache.gearpump.cluster.master">MasterProxy.WatchMaster$</a></li> +<li><a href="org/apache/gearpump/cluster/master/MasterProxySpec.html" title="class in org.apache.gearpump.cluster.master">MasterProxySpec</a></li> +<li><a href="org/apache/gearpump/cluster/master/MasterSpec.html" title="class in org.apache.gearpump.cluster.master">MasterSpec</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterStatus.html" title="class in org.apache.gearpump.cluster.master">MasterStatus</a></li> <li><a href="org/apache/gearpump/cluster/master/MasterSummary.html" title="class in org.apache.gearpump.cluster.master">MasterSummary</a></li> <li><a href="org/apache/gearpump/cluster/MasterToAppMaster.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster</a></li> @@ -512,12 +642,23 @@ <li><a href="org/apache/gearpump/cluster/MasterToClient.SubmitApplicationResultValue$.html" title="class in org.apache.gearpump.cluster">MasterToClient.SubmitApplicationResultValue$</a></li> <li><a href="org/apache/gearpump/cluster/MasterToClient.WorkerConfig.html" title="class in org.apache.gearpump.cluster">MasterToClient.WorkerConfig</a></li> <li><a href="org/apache/gearpump/cluster/MasterToClient.WorkerConfig$.html" title="class in org.apache.gearpump.cluster">MasterToClient.WorkerConfig$</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.op">MergeOp</a></li> +<li><a href="org/apache/gearpump/cluster/MasterToWorker.html" title="class in org.apache.gearpump.cluster">MasterToWorker</a></li> +<li><a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceFailed.html" title="class in org.apache.gearpump.cluster">MasterToWorker.UpdateResourceFailed</a></li> +<li><a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceFailed$.html" title="class in org.apache.gearpump.cluster">MasterToWorker.UpdateResourceFailed$</a></li> +<li><a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceSucceed$.html" title="class in org.apache.gearpump.cluster">MasterToWorker.UpdateResourceSucceed$</a></li> +<li><a href="org/apache/gearpump/cluster/MasterToWorker.WorkerRegistered.html" title="class in org.apache.gearpump.cluster">MasterToWorker.WorkerRegistered</a></li> +<li><a href="org/apache/gearpump/cluster/MasterToWorker.WorkerRegistered$.html" title="class in org.apache.gearpump.cluster">MasterToWorker.WorkerRegistered$</a></li> +<li><a href="org/apache/gearpump/cluster/main/MasterWatcher.html" title="class in org.apache.gearpump.cluster.main">MasterWatcher</a></li> +<li><a href="org/apache/gearpump/cluster/main/MasterWatcher.Shutdown$.html" title="class in org.apache.gearpump.cluster.main">MasterWatcher.Shutdown$</a></li> +<li><a href="org/apache/gearpump/cluster/main/MasterWatcherSpec.html" title="class in org.apache.gearpump.cluster.main">MasterWatcherSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">MergeOp</a></li> <li><a href="org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a></li> +<li><a href="org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html" title="class in org.apache.gearpump.streaming.kafka.lib">MessageAndWatermark</a></li> <li><a href="org/apache/gearpump/transport/netty/MessageBatch.html" title="class in org.apache.gearpump.transport.netty">MessageBatch</a></li> -<li><a href="org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api"><span class="interfaceName">MessageDecoder</span></a></li> <li><a href="org/apache/gearpump/transport/netty/MessageDecoder.html" title="class in org.apache.gearpump.transport.netty">MessageDecoder</a></li> <li><a href="org/apache/gearpump/transport/netty/MessageEncoder.html" title="class in org.apache.gearpump.transport.netty">MessageEncoder</a></li> +<li><a href="org/apache/gearpump/streaming/MessageSerializerSpec.html" title="class in org.apache.gearpump.streaming">MessageSerializerSpec</a></li> +<li><a href="org/apache/gearpump/util/MessageTimeOut.html" title="class in org.apache.gearpump.util">MessageTimeOut</a></li> <li><a href="org/apache/gearpump/metrics/Meter.html" title="class in org.apache.gearpump.metrics">Meter</a></li> <li><a href="org/apache/gearpump/metrics/Metrics.html" title="class in org.apache.gearpump.metrics">Metrics</a></li> <li><a href="org/apache/gearpump/metrics/Metrics.Counter.html" title="class in org.apache.gearpump.metrics">Metrics.Counter</a></li> @@ -539,41 +680,55 @@ <li><a href="org/apache/gearpump/metrics/MetricsAggregator.html" title="interface in org.apache.gearpump.metrics"><span class="interfaceName">MetricsAggregator</span></a></li> <li><a href="org/apache/gearpump/metrics/MetricsReporterService.html" title="class in org.apache.gearpump.metrics">MetricsReporterService</a></li> <li><a href="org/apache/gearpump/metrics/MetricsReporterService.ReportTo.html" title="interface in org.apache.gearpump.metrics"><span class="interfaceName">MetricsReporterService.ReportTo</span></a></li> +<li><a href="org/apache/gearpump/metrics/MetricsSpec.html" title="class in org.apache.gearpump.metrics">MetricsSpec</a></li> +<li><a href="org/apache/gearpump/cluster/MiniCluster.html" title="class in org.apache.gearpump.cluster">MiniCluster</a></li> +<li><a href="org/apache/gearpump/transport/MockTransportSerializer.html" title="class in org.apache.gearpump.transport">MockTransportSerializer</a></li> +<li><a href="org/apache/gearpump/transport/MockTransportSerializer.NettyMessage.html" title="class in org.apache.gearpump.transport">MockTransportSerializer.NettyMessage</a></li> +<li><a href="org/apache/gearpump/transport/MockTransportSerializer.NettyMessage$.html" title="class in org.apache.gearpump.transport">MockTransportSerializer.NettyMessage$</a></li> +<li><a href="org/apache/gearpump/streaming/MockUtil.html" title="class in org.apache.gearpump.streaming">MockUtil</a></li> <li><a href="org/apache/gearpump/streaming/state/api/Monoid.html" title="interface in org.apache.gearpump.streaming.state.api"><span class="interfaceName">Monoid</span></a></li> <li><a href="org/apache/gearpump/streaming/state/api/MonoidState.html" title="class in org.apache.gearpump.streaming.state.api">MonoidState</a></li> -<li><a href="org/apache/gearpump/partitioner/MulticastPartitioner.html" title="interface in org.apache.gearpump.partitioner"><span class="interfaceName">MulticastPartitioner</span></a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/MulticastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner"><span class="interfaceName">MulticastPartitioner</span></a></li> <li><a href="org/apache/gearpump/transport/netty/NettyConfig.html" title="class in org.apache.gearpump.transport.netty">NettyConfig</a></li> <li><a href="org/apache/gearpump/transport/netty/NettyRenameThreadFactory.html" title="class in org.apache.gearpump.transport.netty">NettyRenameThreadFactory</a></li> +<li><a href="org/apache/gearpump/transport/NettySpec.html" title="class in org.apache.gearpump.transport">NettySpec</a></li> <li><a href="org/apache/gearpump/transport/netty/NettyUtil.html" title="class in org.apache.gearpump.transport.netty">NettyUtil</a></li> <li><a href="org/apache/gearpump/streaming/state/impl/NonWindowState.html" title="class in org.apache.gearpump.streaming.state.impl">NonWindowState</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/Op.html" title="interface in org.apache.gearpump.streaming.dsl.op"><span class="interfaceName">Op</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/OpChain.html" title="class in org.apache.gearpump.streaming.dsl.op">OpChain</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/OpEdge.html" title="interface in org.apache.gearpump.streaming.dsl.op"><span class="interfaceName">OpEdge</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.AndThen</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.DummyInputFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.DummyInputFunction</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.FlatMapFunction</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.GroupByTask.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.GroupByTask</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.ReduceFunction</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.SingleInputFunction.html" title="interface in org.apache.gearpump.streaming.dsl.plan"><span class="interfaceName">OpTranslator.SingleInputFunction</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.SinkTask.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.SinkTask</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.SourceTask.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.SourceTask</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.TransformTask.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpTranslator.TransformTask</a></li> +<li><a href="org/apache/gearpump/streaming/state/impl/NonWindowStateSpec.html" title="class in org.apache.gearpump.streaming.state.impl">NonWindowStateSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan"><span class="interfaceName">Op</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/OpChainException.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpChainException</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/OpEdge.html" title="interface in org.apache.gearpump.streaming.dsl.plan"><span class="interfaceName">OpEdge</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpSpec.AnySink</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnySource.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpSpec.AnySource</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnyTask.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpSpec.AnyTask</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/format/OutputFormatter.html" title="interface in org.apache.gearpump.streaming.hadoop.lib.format"><span class="interfaceName">OutputFormatter</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/ParameterizedOp.html" title="interface in org.apache.gearpump.streaming.dsl.op"><span class="interfaceName">ParameterizedOp</span></a></li> <li><a href="org/apache/gearpump/cluster/main/ParseResult.html" title="class in org.apache.gearpump.cluster.main">ParseResult</a></li> -<li><a href="org/apache/gearpump/partitioner/Partitioner.html" title="interface in org.apache.gearpump.partitioner"><span class="interfaceName">Partitioner</span></a></li> -<li><a href="org/apache/gearpump/partitioner/PartitionerByClassName.html" title="class in org.apache.gearpump.partitioner">PartitionerByClassName</a></li> -<li><a href="org/apache/gearpump/partitioner/PartitionerDescription.html" title="class in org.apache.gearpump.partitioner">PartitionerDescription</a></li> -<li><a href="org/apache/gearpump/partitioner/PartitionerFactory.html" title="interface in org.apache.gearpump.partitioner"><span class="interfaceName">PartitionerFactory</span></a></li> -<li><a href="org/apache/gearpump/partitioner/PartitionerObject.html" title="class in org.apache.gearpump.partitioner">PartitionerObject</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/Partitioner.html" title="interface in org.apache.gearpump.streaming.partitioner"><span class="interfaceName">Partitioner</span></a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/PartitionerByClassName.html" title="class in org.apache.gearpump.streaming.partitioner">PartitionerByClassName</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/PartitionerDescription.html" title="class in org.apache.gearpump.streaming.partitioner">PartitionerDescription</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/PartitionerFactory.html" title="interface in org.apache.gearpump.streaming.partitioner"><span class="interfaceName">PartitionerFactory</span></a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/PartitionerObject.html" title="class in org.apache.gearpump.streaming.partitioner">PartitionerObject</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/PartitionerSpec.html" title="class in org.apache.gearpump.streaming.partitioner">PartitionerSpec</a></li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html" title="interface in org.apache.gearpump.streaming.kafka.lib.source.grouper"><span class="interfaceName">PartitionGrouper</span></a></li> <li><a href="org/apache/gearpump/security/PasswordUtil.html" title="class in org.apache.gearpump.security">PasswordUtil</a></li> +<li><a href="org/apache/gearpump/security/PasswordUtilSpec.html" title="class in org.apache.gearpump.security">PasswordUtilSpec</a></li> <li><a href="org/apache/gearpump/streaming/state/api/PersistentState.html" title="interface in org.apache.gearpump.streaming.state.api"><span class="interfaceName">PersistentState</span></a></li> <li><a href="org/apache/gearpump/streaming/state/impl/PersistentStateConfig.html" title="class in org.apache.gearpump.streaming.state.impl">PersistentStateConfig</a></li> <li><a href="org/apache/gearpump/streaming/state/api/PersistentTask.html" title="class in org.apache.gearpump.streaming.state.api">PersistentTask</a></li> <li><a href="org/apache/gearpump/streaming/dsl/plan/Planner.html" title="class in org.apache.gearpump.streaming.dsl.plan">Planner</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.html" title="class in org.apache.gearpump.streaming.dsl.plan">PlannerSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnyGroupByFn.html" title="class in org.apache.gearpump.streaming.dsl.plan">PlannerSpec.AnyGroupByFn</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan">PlannerSpec.AnySink</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySource.html" title="class in org.apache.gearpump.streaming.dsl.plan">PlannerSpec.AnySource</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnyTask.html" title="class in org.apache.gearpump.streaming.dsl.plan">PlannerSpec.AnyTask</a></li> <li><a href="org/apache/gearpump/cluster/scheduler/Priority.html" title="class in org.apache.gearpump.cluster.scheduler">Priority</a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/PriorityScheduler.html" title="class in org.apache.gearpump.cluster.scheduler">PriorityScheduler</a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/PrioritySchedulerSpec.html" title="class in org.apache.gearpump.cluster.scheduler">PrioritySchedulerSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/ProcessingTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">ProcessingTimeTrigger</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" title="class in org.apache.gearpump.streaming.dsl.task">ProcessingTimeTriggerTask</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.Triggering$.html" title="class in org.apache.gearpump.streaming.dsl.task">ProcessingTimeTriggerTask.Triggering$</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task">ProcessingTimeTriggerTaskSpec</a></li> <li><a href="org/apache/gearpump/util/ProcessLogRedirector.html" title="class in org.apache.gearpump.util">ProcessLogRedirector</a></li> <li><a href="org/apache/gearpump/streaming/javaapi/Processor.html" title="class in org.apache.gearpump.streaming.javaapi">Processor</a></li> <li><a href="org/apache/gearpump/streaming/Processor.html" title="interface in org.apache.gearpump.streaming"><span class="interfaceName">Processor</span></a></li> @@ -585,20 +740,28 @@ <li><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.HistogramAggregator.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.HistogramAggregator</a></li> <li><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.MeterAggregator.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.MeterAggregator</a></li> <li><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.MultiLayerMap.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.MultiLayerMap</a></li> +<li><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregatorSpec.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregatorSpec</a></li> <li><a href="org/apache/gearpump/streaming/ProcessorDescription.html" title="class in org.apache.gearpump.streaming">ProcessorDescription</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.op">ProcessorOp</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">ProcessorOp</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a></li> <li><a href="org/apache/gearpump/util/RecreateRollingFileAppender.html" title="class in org.apache.gearpump.util">RecreateRollingFileAppender</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/impl/ReduceFnRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl"><span class="interfaceName">ReduceFnRunner</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">ReduceFunction</a></li> <li><a href="org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html" title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span class="interfaceName">ReduceFunction</span></a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/ReduceOp.html" title="class in org.apache.gearpump.streaming.dsl.op">ReduceOp</a></li> <li><a href="org/apache/gearpump/util/ReferenceEqual.html" title="interface in org.apache.gearpump.util"><span class="interfaceName">ReferenceEqual</span></a></li> <li><a href="org/apache/gearpump/cluster/scheduler/Relaxation.html" title="class in org.apache.gearpump.cluster.scheduler">Relaxation</a></li> +<li><a href="org/apache/gearpump/cluster/main/Replay.html" title="class in org.apache.gearpump.cluster.main">Replay</a></li> <li><a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a></li> <li><a href="org/apache/gearpump/cluster/scheduler/ResourceAllocation.html" title="class in org.apache.gearpump.cluster.scheduler">ResourceAllocation</a></li> <li><a href="org/apache/gearpump/cluster/scheduler/ResourceRequest.html" title="class in org.apache.gearpump.cluster.scheduler">ResourceRequest</a></li> <li><a href="org/apache/gearpump/util/RestartPolicy.html" title="class in org.apache.gearpump.util">RestartPolicy</a></li> <li><a href="org/apache/gearpump/util/RichProcess.html" title="class in org.apache.gearpump.util">RichProcess</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html" title="interface in org.apache.gearpump.streaming.hadoop.lib.rotation"><span class="interfaceName">Rotation</span></a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/Scheduler.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler</a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler.ApplicationFinished</a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished$.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler.ApplicationFinished$</a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler.PendingRequest</a></li> +<li><a href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest$.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler.PendingRequest$</a></li> <li><a href="org/apache/gearpump/streaming/task/SendMessageLoss.html" title="class in org.apache.gearpump.streaming.task">SendMessageLoss</a></li> <li><a href="org/apache/gearpump/streaming/hadoop/SequenceFileSink.html" title="class in org.apache.gearpump.streaming.hadoop">SequenceFileSink</a></li> <li><a href="org/apache/gearpump/serializer/SerializationFramework.html" title="interface in org.apache.gearpump.serializer"><span class="interfaceName">SerializationFramework</span></a></li> @@ -608,6 +771,11 @@ <li><a href="org/apache/gearpump/streaming/state/api/Serializer.html" title="interface in org.apache.gearpump.streaming.state.api"><span class="interfaceName">Serializer</span></a></li> <li><a href="org/apache/gearpump/streaming/task/SerializerResolver.html" title="class in org.apache.gearpump.streaming.task">SerializerResolver</a></li> <li><a href="org/apache/gearpump/streaming/task/SerializerResolver.Registration.html" title="class in org.apache.gearpump.streaming.task">SerializerResolver.Registration</a></li> +<li><a href="org/apache/gearpump/serializer/SerializerSpec.html" title="class in org.apache.gearpump.serializer">SerializerSpec</a></li> +<li><a href="org/apache/gearpump/serializer/SerializerSpec.ClassA.html" title="class in org.apache.gearpump.serializer">SerializerSpec.ClassA</a></li> +<li><a href="org/apache/gearpump/serializer/SerializerSpec.ClassASerializer.html" title="class in org.apache.gearpump.serializer">SerializerSpec.ClassASerializer</a></li> +<li><a href="org/apache/gearpump/serializer/SerializerSpec.ClassB.html" title="class in org.apache.gearpump.serializer">SerializerSpec.ClassB</a></li> +<li><a href="org/apache/gearpump/serializer/SerializerSpec.ClassBSerializer.html" title="class in org.apache.gearpump.serializer">SerializerSpec.ClassBSerializer</a></li> <li><a href="org/apache/gearpump/transport/netty/Server.html" title="class in org.apache.gearpump.transport.netty">Server</a></li> <li><a href="org/apache/gearpump/transport/netty/Server.AddChannel.html" title="class in org.apache.gearpump.transport.netty">Server.AddChannel</a></li> <li><a href="org/apache/gearpump/transport/netty/Server.AddChannel$.html" title="class in org.apache.gearpump.transport.netty">Server.AddChannel$</a></li> @@ -618,12 +786,14 @@ <li><a href="org/apache/gearpump/transport/netty/Server.ServerHandler.html" title="class in org.apache.gearpump.transport.netty">Server.ServerHandler</a></li> <li><a href="org/apache/gearpump/transport/netty/Server.ServerPipelineFactory.html" title="class in org.apache.gearpump.transport.netty">Server.ServerPipelineFactory</a></li> <li><a href="org/apache/gearpump/transport/netty/Server.TaskIdActorRefTranslation.html" title="class in org.apache.gearpump.transport.netty">Server.TaskIdActorRefTranslation</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/Shuffle.html" title="class in org.apache.gearpump.streaming.dsl.op">Shuffle</a></li> -<li><a href="org/apache/gearpump/partitioner/ShuffleGroupingPartitioner.html" title="class in org.apache.gearpump.partitioner">ShuffleGroupingPartitioner</a></li> -<li><a href="org/apache/gearpump/partitioner/ShufflePartitioner.html" title="class in org.apache.gearpump.partitioner">ShufflePartitioner</a></li> -<li><a href="org/apache/gearpump/streaming/dsl/op/SlaveOp.html" title="interface in org.apache.gearpump.streaming.dsl.op"><span class="interfaceName">SlaveOp</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/Shuffle.html" title="class in org.apache.gearpump.streaming.dsl.plan">Shuffle</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">ShuffleGroupingPartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/partitioner/ShufflePartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">ShufflePartitioner</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunction.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions"><span class="interfaceName">SingleInputFunction</span></a></li> +<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunctionSpec.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">SingleInputFunctionSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.api">SlidingWindow</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">SlidingWindowFn</a></li> <li><a href="org/apache/gearpump/streaming/task/StartClock.html" title="class in org.apache.gearpump.streaming.task">StartClock</a></li> -<li><a href="org/apache/gearpump/streaming/task/StartTime.html" title="class in org.apache.gearpump.streaming.task">StartTime</a></li> <li><a href="org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a></li> <li><a href="org/apache/gearpump/streaming/dsl/Stream.Sink.html" title="class in org.apache.gearpump.streaming.dsl">Stream.Sink</a></li> <li><a href="org/apache/gearpump/streaming/dsl/StreamApp.html" title="class in org.apache.gearpump.streaming.dsl">StreamApp</a></li> @@ -631,12 +801,20 @@ <li><a href="org/apache/gearpump/streaming/javaapi/StreamApplication.html" title="class in org.apache.gearpump.streaming.javaapi">StreamApplication</a></li> <li><a href="org/apache/gearpump/streaming/StreamApplication.html" title="class in org.apache.gearpump.streaming">StreamApplication</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/StreamAppSpec.html" title="class in org.apache.gearpump.streaming.dsl">StreamAppSpec</a></li> +<li><a href="org/apache/gearpump/streaming/StreamingTestUtil.html" title="class in org.apache.gearpump.streaming">StreamingTestUtil</a></li> <li><a href="org/apache/gearpump/streaming/task/StreamingTransportSerializer.html" title="class in org.apache.gearpump.streaming.task">StreamingTransportSerializer</a></li> -<li><a href="org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">StringMessageDecoder</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/StreamSpec.html" title="class in org.apache.gearpump.streaming.dsl">StreamSpec</a></li> +<li><a href="org/apache/gearpump/streaming/dsl/StreamSpec.Join.html" title="class in org.apache.gearpump.streaming.dsl">StreamSpec.Join</a></li> <li><a href="org/apache/gearpump/streaming/task/Subscriber.html" title="class in org.apache.gearpump.streaming.task">Subscriber</a></li> +<li><a href="org/apache/gearpump/streaming/task/SubscriberSpec.html" title="class in org.apache.gearpump.streaming.task">SubscriberSpec</a></li> +<li><a href="org/apache/gearpump/streaming/task/SubscriberSpec.TestTask.html" title="class in org.apache.gearpump.streaming.task">SubscriberSpec.TestTask</a></li> <li><a href="org/apache/gearpump/streaming/task/Subscription.html" title="class in org.apache.gearpump.streaming.task">Subscription</a></li> +<li><a href="org/apache/gearpump/streaming/task/SubscriptionSpec.html" title="class in org.apache.gearpump.streaming.task">SubscriptionSpec</a></li> +<li><a href="org/apache/gearpump/streaming/task/SubscriptionSpec.NextTask.html" title="class in org.apache.gearpump.streaming.task">SubscriptionSpec.NextTask</a></li> <li><a href="org/apache/gearpump/streaming/javaapi/Task.html" title="class in org.apache.gearpump.streaming.javaapi">Task</a></li> <li><a href="org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task">Task</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/TaskA.html" title="class in org.apache.gearpump.streaming.appmaster">TaskA</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskActor.html" title="class in org.apache.gearpump.streaming.task">TaskActor</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskActor.FLUSH$.html" title="class in org.apache.gearpump.streaming.task">TaskActor.FLUSH$</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskActor.MessageAndSender.html" title="class in org.apache.gearpump.streaming.task">TaskActor.MessageAndSender</a></li> @@ -644,18 +822,26 @@ <li><a href="org/apache/gearpump/streaming/task/TaskActor.SecurityChecker.html" title="class in org.apache.gearpump.streaming.task">TaskActor.SecurityChecker</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskActor.SendAck.html" title="class in org.apache.gearpump.streaming.task">TaskActor.SendAck</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskActor.SendAck$.html" title="class in org.apache.gearpump.streaming.task">TaskActor.SendAck$</a></li> +<li><a href="org/apache/gearpump/streaming/task/TaskActorSpec.html" title="class in org.apache.gearpump.streaming.task">TaskActorSpec</a></li> +<li><a href="org/apache/gearpump/streaming/task/TaskActorSpec.TestTask.html" title="class in org.apache.gearpump.streaming.task">TaskActorSpec.TestTask</a></li> +<li><a href="org/apache/gearpump/streaming/executor/TaskArgumentStoreSpec.html" title="class in org.apache.gearpump.streaming.executor">TaskArgumentStoreSpec</a></li> +<li><a href="org/apache/gearpump/streaming/appmaster/TaskB.html" title="class in org.apache.gearpump.streaming.appmaster">TaskB</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task"><span class="interfaceName">TaskContext</span></a></li> <li><a href="org/apache/gearpump/streaming/task/TaskContextData.html" title="class in org.apache.gearpump.streaming.task">TaskContextData</a></li> <li><a href="org/apache/gearpump/streaming/appmaster/TaskCount.html" title="class in org.apache.gearpump.streaming.appmaster">TaskCount</a></li> <li><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregator</a></li> <li><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.Options.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregator.Options</a></li> <li><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.Options$.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregator.Options$</a></li> +<li><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregatorSpec.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregatorSpec</a></li> <li><a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a></li> <li><a href="org/apache/gearpump/streaming/TaskIdSerializer.html" title="class in org.apache.gearpump.streaming">TaskIdSerializer</a></li> <li><a href="org/apache/gearpump/strea
<TRUNCATED>
