Package com.logicalclocks.hsfs.beam

Class HopsworksConnection

java.lang.Object

com.logicalclocks.hsfs.HopsworksConnectionBase

com.logicalclocks.hsfs.beam.HopsworksConnection

All Implemented Interfaces:

Closeable, AutoCloseable

public class HopsworksConnection
extends HopsworksConnectionBase

Field Summary

Fields inherited from class com.logicalclocks.hsfs.HopsworksConnectionBase

apiKeyFilePath, apiKeyValue, certPath, featureStoreApi, host, hostnameVerification, keyStorePath, port, project, projectApi, projectObj, region, secretStore, trustStorePath

Constructor Summary

Constructors

Constructor	Description
HopsworksConnection(String host, int port, String project, software.amazon.awssdk.regions.Region region, SecretStore secretStore, boolean hostnameVerification, String trustStorePath, String certPath, String apiKeyFilePath, String apiKeyValue)

Method Summary

Modifier and Type	Method	Description
FeatureStore	getFeatureStore()	Retrieve the project feature store.
FeatureStore	getFeatureStore(String name)	Retrieve a feature store based on name.

Methods inherited from class com.logicalclocks.hsfs.HopsworksConnectionBase

close, getProject, getProjectName, rewriteFeatureStoreName

Methods inherited from class java.lang.Object

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

Constructor Details

HopsworksConnection

public HopsworksConnection(String host,
 int port,
 String project,
 software.amazon.awssdk.regions.Region region,
 SecretStore secretStore,
 boolean hostnameVerification,
 String trustStorePath,
 String certPath,
 String apiKeyFilePath,
 String apiKeyValue)
                    throws IOException,
FeatureStoreException,
CertificateException,
KeyStoreException,
NoSuchAlgorithmException

Throws:

IOException

FeatureStoreException

CertificateException

KeyStoreException

NoSuchAlgorithmException

Method Details

getFeatureStore

public FeatureStore getFeatureStore()
                             throws IOException,
FeatureStoreException

Retrieve the project feature store.

Specified by:

getFeatureStore in class HopsworksConnectionBase

Returns:

FeatureStore object.

Throws:

IOException - Generic IO exception.

FeatureStoreException - If client is not connected to Hopsworks

getFeatureStore

public FeatureStore getFeatureStore(String name)
                             throws IOException,
FeatureStoreException

Retrieve a feature store based on name. The feature store needs to be shared with the connection's project. The name is the project name of the feature store.

Specified by:

getFeatureStore in class HopsworksConnectionBase

Parameters:

name - the name of the feature store to get the handle for

Returns:

FeatureStore object.

Throws:

IOException - Generic IO exception.

FeatureStoreException - If client is not connected to Hopsworks