public class OutputWithTimerRowHandler extends Object
Constructor and Description |
---|
OutputWithTimerRowHandler(KeyedStateBackend<Row> keyedStateBackend,
InternalTimerService internalTimerService,
TimestampedCollector collector,
KeyContext keyContext,
TypeSerializer namespaceSerializer) |
Modifier and Type | Method and Description |
---|---|
void |
accept(Row runnerOutput,
long timestamp) |
static TypeInformation<Row> |
getRunnerOutputTypeInfo(TypeInformation<?> outputType,
TypeInformation<Row> keyType) |
public OutputWithTimerRowHandler(KeyedStateBackend<Row> keyedStateBackend, InternalTimerService internalTimerService, TimestampedCollector collector, KeyContext keyContext, TypeSerializer namespaceSerializer)
public static TypeInformation<Row> getRunnerOutputTypeInfo(TypeInformation<?> outputType, TypeInformation<Row> keyType)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.