You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2017/07/13 14:02:29 UTC
[14/51] [partial] incubator-gearpump-site git commit: Update docs for
release 0.8.4
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-o.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-o.html b/content/releases/latest/api/scala/index/index-o.html
index eaef703..3afa874 100644
--- a/content/releases/latest/api/scala/index/index-o.html
+++ b/content/releases/latest/api/scala/index/index-o.html
@@ -57,16 +57,19 @@
<div class="occurrences"><a href="../org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo">ApplicationRuntimeInfo</a> </div>
</div><div class="entry">
<div class="name">onNext</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.CountTriggerTask">CountTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.EventTimeTriggerTask">EventTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask">ProcessingTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" cl
ass="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="..
/org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/GroupByTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.GroupByTask">GroupByTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/g
earpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onRestartTasks</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/executor/Executor.html" class="extype" name="org.apache.gearpump.streaming.executor.Executor">Executor</a> </div>
</div><div class="entry">
+ <div class="name">onStallingTime</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscription.html" class="extype" name="org.apache.gearpump.streaming.task.Subscription">Subscription</a> </div>
+ </div><div class="entry">
<div class="name">onStart</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask">ProcessingTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataS
ourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class=
"extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onStop</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <
a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class=
"extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onTrigger</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/ReduceFnRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.ReduceFnRunner">ReduceFnRunner</a> </div>
@@ -75,7 +78,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> </div>
</div><div class="entry">
<div class="name">onWatermarkProgress</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.EventTimeTriggerTask">EventTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.strea
ming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/GroupByTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.GroupByTask">GroupByTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gear
pump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">open</div>
<div class="occurrences"><a href="../org/apache/gearpump/external/hbase/HBaseSink.html" class="extype" name="org.apache.gearpump.external.hbase.HBaseSink">HBaseSink</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/CollectionDataSource.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.CollectionDataSource">CollectionDataSource</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/LoggerSink.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.LoggerSink">LoggerSink</a> <a href="../org/apache/gearpump/streaming/hadoop/SequenceFileSink.html" class="extype" name="org.apache.gearpump.streaming.hadoop.SequenceFileSink">SequenceFileSink</a> <a href="../org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.sink.AbstractKafkaSink">AbstractKafkaSink</a> <a href="../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" class="extype" name="org
.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource">AbstractKafkaSource</a> <a href="../org/apache/gearpump/streaming/sink/DataSink.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSink">DataSink</a> <a href="../org/apache/gearpump/streaming/source/DataSource.html" class="extype" name="org.apache.gearpump.streaming.source.DataSource">DataSource</a> </div>
@@ -106,5 +109,8 @@
</div><div class="entry">
<div class="name">outputUnManaged</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ </div><div class="entry">
+ <div class="name">outputs</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/TriggeredOutputs.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.TriggeredOutputs">TriggeredOutputs</a> </div>
</div></body>
</html>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-p.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-p.html b/content/releases/latest/api/scala/index/index-p.html
index 529a7ee..41e67b7 100644
--- a/content/releases/latest/api/scala/index/index-p.html
+++ b/content/releases/latest/api/scala/index/index-p.html
@@ -50,6 +50,9 @@
<div class="name">PendingRequest</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/scheduler/Scheduler$.html" class="extype" name="org.apache.gearpump.cluster.scheduler.Scheduler">Scheduler</a> </div>
</div><div class="entry">
+ <div class="name">PerElementWindowFunction</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/source/DataSourceProcessor$.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceProcessor">DataSourceProcessor</a> </div>
+ </div><div class="entry">
<div class="name">PersistentState</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/state/api/package.html" class="extype" name="org.apache.gearpump.streaming.state.api">api</a> </div>
</div><div class="entry">
@@ -77,12 +80,6 @@
<div class="name">ProcessType</div>
<div class="occurrences"><a href="../org/apache/gearpump/util/LogUtil$.html" class="extype" name="org.apache.gearpump.util.LogUtil">LogUtil</a> <a href="../org/apache/gearpump/util/LogUtil$$ProcessType$.html" class="extype" name="org.apache.gearpump.util.LogUtil.ProcessType">ProcessType</a> </div>
</div><div class="entry">
- <div class="name">ProcessingTimeTrigger</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api">api</a> </div>
- </div><div class="entry">
- <div class="name">ProcessingTimeTriggerTask</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.task">task</a> </div>
- </div><div class="entry">
<div class="name">Processor</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/package.html" class="extype" name="org.apache.gearpump.streaming">streaming</a> <a href="../org/apache/gearpump/streaming/javaapi/package.html" class="extype" name="org.apache.gearpump.streaming.javaapi">javaapi</a> </div>
</div><div class="entry">
@@ -138,7 +135,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/metrics/Metrics$$Histogram.html" class="extype" name="org.apache.gearpump.metrics.Metrics.Histogram">Histogram</a> <a href="../org/apache/gearpump/metrics/Metrics$$Timer.html" class="extype" name="org.apache.gearpump.metrics.Metrics.Timer">Timer</a> <a href="../org/apache/gearpump/streaming/metrics/ProcessorAggregator$$HistogramAggregator.html" class="extype" name="org.apache.gearpump.streaming.metrics.ProcessorAggregator.HistogramAggregator">HistogramAggregator</a> </div>
</div><div class="entry">
<div class="name">parallelism</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/Processor.html" class="extype" name="org.apache.gearpump.streaming.Processor">Processor</a> <a href="../org/apache/gearpump/streaming/Processor$$DefaultProcessor.html" class="extype" name="org.apache.gearpump.streaming.Processor.DefaultProcessor">DefaultProcessor</a> <a href="../org/apache/gearpump/streaming/ProcessorDescription.html" class="extype" name="org.apache.gearpump.streaming.ProcessorDescription">ProcessorDescription</a> <a href="../org/apache/gearpump/streaming/appmaster/ClockService$$ProcessorClock.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ClockService.ProcessorClock">ProcessorClock</a> <a href="../org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ProcessorSummary">ProcessorSummary</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" class="extype" name="org.apache.gearpump.streaming
.dsl.plan.DataSinkOp">DataSinkOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp">DataSourceOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.GroupByOp">GroupByOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp">ProcessorOp</a> <a href="../org/apache/gearpump/streaming/javaapi/Processor.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Processor">Processor</a> <a href="../org/apache/gearpump/streaming/task/Subscriber.html" class="extype" name="org.apache.gearpump.streaming.task.Subscriber">Subscriber</a> <a href="../org/apache/gearpump/streaming/task/TaskContext.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContext">TaskContext</a> <a href="../org/apache/gearpump/streaming/
task/TaskContextData.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContextData">TaskContextData</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/Processor.html" class="extype" name="org.apache.gearpump.streaming.Processor">Processor</a> <a href="../org/apache/gearpump/streaming/Processor$$DefaultProcessor.html" class="extype" name="org.apache.gearpump.streaming.Processor.DefaultProcessor">DefaultProcessor</a> <a href="../org/apache/gearpump/streaming/ProcessorDescription.html" class="extype" name="org.apache.gearpump.streaming.ProcessorDescription">ProcessorDescription</a> <a href="../org/apache/gearpump/streaming/appmaster/ClockService$$ProcessorClock.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ClockService.ProcessorClock">ProcessorClock</a> <a href="../org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ProcessorSummary">ProcessorSummary</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" class="extype" name="org.apache.gearpump.streaming
.dsl.plan.DataSinkOp">DataSinkOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp">DataSourceOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.GroupByOp">GroupByOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/MergeOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.MergeOp">MergeOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp">ProcessorOp</a> <a href="../org/apache/gearpump/streaming/javaapi/Processor.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Processor">Processor</a> <a href="../org/apache/gearpump/streaming/task/Subscriber.html" class="extype" name="org.apache.gearpump.streaming.task.Subscriber">Subscriber</a> <a href="../org/apache/gearpump/streaming/task
/TaskContext.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContext">TaskContext</a> <a href="../org/apache/gearpump/streaming/task/TaskContextData.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContextData">TaskContextData</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">parse</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/main/ArgumentsParser.html" class="extype" name="org.apache.gearpump.cluster.main.ArgumentsParser">ArgumentsParser</a> <a href="../org/apache/gearpump/cluster/worker/WorkerId$.html" class="extype" name="org.apache.gearpump.cluster.worker.WorkerId">WorkerId</a> <a href="../org/apache/gearpump/streaming/metrics/TaskFilterAggregator$$Options$.html" class="extype" name="org.apache.gearpump.streaming.metrics.TaskFilterAggregator.Options">Options</a> </div>
@@ -147,7 +144,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/util/Util$.html" class="extype" name="org.apache.gearpump.util.Util">Util</a> </div>
</div><div class="entry">
<div class="name">partitioner</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/package.html" class="extype" name="org.apache.gearpump.streaming.dsl">dsl</a> <a href="../org/apache/gearpump/streaming/package.html" class="extype" name="org.apache.gearpump.streaming">streaming</a> <a href="../org/apache/gearpump/streaming/partitioner/PartitionerByClassName.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerByClassName">PartitionerByClassName</a> <a href="../org/apache/gearpump/streaming/partitioner/PartitionerFactory.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerFactory">PartitionerFactory</a> <a href="../org/apache/gearpump/streaming/partitioner/PartitionerObject.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerObject">PartitionerObject</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/package.html" class="extype" name="org.apache.gearpump.streaming">streaming</a> <a href="../org/apache/gearpump/streaming/partitioner/PartitionerByClassName.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerByClassName">PartitionerByClassName</a> <a href="../org/apache/gearpump/streaming/partitioner/PartitionerFactory.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerFactory">PartitionerFactory</a> <a href="../org/apache/gearpump/streaming/partitioner/PartitionerObject.html" class="extype" name="org.apache.gearpump.streaming.partitioner.PartitionerObject">PartitionerObject</a> </div>
</div><div class="entry">
<div class="name">partitionerDescription</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscriber.html" class="extype" name="org.apache.gearpump.streaming.task.Subscriber">Subscriber</a> </div>
@@ -201,7 +198,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/cluster/scheduler/ResourceRequest.html" class="extype" name="org.apache.gearpump.cluster.scheduler.ResourceRequest">ResourceRequest</a> </div>
</div><div class="entry">
<div class="name">process</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" class="extype" name="org.apache.gearpump.streaming.dsl.javaapi.JavaStream">JavaStream</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen">AndThen</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/Emit.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.Emit">Emit</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper">FlatMapper</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner">FoldRunner</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" class="extype" name="org.apache.gearpump.streaming
.dsl.plan.functions.FunctionRunner">FunctionRunner</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.Stream">Stream</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner">DefaultWindowRunner</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/ReduceFnRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.ReduceFnRunner">ReduceFnRunner</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.WindowRunner">WindowRunner</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" class="extype" name="org.apache.gearpump.streaming.dsl.javaapi.JavaStream">JavaStream</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen">AndThen</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/DummyRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.DummyRunner">DummyRunner</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper">FlatMapper</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner">FoldRunner</a> <a href="../org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" class="extype" name="org.apac
he.gearpump.streaming.dsl.plan.functions.FunctionRunner">FunctionRunner</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.Stream">Stream</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.AndThen">AndThen</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner">DefaultWindowRunner</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/ReduceFnRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.ReduceFnRunner">ReduceFnRunner</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.WindowRunner">WindowRunner</a> </div>
</div><div class="entry">
<div class="name">processMessage</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> </div>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-r.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-r.html b/content/releases/latest/api/scala/index/index-r.html
index e4bfb00..820fd61 100644
--- a/content/releases/latest/api/scala/index/index-r.html
+++ b/content/releases/latest/api/scala/index/index-r.html
@@ -243,7 +243,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscription.html" class="extype" name="org.apache.gearpump.streaming.task.Subscription">Subscription</a> </div>
</div><div class="entry">
<div class="name">receiveUnManagedMessage</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask">ProcessingTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">recover</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/appmaster/AppMaster.html" class="extype" name="org.apache.gearpump.streaming.appmaster.AppMaster">AppMaster</a> <a href="../org/apache/gearpump/streaming/hadoop/HadoopCheckpointStore.html" class="extype" name="org.apache.gearpump.streaming.hadoop.HadoopCheckpointStore">HadoopCheckpointStore</a> <a href="../org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.store.KafkaStore">KafkaStore</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentState.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentState">PersistentState</a> <a href="../org/apache/gearpump/streaming/state/impl/CheckpointManager.html" class="extype" name="org.apache.gearpump.streaming.state.impl.CheckpointManager">CheckpointManager</a> <a href="../org/apache/gearpump/streaming/state/impl/InMemoryCheckpointStore.html" class="extype" name="org
.apache.gearpump.streaming.state.impl.InMemoryCheckpointStore">InMemoryCheckpointStore</a> <a href="../org/apache/gearpump/streaming/state/impl/NonWindowState.html" class="extype" name="org.apache.gearpump.streaming.state.impl.NonWindowState">NonWindowState</a> <a href="../org/apache/gearpump/streaming/state/impl/WindowState.html" class="extype" name="org.apache.gearpump.streaming.state.impl.WindowState">WindowState</a> <a href="../org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" class="extype" name="org.apache.gearpump.streaming.transaction.api.CheckpointStore">CheckpointStore</a> </div>
@@ -362,6 +362,9 @@
<div class="name">retainRecentDataSeconds</div>
<div class="occurrences"><a href="../org/apache/gearpump/util/HistoryMetricsService$$HistoryMetricsConfig.html" class="extype" name="org.apache.gearpump.util.HistoryMetricsService.HistoryMetricsConfig">HistoryMetricsConfig</a> </div>
</div><div class="entry">
+ <div class="name">right</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.AndThen">AndThen</a> </div>
+ </div><div class="entry">
<div class="name">rotate</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html" class="extype" name="org.apache.gearpump.streaming.hadoop.lib.rotation.FileSizeRotation">FileSizeRotation</a> <a href="../org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html" class="extype" name="org.apache.gearpump.streaming.hadoop.lib.rotation.Rotation">Rotation</a> </div>
</div><div class="entry">
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-s.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-s.html b/content/releases/latest/api/scala/index/index-s.html
index 1801e5c..99ae63c 100644
--- a/content/releases/latest/api/scala/index/index-s.html
+++ b/content/releases/latest/api/scala/index/index-s.html
@@ -266,9 +266,6 @@
<div class="name">selfCheck</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/appmaster/ClockService.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ClockService">ClockService</a> </div>
</div><div class="entry">
- <div class="name">sendAckRequestOnStallingTime</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscription.html" class="extype" name="org.apache.gearpump.streaming.task.Subscription">Subscription</a> </div>
- </div><div class="entry">
<div class="name">sendMessage</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscription.html" class="extype" name="org.apache.gearpump.streaming.task.Subscription">Subscription</a> </div>
</div><div class="entry">
@@ -348,7 +345,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/scalaapi/Stream$$Sink.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.Stream.Sink">Sink</a> <a href="../org/apache/gearpump/streaming/kafka/lib/package.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib">lib</a> <a href="../org/apache/gearpump/streaming/package.html" class="extype" name="org.apache.gearpump.streaming">streaming</a> </div>
</div><div class="entry">
<div class="name">size</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction">CountWindowFunction</a> <a href="../org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction">SlidingWindowFunction</a> <a href="../org/apache/gearpump/streaming/metrics/ProcessorAggregator$$MultiLayerMap.html" class="extype" name="org.apache.gearpump.streaming.metrics.ProcessorAggregator.MultiLayerMap">MultiLayerMap</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction">SlidingWindowFunction</a> <a href="../org/apache/gearpump/streaming/metrics/ProcessorAggregator$$MultiLayerMap.html" class="extype" name="org.apache.gearpump.streaming.metrics.ProcessorAggregator.MultiLayerMap">MultiLayerMap</a> </div>
</div><div class="entry">
<div class="name">skipBytes</div>
<div class="occurrences"><a href="../org/apache/gearpump/transport/netty/WrappedChannelBuffer.html" class="extype" name="org.apache.gearpump.transport.netty.WrappedChannelBuffer">WrappedChannelBuffer</a> </div>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-t.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-t.html b/content/releases/latest/api/scala/index/index-t.html
index 386d8f0..764792f 100644
--- a/content/releases/latest/api/scala/index/index-t.html
+++ b/content/releases/latest/api/scala/index/index-t.html
@@ -143,20 +143,26 @@
<div class="name">Timer</div>
<div class="occurrences"><a href="../org/apache/gearpump/metrics/Metrics$.html" class="extype" name="org.apache.gearpump.metrics.Metrics">Metrics</a> </div>
</div><div class="entry">
- <div class="name">Transform</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> </div>
+ <div class="name">TimestampedValue</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl">impl</a> </div>
+ </div><div class="entry">
+ <div class="name">TransformOp</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
</div><div class="entry">
<div class="name">TransformTask</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.task">task</a> </div>
</div><div class="entry">
+ <div class="name">TransformWindowTransformOp</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
+ </div><div class="entry">
<div class="name">TransitToNewDag</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/appmaster/JarScheduler$.html" class="extype" name="org.apache.gearpump.streaming.appmaster.JarScheduler">JarScheduler</a> </div>
</div><div class="entry">
<div class="name">Trigger</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api">api</a> </div>
</div><div class="entry">
- <div class="name">Triggering</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask$.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask">ProcessingTimeTriggerTask</a> </div>
+ <div class="name">TriggeredOutputs</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl">impl</a> </div>
</div><div class="entry">
<div class="name">Type</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/master/MasterStatus$.html" class="extype" name="org.apache.gearpump.cluster.master.MasterStatus">MasterStatus</a> </div>
@@ -225,7 +231,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/cluster/MasterToClient$$HistoryMetricsItem.html" class="extype" name="org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem">HistoryMetricsItem</a> <a href="../org/apache/gearpump/cluster/MasterToClient$$LastFailure.html" class="extype" name="org.apache.gearpump.cluster.MasterToClient.LastFailure">LastFailure</a> <a href="../org/apache/gearpump/cluster/master/MasterActivity.html" class="extype" name="org.apache.gearpump.cluster.master.MasterActivity">MasterActivity</a> <a href="../org/apache/gearpump/streaming/task/UpdateClock.html" class="extype" name="org.apache.gearpump.streaming.task.UpdateClock">UpdateClock</a> </div>
</div><div class="entry">
<div class="name">timeInMillis</div>
- <div class="occurrences"><a href="../org/apache/gearpump/Message.html" class="extype" name="org.apache.gearpump.Message">Message</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/DefaultMessage.html" class="extype" name="org.apache.gearpump.DefaultMessage">DefaultMessage</a> </div>
</div><div class="entry">
<div class="name">timeStamp</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/AppMasterToMaster$$ApplicationStatusChanged.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged">ApplicationStatusChanged</a> <a href="../org/apache/gearpump/cluster/scheduler/Scheduler$$PendingRequest.html" class="extype" name="org.apache.gearpump.cluster.scheduler.Scheduler.PendingRequest">PendingRequest</a> <a href="../org/apache/gearpump/streaming/task/SerializedMessage.html" class="extype" name="org.apache.gearpump.streaming.task.SerializedMessage">SerializedMessage</a> </div>
@@ -234,7 +240,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/jarstore/JarStoreServer.html" class="extype" name="org.apache.gearpump.jarstore.JarStoreServer">JarStoreServer</a> <a href="../org/apache/gearpump/streaming/storage/InMemoryAppStoreOnMaster.html" class="extype" name="org.apache.gearpump.streaming.storage.InMemoryAppStoreOnMaster">InMemoryAppStoreOnMaster</a> <a href="../org/apache/gearpump/util/ActorSystemBooter$$Daemon.html" class="extype" name="org.apache.gearpump.util.ActorSystemBooter.Daemon">Daemon</a> </div>
</div><div class="entry">
<div class="name">timestamp</div>
- <div class="occurrences"><a href="../org/apache/gearpump/Message.html" class="extype" name="org.apache.gearpump.Message">Message</a> <a href="../org/apache/gearpump/streaming/dsl/window/api/WindowFunction$$Context.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.WindowFunction.Context">Context</a> <a href="../org/apache/gearpump/streaming/task/LatencyProbe.html" class="extype" name="org.apache.gearpump.streaming.task.LatencyProbe">LatencyProbe</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/DefaultMessage.html" class="extype" name="org.apache.gearpump.DefaultMessage">DefaultMessage</a> <a href="../org/apache/gearpump/Message.html" class="extype" name="org.apache.gearpump.Message">Message</a> <a href="../org/apache/gearpump/streaming/dsl/window/api/WindowFunction$$Context.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.WindowFunction.Context">Context</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/TimestampedValue.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.TimestampedValue">TimestampedValue</a> <a href="../org/apache/gearpump/streaming/task/LatencyProbe.html" class="extype" name="org.apache.gearpump.streaming.task.LatencyProbe">LatencyProbe</a> </div>
</div><div class="entry">
<div class="name">to</div>
<div class="occurrences"><a href="../org/apache/gearpump/util/Graph$$Node.html" class="extype" name="org.apache.gearpump.util.Graph.Node">Node</a> <a href="../org/apache/gearpump/util/Graph$$NodeList.html" class="extype" name="org.apache.gearpump.util.Graph.NodeList">NodeList</a> <a href="../org/apache/gearpump/util/Graph$$Path.html" class="extype" name="org.apache.gearpump.util.Graph.Path">Path</a> </div>
@@ -248,6 +254,9 @@
<div class="name">toMessage</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/source/Watermark.html" class="extype" name="org.apache.gearpump.streaming.source.Watermark">Watermark</a> </div>
</div><div class="entry">
+ <div class="name">toProcessor</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp">DataSinkOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp">DataSourceOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.GroupByOp">GroupByOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/MergeOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.MergeOp">MergeOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/Op.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.Op">Op</a> <a href="../org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp">ProcessorOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/TransformOp.
html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.TransformOp">TransformOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp">TransformWindowTransformOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/WindowOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.WindowOp">WindowOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.WindowTransformOp">WindowTransformOp</a> </div>
+ </div><div class="entry">
<div class="name">toString</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/ApplicationStatus.html" class="extype" name="org.apache.gearpump.cluster.ApplicationStatus">ApplicationStatus</a> <a href="../org/apache/gearpump/cluster/ClientToMaster$$CommandResult.html" class="extype" name="org.apache.gearpump.cluster.ClientToMaster.CommandResult">CommandResult</a> <a href="../org/apache/gearpump/util/Graph.html" class="extype" name="org.apache.gearpump.util.Graph">Graph</a> </div>
</div><div class="entry">
@@ -272,6 +281,9 @@
<div class="name">transaction</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/package.html" class="extype" name="org.apache.gearpump.streaming">streaming</a> </div>
</div><div class="entry">
+ <div class="name">transformOp</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp">TransformWindowTransformOp</a> </div>
+ </div><div class="entry">
<div class="name">translateToActorRef</div>
<div class="occurrences"><a href="../org/apache/gearpump/transport/netty/Server$$TaskIdActorRefTranslation.html" class="extype" name="org.apache.gearpump.transport.netty.Server.TaskIdActorRefTranslation">TaskIdActorRefTranslation</a> </div>
</div><div class="entry">
@@ -282,7 +294,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/transport/netty/Client$$Connect.html" class="extype" name="org.apache.gearpump.transport.netty.Client.Connect">Connect</a> </div>
</div><div class="entry">
<div class="name">trigger</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/Windows.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.Windows">Windows</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner">DefaultWindowRunner</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.WindowRunner">WindowRunner</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/Windows.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.Windows">Windows</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/AndThen.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.AndThen">AndThen</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner">DefaultWindowRunner</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.WindowRunner">WindowRunner</a> <a href="../org/apache/gearpump/streaming/task/TaskUtil$.html" class="extype" name="org.apache.gearpump.streaming.task.TaskUtil">TaskUtil</a> </div>
</div><div class="entry">
<div class="name">triggering</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/Windows.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.Windows">Windows</a> </div>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-u.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-u.html b/content/releases/latest/api/scala/index/index-u.html
index 1d5d632..13f0ea3 100644
--- a/content/releases/latest/api/scala/index/index-u.html
+++ b/content/releases/latest/api/scala/index/index-u.html
@@ -77,6 +77,9 @@
<div class="name">updateState</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/state/api/MonoidState.html" class="extype" name="org.apache.gearpump.streaming.state.api.MonoidState">MonoidState</a> </div>
</div><div class="entry">
+ <div class="name">updateWatermark</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskContext.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContext">TaskContext</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
+ </div><div class="entry">
<div class="name">upload</div>
<div class="occurrences"><a href="../org/apache/gearpump/jarstore/FileServer$$Client.html" class="extype" name="org.apache.gearpump.jarstore.FileServer.Client">Client</a> </div>
</div><div class="entry">
@@ -105,7 +108,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/cluster/AppMasterToMaster$$AppMasterSummary.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.AppMasterSummary">AppMasterSummary</a> <a href="../org/apache/gearpump/cluster/AppMasterToMaster$$GeneralAppMasterSummary.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary">GeneralAppMasterSummary</a> <a href="../org/apache/gearpump/cluster/MasterToAppMaster$$AppMasterData.html" class="extype" name="org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData">AppMasterData</a> <a href="../org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo">ApplicationRuntimeInfo</a> <a href="../org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" class="extype" name="org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary">StreamAppMasterSummary</a> </div>
</div><div class="entry">
<div class="name">userConfig</div>
- <div class="occurrences"><a href="../org/apache/gearpump/cluster/AppDescription.html" class="extype" name="org.apache.gearpump.cluster.AppDescription">AppDescription</a> <a href="../org/apache/gearpump/cluster/Application.html" class="extype" name="org.apache.gearpump.cluster.Application">Application</a> <a href="../org/apache/gearpump/cluster/Application$$DefaultApplication.html" class="extype" name="org.apache.gearpump.cluster.Application.DefaultApplication">DefaultApplication</a> <a href="../org/apache/gearpump/streaming/StreamApplication.html" class="extype" name="org.apache.gearpump.streaming.StreamApplication">StreamApplication</a> <a href="../org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.ChainableOp">ChainableOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp">DataSinkOp</a> <a href="../org/apache/gearpump/
streaming/dsl/plan/DataSourceOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp">DataSourceOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.GroupByOp">GroupByOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/MergeOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.MergeOp">MergeOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/Op.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.Op">Op</a> <a href="../org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp">ProcessorOp</a> <a href="../org/apache/gearpump/streaming/javaapi/StreamApplication.html" class="extype" name="org.apache.gearpump.streaming.javaapi.StreamApplication">StreamApplication</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/cluster/AppDescription.html" class="extype" name="org.apache.gearpump.cluster.AppDescription">AppDescription</a> <a href="../org/apache/gearpump/cluster/Application.html" class="extype" name="org.apache.gearpump.cluster.Application">Application</a> <a href="../org/apache/gearpump/cluster/Application$$DefaultApplication.html" class="extype" name="org.apache.gearpump.cluster.Application.DefaultApplication">DefaultApplication</a> <a href="../org/apache/gearpump/streaming/StreamApplication.html" class="extype" name="org.apache.gearpump.streaming.StreamApplication">StreamApplication</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp">DataSinkOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp">DataSourceOp</a> <a href="../org/apache/gearpu
mp/streaming/dsl/plan/GroupByOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.GroupByOp">GroupByOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/MergeOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.MergeOp">MergeOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/Op.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.Op">Op</a> <a href="../org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp">ProcessorOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/TransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.TransformOp">TransformOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp">TransformWindowTransformOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/WindowOp.html" class="extyp
e" name="org.apache.gearpump.streaming.dsl.plan.WindowOp">WindowOp</a> <a href="../org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.WindowTransformOp">WindowTransformOp</a> <a href="../org/apache/gearpump/streaming/javaapi/StreamApplication.html" class="extype" name="org.apache.gearpump.streaming.javaapi.StreamApplication">StreamApplication</a> </div>
</div><div class="entry">
<div class="name">username</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/AppMasterContext.html" class="extype" name="org.apache.gearpump.cluster.AppMasterContext">AppMasterContext</a> <a href="../org/apache/gearpump/cluster/ClientToMaster$$SubmitApplication.html" class="extype" name="org.apache.gearpump.cluster.ClientToMaster.SubmitApplication">SubmitApplication</a> <a href="../org/apache/gearpump/cluster/ExecutorJVMConfig.html" class="extype" name="org.apache.gearpump.cluster.ExecutorJVMConfig">ExecutorJVMConfig</a> <a href="../org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ApplicationMetaData">ApplicationMetaData</a> <a href="../org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler$$ExecutorSystemJvmConfig.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler.ExecutorSystemJvmConfig">ExecutorSystemJvmConfig</a> <a href="../org/apache/gearpump/util/ActorSystemBooter$
$Daemon.html" class="extype" name="org.apache.gearpump.util.ActorSystemBooter.Daemon">Daemon</a> </div>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-v.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-v.html b/content/releases/latest/api/scala/index/index-v.html
index 368de8e..4050e6d 100644
--- a/content/releases/latest/api/scala/index/index-v.html
+++ b/content/releases/latest/api/scala/index/index-v.html
@@ -18,7 +18,7 @@
<div class="occurrences"><a href="../org/apache/gearpump/util/Util$.html" class="extype" name="org.apache.gearpump.util.Util">Util</a> </div>
</div><div class="entry">
<div class="name">value</div>
- <div class="occurrences"><a href="../org/apache/gearpump/cluster/AppMasterToMaster$$GetAppDataResult.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.GetAppDataResult">GetAppDataResult</a> <a href="../org/apache/gearpump/cluster/AppMasterToMaster$$SaveAppData.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.SaveAppData">SaveAppData</a> <a href="../org/apache/gearpump/cluster/MasterToClient$$HistoryMetricsItem.html" class="extype" name="org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem">HistoryMetricsItem</a> <a href="../org/apache/gearpump/cluster/master/InMemoryKVService$$GetKVSuccess.html" class="extype" name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKVSuccess">GetKVSuccess</a> <a href="../org/apache/gearpump/cluster/master/InMemoryKVService$$PutKV.html" class="extype" name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKV">PutKV</a> <a href="../org/apache/gearpump/metrics/Metrics$$Counter.h
tml" class="extype" name="org.apache.gearpump.metrics.Metrics.Counter">Counter</a> <a href="../org/apache/gearpump/metrics/Metrics$$Gauge.html" class="extype" name="org.apache.gearpump.metrics.Metrics.Gauge">Gauge</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/DefaultMessage.html" class="extype" name="org.apache.gearpump.DefaultMessage">DefaultMessage</a> <a href="../org/apache/gearpump/Message.html" class="extype" name="org.apache.gearpump.Message">Message</a> <a href="../org/apache/gearpump/cluster/AppMasterToMaster$$GetAppDataResult.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.GetAppDataResult">GetAppDataResult</a> <a href="../org/apache/gearpump/cluster/AppMasterToMaster$$SaveAppData.html" class="extype" name="org.apache.gearpump.cluster.AppMasterToMaster.SaveAppData">SaveAppData</a> <a href="../org/apache/gearpump/cluster/MasterToClient$$HistoryMetricsItem.html" class="extype" name="org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem">HistoryMetricsItem</a> <a href="../org/apache/gearpump/cluster/master/InMemoryKVService$$GetKVSuccess.html" class="extype" name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKVSuccess">GetKVSu
ccess</a> <a href="../org/apache/gearpump/cluster/master/InMemoryKVService$$PutKV.html" class="extype" name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKV">PutKV</a> <a href="../org/apache/gearpump/metrics/Metrics$$Counter.html" class="extype" name="org.apache.gearpump.metrics.Metrics.Counter">Counter</a> <a href="../org/apache/gearpump/metrics/Metrics$$Gauge.html" class="extype" name="org.apache.gearpump.metrics.Metrics.Gauge">Gauge</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/TimestampedValue.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.TimestampedValue">TimestampedValue</a> </div>
</div><div class="entry">
<div class="name">valueIterator</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/metrics/ProcessorAggregator$$MultiLayerMap.html" class="extype" name="org.apache.gearpump.streaming.metrics.ProcessorAggregator.MultiLayerMap">MultiLayerMap</a> </div>
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/f2a69d38/content/releases/latest/api/scala/index/index-w.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index/index-w.html b/content/releases/latest/api/scala/index/index-w.html
index ceca8bf..2297b6d 100644
--- a/content/releases/latest/api/scala/index/index-w.html
+++ b/content/releases/latest/api/scala/index/index-w.html
@@ -38,14 +38,17 @@
<div class="name">WindowFunction</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api">api</a> </div>
</div><div class="entry">
+ <div class="name">WindowOp</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
+ </div><div class="entry">
<div class="name">WindowRunner</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl">impl</a> </div>
</div><div class="entry">
<div class="name">WindowState</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/state/impl/package.html" class="extype" name="org.apache.gearpump.streaming.state.impl">impl</a> </div>
</div><div class="entry">
- <div class="name">WindowStream</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/scalaapi/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi">scalaapi</a> </div>
+ <div class="name">WindowTransformOp</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
</div><div class="entry">
<div class="name">Windows</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api">api</a> </div>
@@ -120,7 +123,10 @@
<div class="occurrences"><a href="../org/apache/gearpump/cluster/main/MasterWatcher.html" class="extype" name="org.apache.gearpump.cluster.main.MasterWatcher">MasterWatcher</a> </div>
</div><div class="entry">
<div class="name">waitForStartClock</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/appmaster/ClockService.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ClockService">ClockService</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/appmaster/ClockService.html" class="extype" name="org.apache.gearpump.streaming.appmaster.ClockService">ClockService</a> </div>
+ </div><div class="entry">
+ <div class="name">waitForStartTask</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> </div>
</div><div class="entry">
<div class="name">waitForTaskRegistered</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> </div>
@@ -135,20 +141,29 @@
<div class="occurrences"><a href="../org/apache/gearpump/cluster/master/MasterProxy.html" class="extype" name="org.apache.gearpump.cluster.master.MasterProxy">MasterProxy</a> </div>
</div><div class="entry">
<div class="name">watermark</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.MessageAndWatermark">MessageAndWatermark</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/TriggeredOutputs.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.TriggeredOutputs">TriggeredOutputs</a> <a href="../org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.MessageAndWatermark">MessageAndWatermark</a> <a href="../org/apache/gearpump/streaming/task/Subscription.html" class="extype" name="org.apache.gearpump.streaming.task.Subscription">Subscription</a> </div>
</div><div class="entry">
<div class="name">window</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" class="extype" name="org.apache.gearpump.streaming.dsl.javaapi.JavaStream">JavaStream</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.Stream">Stream</a> <a href="../org/apache/gearpump/streaming/dsl/package.html" class="extype" name="org.apache.gearpump.streaming.dsl">dsl</a> <a href="../org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow">GroupAlsoByWindow</a> </div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" class="extype" name="org.apache.gearpump.streaming.dsl.javaapi.JavaStream">JavaStream</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.Stream">Stream</a> <a href="../org/apache/gearpump/streaming/dsl/package.html" class="extype" name="org.apache.gearpump.streaming.dsl">dsl</a> </div>
</div><div class="entry">
<div class="name">windowFn</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/api/Windows.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.api.Windows">Windows</a> </div>
</div><div class="entry">
+ <div class="name">windowRunner</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/WindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.WindowTransformOp">WindowTransformOp</a> </div>
+ </div><div class="entry">
<div class="name">windowSize</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/state/impl/Window.html" class="extype" name="org.apache.gearpump.streaming.state.impl.Window">Window</a> <a href="../org/apache/gearpump/streaming/state/impl/WindowConfig.html" class="extype" name="org.apache.gearpump.streaming.state.impl.WindowConfig">WindowConfig</a> </div>
</div><div class="entry">
<div class="name">windowStep</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/state/impl/Window.html" class="extype" name="org.apache.gearpump.streaming.state.impl.Window">Window</a> <a href="../org/apache/gearpump/streaming/state/impl/WindowConfig.html" class="extype" name="org.apache.gearpump.streaming.state.impl.WindowConfig">WindowConfig</a> </div>
</div><div class="entry">
+ <div class="name">windowTransformOp</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/TransformWindowTransformOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.TransformWindowTransformOp">TransformWindowTransformOp</a> </div>
+ </div><div class="entry">
+ <div class="name">windows</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/WindowOp.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.WindowOp">WindowOp</a> </div>
+ </div><div class="entry">
<div class="name">withBoolean</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/UserConfig.html" class="extype" name="org.apache.gearpump.cluster.UserConfig">UserConfig</a> </div>
</div><div class="entry">
@@ -164,12 +179,12 @@
<div class="name">withDouble</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/UserConfig.html" class="extype" name="org.apache.gearpump.cluster.UserConfig">UserConfig</a> </div>
</div><div class="entry">
- <div class="name">withEmitFn</div>
- <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner$.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner">FunctionRunner</a> </div>
- </div><div class="entry">
<div class="name">withFloat</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/UserConfig.html" class="extype" name="org.apache.gearpump.cluster.UserConfig">UserConfig</a> </div>
</div><div class="entry">
+ <div class="name">withGlobalWindowsDummyRunner</div>
+ <div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/Op$.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan.Op">Op</a> </div>
+ </div><div class="entry">
<div class="name">withInt</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/UserConfig.html" class="extype" name="org.apache.gearpump.cluster.UserConfig">UserConfig</a> </div>
</div><div class="entry">