Constructor and Description |
---|
TimerUtils() |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.CoderInfoDescriptor |
createTimerDataCoderInfoDescriptorProto(TypeInformation<Row> timerDataType) |
static TypeInformation<Row> |
createTimerDataTypeInfo(TypeInformation<Row> keyType) |
public static TypeInformation<Row> createTimerDataTypeInfo(TypeInformation<Row> keyType)
public static FlinkFnApi.CoderInfoDescriptor createTimerDataCoderInfoDescriptorProto(TypeInformation<Row> timerDataType)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.