Class | Description |
---|---|
RowTimeDeduplicateRecordsCombiner |
An implementation of
RecordsCombiner that stores the first/last records of incremental
input records into the window state. |
RowTimeDeduplicateRecordsCombiner.Factory |
Factory to create
RowTimeDeduplicateRecordsCombiner . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.