http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/java/index-all.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/index-all.html b/content/releases/latest/api/java/index-all.html index 7341380..8d74910 100644 --- a/content/releases/latest/api/java/index-all.html +++ b/content/releases/latest/api/java/index-all.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>Index</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> @@ -319,6 +319,8 @@ <div class="block">Add a vertex Current Graph is changed.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html#addWindowOp-org.apache.gearpump.util.Graph-org.apache.gearpump.streaming.dsl.plan.Op-org.apache.gearpump.streaming.dsl.window.api.Windows-">addWindowOp(Graph<Op, OpEdge>, Op, Windows)</a></span> - Static method in class org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker.html#AddWorker-int-">AddWorker(int)</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker.html" title="class in org.apache.gearpump.cluster">ClientToMaster.AddWorker</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker$.html#AddWorker:D--">AddWorker$()</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker$.html" title="class in org.apache.gearpump.cluster">ClientToMaster.AddWorker$</a></dt> @@ -462,6 +464,10 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html#AndThen-org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner-org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner-">AndThen(FunctionRunner<IN, MIDDLE>, FunctionRunner<MIDDLE, OUT>)</a></span> - Constructor for class 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">AndThen</a></dt> <dd> </dd> +<dt><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><<a href="org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" title="type parameter in AndThen">IN</a>,<a href="org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" title="type parameter in AndThen">MIDDLE</a>,<a href="org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" title="type parameter in AndThen">OUT</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/window/impl/package-summary.html">org.apache.gearpump.streaming.dsl.window.impl</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/AndThen.html#AndThen-org.apache.gearpump.streaming.dsl.window.impl.WindowRunner-org.apache.gearpump.streaming.dsl.window.impl.WindowRunner-">AndThen(WindowRunner<IN, MIDDLE>, WindowRunner<MIDDLE, OUT>)</a></span> - Constructor for class 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">AndThen</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/scheduler/Relaxation.html#ANY--">ANY()</a></span> - Static method in class org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/Relaxation.html" title="class in org.apache.gearpump.cluster.scheduler">Relaxation</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnySink.html#AnySink--">AnySink()</a></span> - Constructor for class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan">OpSpec.AnySink</a></dt> @@ -544,8 +550,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure.html#appId--">appId()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure.html" title="class in org.apache.gearpump.cluster">ClientToMaster.GetLastFailure</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html#appId--">appId()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html" title="class in org.apache.gearpump.cluster">ClientToMaster.GetStallingTasks</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.QueryAppMasterConfig.html#appId--">appId()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryAppMasterConfig.html" title="class in org.apache.gearpump.cluster">ClientToMaster.QueryAppMasterConfig</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html#appId--">appId()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html" title="class in org.apache.gearpump.cluster">ClientToMaster.RegisterAppResultListener</a></dt> @@ -745,12 +749,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/external/hbase/HBaseSink.html#apply-org.apache.gearpump.cluster.UserConfig-java.lang.String-">apply(UserConfig, String)</a></span> - Static method in class org.apache.gearpump.external.hbase.<a href="org/apache/gearpump/external/hbase/HBaseSink.html" title="class in org.apache.gearpump.external.hbase">HBaseSink</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/Message.html#apply-java.lang.Object-">apply(Object)</a></span> - Static method in class org.apache.gearpump.<a href="org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a></dt> -<dd> -<div class="block">Instant.EPOCH is used for default timestamp</div> -</dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/Message.html#apply-java.lang.Object-java.time.Instant-">apply(Object, Instant)</a></span> - Static method in class org.apache.gearpump.<a href="org/apache/gearpump/Message.html" title="class in org.apache.gearpump">Message</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/metrics/Metrics.MetricType$.html#apply-org.apache.gearpump.metrics.Metrics.Histogram-org.apache.gearpump.metrics.Metrics.Counter-org.apache.gearpump.metrics.Metrics.Meter-org.apache.gearpump.metrics.Metrics.Timer-org.apache.gearpump.metrics.Metrics.Gauge-">apply(Metrics.Histogram, Metrics.Counter, Metrics.Meter, Metrics.Timer, Metrics.Gauge)</a></span> - Method in class org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.MetricType$.html" title="class in org.apache.gearpump.metrics">Metrics.MetricType$</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/DAG.html#apply-org.apache.gearpump.util.Graph-int-">apply(Graph<ProcessorDescription, PartitionerDescription>, int)</a></span> - Static method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/DAG.html" title="class in org.apache.gearpump.streaming">DAG</a></dt> @@ -769,18 +767,18 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/FlatMapFunction.html#apply-org.apache.gearpump.streaming.dsl.api.functions.FilterFunction-">apply(FilterFunction<T>)</a></span> - Static method in class org.apache.gearpump.streaming.dsl.scalaapi.functions.<a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">FlatMapFunction</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html#apply-org.apache.gearpump.util.Graph-org.apache.gearpump.streaming.dsl.plan.Op-scala.Option-">apply(Graph<Op, OpEdge>, Op, Option<OpEdge>)</a></span> - Static method in class org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html#apply-org.apache.gearpump.util.Graph-org.apache.gearpump.streaming.dsl.plan.Op-scala.Option-org.apache.gearpump.streaming.dsl.window.api.Windows-">apply(Graph<Op, OpEdge>, Op, Option<OpEdge>, Windows)</a></span> - Static method in class org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html#apply-java.lang.String-org.apache.gearpump.cluster.client.ClientContext-org.apache.gearpump.cluster.UserConfig-">apply(String, ClientContext, UserConfig)</a></span> - Static method in class org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">StreamApp</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html#apply-org.apache.gearpump.streaming.dsl.window.api.WindowFunction.Context-">apply(WindowFunction.Context<T>)</a></span> - Method in class 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">CountWindowFunction</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindows.html#apply-int-">apply(int)</a></span> - Static method in class 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">CountWindows</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/FixedWindows.html#apply-java.time.Duration-">apply(Duration)</a></span> - Static method in class org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/FixedWindows.html" title="class in org.apache.gearpump.streaming.dsl.window.api">FixedWindows</a></dt> <dd> <div class="block">Defines a FixedWindow.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindowFunction.html#apply-org.apache.gearpump.streaming.dsl.window.api.WindowFunction.Context-">apply(WindowFunction.Context<T>)</a></span> - Method in class 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">GlobalWindowFunction</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindows.html#apply--">apply()</a></span> - Static method in class 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">GlobalWindows</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html#apply-org.apache.gearpump.streaming.dsl.window.api.WindowFunction.Context-">apply(WindowFunction.Context<T>)</a></span> - Method in class 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">SessionWindowFunction</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindows.html#apply-java.time.Duration-">apply(Duration)</a></span> - Static method in class 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">SessionWindows</a></dt> @@ -805,6 +803,8 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html#apply-org.apache.gearpump.streaming.source.DataSource-int-java.lang.String-org.apache.gearpump.cluster.UserConfig-akka.actor.ActorSystem-">apply(DataSource, int, String, UserConfig, ActorSystem)</a></span> - Static method in class org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source">DataSourceProcessor</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceProcessor.PerElementWindowFunction$.html#apply-org.apache.gearpump.streaming.dsl.window.api.WindowFunction.Context-">apply(WindowFunction.Context<T>)</a></span> - Method in class org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceProcessor.PerElementWindowFunction$.html" title="class in org.apache.gearpump.streaming.source">DataSourceProcessor.PerElementWindowFunction$</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/StreamApplication.html#apply-java.lang.String-org.apache.gearpump.util.Graph-org.apache.gearpump.cluster.UserConfig-">apply(String, Graph<T, P>, UserConfig)</a></span> - Static method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/StreamApplication.html" title="class in org.apache.gearpump.streaming">StreamApplication</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/transport/HostPort.html#apply-java.lang.String-">apply(String)</a></span> - Static method in class org.apache.gearpump.transport.<a href="org/apache/gearpump/transport/HostPort.html" title="class in org.apache.gearpump.transport">HostPort</a></dt> @@ -1411,8 +1411,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html#cause--">cause()</a></span> - Method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class 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">ChainableOp</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class 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">DataSourceOp</a></dt> @@ -1425,12 +1423,13 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">ProcessorOp</a></dt> <dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" title="type parameter in ChainableOp">IN</a>,<a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" title="type parameter in ChainableOp">OUT</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/plan/package-summary.html">org.apache.gearpump.streaming.dsl.plan</a></dt> -<dd> -<div class="block">This represents operations that can be chained together - (e.g.</div> -</dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html#ChainableOp-org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner-org.apache.gearpump.cluster.UserConfig-">ChainableOp(FunctionRunner<IN, OUT>, UserConfig)</a></span> - Constructor for class 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">ChainableOp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/TransformOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class 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">TransformOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class 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">TransformWindowTransformOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/WindowOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class 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">WindowOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html#chain-org.apache.gearpump.streaming.dsl.plan.Op-akka.actor.ActorSystem-">chain(Op, ActorSystem)</a></span> - Method in class 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">WindowTransformOp</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/transport/netty/Client.ChannelReady.html#chanel--">chanel()</a></span> - Method in class org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Client.ChannelReady.html" title="class in org.apache.gearpump.transport.netty">Client.ChannelReady</a></dt> <dd> </dd> @@ -1663,12 +1662,10 @@ </dd> <dt><a href="org/apache/gearpump/cluster/ClientToMaster.GetLastFailure$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetLastFailure$</span></a> - Class in <a href="org/apache/gearpump/cluster/package-summary.html">org.apache.gearpump.cluster</a></dt> <dd> </dd> -<dt><a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetStallingTasks</span></a> - Class in <a href="org/apache/gearpump/cluster/package-summary.html">org.apache.gearpump.cluster</a></dt> +<dt><a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetStallingTasks$</span></a> - Class in <a href="org/apache/gearpump/cluster/package-summary.html">org.apache.gearpump.cluster</a></dt> <dd> <div class="block">If there are message loss, the clock would pause for a while.</div> </dd> -<dt><a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.GetStallingTasks$</span></a> - Class in <a href="org/apache/gearpump/cluster/package-summary.html">org.apache.gearpump.cluster</a></dt> -<dd> </dd> <dt><a href="org/apache/gearpump/cluster/ClientToMaster.JarStoreServerAddress.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.JarStoreServerAddress</span></a> - Class in <a href="org/apache/gearpump/cluster/package-summary.html">org.apache.gearpump.cluster</a></dt> <dd> <div class="block">Service address of JarStore</div> @@ -2123,32 +2120,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.CounterMetricsStore.html#CounterMetricsStore-org.apache.gearpump.util.HistoryMetricsService.HistoryMetricsConfig-">CounterMetricsStore(HistoryMetricsService.HistoryMetricsConfig)</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.CounterMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.CounterMetricsStore</a></dt> <dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/window/api/package-summary.html">org.apache.gearpump.streaming.dsl.window.api</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html#CountTrigger--">CountTrigger()</a></span> - Constructor for class 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">CountTrigger</a></dt> -<dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" title="type parameter in CountTriggerTask">IN</a>,<a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" title="type parameter in CountTriggerTask">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></dt> -<dd> -<div class="block">This task triggers output on number of messages in a window.</div> -</dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html#CountTriggerTask-org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow-org.apache.gearpump.streaming.dsl.window.impl.WindowRunner-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">CountTriggerTask(GroupAlsoByWindow<IN, GROUP>, WindowRunner, TaskContext, UserConfig)</a></span> - Constructor for class 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">CountTriggerTask</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html#CountTriggerTask-org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">CountTriggerTask(GroupAlsoByWindow<IN, GROUP>, TaskContext, UserConfig)</a></span> - Constructor for class 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">CountTriggerTask</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html#CountTriggerTask-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">CountTriggerTask(TaskContext, UserConfig)</a></span> - Constructor for class 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">CountTriggerTask</a></dt> -<dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/CountTriggerTaskSpec.html#CountTriggerTaskSpec--">CountTriggerTaskSpec()</a></span> - Constructor for class 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">CountTriggerTaskSpec</a></dt> -<dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="type parameter in CountWindowFunction">T</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/window/api/package-summary.html">org.apache.gearpump.streaming.dsl.window.api</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html#CountWindowFunction-int-">CountWindowFunction(int)</a></span> - Constructor for class 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">CountWindowFunction</a></dt> -<dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/window/api/package-summary.html">org.apache.gearpump.streaming.dsl.window.api</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/CountWindows.html#CountWindows--">CountWindows()</a></span> - Constructor for class 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">CountWindows</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.AggregatorFactory.html#create-org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem-java.lang.String-">create(MasterToClient.HistoryMetricsItem, String)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.AggregatorFactory.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.AggregatorFactory</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.CreateActor.html#CreateActor-akka.actor.Props-java.lang.String-">CreateActor(Props, String)</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.CreateActor.html" title="class in org.apache.gearpump.util">ActorSystemBooter.CreateActor</a></dt> @@ -2379,7 +2350,7 @@ <dd> <div class="block">This represents a DataSink.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html#DataSinkOp-org.apache.gearpump.streaming.sink.DataSink-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">DataSinkOp(DataSink, int, UserConfig, String)</a></span> - Constructor for class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html#DataSinkOp-org.apache.gearpump.streaming.sink.DataSink-int-java.lang.String-org.apache.gearpump.cluster.UserConfig-">DataSinkOp(DataSink, int, String, UserConfig)</a></span> - Constructor for class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a></dt> <dd> </dd> <dt><a href="org/apache/gearpump/streaming/sink/DataSinkProcessor.html" title="class in org.apache.gearpump.streaming.sink"><span class="typeNameLink">DataSinkProcessor</span></a> - Class in <a href="org/apache/gearpump/streaming/sink/package-summary.html">org.apache.gearpump.streaming.sink</a></dt> <dd> @@ -2414,7 +2385,7 @@ <dd> <div class="block">This represents a DataSource.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html#DataSourceOp-org.apache.gearpump.streaming.source.DataSource-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">DataSourceOp(DataSource, int, UserConfig, String)</a></span> - Constructor for class 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">DataSourceOp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html#DataSourceOp-org.apache.gearpump.streaming.source.DataSource-int-java.lang.String-org.apache.gearpump.cluster.UserConfig-">DataSourceOp(DataSource, int, String, UserConfig)</a></span> - Constructor for class 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">DataSourceOp</a></dt> <dd> </dd> <dt><a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceProcessor</span></a> - Class in <a href="org/apache/gearpump/streaming/source/package-summary.html">org.apache.gearpump.streaming.source</a></dt> <dd> @@ -2423,13 +2394,15 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html#DataSourceProcessor--">DataSourceProcessor()</a></span> - Constructor for class org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source">DataSourceProcessor</a></dt> <dd> </dd> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/source/package-summary.html">org.apache.gearpump.streaming.source</a></dt> +<dd> </dd> <dt><a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceTask</span></a><<a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="type parameter in DataSourceTask">IN</a>,<a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="type parameter in DataSourceTask">OUT</a>> - Class in <a href="org/apache/gearpump/streaming/source/package-summary.html">org.apache.gearpump.streaming.source</a></dt> <dd> <div class="block">Default Task container for <a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source"><code>DataSource</code></a> that reads from DataSource in batch See <a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source"><code>DataSourceProcessor</code></a> for its usage</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceTask.html#DataSourceTask-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-org.apache.gearpump.streaming.source.DataSource-org.apache.gearpump.streaming.dsl.task.TransformTask.Transform-">DataSourceTask(TaskContext, UserConfig, DataSource, TransformTask.Transform<IN, OUT>)</a></span> - Constructor for class org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source">DataSourceTask</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceTask.html#DataSourceTask-org.apache.gearpump.streaming.source.DataSource-org.apache.gearpump.streaming.dsl.window.impl.WindowRunner-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">DataSourceTask(DataSource, WindowRunner<IN, OUT>, TaskContext, UserConfig)</a></span> - Constructor for class org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source">DataSourceTask</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceTask.html#DataSourceTask-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">DataSourceTask(TaskContext, UserConfig)</a></span> - Constructor for class org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceTask.html" title="class in org.apache.gearpump.streaming.source">DataSourceTask</a></dt> <dd> </dd> @@ -2464,6 +2437,18 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html#DefaultKafkaMessageDecoder--">DefaultKafkaMessageDecoder()</a></span> - Constructor for class 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">DefaultKafkaMessageDecoder</a></dt> <dd> </dd> +<dt><a href="org/apache/gearpump/DefaultMessage.html" title="class in org.apache.gearpump"><span class="typeNameLink">DefaultMessage</span></a> - Class in <a href="org/apache/gearpump/package-summary.html">org.apache.gearpump</a></dt> +<dd> +<div class="block">Each message contains an immutable timestamp.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/DefaultMessage.html#DefaultMessage-java.lang.Object-long-">DefaultMessage(Object, long)</a></span> - Constructor for class org.apache.gearpump.<a href="org/apache/gearpump/DefaultMessage.html" title="class in org.apache.gearpump">DefaultMessage</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/DefaultMessage.html#DefaultMessage-java.lang.Object-java.time.Instant-">DefaultMessage(Object, Instant)</a></span> - Constructor for class org.apache.gearpump.<a href="org/apache/gearpump/DefaultMessage.html" title="class in org.apache.gearpump">DefaultMessage</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/DefaultMessage.html#DefaultMessage-java.lang.Object-">DefaultMessage(Object)</a></span> - Constructor for class org.apache.gearpump.<a href="org/apache/gearpump/DefaultMessage.html" title="class in org.apache.gearpump">DefaultMessage</a></dt> +<dd> +<div class="block">Instant.EPOCH is used for default timestamp</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorUtil.html#defaultMsgHandler-akka.actor.ActorRef-">defaultMsgHandler(ActorRef)</a></span> - Static method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorUtil.html" title="class in org.apache.gearpump.util">ActorUtil</a></dt> <dd> </dd> <dt><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> - Class in <a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/package-summary.html">org.apache.gearpump.streaming.kafka.lib.source.grouper</a></dt> @@ -2482,9 +2467,13 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/main/CLIOption.html#defaultValue--">defaultValue()</a></span> - Method in class org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/CLIOption.html" title="class in org.apache.gearpump.cluster.main">CLIOption</a></dt> <dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="type parameter in DefaultWindowRunner">IN</a>,<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="type parameter in DefaultWindowRunner">GROUP</a>,<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="type parameter in DefaultWindowRunner">OUT</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/window/impl/package-summary.html">org.apache.gearpump.streaming.dsl.window.impl</a></dt> +<dt><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><<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="type parameter in DefaultWindowRunner">IN</a>,<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="type parameter in DefaultWindowRunner">OUT</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/window/impl/package-summary.html">org.apache.gearpump.streaming.dsl.window.impl</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html#DefaultWindowRunner-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow-akka.actor.ActorSystem-">DefaultWindowRunner(TaskContext, UserConfig, GroupAlsoByWindow<IN, GROUP>, ActorSystem)</a></span> - Constructor for class 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">DefaultWindowRunner</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html#DefaultWindowRunner-org.apache.gearpump.streaming.dsl.window.api.Windows-org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner-">DefaultWindowRunner(Windows, FunctionRunner<IN, OUT>)</a></span> - Constructor for class 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">DefaultWindowRunner</a></dt> +<dd> </dd> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/window/impl/package-summary.html">org.apache.gearpump.streaming.dsl.window.impl</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunnerSpec.html#DefaultWindowRunnerSpec--">DefaultWindowRunnerSpec()</a></span> - Constructor for class 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">DefaultWindowRunnerSpec</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup.html#DeleteKVGroup-java.lang.String-">DeleteKVGroup(String)</a></span> - Constructor for class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.DeleteKVGroup</a></dt> <dd> </dd> @@ -2514,15 +2503,13 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html#description--">description()</a></span> - Method in class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html#description--">description()</a></span> - Method in class 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">ChainableOp</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html#description--">description()</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html#description--">description()</a></span> - Method in class 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">DataSourceOp</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html#description--">description()</a></span> - Method in class 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">AndThen</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html#description--">description()</a></span> - Method in class 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">Emit</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/DummyRunner.html#description--">description()</a></span> - Method in class 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">DummyRunner</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html#description--">description()</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">FlatMapper</a></dt> <dd> </dd> @@ -2538,6 +2525,16 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html#description--">description()</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">ProcessorOp</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/TransformOp.html#description--">description()</a></span> - Method in class 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">TransformOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html#description--">description()</a></span> - Method in class 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">TransformWindowTransformOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/WindowOp.html#description--">description()</a></span> - Method in class 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">WindowOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html#description--">description()</a></span> - Method in class 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">WindowTransformOp</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html#description--">description()</a></span> - Method in class 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">Windows</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/javaapi/Processor.html#description--">description()</a></span> - Method in class org.apache.gearpump.streaming.javaapi.<a href="org/apache/gearpump/streaming/javaapi/Processor.html" title="class in org.apache.gearpump.streaming.javaapi">Processor</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/Processor.DefaultProcessor.html#description--">description()</a></span> - Method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Processor.DefaultProcessor.html" title="class in org.apache.gearpump.streaming">Processor.DefaultProcessor</a></dt> @@ -2618,6 +2615,10 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.DummyMetricsAggregator.html#DummyMetricsAggregator--">DummyMetricsAggregator()</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.DummyMetricsAggregator.html" title="class in org.apache.gearpump.util">HistoryMetricsService.DummyMetricsAggregator</a></dt> <dd> </dd> +<dt><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><<a href="org/apache/gearpump/streaming/dsl/plan/functions/DummyRunner.html" title="type parameter in DummyRunner">T</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/plan/functions/package-summary.html">org.apache.gearpump.streaming.dsl.plan.functions</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/DummyRunner.html#DummyRunner--">DummyRunner()</a></span> - Constructor for class 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">DummyRunner</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/metrics/Metrics.Timer.html#durationUnit--">durationUnit()</a></span> - Method in class org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.Timer.html" title="class in org.apache.gearpump.metrics">Metrics.Timer</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/executor/Executor.State$.html#DYNAMIC_DAG_PHASE1--">DYNAMIC_DAG_PHASE1()</a></span> - Method in class org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/Executor.State$.html" title="class in org.apache.gearpump.streaming.executor">Executor.State$</a></dt> @@ -2666,10 +2667,6 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html#EmbeddedCluster-com.typesafe.config.Config-">EmbeddedCluster(Config)</a></span> - Constructor for class org.apache.gearpump.cluster.embedded.<a href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html" title="class in org.apache.gearpump.cluster.embedded">EmbeddedCluster</a></dt> <dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html" title="type parameter in Emit">T</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/plan/functions/package-summary.html">org.apache.gearpump.streaming.dsl.plan.functions</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html#Emit-scala.Function1-">Emit(Function1<T, BoxedUnit>)</a></span> - Constructor for class 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">Emit</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/Master.MasterInfo$.html#empty--">empty()</a></span> - Method in class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/Master.MasterInfo$.html" title="class in org.apache.gearpump.cluster.master">Master.MasterInfo$</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/scheduler/Resource.html#empty--">empty()</a></span> - Static method in class org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a></dt> @@ -2746,20 +2743,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html#EventTimeTrigger--">EventTimeTrigger()</a></span> - Constructor for class org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">EventTimeTrigger</a></dt> <dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" title="type parameter in EventTimeTriggerTask">IN</a>,<a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" title="type parameter in EventTimeTriggerTask">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></dt> -<dd> -<div class="block">This task triggers output on watermark progress.</div> -</dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html#EventTimeTriggerTask-org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow-org.apache.gearpump.streaming.dsl.window.impl.WindowRunner-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">EventTimeTriggerTask(GroupAlsoByWindow<IN, GROUP>, WindowRunner, TaskContext, UserConfig)</a></span> - Constructor for class 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">EventTimeTriggerTask</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html#EventTimeTriggerTask-org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">EventTimeTriggerTask(GroupAlsoByWindow<IN, GROUP>, TaskContext, UserConfig)</a></span> - Constructor for class 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">EventTimeTriggerTask</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html#EventTimeTriggerTask-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">EventTimeTriggerTask(TaskContext, UserConfig)</a></span> - Constructor for class 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">EventTimeTriggerTask</a></dt> -<dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTaskSpec.html#EventTimeTriggerTaskSpec--">EventTimeTriggerTaskSpec()</a></span> - Constructor for class 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">EventTimeTriggerTaskSpec</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed.html#ex--">ex()</a></span> - Method in class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVFailed</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed.html#ex--">ex()</a></span> - Method in class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKVFailed</a></dt> @@ -3440,7 +3423,7 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/transport/netty/NettyConfig.html#flushCheckInterval--">flushCheckInterval()</a></span> - Method in class org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyConfig.html" title="class in org.apache.gearpump.transport.netty">NettyConfig</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html#fn--">fn()</a></span> - Method in class 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">ChainableOp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/TransformOp.html#fn--">fn()</a></span> - Method in class 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">TransformOp</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html#fold-A-T-">fold(A, T)</a></span> - Method in class org.apache.gearpump.streaming.dsl.api.functions.<a href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">FoldFunction</a></dt> <dd> </dd> @@ -3614,8 +3597,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/Constants.html#GEARPUMP_STREAMING_SOURCE--">GEARPUMP_STREAMING_SOURCE()</a></span> - Static method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Constants.html" title="class in org.apache.gearpump.streaming">Constants</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/Constants.html#GEARPUMP_STREAMING_WINDOW_FUNCTION--">GEARPUMP_STREAMING_WINDOW_FUNCTION()</a></span> - Static method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Constants.html" title="class in org.apache.gearpump.streaming">Constants</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Constants.html#GEARPUMP_TASK_DISPATCHER--">GEARPUMP_TASK_DISPATCHER()</a></span> - Static method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Constants.html" title="class in org.apache.gearpump.util">Constants</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Constants.html#GEARPUMP_TRANSPORT_SERIALIZER--">GEARPUMP_TRANSPORT_SERIALIZER()</a></span> - Static method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Constants.html" title="class in org.apache.gearpump.util">Constants</a></dt> @@ -3656,7 +3637,7 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/serializer/GearpumpSerialization.html#GearpumpSerialization-com.typesafe.config.Config-">GearpumpSerialization(Config)</a></span> - Constructor for class org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/GearpumpSerialization.html" title="class in org.apache.gearpump.serializer">GearpumpSerialization</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html#gender--">gender()</a></span> - Method in class 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">GroupByPartitionerSpec.People</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People.html#gender--">gender()</a></span> - Method in class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.partitioner">GroupByPartitionerSpec.People</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html#GeneralAppMasterSummary-int-java.lang.String-java.lang.String-java.lang.String-org.apache.gearpump.cluster.ApplicationStatus-long-long-java.lang.String-">GeneralAppMasterSummary(int, String, String, String, ApplicationStatus, long, long, String)</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GeneralAppMasterSummary</a></dt> <dd> </dd> @@ -3882,10 +3863,10 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/hadoop/lib/HadoopUtil.html#getOutputStream-org.apache.hadoop.fs.Path-org.apache.hadoop.conf.Configuration-">getOutputStream(Path, Configuration)</a></span> - Static method in class org.apache.gearpump.streaming.hadoop.lib.<a href="org/apache/gearpump/streaming/hadoop/lib/HadoopUtil.html" title="class in org.apache.gearpump.streaming.hadoop.lib">HadoopUtil</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html#getPartition-org.apache.gearpump.Message-int-int-">getPartition(Message, int, int)</a></span> - Method in class 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">GroupByPartitioner</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html#getPartition-org.apache.gearpump.Message-int-int-">getPartition(Message, int, int)</a></span> - Method in class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">CoLocationPartitioner</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html#getPartition-org.apache.gearpump.Message-int-int-">getPartition(Message, int, int)</a></span> - Method in class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">GroupByPartitioner</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/HashPartitioner.html#getPartition-org.apache.gearpump.Message-int-int-">getPartition(Message, int, int)</a></span> - Method in class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/HashPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">HashPartitioner</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html#getPartition-org.apache.gearpump.Message-int-int-">getPartition(Message, int, int)</a></span> - Method in class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">ShuffleGroupingPartitioner</a></dt> @@ -3912,21 +3893,7 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/MasterHarness.html#getPort--">getPort()</a></span> - Method in interface org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterHarness.html" title="interface in org.apache.gearpump.cluster">MasterHarness</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in class 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">ChainableOp</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in class 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">DataSourceOp</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in class 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">GroupByOp</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in class 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">MergeOp</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/Op.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in interface 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></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html#getProcessor-akka.actor.ActorSystem-">getProcessor(ActorSystem)</a></span> - Method in class org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">ProcessorOp</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html#getProcessor-int-java.lang.String-org.apache.gearpump.cluster.UserConfig-akka.actor.ActorSystem-">getProcessor(int, String, UserConfig, ActorSystem)</a></span> - Method in class 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">GroupAlsoByWindow</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/TaskActor.html#getProcessingWatermark--">getProcessingWatermark()</a></span> - Method in class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskActor.html" title="class in org.apache.gearpump.streaming.task">TaskActor</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/util/KafkaConfig.html#getProducerConfig--">getProducerConfig()</a></span> - Method in class org.apache.gearpump.streaming.kafka.util.<a href="org/apache/gearpump/streaming/kafka/util/KafkaConfig.html" title="class in org.apache.gearpump.streaming.kafka.util">KafkaConfig</a></dt> <dd> </dd> @@ -3952,8 +3919,6 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html#getSleepDuration--">getSleepDuration()</a></span> - Method in class org.apache.gearpump.streaming.kafka.lib.source.consumer.<a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/ExponentialBackoffSleeper.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer">ExponentialBackoffSleeper</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html#GetStallingTasks-int-">GetStallingTasks(int)</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks.html" title="class in org.apache.gearpump.cluster">ClientToMaster.GetStallingTasks</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html#GetStallingTasks:D--">GetStallingTasks$()</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.GetStallingTasks$.html" title="class in org.apache.gearpump.cluster">ClientToMaster.GetStallingTasks$</a></dt> <dd> </dd> <dt><a href="org/apache/gearpump/streaming/task/GetStartClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">GetStartClock</span></a> - Class in <a href="org/apache/gearpump/streaming/task/package-summary.html">org.apache.gearpump.streaming.task</a></dt> @@ -4023,6 +3988,16 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/AppMasterToMaster.GetWorkerData$.html#GetWorkerData:D--">GetWorkerData$()</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GetWorkerData$.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GetWorkerData$</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindowFunction.html#globalWindow--">globalWindow()</a></span> - Static method in class 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">GlobalWindowFunction</a></dt> +<dd> </dd> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/window/api/package-summary.html">org.apache.gearpump.streaming.dsl.window.api</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindowFunction.html#GlobalWindowFunction--">GlobalWindowFunction()</a></span> - Constructor for class 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">GlobalWindowFunction</a></dt> +<dd> </dd> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/window/api/package-summary.html">org.apache.gearpump.streaming.dsl.window.api</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/GlobalWindows.html#GlobalWindows--">GlobalWindows()</a></span> - Constructor for class 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">GlobalWindows</a></dt> +<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/DagManagerSpec.html#graph--">graph()</a></span> - Method in class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster">DagManagerSpec</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/DAG.html#graph--">graph()</a></span> - Method in class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/DAG.html" title="class in org.apache.gearpump.streaming">DAG</a></dt> @@ -4075,30 +4050,18 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/util/KafkaConfig.html#GROUP_ID_DOC">GROUP_ID_DOC</a></span> - Static variable in class org.apache.gearpump.streaming.kafka.util.<a href="org/apache/gearpump/streaming/kafka/util/KafkaConfig.html" title="class in org.apache.gearpump.streaming.kafka.util">KafkaConfig</a></dt> <dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="type parameter in GroupAlsoByWindow">T</a>,<a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="type parameter in GroupAlsoByWindow">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/window/impl/package-summary.html">org.apache.gearpump.streaming.dsl.window.impl</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html#GroupAlsoByWindow-scala.Function1-org.apache.gearpump.streaming.dsl.window.api.Windows-">GroupAlsoByWindow(Function1<T, GROUP>, Windows<T>)</a></span> - Constructor for class 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">GroupAlsoByWindow</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html#groupBy-T-">groupBy(T)</a></span> - Method in class org.apache.gearpump.streaming.dsl.javaapi.functions.<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="class in org.apache.gearpump.streaming.dsl.javaapi.functions">GroupByFunction</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html#groupBy-org.apache.gearpump.streaming.dsl.javaapi.functions.GroupByFunction-int-java.lang.String-">groupBy(GroupByFunction<T, GROUP>, int, String)</a></span> - Method in class 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">JavaStream</a></dt> <dd> <div class="block">Group by a stream and turns it to a list of sub-streams.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/javaapi/JavaWindowStream.html#groupBy-org.apache.gearpump.streaming.dsl.javaapi.functions.GroupByFunction-int-java.lang.String-">groupBy(GroupByFunction<T, GROUP>, int, String)</a></span> - Method in class 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">JavaWindowStream</a></dt> -<dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html#groupBy--">groupBy()</a></span> - Method in class 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">GroupByOp</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html#groupBy-scala.Function1-int-java.lang.String-">groupBy(Function1<T, GROUP>, int, String)</a></span> - Method in class org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a></dt> <dd> <div class="block">Group by function (T => Group)</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/scalaapi/WindowStream.html#groupBy-scala.Function1-int-java.lang.String-">groupBy(Function1<T, GROUP>, int, String)</a></span> - Method in class 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">WindowStream</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html#groupBy-org.apache.gearpump.Message-">groupBy(Message)</a></span> - Method in class 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">GroupAlsoByWindow</a></dt> -<dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html#groupByFn--">groupByFn()</a></span> - Method in class 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">GroupAlsoByWindow</a></dt> -<dd> </dd> <dt><a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="class in org.apache.gearpump.streaming.dsl.javaapi.functions"><span class="typeNameLink">GroupByFunction</span></a><<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="type parameter in GroupByFunction">T</a>,<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="type parameter in GroupByFunction">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/javaapi/functions/package-summary.html">org.apache.gearpump.streaming.dsl.javaapi.functions</a></dt> <dd> <div class="block">Assigns the input value into a group.</div> @@ -4111,23 +4074,33 @@ </dd> <dt><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><<a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" title="type parameter in GroupByOp">IN</a>,<a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" title="type parameter in GroupByOp">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/plan/package-summary.html">org.apache.gearpump.streaming.dsl.plan</a></dt> <dd> -<div class="block">This represents a Processor with window aggregation</div> +<div class="block">This represents a Processor with groupBy and window aggregation</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html#GroupByOp-org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow-int-java.lang.String-org.apache.gearpump.cluster.UserConfig-">GroupByOp(GroupAlsoByWindow<IN, GROUP>, int, String, UserConfig)</a></span> - Constructor for class 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">GroupByOp</a></dt> -<dd> </dd> -<dt><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><<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="type parameter in GroupByPartitioner">T</a>,<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="type parameter in GroupByPartitioner">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/partitioner/package-summary.html">org.apache.gearpump.streaming.dsl.partitioner</a></dt> +<dt><a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">GroupByPartitioner</span></a><<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html" title="type parameter in GroupByPartitioner">T</a>,<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html" title="type parameter in GroupByPartitioner">GROUP</a>> - Class in <a href="org/apache/gearpump/streaming/partitioner/package-summary.html">org.apache.gearpump.streaming.partitioner</a></dt> <dd> <div class="block">Partition messages by applying group by function first.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html#GroupByPartitioner-scala.Function1-">GroupByPartitioner(Function1<T, GROUP>)</a></span> - Constructor for class 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">GroupByPartitioner</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html#GroupByPartitioner-scala.Function1-">GroupByPartitioner(Function1<T, GROUP>)</a></span> - Constructor for class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">GroupByPartitioner</a></dt> <dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/partitioner/package-summary.html">org.apache.gearpump.streaming.dsl.partitioner</a></dt> +<dt><a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">GroupByPartitionerSpec</span></a> - Class in <a href="org/apache/gearpump/streaming/partitioner/package-summary.html">org.apache.gearpump.streaming.partitioner</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.html#GroupByPartitionerSpec--">GroupByPartitionerSpec()</a></span> - Constructor for class 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">GroupByPartitionerSpec</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.html#GroupByPartitionerSpec--">GroupByPartitionerSpec()</a></span> - Constructor for class org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.partitioner">GroupByPartitionerSpec</a></dt> <dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/partitioner/package-summary.html">org.apache.gearpump.streaming.dsl.partitioner</a></dt> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/partitioner/package-summary.html">org.apache.gearpump.streaming.partitioner</a></dt> <dd> </dd> -<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/partitioner/package-summary.html">org.apache.gearpump.streaming.dsl.partitioner</a></dt> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/partitioner/package-summary.html">org.apache.gearpump.streaming.partitioner</a></dt> +<dd> </dd> +<dt><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><<a href="org/apache/gearpump/streaming/dsl/task/GroupByTask.html" title="type parameter in GroupByTask">IN</a>,<a href="org/apache/gearpump/streaming/dsl/task/GroupByTask.html" title="type parameter in GroupByTask">GROUP</a>,<a href="org/apache/gearpump/streaming/dsl/task/GroupByTask.html" title="type parameter in GroupByTask">OUT</a>> - Class in <a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></dt> +<dd> +<div class="block">Processes messages in groups as defined by groupBy function.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/GroupByTask.html#GroupByTask-scala.Function1-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">GroupByTask(Function1<IN, GROUP>, TaskContext, UserConfig)</a></span> - Constructor for class 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">GroupByTask</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/GroupByTask.html#GroupByTask-org.apache.gearpump.streaming.task.TaskContext-org.apache.gearpump.cluster.UserConfig-">GroupByTask(TaskContext, UserConfig)</a></span> - Constructor for class 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">GroupByTask</a></dt> +<dd> </dd> +<dt><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> - Class in <a href="org/apache/gearpump/streaming/dsl/task/package-summary.html">org.apache.gearpump.streaming.dsl.task</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/task/GroupByTaskSpec.html#GroupByTaskSpec--">GroupByTaskSpec()</a></span> - Constructor for class 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">GroupByTaskSpec</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted.html#GroupDeleted-java.lang.String-">GroupDeleted(String)</a></span> - Constructor for class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GroupDeleted</a></dt> <dd> </dd> @@ -4551,6 +4524,8 @@ <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html#isNonMerging--">isNonMerging()</a></span> - Method in interface 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></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/source/DataSourceProcessor.PerElementWindowFunction$.html#isNonMerging--">isNonMerging()</a></span> - Method in class org.apache.gearpump
<TRUNCATED>
