Package org.apache.arrow.driver.jdbc.utils

Class ArrowFlightConnectionConfigImpl

java.lang.Object

org.apache.calcite.avatica.ConnectionConfigImpl

org.apache.arrow.driver.jdbc.utils.ArrowFlightConnectionConfigImpl

All Implemented Interfaces:

org.apache.calcite.avatica.ConnectionConfig

public final class ArrowFlightConnectionConfigImpl
extends org.apache.calcite.avatica.ConnectionConfigImpl

A ConnectionConfig for the ArrowFlightConnection.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ArrowFlightConnectionConfigImpl.ArrowFlightConnectionProperty	Custom ConnectionProperty for the ArrowFlightConnectionConfigImpl.

Nested classes/interfaces inherited from class org.apache.calcite.avatica.ConnectionConfigImpl

org.apache.calcite.avatica.ConnectionConfigImpl.Converter<T extends Object>, org.apache.calcite.avatica.ConnectionConfigImpl.PropEnv

Field Summary

Fields inherited from class org.apache.calcite.avatica.ConnectionConfigImpl

BOOLEAN_CONVERTER, IDENTITY_CONVERTER, NUMBER_CONVERTER, properties

Constructor Summary

Constructors

Constructor	Description
ArrowFlightConnectionConfigImpl(Properties properties)

Method Summary

Modifier and Type	Method	Description
String	getClientCertificatePath()
String	getClientKeyPath()
boolean	getDisableCertificateVerification()
Map<String,String>	getHeaderAttributes()	Gets which properties should be added as headers.
String	getHost()	Gets the host.
String	getPassword()	Gets the host.
int	getPort()	Gets the port.
String	getTlsRootCertificatesPath()
String	getToken()
String	getTrustStorePassword()	Gets the KeyStore password.
String	getTrustStorePath()	Gets the KeyStore path.
String	getUser()	Gets the host.
boolean	retainAuth()	Indicates if sub-connections created for stream retrieval should reuse bearer tokens created from the main connection.
boolean	retainCookies()	Indicates if sub-connections created for stream retrieval should reuse cookies from the main connection.
int	threadPoolSize()	Gets the thread pool size.
CallOption	toCallOption()	Gets the CallOptions from this ConnectionConfig.
boolean	useEncryption()	Whether to use TLS encryption.
boolean	useSystemTrustStore()	Check if the JDBC should use the trusted store files from the operating system.

Methods inherited from class org.apache.calcite.avatica.ConnectionConfigImpl

authentication, avaticaPassword, avaticaUser, enumConverter, factory, fetchSize, getHttpConnectionTimeout, getLBConnectionFailoverRetries, getLBConnectionFailoverSleepTime, getLBStrategy, getLbURLs, hostnameVerification, httpClientClass, httpClientFactory, kerberosKeytab, kerberosPrincipal, keyPassword, keystore, keystorePassword, keystoreType, parse, pluginConverter, schema, serialization, timeZone, transparentReconnectionEnabled, truststore, truststorePassword, url, useClientSideLb

Methods inherited from class java.lang.Object

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

Constructor Details

ArrowFlightConnectionConfigImpl

public ArrowFlightConnectionConfigImpl(Properties properties)

Method Details

getHost

public String getHost()

Gets the host.

Returns:

the host.

getPort

public int getPort()

Gets the port.

Returns:

the port.

getUser

public String getUser()

Gets the host.

Returns:

the host.

getPassword

public String getPassword()

Gets the host.

Returns:

the host.

getToken

public String getToken()

getTrustStorePath

public String getTrustStorePath()

Gets the KeyStore path.

Returns:

the path.

getTrustStorePassword

public String getTrustStorePassword()

Gets the KeyStore password.

Returns:

the password.

useSystemTrustStore

public boolean useSystemTrustStore()

Check if the JDBC should use the trusted store files from the operating system.

Returns:

whether to use system trusted store certificates.

getTlsRootCertificatesPath

public String getTlsRootCertificatesPath()

getClientCertificatePath

public String getClientCertificatePath()

getClientKeyPath

public String getClientKeyPath()

useEncryption

public boolean useEncryption()

Whether to use TLS encryption.

Returns:

whether to use TLS encryption.

getDisableCertificateVerification

public boolean getDisableCertificateVerification()

threadPoolSize

public int threadPoolSize()

Gets the thread pool size.

Returns:

the thread pool size.

retainCookies

public boolean retainCookies()

Indicates if sub-connections created for stream retrieval should reuse cookies from the main connection.

retainAuth

public boolean retainAuth()

Indicates if sub-connections created for stream retrieval should reuse bearer tokens created from the main connection.

toCallOption

public CallOption toCallOption()

Gets the CallOptions from this ConnectionConfig.

Returns:

the call options.

getHeaderAttributes

public Map<String,String> getHeaderAttributes()

Gets which properties should be added as headers.

Returns:

Map