com.logicalclocks.hsfs.flink.engine

Class FeatureViewEngine

java.lang.Object

com.logicalclocks.hsfs.engine.FeatureViewEngineBase<com.logicalclocks.hsfs.flink.constructor.Query,FeatureView,FeatureStore,StreamFeatureGroup,org.apache.flink.streaming.api.datastream.DataStream<?>>

com.logicalclocks.hsfs.flink.engine.FeatureViewEngine

public class FeatureViewEngine
extends FeatureViewEngineBase<com.logicalclocks.hsfs.flink.constructor.Query,FeatureView,FeatureStore,StreamFeatureGroup,org.apache.flink.streaming.api.datastream.DataStream<?>>

Field Summary

Fields inherited from class com.logicalclocks.hsfs.engine.FeatureViewEngineBase

AMBIGUOUS_LABEL_ERROR, featureViewApi, LABEL_NOT_EXIST_ERROR, LOGGER, tagsApi

Constructor Summary

Constructors

Constructor and Description
FeatureViewEngine()

Method Summary

Modifier and Type	Method and Description
FeatureView	get(FeatureStore featureStore, String name, Integer version)
FeatureView	update(FeatureView featureView)

Methods inherited from class com.logicalclocks.hsfs.engine.FeatureViewEngineBase

addTag, addTag, delete, delete, deleteTag, deleteTag, deleteTrainingData, deleteTrainingData, deleteTrainingDatasetOnly, deleteTrainingDatasetOnly, get, get, getBatchQuery, getEndTime, getStartTime, getTag, getTag, getTags, getTags, makeLabelFeatures, save, setEventTime

Methods inherited from class java.lang.Object

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

Constructor Detail

FeatureViewEngine

public FeatureViewEngine()

Method Detail

update

public FeatureView update(FeatureView featureView)
                   throws FeatureStoreException,
                          IOException

Specified by:

update in class FeatureViewEngineBase<com.logicalclocks.hsfs.flink.constructor.Query,FeatureView,FeatureStore,StreamFeatureGroup,org.apache.flink.streaming.api.datastream.DataStream<?>>

Throws:

FeatureStoreException

IOException

get

public FeatureView get(FeatureStore featureStore,
                       String name,
                       Integer version)
                throws FeatureStoreException,
                       IOException

Specified by:

get in class FeatureViewEngineBase<com.logicalclocks.hsfs.flink.constructor.Query,FeatureView,FeatureStore,StreamFeatureGroup,org.apache.flink.streaming.api.datastream.DataStream<?>>

Throws:

FeatureStoreException

IOException