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(Row record)
Emits a record.
|
TimeWindow |
timeWindow() |
Collector<Row> |
wrappedCollector() |
public TimeWindow timeWindow()
public void collect(Row record)
Collector
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.