Package org.apache.drill.exec.store.kafka

Class KafkaAsyncCloser

java.lang.Object

org.apache.drill.exec.store.kafka.KafkaAsyncCloser

All Implemented Interfaces:

AutoCloseable

public class KafkaAsyncCloser
extends Object
implements AutoCloseable

Closes Kafka resources asynchronously which result does not depend on close method in order to improve query execution performance. For example, KafkaConsumer.

Constructor Summary

Constructors

Constructor	Description
KafkaAsyncCloser()

Method Summary

Modifier and Type	Method	Description
void	close()
void	close(AutoCloseable autoCloseable)	Closes given resource in separate thread using thread executor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaAsyncCloser

public KafkaAsyncCloser()

Method Details

close

public void close(AutoCloseable autoCloseable)

Closes given resource in separate thread using thread executor.

Parameters:

autoCloseable - resource to close

close

public void close()

Specified by:

close in interface AutoCloseable