public class KeyedTwoInputWithTimerRowFactory extends Object
Constructor and Description |
---|
KeyedTwoInputWithTimerRowFactory() |
Modifier and Type | Method and Description |
---|---|
Row |
fromNormalData(boolean isLeft,
long timestamp,
long watermark,
Row userInput) |
Row |
fromTimer(TimeDomain timeDomain,
long timestamp,
long watermark,
Row key,
byte[] encodedNamespace) |
static TypeInformation<Row> |
getRunnerInputTypeInfo(TypeInformation<Row> userInputType1,
TypeInformation<Row> userInputType2,
TypeInformation<Row> keyType) |
public Row fromNormalData(boolean isLeft, long timestamp, long watermark, Row userInput)
public Row fromTimer(TimeDomain timeDomain, long timestamp, long watermark, Row key, byte[] encodedNamespace)
public static TypeInformation<Row> getRunnerInputTypeInfo(TypeInformation<Row> userInputType1, TypeInformation<Row> userInputType2, TypeInformation<Row> keyType)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.