Package 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	Description
FeatureViewEngine()

Method Summary

Modifier and Type	Method	Description
FeatureView	get(FeatureStore featureStore, String name, Integer version)
FeatureView	getOrCreateFeatureView(FeatureStore featureStore, String name, Integer version, com.logicalclocks.hsfs.flink.constructor.Query query, String description, List<String> labels)
FeatureView	update(FeatureView featureView)

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

addTag, addTag, delete, delete, 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 Details

FeatureViewEngine

public FeatureViewEngine()

Method Details

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

getOrCreateFeatureView

public FeatureView getOrCreateFeatureView(FeatureStore featureStore,
 String name,
 Integer version,
 com.logicalclocks.hsfs.flink.constructor.Query query,
 String description,
 List<String> labels)
                                   throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException