com.logicalclocks.hsfs.metadata

Class FeatureViewApi

java.lang.Object

com.logicalclocks.hsfs.metadata.FeatureViewApi

public class FeatureViewApi
extends Object

Constructor Summary

Constructors

Constructor and Description
FeatureViewApi()

Method Summary

Modifier and Type	Method and Description
void	computeTrainingData(FeatureStoreBase featureStore, FeatureViewBase featureViewBase, TrainingDatasetBase trainingData)
<T extends TrainingDatasetBase> TrainingDatasetBase	createTrainingData(String featureViewName, Integer featureViewVersion, TrainingDatasetBase trainingData, Class<T> tdType)
void	delete(FeatureStoreBase featureStoreBase, String name)
void	delete(FeatureStoreBase featureStoreBase, String name, Integer version)
void	deleteTrainingData(FeatureStoreBase featureStoreBase, String name, Integer version)
void	deleteTrainingData(FeatureStoreBase featureStoreBase, String featureViewName, Integer featureViewVersion, Integer trainingDataVersion)
void	deleteTrainingDatasetOnly(FeatureStoreBase featureStoreBase, String name, Integer version)
void	deleteTrainingDatasetOnly(FeatureStoreBase featureStoreBase, String name, Integer version, Integer trainingDataVersion)
List<FeatureViewBase>	get(FeatureStoreBase featureStoreBase, String name)
<T extends FeatureViewBase> FeatureViewBase	get(FeatureStoreBase featureStoreBase, String name, Integer version, Class<T> fvType)
<T extends QueryBase> T	getBatchQuery(FeatureStoreBase featureStoreBase, String name, Integer version, Long startTime, Long endTime, Boolean withLabels, Integer trainingDataVersion, Class<T> queryType)
List<ServingPreparedStatement>	getServingPreparedStatement(FeatureViewBase featureViewBase, boolean batch)
<T extends TrainingDatasetBase> TrainingDatasetBase	getTrainingData(FeatureStoreBase featureStoreBase, String featureViewName, Integer featureViewVersion, Integer trainingDataVersion, Class<T> tdType)
List<TransformationFunctionAttached>	getTransformationFunctions(FeatureViewBase featureViewBase)
<T extends FeatureViewBase> T	save(FeatureViewBase featureViewBase, Class<T> fvType)
<T> T	update(FeatureViewBase featureViewBase, Class<T> fvType)

Methods inherited from class java.lang.Object

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

Constructor Detail

FeatureViewApi

public FeatureViewApi()

Method Detail

save

public <T extends FeatureViewBase> T save(FeatureViewBase featureViewBase,
                                          Class<T> fvType)
                                   throws FeatureStoreException,
                                          IOException

Throws:

FeatureStoreException

IOException

get

public <T extends FeatureViewBase> FeatureViewBase get(FeatureStoreBase featureStoreBase,
                                                       String name,
                                                       Integer version,
                                                       Class<T> fvType)
                                                throws FeatureStoreException,
                                                       IOException

Throws:

FeatureStoreException

IOException

get

public List<FeatureViewBase> get(FeatureStoreBase featureStoreBase,
                                 String name)
                          throws FeatureStoreException,
                                 IOException

Throws:

FeatureStoreException

IOException

update

public <T> T update(FeatureViewBase featureViewBase,
                    Class<T> fvType)
             throws FeatureStoreException,
                    IOException

Throws:

FeatureStoreException

IOException

delete

public void delete(FeatureStoreBase featureStoreBase,
                   String name,
                   Integer version)
            throws FeatureStoreException,
                   IOException

Throws:

FeatureStoreException

IOException

delete

public void delete(FeatureStoreBase featureStoreBase,
                   String name)
            throws FeatureStoreException,
                   IOException

Throws:

FeatureStoreException

IOException

getTransformationFunctions

public List<TransformationFunctionAttached> getTransformationFunctions(FeatureViewBase featureViewBase)
                                                                throws FeatureStoreException,
                                                                       IOException

Throws:

FeatureStoreException

IOException

getServingPreparedStatement

public List<ServingPreparedStatement> getServingPreparedStatement(FeatureViewBase featureViewBase,
                                                                  boolean batch)
                                                           throws FeatureStoreException,
                                                                  IOException

Throws:

FeatureStoreException

IOException

createTrainingData

public <T extends TrainingDatasetBase> TrainingDatasetBase createTrainingData(String featureViewName,
                                                                              Integer featureViewVersion,
                                                                              TrainingDatasetBase trainingData,
                                                                              Class<T> tdType)
                                                                       throws FeatureStoreException,
                                                                              IOException

Throws:

FeatureStoreException

IOException

computeTrainingData

public void computeTrainingData(FeatureStoreBase featureStore,
                                FeatureViewBase featureViewBase,
                                TrainingDatasetBase trainingData)
                         throws FeatureStoreException,
                                IOException

Throws:

FeatureStoreException

IOException

getTrainingData

public <T extends TrainingDatasetBase> TrainingDatasetBase getTrainingData(FeatureStoreBase featureStoreBase,
                                                                           String featureViewName,
                                                                           Integer featureViewVersion,
                                                                           Integer trainingDataVersion,
                                                                           Class<T> tdType)
                                                                    throws FeatureStoreException,
                                                                           IOException

Throws:

FeatureStoreException

IOException

deleteTrainingData

public void deleteTrainingData(FeatureStoreBase featureStoreBase,
                               String featureViewName,
                               Integer featureViewVersion,
                               Integer trainingDataVersion)
                        throws FeatureStoreException,
                               IOException

Throws:

FeatureStoreException

IOException

deleteTrainingData

public void deleteTrainingData(FeatureStoreBase featureStoreBase,
                               String name,
                               Integer version)
                        throws FeatureStoreException,
                               IOException

Throws:

FeatureStoreException

IOException

deleteTrainingDatasetOnly

public void deleteTrainingDatasetOnly(FeatureStoreBase featureStoreBase,
                                      String name,
                                      Integer version,
                                      Integer trainingDataVersion)
                               throws FeatureStoreException,
                                      IOException

Throws:

FeatureStoreException

IOException

deleteTrainingDatasetOnly

public void deleteTrainingDatasetOnly(FeatureStoreBase featureStoreBase,
                                      String name,
                                      Integer version)
                               throws FeatureStoreException,
                                      IOException

Throws:

FeatureStoreException

IOException

getBatchQuery

public <T extends QueryBase> T getBatchQuery(FeatureStoreBase featureStoreBase,
                                             String name,
                                             Integer version,
                                             Long startTime,
                                             Long endTime,
                                             Boolean withLabels,
                                             Integer trainingDataVersion,
                                             Class<T> queryType)
                                      throws FeatureStoreException,
                                             IOException

Throws:

FeatureStoreException

IOException