public static class StorageConnector.HopsFsConnector extends StorageConnector
StorageConnector.AdlsConnector, StorageConnector.BigqueryConnector, StorageConnector.GcsConnector, StorageConnector.HopsFsConnector, StorageConnector.JdbcConnector, StorageConnector.KafkaConnector, StorageConnector.RdsConnector, StorageConnector.RedshiftConnector, StorageConnector.S3Connector, StorageConnector.SnowflakeConnector
Modifier and Type | Field and Description |
---|---|
protected String |
datasetName |
protected String |
hopsfsPath |
description, featurestoreId, id, LOGGER, name, storageConnectorApi, storageConnectorType
Constructor and Description |
---|
HopsFsConnector() |
Modifier and Type | Method and Description |
---|---|
String |
getPath(String subPath) |
Map<String,String> |
sparkOptions(DataSource dataSource) |
refetch, sparkOptions
public Map<String,String> sparkOptions(DataSource dataSource)
sparkOptions
in class StorageConnector
public String getPath(String subPath)
getPath
in class StorageConnector
Copyright © 2025. All rights reserved.