org.apache.drill.exec.store.kafka

Class KafkaStoragePluginConfig

java.lang.Object

org.apache.drill.common.logical.StoragePluginConfig

org.apache.drill.exec.store.kafka.KafkaStoragePluginConfig

public class KafkaStoragePluginConfig
extends StoragePluginConfig

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

Constructor Summary

Constructors

Constructor and Description
KafkaStoragePluginConfig(Map<String,String> kafkaConsumerProps)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Properties	getKafkaConsumerProps()
int	hashCode()
String	toString()

Methods inherited from class org.apache.drill.common.logical.StoragePluginConfig

getValue, isEnabled, isEnabledStatusPresent, setEnabled

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

KafkaStoragePluginConfig

public KafkaStoragePluginConfig(Map<String,String> kafkaConsumerProps)

Method Detail

getKafkaConsumerProps

public Properties getKafkaConsumerProps()

hashCode

public int hashCode()

Specified by:

hashCode in class StoragePluginConfig

equals

public boolean equals(Object o)

Specified by:

equals in class StoragePluginConfig

toString

public String toString()

Overrides:

toString in class Object