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

Packages that use StorageConnector.KafkaConnector

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

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

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

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

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.