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)
org.apache.flink.streaming.api.datastream.DataStream	getBatchData(FeatureView featureView, Date startTime, Date endTime, Map<String,String> readOptions, Integer trainingDataVersion)
com.logicalclocks.hsfs.flink.constructor.Query	getBatchQuery(FeatureView featureView, Date date, Date date1, Boolean withLabels, Integer integer)
String	getBatchQueryString(FeatureView featureView, Date startTime, Date endTime, Integer trainingDataVersion)
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, 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

getBatchQuery

public com.logicalclocks.hsfs.flink.constructor.Query getBatchQuery(FeatureView featureView,
                                                                    Date date,
                                                                    Date date1,
                                                                    Boolean withLabels,
                                                                    Integer integer)
                                                             throws FeatureStoreException,
                                                                    IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

getBatchQueryString

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

Specified by:

getBatchQueryString 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

Specified by:

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

Throws:

FeatureStoreException

IOException

getBatchData

public org.apache.flink.streaming.api.datastream.DataStream getBatchData(FeatureView featureView,
                                                                         Date startTime,
                                                                         Date endTime,
                                                                         Map<String,String> readOptions,
                                                                         Integer trainingDataVersion)
                                                                  throws FeatureStoreException,
                                                                         IOException

Specified by:

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

Throws:

FeatureStoreException

IOException