public class RowTimeWindowPropertyCollector extends TimeWindowPropertyCollector<Row>
Constructor and Description |
---|
RowTimeWindowPropertyCollector(scala.Option<Object> startOffset,
scala.Option<Object> endOffset) |
Modifier and Type | Method and Description |
---|---|
Row |
getRow(Row record) |
close, collect, output, windowEnd, windowStart, wrappedCollector
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.