Package org.apache.drill.exec.store.elasticsearch

Class ElasticsearchStorageConfig

java.lang.Object

org.apache.drill.common.logical.StoragePluginConfig

org.apache.drill.exec.store.elasticsearch.ElasticsearchStorageConfig

public class ElasticsearchStorageConfig
extends StoragePluginConfig

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.common.logical.StoragePluginConfig

StoragePluginConfig.AuthMode

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CREDENTIALS_PROVIDER
static final String	NAME

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

authMode, credentialsProvider, directCredentials, enabled, oAuthConfig

Constructor Summary

Constructors

Constructor	Description
ElasticsearchStorageConfig(List<String> hosts, String username, String password, String pathPrefix, String authMode, boolean disableSSLVerification, CredentialsProvider credentialsProvider)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
boolean	getDisableSSLVerification()
List<String>	getHosts()
String	getPathPrefix()
Optional<UsernamePasswordCredentials>	getUsernamePasswordCredentials()
Optional<UsernamePasswordCredentials>	getUsernamePasswordCredentials(String username)	Gets the credentials.
int	hashCode()
Map<String,Object>	toConfigMap()
Map<String,Object>	toConfigMap(String queryUser)	This method is used when user translation is enabled.
String	toString()
ElasticsearchStorageConfig	updateCredentialProvider(CredentialsProvider credentialsProvider)

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

getAuthMode, getCredentialsProvider, getValue, isEnabled, isEnabledStatusPresent, oAuthConfig, setEnabled

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

CREDENTIALS_PROVIDER

public static final String CREDENTIALS_PROVIDER

See Also:

• Constant Field Values

Constructor Details

ElasticsearchStorageConfig

public ElasticsearchStorageConfig(List<String> hosts,
 String username,
 String password,
 String pathPrefix,
 String authMode,
 boolean disableSSLVerification,
 CredentialsProvider credentialsProvider)

Method Details

updateCredentialProvider

public ElasticsearchStorageConfig updateCredentialProvider(CredentialsProvider credentialsProvider)

Overrides:

updateCredentialProvider in class StoragePluginConfig

getHosts

public List<String> getHosts()

getPathPrefix

public String getPathPrefix()

getDisableSSLVerification

public boolean getDisableSSLVerification()

getUsernamePasswordCredentials

public Optional<UsernamePasswordCredentials> getUsernamePasswordCredentials()

getUsernamePasswordCredentials

public Optional<UsernamePasswordCredentials> getUsernamePasswordCredentials(String username)

Gets the credentials. This method is used when user translation is enabled.

Returns:

An Optional containing UsernamePasswordCredentials from the config.

toConfigMap

public Map<String,Object> toConfigMap()
                               throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

toConfigMap

public Map<String,Object> toConfigMap(String queryUser)
                               throws com.fasterxml.jackson.core.JsonProcessingException

This method is used when user translation is enabled.

Parameters:

queryUser - The user who submitted the query

Returns:

A map of the configuration details.

Throws:

com.fasterxml.jackson.core.JsonProcessingException - If JSON is unparsable, throw exception

equals

public boolean equals(Object o)

Specified by:

equals in class StoragePluginConfig

hashCode

public int hashCode()

Specified by:

hashCode in class StoragePluginConfig

toString

public String toString()

Overrides:

toString in class Object