public class KeyedInputWithTimerRowFactory extends Object
Modifier and Type | Field and Description |
---|---|
protected Row |
reuseRunnerInput |
protected Row |
reuseTimerData
Reusable row for timer data runner inputs.
|
Constructor and Description |
---|
KeyedInputWithTimerRowFactory() |
Modifier and Type | Method and Description |
---|---|
Row |
fromNormalData(long timestamp,
long watermark,
Row reuseNormalData) |
Row |
fromTimer(TimeDomain timeDomain,
long timestamp,
long watermark,
Row key,
byte[] encodedNamespace) |
static TypeInformation<Row> |
getRunnerInputTypeInfo(TypeInformation<Row> normalDataTypeInfo,
TypeInformation<Row> keyType) |
protected final Row reuseRunnerInput
protected final Row reuseTimerData
public Row fromTimer(TimeDomain timeDomain, long timestamp, long watermark, Row key, byte[] encodedNamespace)
public static TypeInformation<Row> getRunnerInputTypeInfo(TypeInformation<Row> normalDataTypeInfo, TypeInformation<Row> keyType)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.