You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2017/04/26 03:08:30 UTC
[28/51] [partial] incubator-gearpump-site git commit: [GEARPUMP-299]
Update gearpump.apache.org page for 0.8.3 release
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-summary.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-summary.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-summary.html
index 90850b4..9fe4a51 100644
--- a/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-summary.html
+++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-summary.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
<title>org.apache.gearpump.streaming.appmaster</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>
@@ -43,7 +43,7 @@
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/gearpump/streaming/package-summary.html">Prev Package</a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/package-summary.html">Next Package</a></li>
+<li><a href="../../../../../org/apache/gearpump/streaming/dsl/api/functions/package-summary.html">Next Package</a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/gearpump/streaming/appmaster/package-summary.html" target="_top">Frames</a></li>
@@ -409,310 +409,306 @@
<td class="colLast"> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/ExecutorRestartPolicySpec.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorRestartPolicySpec</a></td>
-<td class="colLast"> </td>
-</tr>
-<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/HistoryMetricsServiceSpec.html" title="class in org.apache.gearpump.streaming.appmaster">HistoryMetricsServiceSpec</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler</a></td>
<td class="colLast">
<div class="block">Different processors of the stream application can use different jars.</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.ExecutorFailed.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ExecutorFailed</a></td>
<td class="colLast">
<div class="block">Some executor JVM is dead, try to recover tasks that are located on failed executor</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.ExecutorFailed$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ExecutorFailed$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.GetResourceRequestDetails$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.GetResourceRequestDetails$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.JarSchedulerImpl.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.JarSchedulerImpl</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.NewDag.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.NewDag</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.NewDag$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.NewDag$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.ResourceRequestDetail.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ResourceRequestDetail</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.ResourceRequestDetail$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ResourceRequestDetail$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.ScheduleTask.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ScheduleTask</a></td>
<td class="colLast">
<div class="block">Schedule tasks for one appJar.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.ScheduleTask$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.ScheduleTask$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.TransitToNewDag$.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler.TransitToNewDag$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/JarSchedulerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">JarSchedulerSpec</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a></td>
<td class="colLast">
<div class="block">Stream application summary, used for REST API</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskA.html" title="class in org.apache.gearpump.streaming.appmaster">TaskA</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskB.html" title="class in org.apache.gearpump.streaming.appmaster">TaskB</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskCount.html" title="class in org.apache.gearpump.streaming.appmaster">TaskCount</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocator.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocator</a></td>
<td class="colLast">
<div class="block">TaskLocator is used to decide which machine one task should run on.</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocator.Localities.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocator.Localities</a></td>
<td class="colLast">
<div class="block">Localities settings.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocator.Localities$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocator.Localities$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocator.NonLocality$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocator.NonLocality$</a></td>
<td class="colLast">
<div class="block">Means no preference on worker</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocator.WorkerLocality.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocator.WorkerLocality</a></td>
<td class="colLast">
<div class="block">Means we require the resource from the specific worker</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocator.WorkerLocality$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocator.WorkerLocality$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocatorSpec.html" title="class in org.apache.gearpump.streaming.appmaster">TaskLocatorSpec</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager</a></td>
<td class="colLast">
<div class="block">TaskManager track all tasks's status.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.ApplicationReady$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.ApplicationReady$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.ChangeTasksOnExecutor.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.ChangeTasksOnExecutor</a></td>
<td class="colLast">
<div class="block">Changes existing tasks on executor executorId</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.ChangeTasksOnExecutor$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.ChangeTasksOnExecutor$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.DAGDiff.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.DAGDiff</a></td>
<td class="colLast">
<div class="block">DAGDiff is used to track impacted processors when doing dynamic dag.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.DAGDiff$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.DAGDiff$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.DagReadyState.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.DagReadyState</a></td>
<td class="colLast">
<div class="block">When application is ready, then transit to DagReadyState</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.DagReadyState$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.DagReadyState$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.ExecutorRegistry.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.ExecutorRegistry</a></td>
<td class="colLast">
<div class="block">Tracks the registration of all new started executors.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.FailedToRecover.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.FailedToRecover</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.FailedToRecover$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.FailedToRecover$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.GetTaskList$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.GetTaskList$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.SessionIdFactory.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.SessionIdFactory</a></td>
<td class="colLast">
<div class="block">Each new task will be assigned with a unique session Id.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.StartDagState.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.StartDagState</a></td>
<td class="colLast">
<div class="block">When application is booting up or doing recovery, it use StartDagState</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.StartDagState$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.StartDagState$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.StartTasksOnExecutor.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.StartTasksOnExecutor</a></td>
<td class="colLast">
<div class="block">Starts new Tasks on Executor executorId</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.StartTasksOnExecutor$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.StartTasksOnExecutor$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.TaskChangeRegistry.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.TaskChangeRegistry</a></td>
<td class="colLast">
<div class="block">Tracks the registration of all changed tasks.</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.TaskChangeRegistry$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.TaskChangeRegistry$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.TaskList.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.TaskList</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManager.TaskList$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.TaskList$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManagerSpec</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Env.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManagerSpec.Env</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Env$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManagerSpec.Env$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Task1.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManagerSpec.Task1</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Task2.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManagerSpec.Task2</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry</a></td>
<td class="colLast">
<div class="block">Tracks the registration of all tasks, when the application is booting up.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.Accept$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.Accept$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.Reject$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.Reject$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.TaskLocation.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.TaskLocation</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.TaskLocation$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.TaskLocation$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.TaskLocations.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.TaskLocations</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistry.TaskLocations$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.TaskLocations$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistrySpec.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistrySpec</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskScheduler.Location.html" title="class in org.apache.gearpump.streaming.appmaster">TaskScheduler.Location</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskScheduler.Location$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskScheduler.Location$</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html" title="class in org.apache.gearpump.streaming.appmaster">TaskScheduler.TaskStatus</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskSchedulerImpl.html" title="class in org.apache.gearpump.streaming.appmaster">TaskSchedulerImpl</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskSchedulerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">TaskSchedulerSpec</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskSchedulerSpec.TestTask1.html" title="class in org.apache.gearpump.streaming.appmaster">TaskSchedulerSpec.TestTask1</a></td>
<td class="colLast"> </td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskSchedulerSpec.TestTask2.html" title="class in org.apache.gearpump.streaming.appmaster">TaskSchedulerSpec.TestTask2</a></td>
<td class="colLast"> </td>
</tr>
@@ -757,7 +753,7 @@
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/gearpump/streaming/package-summary.html">Prev Package</a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/package-summary.html">Next Package</a></li>
+<li><a href="../../../../../org/apache/gearpump/streaming/dsl/api/functions/package-summary.html">Next Package</a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/gearpump/streaming/appmaster/package-summary.html" target="_top">Frames</a></li>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-tree.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-tree.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-tree.html
index 8bfdc7b..ceb2b9d 100644
--- a/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-tree.html
+++ b/content/releases/latest/api/java/org/apache/gearpump/streaming/appmaster/package-tree.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
<title>org.apache.gearpump.streaming.appmaster Class Hierarchy</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>
@@ -43,7 +43,7 @@
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/gearpump/streaming/package-tree.html">Prev</a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/package-tree.html">Next</a></li>
+<li><a href="../../../../../org/apache/gearpump/streaming/dsl/api/functions/package-tree.html">Next</a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/gearpump/streaming/appmaster/package-tree.html" target="_top">Frames</a></li>
@@ -187,27 +187,27 @@
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.StartExecutorActorPlease$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManagerSpec.StartExecutorActorPlease$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskManagerSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManagerSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManagerSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/HistoryMetricsServiceSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">HistoryMetricsServiceSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocatorSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskLocatorSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistrySpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskRegistrySpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskRegistrySpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskRegistrySpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskLocatorSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskLocatorSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/HistoryMetricsServiceSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">HistoryMetricsServiceSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/TaskManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskManagerSpec</span></a></li>
</ul>
</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/JarScheduler.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">JarScheduler</span></a></li>
@@ -282,17 +282,12 @@
</li>
<li type="circle">org.scalatest.WordSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/AppMasterSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMasterSpec</span></a> (implements org.apache.gearpump.cluster.<a href="../../../../../org/apache/gearpump/cluster/MasterHarness.html" title="interface in org.apache.gearpump.cluster">MasterHarness</a>)</li>
-</ul>
-</li>
-<li type="circle">org.scalatest.WordSpec
-<ul>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/JarSchedulerSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">JarSchedulerSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.WordSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/ExecutorRestartPolicySpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorRestartPolicySpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="../../../../../org/apache/gearpump/streaming/appmaster/AppMasterSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMasterSpec</span></a> (implements org.apache.gearpump.cluster.<a href="../../../../../org/apache/gearpump/cluster/MasterHarness.html" title="interface in org.apache.gearpump.cluster">MasterHarness</a>)</li>
</ul>
</li>
</ul>
@@ -328,7 +323,7 @@
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/gearpump/streaming/package-tree.html">Prev</a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/package-tree.html">Next</a></li>
+<li><a href="../../../../../org/apache/gearpump/streaming/dsl/api/functions/package-tree.html">Next</a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/gearpump/streaming/appmaster/package-tree.html" target="_top">Frames</a></li>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/CollectionDataSource.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/CollectionDataSource.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/CollectionDataSource.html
deleted file mode 100644
index 47ba9d7..0000000
--- a/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/CollectionDataSource.html
+++ /dev/null
@@ -1,370 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 -->
-<title>CollectionDataSource</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="CollectionDataSource";
- }
- }
- catch(err) {
- }
-//-->
-var methods = {"i0":10,"i1":10,"i2":10,"i3":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li>Prev Class</li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/gearpump/streaming/dsl/CollectionDataSource.html" target="_top">Frames</a></li>
-<li><a href="CollectionDataSource.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">org.apache.gearpump.streaming.dsl</div>
-<h2 title="Class CollectionDataSource" class="title">Class CollectionDataSource<T></h2>
-</div>
-<div class="contentContainer">
-<ul class="inheritance">
-<li>java.lang.Object</li>
-<li>
-<ul class="inheritance">
-<li>org.apache.gearpump.streaming.dsl.CollectionDataSource<T></li>
-</ul>
-</li>
-</ul>
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<dl>
-<dt>All Implemented Interfaces:</dt>
-<dd>java.io.Serializable, <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></dd>
-</dl>
-<hr>
-<br>
-<pre>public class <span class="typeNameLabel">CollectionDataSource<T></span>
-extends java.lang.Object
-implements <a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></pre>
-<div class="block">A test message source which generated message sequence repeatedly.</div>
-<dl>
-<dt><span class="seeLabel">See Also:</span></dt>
-<dd><a href="../../../../../serialized-form.html#org.apache.gearpump.streaming.dsl.CollectionDataSource">Serialized Form</a></dd>
-</dl>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ======== CONSTRUCTOR SUMMARY ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.summary">
-<!-- -->
-</a>
-<h3>Constructor Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
-<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colOne" scope="col">Constructor and Description</th>
-</tr>
-<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html#CollectionDataSource-scala.collection.Seq-">CollectionDataSource</a></span>(scala.collection.Seq<<a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="type parameter in CollectionDataSource">T</a>> seq)</code> </td>
-</tr>
-</table>
-</li>
-</ul>
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!-- -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html#close--">close</a></span>()</code>
-<div class="block">Closes connection to data source.</div>
-</td>
-</tr>
-<tr id="i1" class="rowColor">
-<td class="colFirst"><code>java.time.Instant</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html#getWatermark--">getWatermark</a></span>()</code>
-<div class="block">Returns a watermark
- no timestamp earlier than the watermark
- should enter the system</div>
-</td>
-</tr>
-<tr id="i2" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">open</a></span>(<a href="../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context,
- java.time.Instant startTime)</code>
-<div class="block">Opens connection to data source
- invoked in onStart() method of <a href="../../../../../org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><code>DataSourceTask</code></a></div>
-</td>
-</tr>
-<tr id="i3" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html#read--">read</a></span>()</code>
-<div class="block">Reads next message from data source and
- returns null if no message is available</div>
-</td>
-</tr>
-</table>
-<ul class="blockList">
-<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
-<!-- -->
-</a>
-<h3>Methods inherited from class java.lang.Object</h3>
-<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========= CONSTRUCTOR DETAIL ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.detail">
-<!-- -->
-</a>
-<h3>Constructor Detail</h3>
-<a name="CollectionDataSource-scala.collection.Seq-">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>CollectionDataSource</h4>
-<pre>public CollectionDataSource(scala.collection.Seq<<a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="type parameter in CollectionDataSource">T</a>> seq)</pre>
-</li>
-</ul>
-</li>
-</ul>
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!-- -->
-</a>
-<h3>Method Detail</h3>
-<a name="open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>open</h4>
-<pre>public void open(<a href="../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context,
- java.time.Instant startTime)</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">DataSource</a></code></span></div>
-<div class="block">Opens connection to data source
- invoked in onStart() method of <a href="../../../../../org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><code>DataSourceTask</code></a>
- <p></div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#open-org.apache.gearpump.streaming.task.TaskContext-java.time.Instant-">open</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></code></dd>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>context</code> - is the task context at runtime</dd>
-<dd><code>startTime</code> - is the start time of system</dd>
-</dl>
-</li>
-</ul>
-<a name="read--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>read</h4>
-<pre>public <a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> read()</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#read--">DataSource</a></code></span></div>
-<div class="block">Reads next message from data source and
- returns null if no message is available
- <p></div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#read--">read</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></code></dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>a <a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump"><code>Message</code></a> or null</dd>
-</dl>
-</li>
-</ul>
-<a name="close--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>close</h4>
-<pre>public void close()</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#close--">DataSource</a></code></span></div>
-<div class="block">Closes connection to data source.
- invoked in onStop() method of <a href="../../../../../org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><code>DataSourceTask</code></a></div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#close--">close</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></code></dd>
-</dl>
-</li>
-</ul>
-<a name="getWatermark--">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>getWatermark</h4>
-<pre>public java.time.Instant getWatermark()</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">DataSource</a></code></span></div>
-<div class="block">Returns a watermark
- no timestamp earlier than the watermark
- should enter the system</div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">getWatermark</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a></code></dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>(undocumented)</dd>
-</dl>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li>Prev Class</li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/gearpump/streaming/dsl/CollectionDataSource.html" target="_top">Frames</a></li>
-<li><a href="CollectionDataSource.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/KVStream.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/KVStream.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/KVStream.html
deleted file mode 100644
index 13a5d35..0000000
--- a/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/KVStream.html
+++ /dev/null
@@ -1,307 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 -->
-<title>KVStream</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KVStream";
- }
- }
- catch(err) {
- }
-//-->
-var methods = {"i0":10,"i1":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/gearpump/streaming/dsl/KVStream.html" target="_top">Frames</a></li>
-<li><a href="KVStream.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">org.apache.gearpump.streaming.dsl</div>
-<h2 title="Class KVStream" class="title">Class KVStream<K,V></h2>
-</div>
-<div class="contentContainer">
-<ul class="inheritance">
-<li>java.lang.Object</li>
-<li>
-<ul class="inheritance">
-<li>org.apache.gearpump.streaming.dsl.KVStream<K,V></li>
-</ul>
-</li>
-</ul>
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<hr>
-<br>
-<pre>public class <span class="typeNameLabel">KVStream<K,V></span>
-extends java.lang.Object</pre>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ======== CONSTRUCTOR SUMMARY ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.summary">
-<!-- -->
-</a>
-<h3>Constructor Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
-<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colOne" scope="col">Constructor and Description</th>
-</tr>
-<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html#KVStream-org.apache.gearpump.streaming.dsl.Stream-">KVStream</a></span>(<a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a><scala.Tuple2<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">K</a>,<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>>> stream)</code> </td>
-</tr>
-</table>
-</li>
-</ul>
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!-- -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a><scala.Tuple2<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">K</a>,<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html#groupByKey-int-">groupByKey</a></span>(int parallelism)</code>
-<div class="block">GroupBy key</div>
-</td>
-</tr>
-<tr id="i1" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a><scala.Tuple2<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">K</a>,<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html#sum-scala.math.Numeric-">sum</a></span>(scala.math.Numeric<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>> numeric)</code>
-<div class="block">Sum the value of the tuples</div>
-</td>
-</tr>
-</table>
-<ul class="blockList">
-<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
-<!-- -->
-</a>
-<h3>Methods inherited from class java.lang.Object</h3>
-<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========= CONSTRUCTOR DETAIL ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.detail">
-<!-- -->
-</a>
-<h3>Constructor Detail</h3>
-<a name="KVStream-org.apache.gearpump.streaming.dsl.Stream-">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>KVStream</h4>
-<pre>public KVStream(<a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a><scala.Tuple2<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">K</a>,<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>>> stream)</pre>
-</li>
-</ul>
-</li>
-</ul>
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!-- -->
-</a>
-<h3>Method Detail</h3>
-<a name="groupByKey-int-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>groupByKey</h4>
-<pre>public <a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a><scala.Tuple2<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">K</a>,<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>>> groupByKey(int parallelism)</pre>
-<div class="block">GroupBy key
- <p>
- Applies to Stream[Tuple2[K,V}
- <p></div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>parallelism</code> - the parallelism for this operation</dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the new KV stream</dd>
-</dl>
-</li>
-</ul>
-<a name="sum-scala.math.Numeric-">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>sum</h4>
-<pre>public <a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl">Stream</a><scala.Tuple2<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">K</a>,<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>>> sum(scala.math.Numeric<<a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="type parameter in KVStream">V</a>> numeric)</pre>
-<div class="block">Sum the value of the tuples
- <p>
- Apply to Stream[Tuple2[K,V}, V must be of type Number
- <p>
- For input (key, value1), (key, value2), will generate (key, value1 + value2)</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>numeric</code> - the numeric operations</dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the sum stream</dd>
-</dl>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/gearpump/streaming/dsl/KVStream.html" target="_top">Frames</a></li>
-<li><a href="KVStream.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/LoggerSink.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/LoggerSink.html b/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/LoggerSink.html
deleted file mode 100644
index b52edc8..0000000
--- a/content/releases/latest/api/java/org/apache/gearpump/streaming/dsl/LoggerSink.html
+++ /dev/null
@@ -1,351 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 -->
-<title>LoggerSink</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="LoggerSink";
- }
- }
- catch(err) {
- }
-//-->
-var methods = {"i0":10,"i1":10,"i2":10,"i3":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/gearpump/streaming/dsl/LoggerSink.html" target="_top">Frames</a></li>
-<li><a href="LoggerSink.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">org.apache.gearpump.streaming.dsl</div>
-<h2 title="Class LoggerSink" class="title">Class LoggerSink<T></h2>
-</div>
-<div class="contentContainer">
-<ul class="inheritance">
-<li>java.lang.Object</li>
-<li>
-<ul class="inheritance">
-<li>org.apache.gearpump.streaming.dsl.LoggerSink<T></li>
-</ul>
-</li>
-</ul>
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<dl>
-<dt>All Implemented Interfaces:</dt>
-<dd>java.io.Serializable, <a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a></dd>
-</dl>
-<hr>
-<br>
-<pre>public class <span class="typeNameLabel">LoggerSink<T></span>
-extends java.lang.Object
-implements <a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a></pre>
-<dl>
-<dt><span class="seeLabel">See Also:</span></dt>
-<dd><a href="../../../../../serialized-form.html#org.apache.gearpump.streaming.dsl.LoggerSink">Serialized Form</a></dd>
-</dl>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ======== CONSTRUCTOR SUMMARY ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.summary">
-<!-- -->
-</a>
-<h3>Constructor Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
-<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colOne" scope="col">Constructor and Description</th>
-</tr>
-<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html#LoggerSink--">LoggerSink</a></span>()</code> </td>
-</tr>
-</table>
-</li>
-</ul>
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!-- -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html#close--">close</a></span>()</code>
-<div class="block">Closes connection to data sink
- invoked at onClose() method of <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div>
-</td>
-</tr>
-<tr id="i1" class="rowColor">
-<td class="colFirst"><code>org.slf4j.Logger</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html#logger--">logger</a></span>()</code> </td>
-</tr>
-<tr id="i2" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html#open-org.apache.gearpump.streaming.task.TaskContext-">open</a></span>(<a href="../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context)</code>
-<div class="block">Opens connection to data sink
- invoked at onStart() method of <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div>
-</td>
-</tr>
-<tr id="i3" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/gearpump/streaming/dsl/LoggerSink.html#write-org.apache.gearpump.Message-">write</a></span>(<a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message)</code>
-<div class="block">Writes message into data sink
- invoked at onNext() method of <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div>
-</td>
-</tr>
-</table>
-<ul class="blockList">
-<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
-<!-- -->
-</a>
-<h3>Methods inherited from class java.lang.Object</h3>
-<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========= CONSTRUCTOR DETAIL ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.detail">
-<!-- -->
-</a>
-<h3>Constructor Detail</h3>
-<a name="LoggerSink--">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>LoggerSink</h4>
-<pre>public LoggerSink()</pre>
-</li>
-</ul>
-</li>
-</ul>
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!-- -->
-</a>
-<h3>Method Detail</h3>
-<a name="logger--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>logger</h4>
-<pre>public org.slf4j.Logger logger()</pre>
-</li>
-</ul>
-<a name="open-org.apache.gearpump.streaming.task.TaskContext-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>open</h4>
-<pre>public void open(<a href="../../../../../org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a> context)</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html#open-org.apache.gearpump.streaming.task.TaskContext-">DataSink</a></code></span></div>
-<div class="block">Opens connection to data sink
- invoked at onStart() method of <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html#open-org.apache.gearpump.streaming.task.TaskContext-">open</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a></code></dd>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>context</code> - is the task context at runtime</dd>
-</dl>
-</li>
-</ul>
-<a name="write-org.apache.gearpump.Message-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>write</h4>
-<pre>public void write(<a href="../../../../../org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a> message)</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html#write-org.apache.gearpump.Message-">DataSink</a></code></span></div>
-<div class="block">Writes message into data sink
- invoked at onNext() method of <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html#write-org.apache.gearpump.Message-">write</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a></code></dd>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>message</code> - wraps data to be written out</dd>
-</dl>
-</li>
-</ul>
-<a name="close--">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>close</h4>
-<pre>public void close()</pre>
-<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html#close--">DataSink</a></code></span></div>
-<div class="block">Closes connection to data sink
- invoked at onClose() method of <a href="../../../../../org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><code>Task</code></a></div>
-<dl>
-<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html#close--">close</a></code> in interface <code><a href="../../../../../org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a></code></dd>
-</dl>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/KVStream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../../../org/apache/gearpump/streaming/dsl/Stream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../../../index.html?org/apache/gearpump/streaming/dsl/LoggerSink.html" target="_top">Frames</a></li>
-<li><a href="LoggerSink.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>