com.logicalclocks.hsfs.flink

Class FeatureView

java.lang.Object

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

com.logicalclocks.hsfs.flink.FeatureView

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

Field Summary

Fields inherited from class com.logicalclocks.hsfs.FeatureViewBase

description, extraFilterVersion, features, featureStore, id, labels, LOGGER, name, query, type, vectorServer, version

Constructor Summary

Constructors

Constructor and Description
FeatureView()

Method Summary

Modifier and Type	Method and Description
void	addTag(String s, Object o) Add name/value tag to the feature view.
void	addTrainingDatasetTag(Integer integer, String s, Object o) Add name/value tag to the training dataset.
void	clean(FeatureStore featureStore, String s, Integer integer)
void	delete()
void	deleteAllTrainingDatasets()
void	deleteTag(String s) Delete a tag of the feature view.
void	deleteTrainingDataset(Integer integer)
void	deleteTrainingDatasetTag(Integer integer, String s) Delete a tag of the training dataset.
org.apache.flink.streaming.api.datastream.DataStream<Object>	getBatchData()
org.apache.flink.streaming.api.datastream.DataStream<Object>	getBatchData(String s, String s1)
org.apache.flink.streaming.api.datastream.DataStream<Object>	getBatchData(String s, String s1, Map<String,String> map)
String	getBatchQuery()
String	getBatchQuery(String s, String s1)
Object	getTag(String s) Get a single tag value of the feature view.
Map<String,Object>	getTags() Get all tags of the feature view.
Object	getTrainingData(Integer integer, Map<String,String> map)
Object	getTrainingDatasetTag(Integer integer, String s) Get a single tag value of the training dataset.
Map<String,Object>	getTrainingDatasetTags(Integer integer) Get all tags of the training dataset.
Object	getTrainTestSplit(Integer integer, Map<String,String> map)
Object	getTrainValidationTestSplit(Integer integer, Map<String,String> map)
void	purgeAllTrainingData()
void	purgeTrainingData(Integer integer)
FeatureView	update(FeatureView featureView)

Methods inherited from class com.logicalclocks.hsfs.FeatureViewBase

getFeatureVector, getFeatureVector, getFeatureVectors, getFeatureVectors, getPrimaryKeys, initBatchScoring, initServing, initServing, validateTrainTestSplit, validateTrainValidationTestSplit

Methods inherited from class java.lang.Object

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

Constructor Detail

FeatureView

public FeatureView()

Method Detail

addTag

public void addTag(String s,
                   Object o)
            throws FeatureStoreException,
                   IOException

Description copied from class: FeatureViewBase

Add name/value tag to the feature view.

Specified by:

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

Parameters:

s - name of the tag

o - value of the tag. The value of a tag can be any valid json - primitives, arrays or json objects

Throws:

FeatureStoreException

IOException

getTags

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

Description copied from class: FeatureViewBase

Get all tags of the feature view.

Specified by:

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

Returns:

a map of tag name and values. The value of a tag can be any valid json - primitives, arrays or json objects

Throws:

FeatureStoreException

IOException

getTag

public Object getTag(String s)
              throws FeatureStoreException,
                     IOException

Description copied from class: FeatureViewBase

Get a single tag value of the feature view.

Specified by:

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

Parameters:

s - name of the tag

Returns:

The value of a tag can be any valid json - primitives, arrays or json objects

Throws:

FeatureStoreException

IOException

deleteTag

public void deleteTag(String s)
               throws FeatureStoreException,
                      IOException

Description copied from class: FeatureViewBase

Delete a tag of the feature view.

Specified by:

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

Parameters:

s - name of the tag to be deleted

Throws:

FeatureStoreException

IOException

addTrainingDatasetTag

public void addTrainingDatasetTag(Integer integer,
                                  String s,
                                  Object o)
                           throws FeatureStoreException,
                                  IOException

Description copied from class: FeatureViewBase

Add name/value tag to the training dataset.

Specified by:

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

s - name of the tag

o - value of the tag. The value of a tag can be any valid json - primitives, arrays or json objects

Throws:

FeatureStoreException

IOException

getTrainingDatasetTags

public Map<String,Object> getTrainingDatasetTags(Integer integer)
                                          throws FeatureStoreException,
                                                 IOException

Description copied from class: FeatureViewBase

Get all tags of the training dataset.

Specified by:

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

Returns:

a map of tag name and values. The value of a tag can be any valid json - primitives, arrays or json objects

Throws:

FeatureStoreException

IOException

getTrainingDatasetTag

public Object getTrainingDatasetTag(Integer integer,
                                    String s)
                             throws FeatureStoreException,
                                    IOException

Description copied from class: FeatureViewBase

Get a single tag value of the training dataset.

Specified by:

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

s - name of the tag

Returns:

The value of a tag can be any valid json - primitives, arrays or json objects

Throws:

FeatureStoreException

IOException

deleteTrainingDatasetTag

public void deleteTrainingDatasetTag(Integer integer,
                                     String s)
                              throws FeatureStoreException,
                                     IOException

Description copied from class: FeatureViewBase

Delete a tag of the training dataset.

Specified by:

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

s - name of the tag to be deleted

Throws:

FeatureStoreException

IOException

delete

public void delete()
            throws FeatureStoreException,
                   IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

clean

public void clean(FeatureStore featureStore,
                  String s,
                  Integer integer)
           throws FeatureStoreException,
                  IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

update

public FeatureView update(FeatureView featureView)
                   throws FeatureStoreException,
                          IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

getBatchQuery

public String getBatchQuery()
                     throws FeatureStoreException,
                            IOException,
                            ParseException

Specified by:

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

Throws:

FeatureStoreException

IOException

ParseException

getBatchQuery

public String getBatchQuery(String s,
                            String s1)
                     throws FeatureStoreException,
                            IOException,
                            ParseException

Specified by:

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

Throws:

FeatureStoreException

IOException

ParseException

getBatchData

public org.apache.flink.streaming.api.datastream.DataStream<Object> getBatchData()
                                                                          throws FeatureStoreException,
                                                                                 IOException,
                                                                                 ParseException

Specified by:

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

Throws:

FeatureStoreException

IOException

ParseException

getBatchData

public org.apache.flink.streaming.api.datastream.DataStream<Object> getBatchData(String s,
                                                                                 String s1)
                                                                          throws FeatureStoreException,
                                                                                 IOException,
                                                                                 ParseException

Specified by:

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

Throws:

FeatureStoreException

IOException

ParseException

getBatchData

public org.apache.flink.streaming.api.datastream.DataStream<Object> getBatchData(String s,
                                                                                 String s1,
                                                                                 Map<String,String> map)
                                                                          throws FeatureStoreException,
                                                                                 IOException,
                                                                                 ParseException

Specified by:

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

Throws:

FeatureStoreException

IOException

ParseException

getTrainingData

public Object getTrainingData(Integer integer,
                              Map<String,String> map)
                       throws IOException,
                              FeatureStoreException,
                              ParseException

Specified by:

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

Throws:

IOException

FeatureStoreException

ParseException

getTrainTestSplit

public Object getTrainTestSplit(Integer integer,
                                Map<String,String> map)
                         throws IOException,
                                FeatureStoreException,
                                ParseException

Specified by:

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

Throws:

IOException

FeatureStoreException

ParseException

getTrainValidationTestSplit

public Object getTrainValidationTestSplit(Integer integer,
                                          Map<String,String> map)
                                   throws IOException,
                                          FeatureStoreException,
                                          ParseException

Specified by:

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

Throws:

IOException

FeatureStoreException

ParseException

purgeTrainingData

public void purgeTrainingData(Integer integer)
                       throws FeatureStoreException,
                              IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

purgeAllTrainingData

public void purgeAllTrainingData()
                          throws FeatureStoreException,
                                 IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

deleteTrainingDataset

public void deleteTrainingDataset(Integer integer)
                           throws FeatureStoreException,
                                  IOException

Specified by:

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

Throws:

FeatureStoreException

IOException

deleteAllTrainingDatasets

public void deleteAllTrainingDatasets()
                               throws FeatureStoreException,
                                      IOException

Specified by:

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

Throws:

FeatureStoreException

IOException