Package com.logicalclocks.hsfs.metadata

Class StorageConnectorApi

java.lang.Object

com.logicalclocks.hsfs.metadata.StorageConnectorApi

public class StorageConnectorApi
extends Object

Constructor Summary

Constructors

Constructor	Description
StorageConnectorApi()

Method Summary

Modifier and Type	Method	Description
<U> U	get(Integer featureStoreId, String name, Class<U> storageConnectorType)
<T> T	getByName(FeatureStoreBase featureStoreBase, String name, Class<T> storageConnectorType)
StorageConnector.KafkaConnector	getKafkaStorageConnector(FeatureStoreBase featureStoreBase, boolean external)
<T> T	getOnlineStorageConnector(FeatureStoreBase featureStoreBase, Class<T> storageConnectorType)

Methods inherited from class java.lang.Object

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

Constructor Details

StorageConnectorApi

public StorageConnectorApi()

Method Details

get

public <U> U get(Integer featureStoreId,
 String name,
 Class<U> storageConnectorType)
          throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getByName

public <T> T getByName(FeatureStoreBase featureStoreBase,
 String name,
 Class<T> storageConnectorType)
                throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException

getOnlineStorageConnector

public <T> T getOnlineStorageConnector(FeatureStoreBase featureStoreBase,
 Class<T> storageConnectorType)
                                throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException

getKafkaStorageConnector

public StorageConnector.KafkaConnector getKafkaStorageConnector(FeatureStoreBase featureStoreBase,
 boolean external)
                                                         throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException