io.druid.query.extraction.namespace

Class KafkaExtractionNamespace

java.lang.Object

io.druid.query.extraction.namespace.KafkaExtractionNamespace

All Implemented Interfaces:

ExtractionNamespace

public class KafkaExtractionNamespace
extends Object
implements ExtractionNamespace

Constructor Summary

Constructors

Constructor and Description
KafkaExtractionNamespace(String kafkaTopic, String namespace)

Method Summary

Methods

Modifier and Type	Method and Description
String	getKafkaTopic()
String	getNamespace() This is expected to return the namespace name.
long	getPollMs()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaExtractionNamespace

public KafkaExtractionNamespace(@NotNull
                        String kafkaTopic,
                        @NotNull
                        String namespace)

Method Detail

getKafkaTopic

public String getKafkaTopic()

getNamespace

public String getNamespace()

Description copied from interface: ExtractionNamespace

This is expected to return the namespace name. As an additional requirement, the implementation MUST supply a "namespace" field in the json representing the object which is equal to the return of this function

Specified by:

getNamespace in interface ExtractionNamespace

Returns:

The name of the namespace

getPollMs

public long getPollMs()

Specified by:

getPollMs in interface ExtractionNamespace

toString

public String toString()

Overrides:

toString in class Object