com.logicalclocks.hsfs.metadata

Class StorageConnectorApi

java.lang.Object

com.logicalclocks.hsfs.metadata.StorageConnectorApi

public class StorageConnectorApi
extends Object

Constructor Summary

Constructors

Constructor and Description
StorageConnectorApi()

Method Summary

Modifier and Type	Method and 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 Detail

StorageConnectorApi

public StorageConnectorApi()

Method Detail

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