Constructor and Description |
---|
RunnerOutputCollector(TimestampedCollector<OUT> collector) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the collector.
|
void |
collect(Row runnerOutput)
Emits a record.
|
static TypeInformation<Row> |
getRunnerOutputTypeInfo(TypeInformation<?> elementDataTypeInfo) |
public RunnerOutputCollector(TimestampedCollector<OUT> collector)
public void collect(Row runnerOutput)
Collector
public void close()
Collector
public static TypeInformation<Row> getRunnerOutputTypeInfo(TypeInformation<?> elementDataTypeInfo)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.