public class WindowNode extends Object
Node that captures the windowing configurations.
Modifier and Type | Field and Description |
---|---|
protected String |
componentId |
protected org.apache.storm.streams.GroupingInfo |
groupingInfo |
protected Fields |
outputFields |
protected int |
parallelism |
static String |
PUNCTUATION |
Modifier and Type | Method and Description |
---|---|
boolean |
emitsPair() |
Fields |
getOutputFields() |
boolean |
isWindowed() |
void |
setEmitsPair(boolean emitsPair) |
void |
setWindowed(boolean windowed) |
String |
toString() |
public static final String PUNCTUATION
protected final Fields outputFields
protected org.apache.storm.streams.GroupingInfo groupingInfo
protected String componentId
protected int parallelism
public Fields getOutputFields()
public boolean isWindowed()
public void setWindowed(boolean windowed)
public boolean emitsPair()
public void setEmitsPair(boolean emitsPair)
Copyright © 2022 The Apache Software Foundation. All rights reserved.