io.druid.query.lookup

Class KafkaLookupExtractorFactory

java.lang.Object

io.druid.query.lookup.KafkaLookupExtractorFactory

All Implemented Interfaces:

com.google.common.base.Supplier<LookupExtractor>, LookupExtractorFactory

public class KafkaLookupExtractorFactory
extends Object
implements LookupExtractorFactory

Constructor Summary

Constructors

Constructor and Description
KafkaLookupExtractorFactory(NamespaceExtractionCacheManager cacheManager, String kafkaTopic, Map<String,String> kafkaProperties)
KafkaLookupExtractorFactory(NamespaceExtractionCacheManager cacheManager, String kafkaTopic, Map<String,String> kafkaProperties, long connectTimeout, boolean injective)

Method Summary

Modifier and Type	Method and Description
boolean	close() This method will be called to stop the LookupExtractor upon deletion.
LookupExtractor	get()
long	getCompletedEventCount()
long	getConnectTimeout()
LookupIntrospectHandler	getIntrospectHandler()
Map<String,String>	getKafkaProperties()
String	getKafkaTopic()
boolean	isInjective()
boolean	replaces(LookupExtractorFactory other) Determine if this LookupExtractorFactory should replace some other LookupExtractorFactory.
boolean	start() This method will be called to start the LookupExtractor upon registered Calling start multiple times should return true if successfully started.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaLookupExtractorFactory

public KafkaLookupExtractorFactory(NamespaceExtractionCacheManager cacheManager,
                                   String kafkaTopic,
                                   Map<String,String> kafkaProperties,
                                   @Min(value=0L)
                                   long connectTimeout,
                                   boolean injective)

KafkaLookupExtractorFactory

public KafkaLookupExtractorFactory(NamespaceExtractionCacheManager cacheManager,
                                   String kafkaTopic,
                                   Map<String,String> kafkaProperties)

Method Detail

getKafkaTopic

public String getKafkaTopic()

getKafkaProperties

public Map<String,String> getKafkaProperties()

getConnectTimeout

public long getConnectTimeout()

isInjective

public boolean isInjective()

start

public boolean start()

Description copied from interface: LookupExtractorFactory

This method will be called to start the LookupExtractor upon registered Calling start multiple times should return true if successfully started.

Specified by:

start in interface LookupExtractorFactory

Returns:

Returns false if is not successfully started the LookupExtractor otherwise returns true.

close

public boolean close()

Description copied from interface: LookupExtractorFactory

This method will be called to stop the LookupExtractor upon deletion. Calling this method multiple times should always return true if successfully closed.

Specified by:

close in interface LookupExtractorFactory

Returns:

Returns false if not successfully closed the LookupExtractor otherwise returns true

replaces

public boolean replaces(@Nullable
                        LookupExtractorFactory other)

Description copied from interface: LookupExtractorFactory

Determine if this LookupExtractorFactory should replace some other LookupExtractorFactory. This is used to implement no-down-time

Specified by:

replaces in interface LookupExtractorFactory

Parameters:

other - Some other LookupExtractorFactory which might need replaced

Returns:

`true` if the other should be replaced by this one. `false` if this one should not replace the other factory

getIntrospectHandler

@Nullable
public LookupIntrospectHandler getIntrospectHandler()

Specified by:

getIntrospectHandler in interface LookupExtractorFactory

Returns:

Returns the actual introspection request handler, can return null if it is not supported. This will be called once per HTTP request to introspect the actual lookup.

get

public LookupExtractor get()

Specified by:

get in interface com.google.common.base.Supplier<LookupExtractor>

getCompletedEventCount

public long getCompletedEventCount()