- All Implemented Interfaces:
- Closeable, AutoCloseable
public class RuntimeFilterSink
This sink receives the RuntimeFilters from the netty thread,
aggregates them in an async thread, broadcast the final aggregated
one to the RuntimeFilterRecordBatch.
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Copyright © 1970 The Apache Software Foundation. All rights reserved.