Class BaseWindow<L,I>
java.lang.Object
org.apache.storm.streams.windowing.BaseWindow<L,I>
- All Implemented Interfaces:
Serializable
,Window<L,
I>
- Direct Known Subclasses:
SlidingWindows
,TumblingWindows
- See Also:
-
Field Summary
Modifier and TypeFieldDescriptionprotected BaseWindowedBolt.Duration
protected String
protected String
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
getLag()
The maximum time lag of the tuple timestamp in milliseconds.The name of the stream where late arriving tuples should be emitted.The name of the field in the tuple that contains the timestamp when the event occurred as a long value.int
hashCode()
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.storm.streams.windowing.Window
getSlidingInterval, getWindowLength
-
Field Details
-
timestampField
-
lateTupleStream
-
lag
-
-
Constructor Details
-
BaseWindow
public BaseWindow()
-
-
Method Details
-
getTimestampField
Description copied from interface:Window
The name of the field in the tuple that contains the timestamp when the event occurred as a long value. This is used of event-time based processing. If this config is set and the field is not present in the incoming tuple, anIllegalArgumentException
will be thrown.- Specified by:
getTimestampField
in interfaceWindow<L,
I> - Returns:
- the timestamp field.
-
getLateTupleStream
Description copied from interface:Window
The name of the stream where late arriving tuples should be emitted. If this is not provided, the late tuples would be discarded.- Specified by:
getLateTupleStream
in interfaceWindow<L,
I> - Returns:
- the name of the stream used to emit late tuples on
-
getLag
Description copied from interface:Window
The maximum time lag of the tuple timestamp in milliseconds. It means that the tuple timestamps cannot be out of order by more than this amount. -
equals
-
hashCode
public int hashCode()
-