http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/allclasses-frame.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/allclasses-frame.html
b/content/releases/latest/api/java/allclasses-frame.html
index 8476b25..93c315b 100644
--- a/content/releases/latest/api/java/allclasses-frame.html
+++ b/content/releases/latest/api/java/allclasses-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:22 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 -->
<title>All Classes</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -59,11 +59,23 @@
<li><a href="org/apache/gearpump/cluster/Application.html" title="interface in
org.apache.gearpump.cluster" target="classFrame"><span
class="interfaceName">Application</span></a></li>
<li><a href="org/apache/gearpump/cluster/Application.DefaultApplication.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">Application.DefaultApplication</a></li>
<li><a href="org/apache/gearpump/cluster/ApplicationMaster.html" title="class
in org.apache.gearpump.cluster" target="classFrame">ApplicationMaster</a></li>
-<li><a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">ApplicationState</a></li>
-<li><a href="org/apache/gearpump/cluster/master/ApplicationStateSpec.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">ApplicationStateSpec</a></li>
+<li><a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">ApplicationMetaData</a></li>
+<li><a href="org/apache/gearpump/cluster/master/ApplicationMetaDataSpec.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">ApplicationMetaDataSpec</a></li>
+<li><a
href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">ApplicationRuntimeInfo</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class
in org.apache.gearpump.cluster" target="classFrame">ApplicationStatus</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.ACTIVE$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatus.ACTIVE$</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.FAILED$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatus.FAILED$</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.NONEXIST$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatus.NONEXIST$</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.PENDING$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatus.PENDING$</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.SUCCEEDED$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatus.SUCCEEDED$</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatus.TERMINATED$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatus.TERMINATED$</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationStatusSpec.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationStatusSpec</a></li>
+<li><a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ApplicationTerminalStatus</a></li>
<li><a href="org/apache/gearpump/cluster/master/AppManager.html" title="class
in org.apache.gearpump.cluster.master" target="classFrame">AppManager</a></li>
<li><a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">AppManager.MasterState</a></li>
<li><a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">AppManager.MasterState$</a></li>
+<li><a
href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">AppManager.RecoverApplication</a></li>
+<li><a
href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication$.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">AppManager.RecoverApplication$</a></li>
<li><a href="org/apache/gearpump/cluster/appmaster/AppManagerSpec.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppManagerSpec</a></li>
<li><a href="org/apache/gearpump/streaming/appmaster/AppMaster.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">AppMaster</a></li>
<li><a
href="org/apache/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">AppMaster.AllocateResourceTimeOut$</a></li>
@@ -78,7 +90,6 @@
<li><a href="org/apache/gearpump/cluster/master/AppMasterLauncher.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">AppMasterLauncher</a></li>
<li><a href="org/apache/gearpump/cluster/master/AppMasterLauncherFactory.html"
title="interface in org.apache.gearpump.cluster.master"
target="classFrame"><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"
target="classFrame">AppMasterLauncherSpec</a></li>
-<li><a href="org/apache/gearpump/cluster/AppMasterRegisterData.html"
title="interface in org.apache.gearpump.cluster" target="classFrame"><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"
target="classFrame">AppMasterRuntimeEnvironment</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.LazyStartAppMaster.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppMasterRuntimeEnvironment.LazyStartAppMaster</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.LazyStartAppMaster$.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppMasterRuntimeEnvironment.LazyStartAppMaster$</a></li>
@@ -88,7 +99,6 @@
<li><a
href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppMasterRuntimeEnvironmentSpec</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</a></li>
-<li><a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">AppMasterRuntimeInfo</a></li>
<li><a href="org/apache/gearpump/streaming/appmaster/AppMasterSpec.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">AppMasterSpec</a></li>
<li><a
href="org/apache/gearpump/streaming/appmaster/AppMasterSpec.TaskStarted$.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">AppMasterSpec.TaskStarted$</a></li>
<li><a href="org/apache/gearpump/streaming/AppMasterToExecutor.html"
title="class in org.apache.gearpump.streaming"
target="classFrame">AppMasterToExecutor</a></li>
@@ -125,9 +135,9 @@
<li><a
href="org/apache/gearpump/streaming/AppMasterToExecutor.TasksLaunched$.html"
title="class in org.apache.gearpump.streaming"
target="classFrame">AppMasterToExecutor.TasksLaunched$</a></li>
<li><a href="org/apache/gearpump/cluster/AppMasterToMaster.html" title="class
in org.apache.gearpump.cluster" target="classFrame">AppMasterToMaster</a></li>
<li><a href="org/apache/gearpump/streaming/AppMasterToMaster.html"
title="class in org.apache.gearpump.streaming"
target="classFrame">AppMasterToMaster</a></li>
-<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.ActivateAppMaster</a></li>
-<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.ActivateAppMaster$</a></li>
<li><a href="org/apache/gearpump/cluster/AppMasterToMaster.AppDataSaved$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.AppDataSaved$</a></li>
+<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.ApplicationStatusChanged</a></li>
+<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.ApplicationStatusChanged$</a></li>
<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.AppMasterSummary.html"
title="interface in org.apache.gearpump.cluster" target="classFrame"><span
class="interfaceName">AppMasterToMaster.AppMasterSummary</span></a></li>
<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.GeneralAppMasterSummary</a></li>
<li><a
href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">AppMasterToMaster.GeneralAppMasterSummary$</a></li>
@@ -169,7 +179,6 @@
<li><a href="org/apache/gearpump/security/Authenticator.html" title="interface
in org.apache.gearpump.security" target="classFrame"><span
class="interfaceName">Authenticator</span></a></li>
<li><a
href="org/apache/gearpump/security/Authenticator.AuthenticationResult.html"
title="interface in org.apache.gearpump.security" target="classFrame"><span
class="interfaceName">Authenticator.AuthenticationResult</span></a></li>
<li><a
href="org/apache/gearpump/streaming/partitioner/BroadcastPartitioner.html"
title="class in org.apache.gearpump.streaming.partitioner"
target="classFrame">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"
target="classFrame">Bucket</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html"
title="class in org.apache.gearpump.streaming.dsl.plan"
target="classFrame">ChainableOp</a></li>
<li><a href="org/apache/gearpump/streaming/task/CheckpointClock.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">CheckpointClock</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/CheckpointManager.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">CheckpointManager</a></li>
@@ -212,6 +221,8 @@
<li><a
href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.QueryWorkerConfig</a></li>
<li><a
href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.QueryWorkerConfig$</a></li>
<li><a href="org/apache/gearpump/cluster/ClientToMaster.ReadOption$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.ReadOption$</a></li>
+<li><a
href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.RegisterAppResultListener</a></li>
+<li><a
href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.RegisterAppResultListener$</a></li>
<li><a href="org/apache/gearpump/cluster/ClientToMaster.RemoveMaster.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.RemoveMaster</a></li>
<li><a href="org/apache/gearpump/cluster/ClientToMaster.RemoveMaster$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.RemoveMaster$</a></li>
<li><a href="org/apache/gearpump/cluster/ClientToMaster.RemoveWorker.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClientToMaster.RemoveWorker</a></li>
@@ -253,7 +264,7 @@
<li><a
href="org/apache/gearpump/cluster/ClusterConfig.ConfigValidationException.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClusterConfig.ConfigValidationException</a></li>
<li><a href="org/apache/gearpump/cluster/ClusterConfigSource.html"
title="interface in org.apache.gearpump.cluster" target="classFrame"><span
class="interfaceName">ClusterConfigSource</span></a></li>
<li><a
href="org/apache/gearpump/cluster/ClusterConfigSource.ClusterConfigSourceImpl.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">ClusterConfigSource.ClusterConfigSourceImpl</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html"
title="class in org.apache.gearpump.streaming.dsl"
target="classFrame">CollectionDataSource</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/scalaapi/CollectionDataSource.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">CollectionDataSource</a></li>
<li><a
href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html"
title="class in org.apache.gearpump.streaming.partitioner"
target="classFrame">CoLocationPartitioner</a></li>
<li><a href="org/apache/gearpump/security/ConfigFileBasedAuthenticator.html"
title="class in org.apache.gearpump.security"
target="classFrame">ConfigFileBasedAuthenticator</a></li>
<li><a
href="org/apache/gearpump/security/ConfigFileBasedAuthenticatorSpec.html"
title="class in org.apache.gearpump.security"
target="classFrame">ConfigFileBasedAuthenticatorSpec</a></li>
@@ -268,8 +279,8 @@
<li><a href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">CountTrigger</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">CountTriggerTask</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTaskSpec.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">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"
target="classFrame">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"
target="classFrame">CountWindowFn</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">CountWindowFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindows.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">CountWindows</a></li>
<li><a href="org/apache/gearpump/streaming/DAG.html" title="class in
org.apache.gearpump.streaming" target="classFrame">DAG</a></li>
<li><a href="org/apache/gearpump/streaming/appmaster/DagManager.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">DagManager</a></li>
<li><a
href="org/apache/gearpump/streaming/appmaster/DagManager.DagInitiated$.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">DagManager.DagInitiated$</a></li>
@@ -309,8 +320,6 @@
<li><a
href="org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html"
title="class in org.apache.gearpump.streaming.kafka.lib.source.grouper"
target="classFrame">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"
target="classFrame">DefaultSequenceFormatter</a></li>
<li><a
href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html"
title="class in org.apache.gearpump.streaming.dsl.window.impl"
target="classFrame">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"
target="classFrame">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"
target="classFrame">DefaultWindowRunner.WindowGroup$</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/Direct.html" title="class
in org.apache.gearpump.streaming.dsl.plan" target="classFrame">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"
target="classFrame">Discarding</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncher.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">DummyAppMasterLauncher</a></li>
@@ -318,7 +327,8 @@
<li><a href="org/apache/gearpump/util/Echo.html" title="class in
org.apache.gearpump.util" target="classFrame">Echo</a></li>
<li><a href="org/apache/gearpump/util/EchoActor.html" title="class in
org.apache.gearpump.util" target="classFrame">EchoActor</a></li>
<li><a href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html"
title="class in org.apache.gearpump.cluster.embedded"
target="classFrame">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"
target="classFrame">EmitFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html"
title="class in org.apache.gearpump.streaming.dsl.plan.functions"
target="classFrame">Emit</a></li>
+<li><a href="org/apache/gearpump/streaming/task/EndingClock.html" title="class
in org.apache.gearpump.streaming.task" target="classFrame">EndingClock</a></li>
<li><a
href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">EventTimeTrigger</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">EventTimeTriggerTask</a></li>
<li><a
href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTaskSpec.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">EventTimeTriggerTaskSpec</a></li>
@@ -363,8 +373,6 @@
<li><a href="org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">ExecutorManagerSpec</a></li>
<li><a
href="org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.StartExecutorActorPlease$.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">ExecutorManagerSpec.StartExecutorActorPlease$</a></li>
<li><a href="org/apache/gearpump/cluster/worker/ExecutorProcessLauncher.html"
title="interface in org.apache.gearpump.cluster.worker"
target="classFrame"><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"
target="classFrame">ExecutorRestartPolicy</a></li>
-<li><a
href="org/apache/gearpump/streaming/appmaster/ExecutorRestartPolicySpec.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">ExecutorRestartPolicySpec</a></li>
<li><a href="org/apache/gearpump/cluster/worker/ExecutorSlots.html"
title="class in org.apache.gearpump.cluster.worker"
target="classFrame">ExecutorSlots</a></li>
<li><a href="org/apache/gearpump/streaming/executor/ExecutorSpec.html"
title="class in org.apache.gearpump.streaming.executor"
target="classFrame">ExecutorSpec</a></li>
<li><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">ExecutorSystem</a></li>
@@ -430,10 +438,15 @@
<li><a
href="org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html"
title="class in org.apache.gearpump.streaming.hadoop.lib.rotation"
target="classFrame">FileSizeRotation</a></li>
<li><a href="org/apache/gearpump/util/FileUtils.html" title="class in
org.apache.gearpump.util" target="classFrame">FileUtils</a></li>
<li><a href="org/apache/gearpump/util/FileUtilsSpec.html" title="class in
org.apache.gearpump.util" target="classFrame">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"
target="classFrame"><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"
target="classFrame">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"
target="classFrame">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"
target="classFrame"><span class="interfaceName">FlatMapFunction</span></a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/api/functions/FilterFunction.html"
title="class in org.apache.gearpump.streaming.dsl.api.functions"
target="classFrame">FilterFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/api/FixedWindows.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">FixedWindows</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/javaapi/functions/FlatMapFunction.html"
title="class in org.apache.gearpump.streaming.dsl.javaapi.functions"
target="classFrame">FlatMapFunction</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/scalaapi/functions/FlatMapFunction.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions"
target="classFrame">FlatMapFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html"
title="class in org.apache.gearpump.streaming.dsl.plan.functions"
target="classFrame">FlatMapper</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html"
title="class in org.apache.gearpump.streaming.dsl.api.functions"
target="classFrame">FoldFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html"
title="class in org.apache.gearpump.streaming.dsl.plan.functions"
target="classFrame">FoldRunner</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html"
title="interface in org.apache.gearpump.streaming.dsl.plan.functions"
target="classFrame"><span class="interfaceName">FunctionRunner</span></a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunnerSpec.html"
title="class in org.apache.gearpump.streaming.dsl.plan.functions"
target="classFrame">FunctionRunnerSpec</a></li>
<li><a href="org/apache/gearpump/cluster/main/Gear.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">Gear</a></li>
<li><a href="org/apache/gearpump/serializer/GearpumpSerialization.html"
title="class in org.apache.gearpump.serializer"
target="classFrame">GearpumpSerialization</a></li>
<li><a href="org/apache/gearpump/streaming/task/GetCheckpointClock.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">GetCheckpointClock</a></li>
@@ -450,8 +463,7 @@
<li><a href="org/apache/gearpump/util/GraphSpec.html" title="class in
org.apache.gearpump.util" target="classFrame">GraphSpec</a></li>
<li><a href="org/apache/gearpump/streaming/state/api/Group.html"
title="interface in org.apache.gearpump.streaming.state.api"
target="classFrame"><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"
target="classFrame">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"
target="classFrame"><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"
target="classFrame"><span class="interfaceName">GroupByFunction</span></a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html"
title="class in org.apache.gearpump.streaming.dsl.javaapi.functions"
target="classFrame">GroupByFunction</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html"
title="class in org.apache.gearpump.streaming.dsl.plan"
target="classFrame">GroupByOp</a></li>
<li><a
href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html"
title="class in org.apache.gearpump.streaming.dsl.partitioner"
target="classFrame">GroupByPartitioner</a></li>
<li><a
href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.html"
title="class in org.apache.gearpump.streaming.dsl.partitioner"
target="classFrame">GroupByPartitionerSpec</a></li>
@@ -549,7 +561,7 @@
<li><a href="org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html"
title="class in org.apache.gearpump.streaming.kafka.lib.store"
target="classFrame">KafkaStore</a></li>
<li><a href="org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html"
title="class in org.apache.gearpump.streaming.kafka"
target="classFrame">KafkaStoreFactory</a></li>
<li><a href="org/apache/gearpump/cluster/main/Kill.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">Kill</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/KVStream.html" title="class in
org.apache.gearpump.streaming.dsl" target="classFrame">KVStream</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/KVStream.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">KVStream</a></li>
<li><a href="org/apache/gearpump/streaming/task/LatencyProbe.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">LatencyProbe</a></li>
<li><a href="org/apache/gearpump/streaming/LatencyProbeSerializer.html"
title="class in org.apache.gearpump.streaming"
target="classFrame">LatencyProbeSerializer</a></li>
<li><a href="org/apache/gearpump/streaming/task/LatestMinClock.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">LatestMinClock</a></li>
@@ -557,12 +569,12 @@
<li><a href="org/apache/gearpump/streaming/LifeTime.html" title="class in
org.apache.gearpump.streaming" target="classFrame">LifeTime</a></li>
<li><a href="org/apache/gearpump/cluster/main/Local.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">Local</a></li>
<li><a href="org/apache/gearpump/jarstore/local/LocalJarStore.html"
title="class in org.apache.gearpump.jarstore.local"
target="classFrame">LocalJarStore</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class
in org.apache.gearpump.streaming.dsl" target="classFrame">LoggerSink</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/LoggerSink.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">LoggerSink</a></li>
<li><a href="org/apache/gearpump/util/LogUtil.html" title="class in
org.apache.gearpump.util" target="classFrame">LogUtil</a></li>
<li><a href="org/apache/gearpump/util/LogUtil.ProcessType$.html" title="class
in org.apache.gearpump.util" target="classFrame">LogUtil.ProcessType$</a></li>
<li><a href="org/apache/gearpump/cluster/main/MainRunner.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">MainRunner</a></li>
<li><a href="org/apache/gearpump/cluster/main/MainSpec.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">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"
target="classFrame"><span class="interfaceName">MapFunction</span></a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/api/functions/MapFunction.html"
title="class in org.apache.gearpump.streaming.dsl.api.functions"
target="classFrame">MapFunction</a></li>
<li><a href="org/apache/gearpump/cluster/main/Master.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">Master</a></li>
<li><a href="org/apache/gearpump/cluster/master/Master.html" title="class in
org.apache.gearpump.cluster.master" target="classFrame">Master</a></li>
<li><a href="org/apache/gearpump/cluster/master/Master.MasterInfo.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">Master.MasterInfo</a></li>
@@ -574,7 +586,6 @@
<li><a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">Master.WorkerTerminated</a></li>
<li><a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated$.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">Master.WorkerTerminated$</a></li>
<li><a href="org/apache/gearpump/cluster/master/MasterActivity.html"
title="class in org.apache.gearpump.cluster.master"
target="classFrame">MasterActivity</a></li>
-<li><a href="org/apache/gearpump/cluster/client/MasterClient.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">MasterClient</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">MasterConnectionKeeper</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.AppMasterRegisterTimeout$.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">MasterConnectionKeeper.AppMasterRegisterTimeout$</a></li>
<li><a
href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.MasterConnectionStatus$.html"
title="class in org.apache.gearpump.cluster.appmaster"
target="classFrame">MasterConnectionKeeper.MasterConnectionStatus$</a></li>
@@ -618,6 +629,11 @@
<li><a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToAppMaster.WorkerList</a></li>
<li><a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToAppMaster.WorkerList$</a></li>
<li><a href="org/apache/gearpump/cluster/MasterToClient.html" title="class in
org.apache.gearpump.cluster" target="classFrame">MasterToClient</a></li>
+<li><a
href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.ApplicationFailed</a></li>
+<li><a
href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.ApplicationFailed$</a></li>
+<li><a
href="org/apache/gearpump/cluster/MasterToClient.ApplicationResult.html"
title="interface in org.apache.gearpump.cluster" target="classFrame"><span
class="interfaceName">MasterToClient.ApplicationResult</span></a></li>
+<li><a
href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.ApplicationSucceeded</a></li>
+<li><a
href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.ApplicationSucceeded$</a></li>
<li><a href="org/apache/gearpump/cluster/MasterToClient.AppMasterConfig.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.AppMasterConfig</a></li>
<li><a href="org/apache/gearpump/cluster/MasterToClient.AppMasterConfig$.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.AppMasterConfig$</a></li>
<li><a href="org/apache/gearpump/cluster/MasterToClient.HistoryMetrics.html"
title="class in org.apache.gearpump.cluster"
target="classFrame">MasterToClient.HistoryMetrics</a></li>
@@ -693,6 +709,7 @@
<li><a
href="org/apache/gearpump/transport/netty/NettyRenameThreadFactory.html"
title="class in org.apache.gearpump.transport.netty"
target="classFrame">NettyRenameThreadFactory</a></li>
<li><a href="org/apache/gearpump/transport/NettySpec.html" title="class in
org.apache.gearpump.transport" target="classFrame">NettySpec</a></li>
<li><a href="org/apache/gearpump/transport/netty/NettyUtil.html" title="class
in org.apache.gearpump.transport.netty" target="classFrame">NettyUtil</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">NonMergingWindowFunction</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/NonWindowState.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">NonWindowState</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/NonWindowStateSpec.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">NonWindowStateSpec</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface
in org.apache.gearpump.streaming.dsl.plan" target="classFrame"><span
class="interfaceName">Op</span></a></li>
@@ -718,7 +735,6 @@
<li><a href="org/apache/gearpump/streaming/state/api/PersistentTask.html"
title="class in org.apache.gearpump.streaming.state.api"
target="classFrame">PersistentTask</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/Planner.html" title="class
in org.apache.gearpump.streaming.dsl.plan" target="classFrame">Planner</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.html"
title="class in org.apache.gearpump.streaming.dsl.plan"
target="classFrame">PlannerSpec</a></li>
-<li><a
href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnyGroupByFn.html"
title="class in org.apache.gearpump.streaming.dsl.plan"
target="classFrame">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"
target="classFrame">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"
target="classFrame">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"
target="classFrame">PlannerSpec.AnyTask</a></li>
@@ -746,8 +762,7 @@
<li><a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">ProcessorSummary</a></li>
<li><a href="org/apache/gearpump/util/RecreateRollingFileAppender.html"
title="class in org.apache.gearpump.util"
target="classFrame">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"
target="classFrame"><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"
target="classFrame">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"
target="classFrame"><span class="interfaceName">ReduceFunction</span></a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html"
title="class in org.apache.gearpump.streaming.dsl.api.functions"
target="classFrame">ReduceFunction</a></li>
<li><a href="org/apache/gearpump/util/ReferenceEqual.html" title="interface in
org.apache.gearpump.util" target="classFrame"><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"
target="classFrame">Relaxation</a></li>
<li><a href="org/apache/gearpump/cluster/main/Replay.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">Replay</a></li>
@@ -755,8 +770,15 @@
<li><a href="org/apache/gearpump/cluster/scheduler/ResourceAllocation.html"
title="class in org.apache.gearpump.cluster.scheduler"
target="classFrame">ResourceAllocation</a></li>
<li><a href="org/apache/gearpump/cluster/scheduler/ResourceRequest.html"
title="class in org.apache.gearpump.cluster.scheduler"
target="classFrame">ResourceRequest</a></li>
<li><a href="org/apache/gearpump/util/RestartPolicy.html" title="class in
org.apache.gearpump.util" target="classFrame">RestartPolicy</a></li>
+<li><a href="org/apache/gearpump/util/RestartPolicySpec.html" title="class in
org.apache.gearpump.util" target="classFrame">RestartPolicySpec</a></li>
<li><a href="org/apache/gearpump/util/RichProcess.html" title="class in
org.apache.gearpump.util" target="classFrame">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"
target="classFrame"><span class="interfaceName">Rotation</span></a></li>
+<li><a href="org/apache/gearpump/cluster/client/RunningApplication.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">RunningApplication</a></li>
+<li><a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">RunningApplicationSpec</a></li>
+<li><a
href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">RunningApplicationSpec.MockAskAppMasterRequest</a></li>
+<li><a
href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest$.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">RunningApplicationSpec.MockAskAppMasterRequest$</a></li>
+<li><a
href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">RunningApplicationSpec.MockAskAppMasterResponse</a></li>
+<li><a
href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse$.html"
title="class in org.apache.gearpump.cluster.client"
target="classFrame">RunningApplicationSpec.MockAskAppMasterResponse$</a></li>
<li><a href="org/apache/gearpump/cluster/scheduler/Scheduler.html"
title="class in org.apache.gearpump.cluster.scheduler"
target="classFrame">Scheduler</a></li>
<li><a
href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished.html"
title="class in org.apache.gearpump.cluster.scheduler"
target="classFrame">Scheduler.ApplicationFinished</a></li>
<li><a
href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished$.html"
title="class in org.apache.gearpump.cluster.scheduler"
target="classFrame">Scheduler.ApplicationFinished$</a></li>
@@ -764,6 +786,7 @@
<li><a
href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest$.html"
title="class in org.apache.gearpump.cluster.scheduler"
target="classFrame">Scheduler.PendingRequest$</a></li>
<li><a href="org/apache/gearpump/streaming/task/SendMessageLoss.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">SendMessageLoss</a></li>
<li><a href="org/apache/gearpump/streaming/hadoop/SequenceFileSink.html"
title="class in org.apache.gearpump.streaming.hadoop"
target="classFrame">SequenceFileSink</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions"
target="classFrame">SerializableFunction</a></li>
<li><a href="org/apache/gearpump/serializer/SerializationFramework.html"
title="interface in org.apache.gearpump.serializer" target="classFrame"><span
class="interfaceName">SerializationFramework</span></a></li>
<li><a href="org/apache/gearpump/streaming/task/SerializedMessage.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">SerializedMessage</a></li>
<li><a
href="org/apache/gearpump/streaming/task/SerializedMessageSerializer.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">SerializedMessageSerializer</a></li>
@@ -786,26 +809,26 @@
<li><a href="org/apache/gearpump/transport/netty/Server.ServerHandler.html"
title="class in org.apache.gearpump.transport.netty"
target="classFrame">Server.ServerHandler</a></li>
<li><a
href="org/apache/gearpump/transport/netty/Server.ServerPipelineFactory.html"
title="class in org.apache.gearpump.transport.netty"
target="classFrame">Server.ServerPipelineFactory</a></li>
<li><a
href="org/apache/gearpump/transport/netty/Server.TaskIdActorRefTranslation.html"
title="class in org.apache.gearpump.transport.netty"
target="classFrame">Server.TaskIdActorRefTranslation</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">SessionWindowFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindows.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">SessionWindows</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/Shuffle.html" title="class
in org.apache.gearpump.streaming.dsl.plan" target="classFrame">Shuffle</a></li>
<li><a
href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html"
title="class in org.apache.gearpump.streaming.partitioner"
target="classFrame">ShuffleGroupingPartitioner</a></li>
<li><a
href="org/apache/gearpump/streaming/partitioner/ShufflePartitioner.html"
title="class in org.apache.gearpump.streaming.partitioner"
target="classFrame">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"
target="classFrame"><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"
target="classFrame">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"
target="classFrame">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"
target="classFrame">SlidingWindowFn</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">SlidingWindowFunction</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindows.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">SlidingWindows</a></li>
<li><a href="org/apache/gearpump/streaming/task/StartClock.html" title="class
in org.apache.gearpump.streaming.task" target="classFrame">StartClock</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/Stream.html" title="class in
org.apache.gearpump.streaming.dsl" target="classFrame">Stream</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/Stream.Sink.html" title="class
in org.apache.gearpump.streaming.dsl" target="classFrame">Stream.Sink</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/StreamApp.html" title="class in
org.apache.gearpump.streaming.dsl" target="classFrame">StreamApp</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/StreamApp.Source.html"
title="class in org.apache.gearpump.streaming.dsl"
target="classFrame">StreamApp.Source</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">Stream</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.Sink.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">Stream.Sink</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">StreamApp</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.Source.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">StreamApp.Source</a></li>
<li><a href="org/apache/gearpump/streaming/javaapi/StreamApplication.html"
title="class in org.apache.gearpump.streaming.javaapi"
target="classFrame">StreamApplication</a></li>
<li><a href="org/apache/gearpump/streaming/StreamApplication.html"
title="class in org.apache.gearpump.streaming"
target="classFrame">StreamApplication</a></li>
<li><a
href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html"
title="class in org.apache.gearpump.streaming.appmaster"
target="classFrame">StreamAppMasterSummary</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/StreamAppSpec.html"
title="class in org.apache.gearpump.streaming.dsl"
target="classFrame">StreamAppSpec</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamAppSpec.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">StreamAppSpec</a></li>
<li><a href="org/apache/gearpump/streaming/StreamingTestUtil.html"
title="class in org.apache.gearpump.streaming"
target="classFrame">StreamingTestUtil</a></li>
<li><a
href="org/apache/gearpump/streaming/task/StreamingTransportSerializer.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">StreamingTransportSerializer</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/StreamSpec.html" title="class
in org.apache.gearpump.streaming.dsl" target="classFrame">StreamSpec</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/StreamSpec.Join.html"
title="class in org.apache.gearpump.streaming.dsl"
target="classFrame">StreamSpec.Join</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamSpec.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">StreamSpec</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamSpec.Join.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">StreamSpec.Join</a></li>
<li><a href="org/apache/gearpump/streaming/task/Subscriber.html" title="class
in org.apache.gearpump.streaming.task" target="classFrame">Subscriber</a></li>
<li><a href="org/apache/gearpump/streaming/task/SubscriberSpec.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">SubscriberSpec</a></li>
<li><a href="org/apache/gearpump/streaming/task/SubscriberSpec.TestTask.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">SubscriberSpec.TestTask</a></li>
@@ -906,6 +929,9 @@
<li><a
href="org/apache/gearpump/streaming/transaction/api/TimeReplayableSource.html"
title="interface in org.apache.gearpump.streaming.transaction.api"
target="classFrame"><span
class="interfaceName">TimeReplayableSource</span></a></li>
<li><a
href="org/apache/gearpump/streaming/transaction/api/TimeStampFilter.html"
title="interface in org.apache.gearpump.streaming.transaction.api"
target="classFrame"><span class="interfaceName">TimeStampFilter</span></a></li>
<li><a href="org/apache/gearpump/streaming/dsl/task/TransformTask.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">TransformTask</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/task/TransformTask.Transform.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">TransformTask.Transform</a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/task/TransformTask.Transform$.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">TransformTask.Transform$</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/task/TransformTaskSpec.html"
title="class in org.apache.gearpump.streaming.dsl.task"
target="classFrame">TransformTaskSpec</a></li>
<li><a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html"
title="interface in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame"><span class="interfaceName">Trigger</span></a></li>
<li><a
href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html"
title="interface in org.apache.gearpump.streaming.partitioner"
target="classFrame"><span
class="interfaceName">UnicastPartitioner</span></a></li>
<li><a href="org/apache/gearpump/streaming/task/UpdateCheckpointClock.html"
title="class in org.apache.gearpump.streaming.task"
target="classFrame">UpdateCheckpointClock</a></li>
@@ -919,15 +945,17 @@
<li><a href="org/apache/gearpump/util/Util.JvmSetting$.html" title="class in
org.apache.gearpump.util" target="classFrame">Util.JvmSetting$</a></li>
<li><a href="org/apache/gearpump/util/UtilSpec.html" title="class in
org.apache.gearpump.util" target="classFrame">UtilSpec</a></li>
<li><a href="org/apache/gearpump/streaming/source/Watermark.html" title="class
in org.apache.gearpump.streaming.source" target="classFrame">Watermark</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/window/api/Window.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">Window</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/impl/Window.html"
title="class in org.apache.gearpump.streaming.dsl.window.impl"
target="classFrame">Window</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/Window.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">Window</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/WindowConfig.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">WindowConfig</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/window/api/WindowFn.html"
title="interface in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame"><span class="interfaceName">WindowFn</span></a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html"
title="interface in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame"><span class="interfaceName">WindowFunction</span></a></li>
+<li><a
href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.Context.html"
title="interface in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame"><span
class="interfaceName">WindowFunction.Context</span></a></li>
<li><a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html"
title="interface in org.apache.gearpump.streaming.dsl.window.impl"
target="classFrame"><span class="interfaceName">WindowRunner</span></a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html"
title="class in org.apache.gearpump.streaming.dsl.window.api"
target="classFrame">Windows</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/WindowSpec.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">WindowSpec</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/WindowState.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">WindowState</a></li>
<li><a href="org/apache/gearpump/streaming/state/impl/WindowStateSpec.html"
title="class in org.apache.gearpump.streaming.state.impl"
target="classFrame">WindowStateSpec</a></li>
-<li><a href="org/apache/gearpump/streaming/dsl/WindowStream.html" title="class
in org.apache.gearpump.streaming.dsl" target="classFrame">WindowStream</a></li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/WindowStream.html"
title="class in org.apache.gearpump.streaming.dsl.scalaapi"
target="classFrame">WindowStream</a></li>
<li><a href="org/apache/gearpump/cluster/main/Worker.html" title="class in
org.apache.gearpump.cluster.main" target="classFrame">Worker</a></li>
<li><a href="org/apache/gearpump/cluster/worker/Worker.html" title="class in
org.apache.gearpump.cluster.worker" target="classFrame">Worker</a></li>
<li><a href="org/apache/gearpump/cluster/worker/Worker.ExecutorHandler.html"
title="interface in org.apache.gearpump.cluster.worker"
target="classFrame"><span
class="interfaceName">Worker.ExecutorHandler</span></a></li>
