[
https://issues.apache.org/jira/browse/STORM-1167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15004416#comment-15004416
]
ASF GitHub Bot commented on STORM-1167:
---------------------------------------
Github user ptgoetz commented on a diff in the pull request:
https://github.com/apache/storm/pull/855#discussion_r44814116
--- Diff: storm-core/src/jvm/backtype/storm/topology/TopologyBuilder.java
---
@@ -177,6 +179,21 @@ public BoltDeclarer setBolt(String id, IBasicBolt
bolt, Number parallelism_hint)
}
/**
+ * Define a new bolt in this topology. This defines a windowed bolt,
intended
+ * for windowing operations. The {@link
IWindowedBolt#execute(TupleWindow)} method
+ * is triggered for each window interval with the list of current
events in the window.
+ *
+ * @param id the id of this component. This id is referenced by other
components that want to consume this bolt's outputs.
+ * @param bolt the windowed bolt
+ * @param parallelism_hint the number of tasks that should be assigned
to execute this bolt. Each task will run on a thread in a process somwehere
around the cluster.
+ * @return use the returned object to declare the inputs to this
component
+ * @throws IllegalArgumentException if {@code parallelism_hint} is not
positive
+ */
+ public BoltDeclarer setBolt(String id, IWindowedBolt bolt, Number
parallelism_hint) throws IllegalArgumentException {
--- End diff --
This API addition will require changes in Flux in order for it to support
windowing.
We should file a JIRA to track that.
> Add sliding & tumbling window support for core storm
> ----------------------------------------------------
>
> Key: STORM-1167
> URL: https://issues.apache.org/jira/browse/STORM-1167
> Project: Apache Storm
> Issue Type: Improvement
> Reporter: Arun Mahadevan
> Assignee: Arun Mahadevan
>
> Currently, topologies that needs windowing support requires writing custom
> logic inside bolts making it tedious to handle the windowing and acking logic
> with custom logic.
> We can add framework level support to core storm bolts to process tuples in a
> time or a count based window. Sliding and tumbling windows can be supported.
> Later this can be extended to trident apis as well.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
