Uses of Class
com.logicalclocks.hsfs.StorageConnector.KafkaConnector

Packages that use StorageConnector.KafkaConnector

Package	Description
com.logicalclocks.hsfs
com.logicalclocks.hsfs.metadata
com.logicalclocks.hsfs.spark.util

Uses of StorageConnector.KafkaConnector in com.logicalclocks.hsfs

Methods in com.logicalclocks.hsfs that return StorageConnector.KafkaConnector

Modifier and Type	Method and Description
StorageConnector.KafkaConnector	FeatureStoreBase.getKafkaConnector(String name) Get a previously created Kafka compliant storage connector from the feature store.

Uses of StorageConnector.KafkaConnector in com.logicalclocks.hsfs.metadata

Methods in com.logicalclocks.hsfs.metadata that return StorageConnector.KafkaConnector

Modifier and Type	Method and Description
StorageConnector.KafkaConnector	StorageConnectorApi.getKafkaStorageConnector(FeatureStoreBase featureStoreBase, boolean external)

Uses of StorageConnector.KafkaConnector in com.logicalclocks.hsfs.spark.util

Methods in com.logicalclocks.hsfs.spark.util with parameters of type StorageConnector.KafkaConnector

Modifier and Type	Method and Description
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	StorageConnectorUtils.readStream(StorageConnector.KafkaConnector connector, String topic, boolean topicPattern, String messageFormat, String schema, Map<String,String> options, boolean includeMetadata) Reads stream into a spark dataframe using the kafka storage connector.