Package 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, 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	Description
static String	AMBIGUOUS_LABEL_ERROR
protected FeatureViewApi	featureViewApi
static String	LABEL_NOT_EXIST_ERROR
protected static final org.slf4j.Logger	LOGGER
protected TagsApi	tagsApi

Constructor Summary

Constructors

Constructor	Description
FeatureViewEngineBase()

Method Summary

Modifier and Type	Method	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, Boolean force)
void	delete(T3 featureStoreBase, String name, Integer version)
void	delete(T3 featureStoreBase, String name, Integer version, Boolean force)
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)
T1	getBatchQuery(T2 featureView, Date startTime, Date endTime, Boolean withLabels, Integer trainingDataVersion, Class<T1> queryType)
protected Date	getEndTime()
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 Details

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 Details

FeatureViewEngineBase

public FeatureViewEngineBase()

Method Details

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

delete

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

Throws:

FeatureStoreException

IOException

delete

public void delete(T3 featureStoreBase,
 String name,
 Integer version,
 Boolean force)
            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 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