Package com.logicalclocks.hsfs.metadata

Class HopsworksClient

java.lang.Object

com.logicalclocks.hsfs.metadata.HopsworksClient

public class HopsworksClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	HopsworksClient.BaseHandler<T>
protected static class	HopsworksClient.HopsworksErrorClass

Field Summary

Fields

Modifier and Type	Field	Description
static final String	API_PATH
protected static HopsworksClient	hopsworksClientInstance
protected HopsworksHttpClient	hopsworksHttpClient
protected String	host
protected static final org.slf4j.Logger	LOGGER
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected Project	project
static final String	PROJECT_PATH

Constructor Summary

Constructors

Constructor	Description
HopsworksClient(HopsworksHttpClient hopsworksHttpClient, String host)

Method Summary

Modifier and Type	Method	Description
org.apache.http.entity.StringEntity	buildStringEntity(Object object)
Credentials	getCredentials()
static HopsworksClient	getInstance()
<T> T	handleRequest(org.apache.http.HttpRequest request)
<T> T	handleRequest(org.apache.http.HttpRequest request, Class<T> cls)
<T> T	handleRequest(org.apache.http.HttpRequest request, org.apache.http.client.ResponseHandler<T> responseHandler)
static void	setInstance(HopsworksClient instance)
static HopsworksClient	setupHopsworksClient(String host, int port, software.amazon.awssdk.regions.Region region, SecretStore secretStore, boolean hostnameVerification, String trustStorePath, String apiKeyFilePath, String apiKeyValue)

Methods inherited from class java.lang.Object

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

Field Details

API_PATH

public static final String API_PATH

See Also:

• Constant Field Values

PROJECT_PATH

public static final String PROJECT_PATH

See Also:

• Constant Field Values

hopsworksClientInstance

protected static HopsworksClient hopsworksClientInstance

LOGGER

protected static final org.slf4j.Logger LOGGER

project

protected Project project

host

protected String host

hopsworksHttpClient

protected HopsworksHttpClient hopsworksHttpClient

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

HopsworksClient

public HopsworksClient(HopsworksHttpClient hopsworksHttpClient,
 String host)

Method Details

getInstance

public static HopsworksClient getInstance()
                                   throws FeatureStoreException

Throws:

FeatureStoreException

setInstance

public static void setInstance(HopsworksClient instance)

setupHopsworksClient

public static HopsworksClient setupHopsworksClient(String host,
 int port,
 software.amazon.awssdk.regions.Region region,
 SecretStore secretStore,
 boolean hostnameVerification,
 String trustStorePath,
 String apiKeyFilePath,
 String apiKeyValue)
                                            throws FeatureStoreException

Throws:

FeatureStoreException

getCredentials

public Credentials getCredentials()
                           throws FeatureStoreException,
IOException,
KeyStoreException,
CertificateException,
NoSuchAlgorithmException

Throws:

FeatureStoreException

IOException

KeyStoreException

CertificateException

NoSuchAlgorithmException

handleRequest

public <T> T handleRequest(org.apache.http.HttpRequest request,
 org.apache.http.client.ResponseHandler<T> responseHandler)
                    throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException

handleRequest

public <T> T handleRequest(org.apache.http.HttpRequest request,
 Class<T> cls)
                    throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException

handleRequest

public <T> T handleRequest(org.apache.http.HttpRequest request)
                    throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException

buildStringEntity

public org.apache.http.entity.StringEntity buildStringEntity(Object object)
                                                      throws IOException

Throws:

IOException