io.druid.query.extraction.namespace

Class JDBCExtractionNamespace

java.lang.Object

io.druid.query.extraction.namespace.JDBCExtractionNamespace

All Implemented Interfaces:

ExtractionNamespace

public class JDBCExtractionNamespace
extends Object
implements ExtractionNamespace

Constructor Summary

Constructors

Constructor and Description
JDBCExtractionNamespace(String namespace, MetadataStorageConnectorConfig connectorConfig, String table, String keyColumn, String valueColumn, String tsColumn, org.joda.time.Period pollPeriod)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
MetadataStorageConnectorConfig	getConnectorConfig()
String	getKeyColumn()
String	getNamespace() This is expected to return the namespace name.
long	getPollMs()
String	getTable()
String	getTsColumn()
String	getValueColumn()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

JDBCExtractionNamespace

public JDBCExtractionNamespace(@NotNull
                       String namespace,
                       @NotNull
                       MetadataStorageConnectorConfig connectorConfig,
                       @NotNull
                       String table,
                       @NotNull
                       String keyColumn,
                       @NotNull
                       String valueColumn,
                       @Nullable
                       String tsColumn,
                       @Min(value=0L)@Nullable
                       org.joda.time.Period pollPeriod)

Method Detail

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

getConnectorConfig

public MetadataStorageConnectorConfig getConnectorConfig()

getTable

public String getTable()

getKeyColumn

public String getKeyColumn()

getValueColumn

public String getValueColumn()

getTsColumn

public String getTsColumn()

getPollMs

public long getPollMs()

Specified by:

getPollMs in interface ExtractionNamespace

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object