public abstract class TimeWindowPropertyCollector<T> extends Object implements Collector<T>
Constructor and Description |
---|
TimeWindowPropertyCollector(scala.Option<Object> windowStartOffset,
scala.Option<Object> windowEndOffset) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the collector.
|
void |
collect(T record)
Emits a record.
|
abstract Row |
getRow(T record) |
Row |
output() |
long |
windowEnd() |
long |
windowStart() |
Collector<T> |
wrappedCollector() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.