public abstract class BaseWindow<L,I> extends Object implements Window<L,I>
| Modifier and Type | Field and Description |
|---|---|
protected BaseWindowedBolt.Duration |
lag |
protected String |
lateTupleStream |
protected String |
timestampField |
| Constructor and Description |
|---|
BaseWindow() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object o) |
BaseWindowedBolt.Duration |
getLag()
The maximum time lag of the tuple timestamp in milliseconds.
|
String |
getLateTupleStream()
The name of the stream where late arriving tuples should be emitted.
|
String |
getTimestampField()
The name of the field in the tuple that contains the timestamp when the event occurred as a long value.
|
int |
hashCode() |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitgetSlidingInterval, getWindowLengthprotected String timestampField
protected String lateTupleStream
protected BaseWindowedBolt.Duration lag
public String getTimestampField()
WindowThe 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, an IllegalArgumentException will be thrown.
getTimestampField in interface Window<L,I>public String getLateTupleStream()
WindowThe name of the stream where late arriving tuples should be emitted. If this is not provided, the late tuples would be discarded.
getLateTupleStream in interface Window<L,I>public BaseWindowedBolt.Duration getLag()
WindowThe 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.
Copyright © 2021 The Apache Software Foundation. All rights reserved.