T
- the record type.public class CacheElement<T> extends Object
AbstractBroadcastWrapperOperator
. It could be
either Watermark
, StreamRecord
, etc.Modifier and Type | Class and Description |
---|---|
static class |
CacheElement.Type
The type of cached elements.
|
Constructor and Description |
---|
CacheElement(T record,
long watermark,
CacheElement.Type type) |
Modifier and Type | Method and Description |
---|---|
T |
getRecord() |
CacheElement.Type |
getType() |
long |
getWatermark() |
static <T> CacheElement<T> |
newRecord(T record) |
static <T> CacheElement<T> |
newWatermark(long watermark) |
void |
setRecord(T record) |
void |
setType(CacheElement.Type type) |
void |
setWatermark(long watermark) |
public CacheElement(T record, long watermark, CacheElement.Type type)
public static <T> CacheElement<T> newRecord(T record)
public static <T> CacheElement<T> newWatermark(long watermark)
public T getRecord()
public void setRecord(T record)
public long getWatermark()
public void setWatermark(long watermark)
public CacheElement.Type getType()
public void setType(CacheElement.Type type)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.