com.logicalclocks.hsfs

Class StorageConnector.KafkaConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.KafkaConnector

Enclosing class:

StorageConnector

public static class StorageConnector.KafkaConnector
extends StorageConnector

Nested Class Summary

Nested classes/interfaces inherited from class com.logicalclocks.hsfs.StorageConnector

StorageConnector.AdlsConnector, StorageConnector.BigqueryConnector, StorageConnector.GcsConnector, StorageConnector.HopsFsConnector, StorageConnector.JdbcConnector, StorageConnector.KafkaConnector, StorageConnector.RdsConnector, StorageConnector.RedshiftConnector, StorageConnector.S3Connector, StorageConnector.SnowflakeConnector

Field Summary

Fields

Modifier and Type	Field and Description
protected String	bootstrapServers
protected Boolean	externalKafka
protected List<Option>	options
protected SecurityProtocol	securityProtocol
static String	sparkFormat
protected SslEndpointIdentificationAlgorithm	sslEndpointIdentificationAlgorithm
protected String	sslKeyPassword
protected String	sslKeystoreLocation
protected String	sslKeystorePassword
protected String	sslTruststoreLocation
protected String	sslTruststorePassword

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

description, featurestoreId, id, LOGGER, name, storageConnectorApi, storageConnectorType

Constructor Summary

Constructors

Constructor and Description
KafkaConnector()

Method Summary

Modifier and Type	Method and Description
String	getPath(String subPath)
Map<String,String>	kafkaOptions()
Map<String,String>	sparkOptions(DataSource dataSource)

Methods inherited from class com.logicalclocks.hsfs.StorageConnector

refetch, sparkOptions

Methods inherited from class java.lang.Object

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

Field Detail

sparkFormat

public static final String sparkFormat

See Also:

Constant Field Values

bootstrapServers

protected String bootstrapServers

securityProtocol

protected SecurityProtocol securityProtocol

sslTruststoreLocation

protected String sslTruststoreLocation

sslTruststorePassword

protected String sslTruststorePassword

sslKeystoreLocation

protected String sslKeystoreLocation

sslKeystorePassword

protected String sslKeystorePassword

sslKeyPassword

protected String sslKeyPassword

sslEndpointIdentificationAlgorithm

protected SslEndpointIdentificationAlgorithm sslEndpointIdentificationAlgorithm

options

protected List<Option> options

externalKafka

protected Boolean externalKafka

Constructor Detail

KafkaConnector

public KafkaConnector()

Method Detail

kafkaOptions

public Map<String,String> kafkaOptions()
                                throws FeatureStoreException

Throws:

FeatureStoreException

sparkOptions

public Map<String,String> sparkOptions(DataSource dataSource)
                                throws FeatureStoreException

Specified by:

sparkOptions in class StorageConnector

Throws:

FeatureStoreException

getPath

public String getPath(String subPath)

Specified by:

getPath in class StorageConnector