Package org.apache.storm.streams
Class WindowNode
java.lang.Object
org.apache.storm.streams.WindowNode
- All Implemented Interfaces:
Serializable
Node that captures the windowing configurations.
- See Also:
-
Field Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
boolean
void
setEmitsPair
(boolean emitsPair) void
setWindowed
(boolean windowed) toString()
-
Field Details
-
PUNCTUATION
- See Also:
-
outputFields
-
groupingInfo
protected org.apache.storm.streams.GroupingInfo groupingInfo -
componentId
-
parallelism
protected int parallelism
-
-
Method Details