Package com.logicalclocks.hsfs.engine

Class VectorServer

java.lang.Object

com.logicalclocks.hsfs.engine.VectorServer

public class VectorServer
extends Object

Constructor Summary

Constructors

Constructor	Description
VectorServer()

Method Summary

Modifier and Type	Method	Description
void	close()
Map<Integer,Map<String,org.apache.avro.io.DatumReader<Object>>>	getComplexFeatureSchemas(List<TrainingDatasetFeature> features, Map<Integer,String> prefixMap)
List<Object>	getFeatureVector(FeatureViewBase featureViewBase, Map<String,Object> entry)
List<Object>	getFeatureVector(FeatureViewBase featureViewBase, Map<String,Object> entry, boolean external)
List<Object>	getFeatureVector(Map<String,Object> entry)
<T> T	getFeatureVectorObject(FeatureViewBase featureViewBase, Map<String,Object> entry, boolean external, Class<T> returnType)
<T> T	getFeatureVectorObject(Map<String,Object> entry, Class<T> returnType)
List<List<Object>>	getFeatureVectors(FeatureViewBase featureViewBase, Map<String,List<Object>> entry, boolean external)
List<List<Object>>	getFeatureVectors(Map<String,List<Object>> entry)
void	initPreparedStatement(FeatureStoreBase featureStoreBase, List<TrainingDatasetFeature> features, List<ServingPreparedStatement> servingPreparedStatements, boolean batch, boolean external)
void	initPreparedStatement(FeatureViewBase featureViewBase, boolean batch)
void	initPreparedStatement(FeatureViewBase featureViewBase, boolean batch, boolean external)
void	initServing(FeatureViewBase featureViewBase, boolean batch)
void	initServing(FeatureViewBase featureViewBase, boolean batch, boolean external)
<T> void	processQuery(Map<String,Object> entry, int preparedStatementIndex, T returnObject)
void	setupHikariPool(FeatureStoreBase featureStoreBase, Boolean external)
String	zipArraysToTupleString(List<List<Object>> lists)

Methods inherited from class java.lang.Object

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

Constructor Details

VectorServer

public VectorServer()

Method Details

getFeatureVector

public List<Object> getFeatureVector(FeatureViewBase featureViewBase,
 Map<String,Object> entry)
                              throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

getFeatureVector

public List<Object> getFeatureVector(FeatureViewBase featureViewBase,
 Map<String,Object> entry,
 boolean external)
                              throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

getFeatureVector

public List<Object> getFeatureVector(Map<String,Object> entry)
                              throws FeatureStoreException

Throws:

FeatureStoreException

getFeatureVectorObject

public <T> T getFeatureVectorObject(FeatureViewBase featureViewBase,
 Map<String,Object> entry,
 boolean external,
 Class<T> returnType)
                             throws FeatureStoreException,
IOException,
ClassNotFoundException,
IllegalAccessException,
InstantiationException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

IllegalAccessException

InstantiationException

getFeatureVectorObject

public <T> T getFeatureVectorObject(Map<String,Object> entry,
 Class<T> returnType)
                             throws FeatureStoreException,
InstantiationException,
IllegalAccessException

Throws:

FeatureStoreException

InstantiationException

IllegalAccessException

processQuery

public <T> void processQuery(Map<String,Object> entry,
 int preparedStatementIndex,
 T returnObject)
                      throws SQLException,
FeatureStoreException,
IOException,
NoSuchMethodException,
InvocationTargetException,
IllegalAccessException

Throws:

SQLException

FeatureStoreException

IOException

NoSuchMethodException

InvocationTargetException

IllegalAccessException

getFeatureVectors

public List<List<Object>> getFeatureVectors(FeatureViewBase featureViewBase,
 Map<String,List<Object>> entry,
 boolean external)
                                     throws SQLException,
FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

SQLException

FeatureStoreException

IOException

ClassNotFoundException

getFeatureVectors

public List<List<Object>> getFeatureVectors(Map<String,List<Object>> entry)
                                     throws SQLException,
FeatureStoreException,
IOException

Throws:

SQLException

FeatureStoreException

IOException

initServing

public void initServing(FeatureViewBase featureViewBase,
 boolean batch)
                 throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

initServing

public void initServing(FeatureViewBase featureViewBase,
 boolean batch,
 boolean external)
                 throws FeatureStoreException,
IOException,
SQLException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

SQLException

ClassNotFoundException

initPreparedStatement

public void initPreparedStatement(FeatureViewBase featureViewBase,
 boolean batch)
                           throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

initPreparedStatement

public void initPreparedStatement(FeatureViewBase featureViewBase,
 boolean batch,
 boolean external)
                           throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

initPreparedStatement

public void initPreparedStatement(FeatureStoreBase featureStoreBase,
 List<TrainingDatasetFeature> features,
 List<ServingPreparedStatement> servingPreparedStatements,
 boolean batch,
 boolean external)
                           throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

setupHikariPool

public void setupHikariPool(FeatureStoreBase featureStoreBase,
 Boolean external)
                     throws FeatureStoreException,
IOException,
ClassNotFoundException

Throws:

FeatureStoreException

IOException

ClassNotFoundException

zipArraysToTupleString

public String zipArraysToTupleString(List<List<Object>> lists)

getComplexFeatureSchemas

public Map<Integer,Map<String,org.apache.avro.io.DatumReader<Object>>> getComplexFeatureSchemas(List<TrainingDatasetFeature> features,
 Map<Integer,String> prefixMap)
                                                                                         throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

close

public void close()