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>
