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