Interface | Description |
---|---|
ListenableCollector.CollectListener<T> |
An interface can listen on collecting original record.
|
Class | Description |
---|---|
ListenableCollector<T> |
A listenable collector for lookup join that can be called when an original record was collected.
|
TableFunctionCollector<T> |
The basic implementation of collector for
TableFunction . |
TableFunctionResultFuture<T> |
The basic implementation of collector for
ResultFuture in table joining. |
WrappingCollector<T> |
A
Collector that wraps another collector. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.