http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/overview-summary.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/overview-summary.html b/content/releases/latest/api/java/overview-summary.html index 0aa1d34..d1714f2 100644 --- a/content/releases/latest/api/java/overview-summary.html +++ b/content/releases/latest/api/java/overview-summary.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:29 CEST 2017 --> <title>Overview</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -161,154 +161,150 @@ <td class="colLast"> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/partitioner/package-summary.html">org.apache.gearpump.streaming.dsl.partitioner</a></td> -<td class="colLast"> </td> -</tr> -<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/plan/package-summary.html">org.apache.gearpump.streaming.dsl.plan</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/plan/functions/package-summary.html">org.apache.gearpump.streaming.dsl.plan.functions</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/scalaapi/package-summary.html">org.apache.gearpump.streaming.dsl.scalaapi</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/package-summary.html">org.apache.gearpump.streaming.dsl.scalaapi.functions</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/window/api/package-summary.html">org.apache.gearpump.streaming.dsl.window.api</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/dsl/window/impl/package-summary.html">org.apache.gearpump.streaming.dsl.window.impl</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/executor/package-summary.html">org.apache.gearpump.streaming.executor</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/hadoop/package-summary.html">org.apache.gearpump.streaming.hadoop</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/hadoop/lib/package-summary.html">org.apache.gearpump.streaming.hadoop.lib</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/hadoop/lib/format/package-summary.html">org.apache.gearpump.streaming.hadoop.lib.format</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html">org.apache.gearpump.streaming.hadoop.lib.rotation</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/javaapi/package-summary.html">org.apache.gearpump.streaming.javaapi</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/package-summary.html">org.apache.gearpump.streaming.kafka</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/dsl/package-summary.html">org.apache.gearpump.streaming.kafka.dsl</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/package-summary.html">org.apache.gearpump.streaming.kafka.lib</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html">org.apache.gearpump.streaming.kafka.lib.sink</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/source/package-summary.html">org.apache.gearpump.streaming.kafka.lib.source</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/package-summary.html">org.apache.gearpump.streaming.kafka.lib.source.consumer</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html">org.apache.gearpump.streaming.kafka.lib.source.grouper</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/store/package-summary.html">org.apache.gearpump.streaming.kafka.lib.store</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/lib/util/package-summary.html">org.apache.gearpump.streaming.kafka.lib.util</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/kafka/util/package-summary.html">org.apache.gearpump.streaming.kafka.util</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/metrics/package-summary.html">org.apache.gearpump.streaming.metrics</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/monoid/package-summary.html">org.apache.gearpump.streaming.monoid</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/partitioner/package-summary.html">org.apache.gearpump.streaming.partitioner</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/sink/package-summary.html">org.apache.gearpump.streaming.sink</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/source/package-summary.html">org.apache.gearpump.streaming.source</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/state/api/package-summary.html">org.apache.gearpump.streaming.state.api</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/state/impl/package-summary.html">org.apache.gearpump.streaming.state.impl</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/storage/package-summary.html">org.apache.gearpump.streaming.storage</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/task/package-summary.html">org.apache.gearpump.streaming.task</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/transaction/api/package-summary.html">org.apache.gearpump.streaming.transaction.api</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/streaming/util/package-summary.html">org.apache.gearpump.streaming.util</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/transport/package-summary.html">org.apache.gearpump.transport</a></td> <td class="colLast"> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><a href="org/apache/gearpump/transport/netty/package-summary.html">org.apache.gearpump.transport.netty</a></td> <td class="colLast"> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></td> <td class="colLast"> </td> </tr>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/overview-tree.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/overview-tree.html b/content/releases/latest/api/java/overview-tree.html index 5c26d7f..135efe4 100644 --- a/content/releases/latest/api/java/overview-tree.html +++ b/content/releases/latest/api/java/overview-tree.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 --> +<!-- Generated by javadoc (1.8.0_121) on Sun Jul 09 07:41:29 CEST 2017 --> <title>Class Hierarchy</title> -<meta name="date" content="2017-04-25"> +<meta name="date" content="2017-07-09"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -93,7 +93,6 @@ <li><a href="org/apache/gearpump/streaming/dsl/api/functions/package-tree.html">org.apache.gearpump.streaming.dsl.api.functions</a>, </li> <li><a href="org/apache/gearpump/streaming/dsl/javaapi/package-tree.html">org.apache.gearpump.streaming.dsl.javaapi</a>, </li> <li><a href="org/apache/gearpump/streaming/dsl/javaapi/functions/package-tree.html">org.apache.gearpump.streaming.dsl.javaapi.functions</a>, </li> -<li><a href="org/apache/gearpump/streaming/dsl/partitioner/package-tree.html">org.apache.gearpump.streaming.dsl.partitioner</a>, </li> <li><a href="org/apache/gearpump/streaming/dsl/plan/package-tree.html">org.apache.gearpump.streaming.dsl.plan</a>, </li> <li><a href="org/apache/gearpump/streaming/dsl/plan/functions/package-tree.html">org.apache.gearpump.streaming.dsl.plan.functions</a>, </li> <li><a href="org/apache/gearpump/streaming/dsl/scalaapi/package-tree.html">org.apache.gearpump.streaming.dsl.scalaapi</a>, </li> @@ -168,7 +167,6 @@ <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Client.Flush$.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Client.Flush$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.AddWorker$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetLastFailure$</span></a> (implements scala.Serializable)</li> -<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetStallingTasks$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.JarStoreServerAddress$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.JarStoreServerAddress$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryAppMasterConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryAppMasterConfig$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryWorkerConfig$</span></a> (implements scala.Serializable)</li> @@ -270,7 +268,7 @@ <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.Session$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.Session$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StartExecutorSystems$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.StartExecutorSystems$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.UnRegisterTask$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster.UnRegisterTask$</span></a> (implements scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People$.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitionerSpec.People$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People$.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">GroupByPartitionerSpec.People$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.GetKV$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.GetKVSuccess$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.PutKVFailed$</span></a> (implements scala.Serializable)</li> @@ -416,6 +414,7 @@ <li type="circle">org.apache.gearpump.streaming.monoid.<a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" title="class in org.apache.gearpump.streaming.monoid"><span class="typeNameLink">AlgebirdGroup</span></a><T> (implements org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/Group.html" title="interface in org.apache.gearpump.streaming.state.api">Group</a><T>)</li> <li type="circle">org.apache.gearpump.streaming.monoid.<a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" title="class in org.apache.gearpump.streaming.monoid"><span class="typeNameLink">AlgebirdMonoid</span></a><T> (implements org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/Monoid.html" title="interface in org.apache.gearpump.streaming.state.api">Monoid</a><T>)</li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">AndThen</span></a><IN,MIDDLE,OUT> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">AndThen</span></a><IN,MIDDLE,OUT> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl">WindowRunner</a><IN,OUT>)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppDescription</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.log4j.AppenderSkeleton (implements org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler) <ul> @@ -518,7 +517,6 @@ <li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/AppSubmitter.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">AppSubmitter</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li> <li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.Syntax.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">ArgumentsParser.Syntax</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">BroadcastPartitioner</span></a> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/MulticastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">MulticastPartitioner</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">ChainableOp</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/CheckpointClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">CheckpointClock</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.state.impl.<a href="org/apache/gearpump/streaming/state/impl/CheckpointManager.html" title="class in org.apache.gearpump.streaming.state.impl"><span class="typeNameLink">CheckpointManager</span></a></li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/CheckProcessorDeath.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">CheckProcessorDeath</span></a> (implements scala.Product, scala.Serializable)</li> @@ -537,7 +535,7 @@ <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.CommandResult.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.CommandResult</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetJarStoreServer$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetJarStoreServer$</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetLastFailure</span></a> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetStallingTasks</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetStallingTasks$</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.JarStoreServerAddress.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.JarStoreServerAddress</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryAppMasterConfig.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryAppMasterConfig</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryHistoryMetrics.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryHistoryMetrics</span></a> (implements scala.Product, scala.Serializable)</li> @@ -578,8 +576,6 @@ <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Constants.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">Constants</span></a></li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Context.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Context</span></a> (implements org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/IContext.html" title="interface in org.apache.gearpump.transport.netty">IContext</a>)</li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Counter.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Counter</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountTrigger</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">Trigger</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountWindows</span></a></li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/DAG.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">DAG</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager</span></a> (implements akka.actor.Actor, akka.actor.Stash)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.DagInitiated$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.DagInitiated$</span></a> (implements scala.Product, scala.Serializable)</li> @@ -598,19 +594,21 @@ <li type="circle">org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceConfig.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceConfig</span></a></li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">DataSourceOp</span></a> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceProcessor</span></a></li> +<li type="circle">org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceProcessor.PerElementWindowFunction$.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceProcessor.PerElementWindowFunction$</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a>)</li> <li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/DefaultExecutorProcessLauncher.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">DefaultExecutorProcessLauncher</span></a> (implements org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/ExecutorProcessLauncher.html" title="interface in org.apache.gearpump.cluster.worker">ExecutorProcessLauncher</a>)</li> <li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">DefaultKafkaMessageDecoder</span></a> (implements org.apache.gearpump.streaming.kafka.lib.<a href="org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html" title="interface in org.apache.gearpump.streaming.kafka.lib">KafkaMessageDecoder</a>)</li> +<li type="circle">org.apache.gearpump.<a href="org/apache/gearpump/DefaultMessage.html" title="class in org.apache.gearpump"><span class="typeNameLink">DefaultMessage</span></a> (implements org.apache.gearpump.<a href="org/apache/gearpump/Message.html" title="interface in org.apache.gearpump">Message</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.kafka.lib.source.grouper.<a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.grouper"><span class="typeNameLink">DefaultPartitionGrouper</span></a> (implements org.apache.gearpump.streaming.kafka.lib.source.grouper.<a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html" title="interface in org.apache.gearpump.streaming.kafka.lib.source.grouper">PartitionGrouper</a>)</li> <li type="circle">org.apache.gearpump.streaming.hadoop.lib.format.<a href="org/apache/gearpump/streaming/hadoop/lib/format/DefaultSequenceFormatter.html" title="class in org.apache.gearpump.streaming.hadoop.lib.format"><span class="typeNameLink">DefaultSequenceFormatter</span></a> (implements org.apache.gearpump.streaming.hadoop.lib.format.<a href="org/apache/gearpump/streaming/hadoop/lib/format/OutputFormatter.html" title="interface in org.apache.gearpump.streaming.hadoop.lib.format">OutputFormatter</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">DefaultWindowRunner</span></a><IN,GROUP,OUT> (implements org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl">WindowRunner</a>)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">DefaultWindowRunner</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl">WindowRunner</a><IN,OUT>)</li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Direct.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">Direct</span></a> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/OpEdge.html" title="interface in org.apache.gearpump.streaming.dsl.plan">OpEdge</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Discarding.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">Discarding</span></a> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">AccumulationMode</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncher.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">DummyAppMasterLauncher</span></a> (implements akka.actor.Actor)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncherFactory.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">DummyAppMasterLauncherFactory</span></a> (implements org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppMasterLauncherFactory.html" title="interface in org.apache.gearpump.cluster.master">AppMasterLauncherFactory</a>)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/DummyRunner.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">DummyRunner</span></a><T> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/Echo.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">Echo</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/EchoActor.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">EchoActor</span></a> (implements akka.actor.Actor)</li> <li type="circle">org.apache.gearpump.cluster.embedded.<a href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html" title="class in org.apache.gearpump.cluster.embedded"><span class="typeNameLink">EmbeddedCluster</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">Emit</span></a><T> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/EndingClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">EndingClock</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">scala.Enumeration (implements scala.Serializable) <ul> @@ -834,11 +832,6 @@ </li> <li type="circle">org.scalatest.FlatSpec <ul> -<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitionerSpec</span></a></li> -</ul> -</li> -<li type="circle">org.scalatest.FlatSpec -<ul> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec</span></a></li> </ul> </li> @@ -879,6 +872,11 @@ </li> <li type="circle">org.scalatest.FlatSpec <ul> +<li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">GroupByPartitionerSpec</span></a></li> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> <li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/PartitionerSpec.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">PartitionerSpec</span></a></li> </ul> </li> @@ -900,6 +898,7 @@ <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/GetLatestMinClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">GetLatestMinClock</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/ClockEvent.html" title="interface in org.apache.gearpump.streaming.task">ClockEvent</a>)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/GetStartClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">GetStartClock</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/GetUpstreamMinClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">GetUpstreamMinClock</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/ClockEvent.html" title="interface in org.apache.gearpump.streaming.task">ClockEvent</a>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">GlobalWindows</span></a></li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">Graph</span></a><N,E> (implements scala.Serializable) <ul> <li type="circle">org.apache.gearpump.streaming.javaapi.<a href="org/apache/gearpump/streaming/javaapi/Graph.html" title="class in org.apache.gearpump.streaming.javaapi"><span class="typeNameLink">Graph</span></a></li> @@ -914,10 +913,9 @@ <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.Path$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">Graph.Path$</span></a></li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/GraphSpec.Edge.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">GraphSpec.Edge</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/GraphSpec.Vertex.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">GraphSpec.Vertex</span></a> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">GroupAlsoByWindow</span></a><T,GROUP> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">GroupByOp</span></a><IN,GROUP> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitioner</span></a><T,GROUP> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">UnicastPartitioner</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitionerSpec.People</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">GroupByPartitioner</span></a><T,GROUP> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">UnicastPartitioner</a>)</li> +<li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">GroupByPartitionerSpec.People</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.hadoop.<a href="org/apache/gearpump/streaming/hadoop/HadoopCheckpointStore.html" title="class in org.apache.gearpump.streaming.hadoop"><span class="typeNameLink">HadoopCheckpointStore</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in org.apache.gearpump.streaming.transaction.api">CheckpointStore</a>)</li> <li type="circle">org.apache.gearpump.streaming.hadoop.<a href="org/apache/gearpump/streaming/hadoop/HadoopCheckpointStoreFactory.html" title="class in org.apache.gearpump.streaming.hadoop"><span class="typeNameLink">HadoopCheckpointStoreFactory</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/CheckpointStoreFactory.html" title="interface in org.apache.gearpump.streaming.transaction.api">CheckpointStoreFactory</a>)</li> <li type="circle">org.apache.gearpump.streaming.hadoop.lib.<a href="org/apache/gearpump/streaming/hadoop/lib/HadoopCheckpointStoreReader.html" title="class in org.apache.gearpump.streaming.hadoop.lib"><span class="typeNameLink">HadoopCheckpointStoreReader</span></a> (implements scala.collection.Iterator<A>)</li> @@ -974,7 +972,6 @@ <li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/JarStoreServer.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">JarStoreServer</span></a> (implements akka.actor.Actor, akka.actor.Stash)</li> <li type="circle">org.apache.gearpump.streaming.dsl.javaapi.<a href="org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" title="class in org.apache.gearpump.streaming.dsl.javaapi"><span class="typeNameLink">JavaStream</span></a><T></li> <li type="circle">org.apache.gearpump.streaming.dsl.javaapi.<a href="org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.html" title="class in org.apache.gearpump.streaming.dsl.javaapi"><span class="typeNameLink">JavaStreamApp</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.javaapi.<a href="org/apache/gearpump/streaming/dsl/javaapi/JavaWindowStream.html" title="class in org.apache.gearpump.streaming.dsl.javaapi"><span class="typeNameLink">JavaWindowStream</span></a><T></li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/JvmMetricsSet.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">JvmMetricsSet</span></a> (implements com.codahale.metrics.MetricSet)</li> <li type="circle">org.apache.gearpump.streaming.kafka.lib.util.<a href="org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.html" title="class in org.apache.gearpump.streaming.kafka.lib.util"><span class="typeNameLink">KafkaClient</span></a></li> <li type="circle">org.apache.gearpump.streaming.kafka.lib.util.<a href="org/apache/gearpump/streaming/kafka/lib/util/KafkaClient.KafkaClientFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.util"><span class="typeNameLink">KafkaClient.KafkaClientFactory</span></a> (implements java.io.Serializable)</li> @@ -1054,7 +1051,6 @@ <li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/MasterWatcher.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">MasterWatcher</span></a> (implements akka.actor.Actor, akka.actor.ActorLogging)</li> <li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/MasterWatcher.Shutdown$.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">MasterWatcher.Shutdown$</span></a></li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">MergeOp</span></a> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.<a href="org/apache/gearpump/Message.html" title="class in org.apache.gearpump"><span class="typeNameLink">Message</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.kafka.lib.<a href="org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html" title="class in org.apache.gearpump.streaming.kafka.lib"><span class="typeNameLink">MessageAndWatermark</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/MessageBatch.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">MessageBatch</span></a></li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/MessageTimeOut.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">MessageTimeOut</span></a> (implements scala.Product, scala.Serializable)</li> @@ -1086,10 +1082,10 @@ <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyConfig.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">NettyConfig</span></a></li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyRenameThreadFactory.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">NettyRenameThreadFactory</span></a> (implements java.util.concurrent.ThreadFactory)</li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyUtil.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">NettyUtil</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">NonMergingWindowFunction</span></a><T> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a><T>) +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">NonMergingWindowFunction</span></a> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a>) <ul> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountWindowFunction</span></a><T> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">SlidingWindowFunction</span></a><T> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">GlobalWindowFunction</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">SlidingWindowFunction</span></a> (implements scala.Product, scala.Serializable)</li> </ul> </li> <li type="circle">org.jboss.netty.handler.codec.oneone.OneToOneEncoder (implements org.jboss.netty.channel.ChannelDownstreamHandler) @@ -1108,8 +1104,6 @@ <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Planner.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">Planner</span></a></li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec.AnySink</span></a> (implements org.apache.gearpump.streaming.sink.<a href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a>)</li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySource.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec.AnySource</span></a> (implements org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/ProcessingTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">ProcessingTimeTrigger</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">Trigger</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.Triggering$.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">ProcessingTimeTriggerTask.Triggering$</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ProcessLogRedirector.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ProcessLogRedirector</span></a> (implements java.io.Closeable, org.apache.gearpump.util.<a href="org/apache/gearpump/util/ConsoleOutput.html" title="interface in org.apache.gearpump.util">ConsoleOutput</a>, java.io.Flushable, scala.sys.process.ProcessLogger)</li> <li type="circle">org.apache.gearpump.streaming.javaapi.<a href="org/apache/gearpump/streaming/javaapi/Processor.html" title="class in org.apache.gearpump.streaming.javaapi"><span class="typeNameLink">Processor</span></a><T> (implements org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Processor.html" title="interface in org.apache.gearpump.streaming">Processor</a><T>)</li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Processor.DefaultProcessor.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">Processor.DefaultProcessor</span></a><T> (implements org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Processor.html" title="interface in org.apache.gearpump.streaming">Processor</a><T>, scala.Product, scala.Serializable)</li> @@ -1134,22 +1128,17 @@ </li> <li type="circle">org.scalatest.PropSpec <ul> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">CountTriggerTaskSpec</span></a></li> +<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/GroupByTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">GroupByTaskSpec</span></a></li> </ul> </li> <li type="circle">org.scalatest.PropSpec <ul> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">EventTimeTriggerTaskSpec</span></a></li> -</ul> -</li> -<li type="circle">org.scalatest.PropSpec -<ul> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">ProcessingTimeTriggerTaskSpec</span></a></li> +<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/TransformTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">TransformTaskSpec</span></a></li> </ul> </li> <li type="circle">org.scalatest.PropSpec <ul> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/TransformTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">TransformTaskSpec</span></a></li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunnerSpec.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">DefaultWindowRunnerSpec</span></a></li> </ul> </li> <li type="circle">org.scalatest.PropSpec @@ -1240,7 +1229,7 @@ <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.MsgBatch.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Server.MsgBatch</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.ServerPipelineFactory.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Server.ServerPipelineFactory</span></a> (implements org.jboss.netty.channel.ChannelPipelineFactory)</li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.TaskIdActorRefTranslation.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Server.TaskIdActorRefTranslation</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">SessionWindowFunction</span></a><T> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a><T>)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">SessionWindowFunction</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a>)</li> <li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">SessionWindows</span></a></li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Shuffle.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">Shuffle</span></a> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/OpEdge.html" title="interface in org.apache.gearpump.streaming.dsl.plan">OpEdge</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">ShuffleGroupingPartitioner</span></a> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">UnicastPartitioner</a>)</li> @@ -1272,14 +1261,12 @@ <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/Subscription.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">Subscription</span></a></li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">Task</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskInterface.html" title="interface in org.apache.gearpump.streaming.task">TaskInterface</a>) <ul> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">CountTriggerTask</span></a><IN,GROUP></li> <li type="circle">org.apache.gearpump.streaming.sink.<a href="org/apache/gearpump/streaming/sink/DataSinkTask.html" title="class in org.apache.gearpump.streaming.sink"><span class="typeNameLink">DataSinkTask</span></a></li> <li type="circle">org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceTask</span></a><IN,OUT></li> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">EventTimeTriggerTask</span></a><IN,GROUP></li> +<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/GroupByTask.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">GroupByTask</span></a><IN,GROUP,OUT></li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnyTask.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">OpSpec.AnyTask</span></a></li> <li type="circle">org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/PersistentTask.html" title="class in org.apache.gearpump.streaming.state.api"><span class="typeNameLink">PersistentTask</span></a><T></li> <li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnyTask.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec.AnyTask</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">ProcessingTimeTriggerTask</span></a><IN,GROUP></li> <li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamSpec.Join.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">StreamSpec.Join</span></a></li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/SubscriptionSpec.NextTask.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">SubscriptionSpec.NextTask</span></a></li> <li type="circle">org.apache.gearpump.streaming.javaapi.<a href="org/apache/gearpump/streaming/javaapi/Task.html" title="class in org.apache.gearpump.streaming.javaapi"><span class="typeNameLink">Task</span></a></li> @@ -1383,8 +1370,10 @@ </li> </ul> </li> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/TransformTask.Transform.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">TransformTask.Transform</span></a><IN,OUT></li> -<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/TransformTask.Transform$.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">TransformTask.Transform$</span></a></li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/TimestampedValue.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">TimestampedValue</span></a><T> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/TransformOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">TransformOp</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">TransformWindowTransformOp</span></a><IN,MIDDLE,OUT> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/TriggeredOutputs.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">TriggeredOutputs</span></a><T> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/UpdateCheckpointClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">UpdateCheckpointClock</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/ClockEvent.html" title="interface in org.apache.gearpump.streaming.task">ClockEvent</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/UpdateClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">UpdateClock</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/ClockEvent.html" title="interface in org.apache.gearpump.streaming.task">ClockEvent</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/UpstreamMinClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">UpstreamMinClock</span></a> (implements scala.Product, scala.Serializable)</li> @@ -1396,8 +1385,9 @@ <li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">Window</span></a> (implements java.lang.Comparable<T>, scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.state.impl.<a href="org/apache/gearpump/streaming/state/impl/Window.html" title="class in org.apache.gearpump.streaming.state.impl"><span class="typeNameLink">Window</span></a></li> <li type="circle">org.apache.gearpump.streaming.state.impl.<a href="org/apache/gearpump/streaming/state/impl/WindowConfig.html" title="class in org.apache.gearpump.streaming.state.impl"><span class="typeNameLink">WindowConfig</span></a> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">Windows</span></a><T> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/WindowStream.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">WindowStream</span></a><T></li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/WindowOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">WindowOp</span></a> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">Windows</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">WindowTransformOp</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li> <li type="circle">org.scalatest.WordSpec <ul> <li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/WorkerSpec.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">WorkerSpec</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> @@ -1493,6 +1483,7 @@ <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterHarness.html" title="interface in org.apache.gearpump.cluster"><span class="typeNameLink">MasterHarness</span></a></li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.StreamingType.html" title="interface in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.StreamingType</span></a></li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationResult.html" title="interface in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.ApplicationResult</span></a></li> +<li type="circle">org.apache.gearpump.<a href="org/apache/gearpump/Message.html" title="interface in org.apache.gearpump"><span class="typeNameLink">Message</span></a></li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.MetricType.html" title="interface in org.apache.gearpump.metrics"><span class="typeNameLink">Metrics.MetricType</span></a></li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/MetricsAggregator.html" title="interface in org.apache.gearpump.metrics"><span class="typeNameLink">MetricsAggregator</span></a></li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/MetricsReporterService.ReportTo.html" title="interface in org.apache.gearpump.metrics"><span class="typeNameLink">MetricsReporterService.ReportTo</span></a></li> @@ -1540,6 +1531,7 @@ </li> <li type="circle">org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/Serializer.html" title="interface in org.apache.gearpump.streaming.state.api"><span class="typeNameLink">Serializer</span></a><T></li> <li type="circle">org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/TimeStampFilter.html" title="interface in org.apache.gearpump.streaming.transaction.api"><span class="typeNameLink">TimeStampFilter</span></a></li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">WindowRunner</span></a><IN,OUT></li> </ul> </li> <li type="circle">org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/SerializationFramework.html" title="interface in org.apache.gearpump.serializer"><span class="typeNameLink">SerializationFramework</span></a></li> @@ -1552,9 +1544,8 @@ <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskScheduler.html" title="interface in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskScheduler</span></a></li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/TimeOutScheduler.html" title="interface in org.apache.gearpump.util"><span class="typeNameLink">TimeOutScheduler</span></a></li> <li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">Trigger</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">WindowFunction</span></a><T></li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">WindowFunction</span></a></li> <li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.Context.html" title="interface in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">WindowFunction.Context</span></a><T></li> -<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">WindowRunner</span></a></li> <li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/Worker.ExecutorHandler.html" title="interface in org.apache.gearpump.cluster.worker"><span class="typeNameLink">Worker.ExecutorHandler</span></a></li> </ul> </div> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/package-list ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/package-list b/content/releases/latest/api/java/package-list index 110c4a4..3d041ac 100644 --- a/content/releases/latest/api/java/package-list +++ b/content/releases/latest/api/java/package-list @@ -19,7 +19,6 @@ org.apache.gearpump.streaming.appmaster org.apache.gearpump.streaming.dsl.api.functions org.apache.gearpump.streaming.dsl.javaapi org.apache.gearpump.streaming.dsl.javaapi.functions -org.apache.gearpump.streaming.dsl.partitioner org.apache.gearpump.streaming.dsl.plan org.apache.gearpump.streaming.dsl.plan.functions org.apache.gearpump.streaming.dsl.scalaapi
