http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/serialized-form.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/serialized-form.html
b/content/releases/latest/api/java/serialized-form.html
index 60fed1f..fd28395 100644
--- a/content/releases/latest/api/java/serialized-form.html
+++ b/content/releases/latest/api/java/serialized-form.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 -->
+<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:29 CEST 2017 -->
<title>Serialized Form</title>
-<meta name="date" content="2017-04-25">
+<meta name="date" content="2017-07-09">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -76,15 +76,15 @@
<li class="blockList">
<h2 title="Package">Package org.apache.gearpump</h2>
<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.Message">
+<li class="blockList"><a name="org.apache.gearpump.DefaultMessage">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/Message.html" title="class in
org.apache.gearpump">org.apache.gearpump.Message</a> extends java.lang.Object
implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/DefaultMessage.html" title="class in
org.apache.gearpump">org.apache.gearpump.DefaultMessage</a> extends
java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.Message:D">
+<li class="blockList"><a name="org.apache.gearpump.DefaultMessage:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.Message$ extends java.lang.Object implements
Serializable</h3>
+<h3>Class org.apache.gearpump.DefaultMessage$ extends
scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,<a
href="org/apache/gearpump/DefaultMessage.html" title="class in
org.apache.gearpump">DefaultMessage</a>> implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -421,15 +421,10 @@
</a>
<h3>Class <a
href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure$.html"
title="class in
org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.GetLastFailure$</a>
extends scala.runtime.AbstractFunction1<java.lang.Object,<a
href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure.html"
title="class in
org.apache.gearpump.cluster">ClientToMaster.GetLastFailure</a>> implements
Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.cluster.ClientToMaster.GetStallingTasks">
-<!-- -->
-</a>
-<h3>Class <a
href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html"
title="class in
org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.GetStallingTasks</a>
extends java.lang.Object implements Serializable</h3>
-</li>
<li class="blockList"><a
name="org.apache.gearpump.cluster.ClientToMaster.GetStallingTasks:D">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html"
title="class in
org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.GetStallingTasks$</a>
extends scala.runtime.AbstractFunction1<java.lang.Object,<a
href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html"
title="class in
org.apache.gearpump.cluster">ClientToMaster.GetStallingTasks</a>> implements
Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html"
title="class in
org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.GetStallingTasks$</a>
extends java.lang.Object implements Serializable</h3>
</li>
<li class="blockList"><a
name="org.apache.gearpump.cluster.ClientToMaster.JarStoreServerAddress">
<!-- -->
@@ -2379,6 +2374,11 @@
</a>
<h3>Class <a
href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html"
title="class in
org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.ClockService.StoredStartClock$</a>
extends scala.runtime.AbstractFunction1<java.lang.Object,<a
href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock.html"
title="class in
org.apache.gearpump.streaming.appmaster">ClockService.StoredStartClock</a>>
implements Serializable</h3>
</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.appmaster.ClockService:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dappmaster:DClockService:D:DremoveProcessor:D2:D:Danonfun:D5">
+<!-- -->
+</a>
+<h3>Class
org.apache.gearpump.streaming.appmaster.ClockService$$anonfun$org$apache$gearpump$streaming$appmaster$ClockService$$removeProcessor$2$$anonfun$5
extends java.lang.Object implements Serializable</h3>
+</li>
<li class="blockList"><a
name="org.apache.gearpump.streaming.appmaster.ClockService:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dappmaster:DClockService:D:DupdateCheckpointClocks:D2:D:Danonfun:Dapply:D1">
<!-- -->
</a>
@@ -2898,49 +2898,8 @@
</ul>
</li>
<li class="blockList">
-<h2
title="Package">Package org.apache.gearpump.streaming.dsl.partitioner</h2>
-<ul class="blockList">
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner">
-<!-- -->
-</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html"
title="class in
org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner</a>
extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People">
-<!-- -->
-</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html"
title="class in
org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People</a>
extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People:D">
-<!-- -->
-</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People$.html"
title="class in
org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People$</a>
extends
scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,<a
href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html"
title="class in
org.apache.gearpump.streaming.dsl.partitioner">GroupByPartitionerSpec.People</a>>
implements Serializable</h3>
-</li>
-</ul>
-</li>
-<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.streaming.dsl.plan</h2>
<ul class="blockList">
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.ChainableOp">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html"
title="class in
org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.ChainableOp</a>
extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.ChainableOp:D">
-<!-- -->
-</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.ChainableOp$ extends
java.lang.Object implements Serializable</h3>
-<ul class="blockList">
-<li class="blockList">
-<h3>Serialization Methods</h3>
-<ul class="blockList">
-<li class="blockListLast">
-<h4>readResolve</h4>
-<pre>private java.lang.Object readResolve()</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp">
<!-- -->
</a>
@@ -2949,7 +2908,7 @@
<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.DataSinkOp$ extends
scala.runtime.AbstractFunction4<<a
href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in
org.apache.gearpump.streaming.sink">DataSink</a>,java.lang.Object,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,java.lang.String,<a
href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a>> implements
Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.DataSinkOp$ extends
scala.runtime.AbstractFunction4<<a
href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in
org.apache.gearpump.streaming.sink">DataSink</a>,java.lang.Object,java.lang.String,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,<a
href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a>> implements
Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2970,7 +2929,7 @@
<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.DataSourceOp$ extends
scala.runtime.AbstractFunction4<<a
href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in
org.apache.gearpump.streaming.source">DataSource</a>,java.lang.Object,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,java.lang.String,<a
href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">DataSourceOp</a>> implements
Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.DataSourceOp$ extends
scala.runtime.AbstractFunction4<<a
href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in
org.apache.gearpump.streaming.source">DataSource</a>,java.lang.Object,java.lang.String,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,<a
href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">DataSourceOp</a>> implements
Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3033,7 +2992,7 @@
<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.MergeOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.MergeOp$ extends
scala.runtime.AbstractFunction2<java.lang.String,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,<a
href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">MergeOp</a>> implements
Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.MergeOp$ extends
scala.runtime.AbstractFunction3<java.lang.Object,java.lang.String,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,<a
href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">MergeOp</a>> implements
Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3113,20 +3072,57 @@
</li>
</ul>
</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.TransformOp">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/TransformOp.html"
title="class in
org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.TransformOp</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.TransformOp:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.TransformOp$ extends
java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
</ul>
</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html"
title="class in
org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp$
extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
<li class="blockList">
-<h2
title="Package">Package org.apache.gearpump.streaming.dsl.plan.functions</h2>
+<h3>Serialization Methods</h3>
<ul class="blockList">
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.WindowOp">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.AndThen</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/WindowOp.html"
title="class in
org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.WindowOp</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.WindowOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.AndThen$ extends
java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.WindowOp$ extends
scala.runtime.AbstractFunction2<<a
href="org/apache/gearpump/streaming/dsl/window/api/Windows.html" title="class
in org.apache.gearpump.streaming.dsl.window.api">Windows</a>,<a
href="org/apache/gearpump/cluster/UserConfig.html" title="class in
org.apache.gearpump.cluster">UserConfig</a>,<a
href="org/apache/gearpump/streaming/dsl/plan/WindowOp.html" title="class in
org.apache.gearpump.streaming.dsl.plan">WindowOp</a>> implements
Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3139,25 +3135,41 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.Emit">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.WindowTransformOp">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.Emit</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html"
title="class in
org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.WindowTransformOp</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.WindowTransformOp:D">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.WindowTransformOp$ extends
java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner">
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2
title="Package">Package org.apache.gearpump.streaming.dsl.plan.functions</h2>
+<ul class="blockList">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.AndThen</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.AndThen$ extends
java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3170,6 +3182,21 @@
</li>
</ul>
</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.DummyRunner">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/DummyRunner.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.DummyRunner</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html"
title="class in
org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner</a>
extends java.lang.Object implements Serializable</h3>
+</li>
</ul>
</li>
<li class="blockList">
@@ -3229,16 +3256,6 @@
</ul>
</li>
<li class="blockList">
-<h2 title="Package">Package org.apache.gearpump.streaming.dsl.task</h2>
-<ul class="blockList">
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask.Triggering:D">
-<!-- -->
-</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.Triggering$.html"
title="class in
org.apache.gearpump.streaming.dsl.task">org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask.Triggering$</a>
extends java.lang.Object implements Serializable</h3>
-</li>
-</ul>
-</li>
-<li class="blockList">
<h2
title="Package">Package org.apache.gearpump.streaming.dsl.window.api</h2>
<ul class="blockList">
<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Accumulating">
@@ -3262,15 +3279,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.CountTrigger">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Discarding">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountTrigger</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/Discarding.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Discarding</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.CountTrigger:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Discarding:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountTrigger$ extends
java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.Discarding$ extends
java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3283,15 +3300,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction</a>
extends <a
href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a><<a
href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html"
title="type parameter in CountWindowFunction">T</a>> implements
Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger$
extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3304,15 +3321,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Discarding">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.GlobalWindowFunction">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/Discarding.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Discarding</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.GlobalWindowFunction</a>
extends <a
href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a>
implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Discarding:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.GlobalWindowFunction:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.Discarding$ extends
java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.GlobalWindowFunction$
extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3323,17 +3340,26 @@
</li>
</ul>
</li>
+<li class="blockList">
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>globalWindow</h4>
+<pre><a href="org/apache/gearpump/streaming/dsl/window/impl/Window.html"
title="class in org.apache.gearpump.streaming.dsl.window.impl">Window</a>[]
globalWindow</pre>
+</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger">
+</ul>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction$
extends scala.runtime.AbstractFunction1<java.time.Duration,<a
href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">SessionWindowFunction</a>>
implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3346,15 +3372,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/ProcessingTimeTrigger.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction</a>
extends <a
href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a>
implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction$
extends
scala.runtime.AbstractFunction2<java.time.Duration,java.time.Duration,<a
href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">SlidingWindowFunction</a>>
implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3367,15 +3393,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Windows">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Windows</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Windows:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.Windows$ extends
scala.runtime.AbstractFunction4<<a
href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html"
title="interface in
org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a>,<a
href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html"
title="interface in
org.apache.gearpump.streaming.dsl.window.api">Trigger</a>,<a
href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html"
title="interface in
org.apache.gearpump.streaming.dsl.window.api">AccumulationMode</a>,java.lang.String,<a
href="org/apache/gearpump/streaming/dsl/window/api/Windows.html" title="class
in org.apache.gearpump.streaming.dsl.window.api">Windows</a>> implements
Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3388,15 +3414,20 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction">
+</ul>
+</li>
+<li class="blockList">
+<h2
title="Package">Package org.apache.gearpump.streaming.dsl.window.impl</h2>
+<ul class="blockList">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.AndThen">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction</a>
extends <a
href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a><<a
href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html"
title="type parameter in SlidingWindowFunction">T</a>> implements
Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/AndThen.html"
title="class in
org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.AndThen</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.AndThen:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.impl.AndThen$ extends
java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3409,15 +3440,25 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Windows">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html"
title="class in
org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Windows</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html"
title="class in
org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.api.Windows:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner:D:Danon:D3:D:Danonfun:Dvalue:D1">
+<!-- -->
+</a>
+<h3>Class
org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner$$anon$3$$anonfun$value$1
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.TimestampedValue">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.Windows$ extends
java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/impl/TimestampedValue.html"
title="class in
org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.TimestampedValue</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.TimestampedValue:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.window.impl.TimestampedValue$
extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3430,20 +3471,15 @@
</li>
</ul>
</li>
-</ul>
-</li>
-<li class="blockList">
-<h2
title="Package">Package org.apache.gearpump.streaming.dsl.window.impl</h2>
-<ul class="blockList">
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.TriggeredOutputs">
<!-- -->
</a>
-<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html"
title="class in
org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow</a>
extends java.lang.Object implements Serializable</h3>
+<h3>Class <a
href="org/apache/gearpump/streaming/dsl/window/impl/TriggeredOutputs.html"
title="class in
org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.TriggeredOutputs</a>
extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow:D">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.dsl.window.impl.TriggeredOutputs:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow$
extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.impl.TriggeredOutputs$
extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -3771,6 +3807,21 @@
</a>
<h3>Class <a
href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html"
title="class in
org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.CoLocationPartitioner</a>
extends java.lang.Object implements Serializable</h3>
</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.partitioner.GroupByPartitioner">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html"
title="class in
org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.GroupByPartitioner</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.partitioner.GroupByPartitionerSpec.People">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People.html"
title="class in
org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.GroupByPartitionerSpec.People</a>
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.streaming.partitioner.GroupByPartitionerSpec.People:D">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People$.html"
title="class in
org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.GroupByPartitionerSpec.People$</a>
extends
scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,<a
href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People.html"
title="class in
org.apache.gearpump.streaming.partitioner">GroupByPartitionerSpec.People</a>>
implements Serializable</h3>
+</li>
<li class="blockList"><a
name="org.apache.gearpump.streaming.partitioner.HashPartitioner">
<!-- -->
</a>
@@ -3850,6 +3901,11 @@
<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.streaming.source</h2>
<ul class="blockList">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.source.DataSourceProcessor.PerElementWindowFunction:D">
+<!-- -->
+</a>
+<h3>Class <a
href="org/apache/gearpump/streaming/source/DataSourceProcessor.PerElementWindowFunction$.html"
title="class in
org.apache.gearpump.streaming.source">org.apache.gearpump.streaming.source.DataSourceProcessor.PerElementWindowFunction$</a>
extends java.lang.Object implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.streaming.source.Watermark">
<!-- -->
</a>
@@ -4314,10 +4370,10 @@
</a>
<h3>Class <a href="org/apache/gearpump/streaming/task/TaskActor.SendAck$.html"
title="class in
org.apache.gearpump.streaming.task">org.apache.gearpump.streaming.task.TaskActor.SendAck$</a>
extends scala.runtime.AbstractFunction2<<a
href="org/apache/gearpump/streaming/task/Ack.html" title="class in
org.apache.gearpump.streaming.task">Ack</a>,<a
href="org/apache/gearpump/streaming/task/TaskId.html" title="class in
org.apache.gearpump.streaming.task">TaskId</a>,<a
href="org/apache/gearpump/streaming/task/TaskActor.SendAck.html" title="class
in org.apache.gearpump.streaming.task">TaskActor.SendAck</a>> implements
Serializable</h3>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.streaming.task.TaskActor:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dtask:DTaskActor:D:DonStartClock:D4:D:Danonfun:Dapply:D1">
+<li class="blockList"><a
name="org.apache.gearpump.streaming.task.TaskActor:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dtask:DTaskActor:D:DonStartTask:D4:D:Danonfun:Dapply:D2">
<!-- -->
</a>
-<h3>Class
org.apache.gearpump.streaming.task.TaskActor$$anonfun$org$apache$gearpump$streaming$task$TaskActor$$onStartClock$4$$anonfun$apply$1
extends java.lang.Object implements Serializable</h3>
+<h3>Class
org.apache.gearpump.streaming.task.TaskActor$$anonfun$org$apache$gearpump$streaming$task$TaskActor$$onStartTask$4$$anonfun$apply$2
extends java.lang.Object implements Serializable</h3>
</li>
<li class="blockList"><a
name="org.apache.gearpump.streaming.task.TaskContextData">
<!-- -->
@@ -4664,10 +4720,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a
name="org.apache.gearpump.util.Graph:D:Danonfun:DgetAcyclicCopy:D2:D:Danonfun:Dapply:D4:D:Danonfun:Dapply:D5:D:Danonfun:Dapply:D6">
+<li class="blockList"><a
name="org.apache.gearpump.util.Graph:D:Danonfun:DgetAcyclicCopy:D2:D:Danonfun:Dapply:D4:D:Danonfun:Dapply:D5:D:Danonfun:Dapply:D6:D:Danonfun:Dapply:D8">
+<!-- -->
+</a>
+<h3>Class
org.apache.gearpump.util.Graph$$anonfun$getAcyclicCopy$2$$anonfun$apply$4$$anonfun$apply$5$$anonfun$apply$6$$anonfun$apply$8
extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a
name="org.apache.gearpump.util.Graph:D:Danonfun:DgetAcyclicCopy:D2:D:Danonfun:Dapply:D4:D:Danonfun:Dapply:D5:D:Danonfun:Dapply:D6:D:Danonfun:Dapply:D9">
<!-- -->
</a>
-<h3>Class
org.apache.gearpump.util.Graph$$anonfun$getAcyclicCopy$2$$anonfun$apply$4$$anonfun$apply$5$$anonfun$apply$6
extends java.lang.Object implements Serializable</h3>
+<h3>Class
org.apache.gearpump.util.Graph$$anonfun$getAcyclicCopy$2$$anonfun$apply$4$$anonfun$apply$5$$anonfun$apply$6$$anonfun$apply$9
extends java.lang.Object implements Serializable</h3>
</li>
<li class="blockList"><a name="org.apache.gearpump.util.GraphSpec.Edge">
<!-- -->