Package com.logicalclocks.hsfs

Class FeatureGroupBase<T>

java.lang.Object

com.logicalclocks.hsfs.FeatureGroupBase<T>

Direct Known Subclasses:

ExternalFeatureGroup, FeatureGroup, StreamFeatureGroup, StreamFeatureGroup, StreamFeatureGroup, StreamFeatureGroup

public abstract class FeatureGroupBase<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Date	created
protected User	creator
protected DataSource	dataSource
protected DeltaStreamerJobConf	deltaStreamerJobConf
protected Boolean	deprecated
protected String	description
protected String	eventTime
protected List<String>	expectationsNames
protected FeatureGroupEngineBase	featureGroupEngineBase
protected List<Feature>	features
protected FeatureStoreBase	featureStore
protected Integer	featurestoreId
protected String	hudiPrecombineKey
protected Integer	id
protected String	location
protected static final org.slf4j.Logger	LOGGER
protected String	name
protected String	notificationTopicName
protected OnlineConfig	onlineConfig
protected Boolean	onlineEnabled
protected OnlineIngestionApi	onlineIngestionApi
protected String	onlineTopicName
protected List<String>	partitionKeys
protected List<String>	primaryKeys
protected List<String>	statisticColumns
protected StatisticsConfig	statisticsConfig
protected Subject	subject
protected TimeTravelFormat	timeTravelFormat
protected String	topicName
protected String	type
protected FeatureGroupUtils	utils
protected Integer	version

Constructor Summary

Constructors

Constructor	Description
FeatureGroupBase()

Method Summary

Modifier and Type	Method	Description
void	addTag(String name, Object value)	Add name/value tag to the feature group.
void	checkDeprecated()
void	delete()
void	deleteTag(String name)	Delete a tag of the feature group.
String	getAvroSchema()
List<String>	getComplexFeatures()
org.apache.avro.Schema	getDeserializedAvroSchema()
org.apache.avro.Schema	getDeserializedEncodedAvroSchema()
String	getEncodedAvroSchema()
Feature	getFeature(String name)	Retrieve a feature of the feature group by name.
String	getFeatureAvroSchema(String featureName)
OnlineIngestion	getLatestOnlineIngestion()
OnlineIngestion	getOnlineIngestion(Integer id)
List<String>	getPrimaryKeys()
Subject	getSubject()
Object	getTag(String name)	Get a single tag value of the feature group.
Map<String,Object>	getTags()	Get all tags of the feature group.
abstract Object	insertStream(T featureData)
abstract Object	insertStream(T featureData, Map<String,String> writeOptions)
void	setDataSource(DataSource dataSource)
void	setDeprecated(Boolean deprecated)
void	unloadSubject()
void	updateDeprecated()	Deprecate the feature group.
void	updateDeprecated(Boolean deprecate)	Deprecate the feature group.
void	updateDescription(String description)	Update the description of the feature group.
void	updateFeatureDescription(String featureName, String description)	Update the description of a single feature.
void	updateNotificationTopicName(String notificationTopicName)	Update the notification topic name of the feature group.
void	updateStatisticsConfig()	Update the statistics configuration of the feature group.

Methods inherited from class java.lang.Object

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

Field Details

id

protected Integer id

featureStore

protected FeatureStoreBase featureStore

featurestoreId

protected Integer featurestoreId

type

protected String type

name

protected String name

version

protected Integer version

description

protected String description

primaryKeys

protected List<String> primaryKeys

features

protected List<Feature> features

eventTime

protected String eventTime

created

protected Date created

creator

protected User creator

statisticsConfig

protected StatisticsConfig statisticsConfig

expectationsNames

protected List<String> expectationsNames

location

protected String location

timeTravelFormat

protected TimeTravelFormat timeTravelFormat

onlineEnabled

protected Boolean onlineEnabled

onlineTopicName

protected String onlineTopicName

topicName

protected String topicName

notificationTopicName

protected String notificationTopicName

statisticColumns

protected List<String> statisticColumns

deltaStreamerJobConf

protected DeltaStreamerJobConf deltaStreamerJobConf

deprecated

protected Boolean deprecated

onlineConfig

protected OnlineConfig onlineConfig

dataSource

protected DataSource dataSource

partitionKeys

protected List<String> partitionKeys

hudiPrecombineKey

protected String hudiPrecombineKey

subject

protected Subject subject

featureGroupEngineBase

protected FeatureGroupEngineBase featureGroupEngineBase

utils

protected FeatureGroupUtils utils

onlineIngestionApi

protected OnlineIngestionApi onlineIngestionApi

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Details

FeatureGroupBase

public FeatureGroupBase()

Method Details

setDeprecated

public void setDeprecated(Boolean deprecated)

checkDeprecated

public void checkDeprecated()

setDataSource

public void setDataSource(DataSource dataSource)

delete

public void delete()
            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

addTag

public void addTag(String name,
 Object value)
            throws FeatureStoreException,
IOException

Add name/value tag to the feature group.

Parameters:

name - name of the tag

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

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

getTags

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

Get all tags of the feature group.

Returns:

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

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

getTag

public Object getTag(String name)
              throws FeatureStoreException,
IOException

Get a single tag value of the feature group.

Parameters:

name - name of tha tag

Returns:

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

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

deleteTag

public void deleteTag(String name)
               throws FeatureStoreException,
IOException

Delete a tag of the feature group.

Parameters:

name - name of the tag to be deleted

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

updateDescription

public void updateDescription(String description)
                       throws FeatureStoreException,
IOException

Update the description of the feature group.

Parameters:

description - feature group description.

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

updateNotificationTopicName

public void updateNotificationTopicName(String notificationTopicName)
                                 throws FeatureStoreException,
IOException

Update the notification topic name of the feature group.

Parameters:

notificationTopicName - feature group notification topic name.

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

updateDeprecated

public void updateDeprecated()
                      throws FeatureStoreException,
IOException

Deprecate the feature group.

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

updateDeprecated

public void updateDeprecated(Boolean deprecate)
                      throws FeatureStoreException,
IOException

Deprecate the feature group.

Parameters:

deprecate - identifies if feature group should be deprecated.

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

updateFeatureDescription

public void updateFeatureDescription(String featureName,
 String description)
                              throws FeatureStoreException,
IOException

Update the description of a single feature.

Parameters:

featureName - Name of the feature

description - Description of the feature

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

insertStream

public abstract Object insertStream(T featureData)
                             throws Exception

Throws:

Exception

insertStream

public abstract Object insertStream(T featureData,
 Map<String,String> writeOptions)
                             throws Exception

Throws:

Exception

updateStatisticsConfig

public void updateStatisticsConfig()
                            throws FeatureStoreException,
IOException

Update the statistics configuration of the feature group. Change the `enabled`, `histograms`, `correlations` or `columns` attributes and persist the changes by calling this method.

Throws:

FeatureStoreException - FeatureStoreException

IOException - IOException

getSubject

public Subject getSubject()
                   throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

unloadSubject

public void unloadSubject()

getFeature

public Feature getFeature(String name)
                   throws FeatureStoreException

Retrieve a feature of the feature group by name.

Parameters:

name - feature name

Returns:

Feature metadata object

Throws:

FeatureStoreException - FeatureStoreException

getPrimaryKeys

public List<String> getPrimaryKeys()

getComplexFeatures

public List<String> getComplexFeatures()

getAvroSchema

public String getAvroSchema()
                     throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getFeatureAvroSchema

public String getFeatureAvroSchema(String featureName)
                            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getEncodedAvroSchema

public String getEncodedAvroSchema()
                            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getDeserializedEncodedAvroSchema

public org.apache.avro.Schema getDeserializedEncodedAvroSchema()
                                                        throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getDeserializedAvroSchema

public org.apache.avro.Schema getDeserializedAvroSchema()
                                                 throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getLatestOnlineIngestion

public OnlineIngestion getLatestOnlineIngestion()
                                         throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getOnlineIngestion

public OnlineIngestion getOnlineIngestion(Integer id)
                                   throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException