Uses of Class
org.apache.drill.exec.work.filter.RuntimeFilterWritable

Packages that use RuntimeFilterWritable

Package	Description
org.apache.drill.exec.ops
org.apache.drill.exec.rpc.data
org.apache.drill.exec.work
org.apache.drill.exec.work.filter

Uses of RuntimeFilterWritable in org.apache.drill.exec.ops

Methods in org.apache.drill.exec.ops that return RuntimeFilterWritable

Modifier and Type	Method	Description
RuntimeFilterWritable	FragmentContext.getRuntimeFilter(long rfIdentifier)
RuntimeFilterWritable	FragmentContext.getRuntimeFilter(long rfIdentifier, long maxWaitTime, TimeUnit timeUnit)	Get the RuntimeFilter with a blocking wait, if the waiting option is enabled.
RuntimeFilterWritable	FragmentContextImpl.getRuntimeFilter(long rfIdentifier)
RuntimeFilterWritable	FragmentContextImpl.getRuntimeFilter(long rfIdentifier, long maxWaitTime, TimeUnit timeUnit)

Methods in org.apache.drill.exec.ops with parameters of type RuntimeFilterWritable

Modifier and Type	Method	Description
void	FragmentContext.addRuntimeFilter(RuntimeFilterWritable runtimeFilter)	Add a RuntimeFilter when the RuntimeFilter receiver belongs to the same MinorFragment.
void	FragmentContextImpl.addRuntimeFilter(RuntimeFilterWritable runtimeFilter)
void	AccountingDataTunnel.sendRuntimeFilter(RuntimeFilterWritable batch)

Uses of RuntimeFilterWritable in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data with parameters of type RuntimeFilterWritable

Modifier and Type	Method	Description
void	DataTunnel.sendRuntimeFilter(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, RuntimeFilterWritable runtimeFilter)

Uses of RuntimeFilterWritable in org.apache.drill.exec.work

Methods in org.apache.drill.exec.work with parameters of type RuntimeFilterWritable

Modifier and Type	Method	Description
void	WorkManager.WorkerBee.receiveRuntimeFilter(RuntimeFilterWritable runtimeFilter)	receive the RuntimeFilter thorough the wire

Uses of RuntimeFilterWritable in org.apache.drill.exec.work.filter

Methods in org.apache.drill.exec.work.filter that return RuntimeFilterWritable

Modifier and Type	Method	Description
RuntimeFilterWritable	RuntimeFilterWritable.duplicate(BufferAllocator bufferAllocator)
RuntimeFilterWritable	RuntimeFilterWritable.newRuntimeFilterWritable(BufferAllocator bufferAllocator)

Methods in org.apache.drill.exec.work.filter with parameters of type RuntimeFilterWritable

Modifier and Type	Method	Description
void	RuntimeFilterSink.add(RuntimeFilterWritable runtimeFilterWritable)
void	RuntimeFilterWritable.aggregate(RuntimeFilterWritable runtimeFilterWritable)
void	RuntimeFilterRouter.register(RuntimeFilterWritable srcRuntimeFilterWritable)	This method is passively invoked by receiving a runtime filter from the network