com.logicalclocks.hsfs.engine

Class FeatureViewEngineBase<T1 extends QueryBase<T1,T4,T5>,T2 extends FeatureViewBase<T2,T3,T1,T5>,T3 extends FeatureStoreBase<T1>,T4 extends FeatureGroupBase,T5>

java.lang.Object

com.logicalclocks.hsfs.engine.FeatureViewEngineBase<T1,T2,T3,T4,T5>

Direct Known Subclasses:

FeatureViewEngine, FeatureViewEngine

public abstract class FeatureViewEngineBase<T1 extends QueryBase<T1,T4,T5>,T2 extends FeatureViewBase<T2,T3,T1,T5>,T3 extends FeatureStoreBase<T1>,T4 extends FeatureGroupBase,T5>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	AMBIGUOUS_LABEL_ERROR
protected FeatureViewApi	featureViewApi
static String	LABEL_NOT_EXIST_ERROR
protected static org.slf4j.Logger	LOGGER
protected TagsApi	tagsApi

Constructor Summary

Constructors

Constructor and Description
FeatureViewEngineBase()

Method Summary

Modifier and Type	Method and Description
void	addTag(FeatureViewBase featureViewBase, String name, Object value)
void	addTag(FeatureViewBase featureViewBase, String name, Object value, Integer trainingDataVersion)
void	delete(T3 featureStoreBase, String name)
void	delete(T3 featureStoreBase, String name, Integer version)
void	deleteTag(FeatureViewBase featureViewBase, String name)
void	deleteTag(FeatureViewBase featureViewBase, String name, Integer trainingDataVersion)
void	deleteTrainingData(T2 featureView)
void	deleteTrainingData(T2 featureView, Integer trainingDataVersion)
void	deleteTrainingDatasetOnly(T2 featureView)
void	deleteTrainingDatasetOnly(T2 featureView, Integer trainingDataVersion)
List<FeatureViewBase>	get(T3 featureStoreBase, String name)
abstract T2	get(T3 featureStore, String name, Integer version)
T2	get(T3 featureStoreBase, String name, Integer version, Class<T2> fvType)
abstract T5	getBatchData(T2 featureView, Date startTime, Date endTime, Map<String,String> readOptions, Integer trainingDataVersion)
abstract T1	getBatchQuery(T2 featureView, Date startTime, Date endTime, Boolean withLabels, Integer trainingDataVersion)
T1	getBatchQuery(T2 featureView, Date startTime, Date endTime, Boolean withLabels, Integer trainingDataVersion, Class<T1> queryType)
abstract String	getBatchQueryString(T2 featureView, Date startTime, Date endTime, Integer trainingDataVersion)
protected Date	getEndTime()
abstract T2	getOrCreateFeatureView(T3 featureStore, String name, Integer version, T1 query, String description, List<String> labels)
protected Date	getStartTime()
Object	getTag(FeatureViewBase featureViewBase, String name)
Object	getTag(FeatureViewBase featureViewBase, String name, Integer trainingDataVersion)
Map<String,Object>	getTags(FeatureViewBase featureViewBase)
Map<String,Object>	getTags(FeatureViewBase featureViewBase, Integer trainingDataVersion)
static List<TrainingDatasetFeature>	makeLabelFeatures(QueryBase query, List<String> labels)
T2	save(T2 featureViewBase, Class<T2> fvType)
protected void	setEventTime(FeatureViewBase featureView, TrainingDatasetBase trainingDataset)
abstract T2	update(T2 featureView)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

featureViewApi

protected FeatureViewApi featureViewApi

tagsApi

protected TagsApi tagsApi

AMBIGUOUS_LABEL_ERROR

public static String AMBIGUOUS_LABEL_ERROR

LABEL_NOT_EXIST_ERROR

public static String LABEL_NOT_EXIST_ERROR

Constructor Detail

FeatureViewEngineBase

public FeatureViewEngineBase()

Method Detail

save

public T2 save(T2 featureViewBase,
               Class<T2> fvType)
        throws FeatureStoreException,
               IOException

Throws:

FeatureStoreException

IOException

makeLabelFeatures

public static List<TrainingDatasetFeature> makeLabelFeatures(QueryBase query,
                                                             List<String> labels)
                                                      throws FeatureStoreException

Throws:

FeatureStoreException

update

public abstract T2 update(T2 featureView)
                   throws FeatureStoreException,
                          IOException

Throws:

FeatureStoreException

IOException

get

public abstract T2 get(T3 featureStore,
                       String name,
                       Integer version)
                throws FeatureStoreException,
                       IOException

Throws:

FeatureStoreException

IOException

get

public T2 get(T3 featureStoreBase,
              String name,
              Integer version,
              Class<T2> fvType)
       throws FeatureStoreException,
              IOException

Throws:

FeatureStoreException

IOException

get

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

Throws:

FeatureStoreException

IOException

delete

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

Throws:

FeatureStoreException

IOException

delete

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

Throws:

FeatureStoreException

IOException

getStartTime

protected Date getStartTime()

getEndTime

protected Date getEndTime()

addTag

public void addTag(FeatureViewBase featureViewBase,
                   String name,
                   Object value)
            throws FeatureStoreException,
                   IOException

Throws:

FeatureStoreException

IOException

addTag

public void addTag(FeatureViewBase featureViewBase,
                   String name,
                   Object value,
                   Integer trainingDataVersion)
            throws FeatureStoreException,
                   IOException

Throws:

FeatureStoreException

IOException

deleteTag

public void deleteTag(FeatureViewBase featureViewBase,
                      String name)
               throws FeatureStoreException,
                      IOException

Throws:

FeatureStoreException

IOException

deleteTag

public void deleteTag(FeatureViewBase featureViewBase,
                      String name,
                      Integer trainingDataVersion)
               throws FeatureStoreException,
                      IOException

Throws:

FeatureStoreException

IOException

getTag

public Object getTag(FeatureViewBase featureViewBase,
                     String name)
              throws FeatureStoreException,
                     IOException

Throws:

FeatureStoreException

IOException

getTag

public Object getTag(FeatureViewBase featureViewBase,
                     String name,
                     Integer trainingDataVersion)
              throws FeatureStoreException,
                     IOException

Throws:

FeatureStoreException

IOException

getTags

public Map<String,Object> getTags(FeatureViewBase featureViewBase)
                           throws FeatureStoreException,
                                  IOException

Throws:

FeatureStoreException

IOException

getTags

public Map<String,Object> getTags(FeatureViewBase featureViewBase,
                                  Integer trainingDataVersion)
                           throws FeatureStoreException,
                                  IOException

Throws:

FeatureStoreException

IOException

getBatchQuery

public abstract T1 getBatchQuery(T2 featureView,
                                 Date startTime,
                                 Date endTime,
                                 Boolean withLabels,
                                 Integer trainingDataVersion)
                          throws FeatureStoreException,
                                 IOException

Throws:

FeatureStoreException

IOException

getBatchQuery

public T1 getBatchQuery(T2 featureView,
                        Date startTime,
                        Date endTime,
                        Boolean withLabels,
                        Integer trainingDataVersion,
                        Class<T1> queryType)
                 throws FeatureStoreException,
                        IOException

Throws:

FeatureStoreException

IOException

setEventTime

protected void setEventTime(FeatureViewBase featureView,
                            TrainingDatasetBase trainingDataset)

deleteTrainingData

public void deleteTrainingData(T2 featureView,
                               Integer trainingDataVersion)
                        throws FeatureStoreException,
                               IOException

Throws:

FeatureStoreException

IOException

deleteTrainingData

public void deleteTrainingData(T2 featureView)
                        throws FeatureStoreException,
                               IOException

Throws:

FeatureStoreException

IOException

deleteTrainingDatasetOnly

public void deleteTrainingDatasetOnly(T2 featureView,
                                      Integer trainingDataVersion)
                               throws FeatureStoreException,
                                      IOException

Throws:

FeatureStoreException

IOException

deleteTrainingDatasetOnly

public void deleteTrainingDatasetOnly(T2 featureView)
                               throws FeatureStoreException,
                                      IOException

Throws:

FeatureStoreException

IOException

getBatchQueryString

public abstract String getBatchQueryString(T2 featureView,
                                           Date startTime,
                                           Date endTime,
                                           Integer trainingDataVersion)
                                    throws FeatureStoreException,
                                           IOException

Throws:

FeatureStoreException

IOException

getOrCreateFeatureView

public abstract T2 getOrCreateFeatureView(T3 featureStore,
                                          String name,
                                          Integer version,
                                          T1 query,
                                          String description,
                                          List<String> labels)
                                   throws FeatureStoreException,
                                          IOException

Throws:

FeatureStoreException

IOException

getBatchData

public abstract T5 getBatchData(T2 featureView,
                                Date startTime,
                                Date endTime,
                                Map<String,String> readOptions,
                                Integer trainingDataVersion)
                         throws FeatureStoreException,
                                IOException

Throws:

FeatureStoreException

IOException