Modifier and Type | Field and Description |
---|---|
protected List<Feature> |
FeatureGroupBase.features |
Modifier and Type | Method and Description |
---|---|
Feature |
FeatureGroupBase.getFeature(String name)
Retrieve a feature of the feature group by name.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
FeatureGroupBase.appendFeatures(Feature features)
Append a single feature to the schema of the feature group.
|
void |
FeatureGroupBaseForApi.appendFeatures(Feature features) |
Filter |
Feature.eq(Feature value) |
Filter |
Feature.ge(Feature value) |
Filter |
Feature.gt(Feature value) |
Filter |
Feature.le(Feature value) |
Filter |
Feature.lt(Feature value) |
Filter |
Feature.ne(Feature value) |
abstract void |
FeatureGroupBase.updateFeatures(Feature feature)
Update the metadata of multiple features.
|
void |
FeatureGroupBaseForApi.updateFeatures(Feature feature) |
Modifier and Type | Method and Description |
---|---|
abstract void |
FeatureGroupBase.appendFeatures(List<Feature> features)
Append features to the schema of the feature group.
|
void |
FeatureGroupBaseForApi.appendFeatures(List<Feature> features) |
abstract QueryBase |
FeatureGroupBase.selectExceptFeatures(List<Feature> features) |
QueryBase |
FeatureGroupBaseForApi.selectExceptFeatures(List<Feature> features) |
abstract QueryBase |
FeatureGroupBase.selectFeatures(List<Feature> features) |
QueryBase |
FeatureGroupBaseForApi.selectFeatures(List<Feature> features) |
abstract void |
FeatureGroupBase.updateFeatures(List<Feature> features)
Update the metadata of multiple features.
|
void |
FeatureGroupBaseForApi.updateFeatures(List<Feature> features) |
Modifier and Type | Field and Description |
---|---|
protected List<Feature> |
QueryBase.leftFeatures |
Modifier and Type | Method and Description |
---|---|
protected List<Feature> |
QueryBase.addFeatureGroupToFeatures(FeatureGroupBase featureGroupBase,
List<Feature> leftFeatures) |
Modifier and Type | Method and Description |
---|---|
T |
QueryBase.appendFeature(Feature feature) |
Modifier and Type | Method and Description |
---|---|
protected List<Feature> |
QueryBase.addFeatureGroupToFeatures(FeatureGroupBase featureGroupBase,
List<Feature> leftFeatures) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> on) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> on,
JoinType joinType) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> on,
JoinType joinType,
String prefix) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn,
JoinType joinType) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn,
JoinType joinType) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn,
JoinType joinType,
String prefix) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn,
JoinType joinType,
String prefix) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn,
String prefix) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> leftOn,
List<Feature> rightOn,
String prefix) |
T |
QueryBase.joinFeatures(T subquery,
List<Feature> on,
String prefix) |
Constructor and Description |
---|
Join(T query,
List<Feature> on,
JoinType type,
String prefix) |
Join(T query,
List<Feature> leftOn,
List<Feature> rightOn,
JoinType type,
String prefix) |
Join(T query,
List<Feature> leftOn,
List<Feature> rightOn,
JoinType type,
String prefix) |
QueryBase(T2 leftFeatureGroup,
List<Feature> leftFeatures) |
Modifier and Type | Method and Description |
---|---|
List<String> |
FeatureGroupUtils.getComplexFeatures(List<Feature> features) |
<T extends FeatureGroupBase> |
FeatureGroupEngineBase.updateFeatures(FeatureGroupBase featureGroup,
List<Feature> features,
Class<T> fgClass) |
Modifier and Type | Method and Description |
---|---|
void |
StreamFeatureGroup.appendFeatures(Feature feature) |
void |
StreamFeatureGroup.updateFeatures(Feature feature) |
Modifier and Type | Method and Description |
---|---|
void |
StreamFeatureGroup.appendFeatures(List<Feature> feature) |
QueryBase |
StreamFeatureGroup.selectExceptFeatures(List<Feature> features) |
QueryBase |
StreamFeatureGroup.selectFeatures(List<Feature> features) |
void |
StreamFeatureGroup.updateFeatures(List<Feature> feature) |
Constructor and Description |
---|
StreamFeatureGroup(FeatureStore featureStore,
@NonNull String name,
Integer version,
String description,
List<String> primaryKeys,
List<String> partitionKeys,
String hudiPrecombineKey,
boolean onlineEnabled,
List<Feature> features,
StatisticsConfig statisticsConfig,
String onlineTopicName,
String eventTime) |
StreamFeatureGroup(Integer id,
String description,
List<Feature> features) |
Modifier and Type | Method and Description |
---|---|
void |
ExternalFeatureGroup.appendFeatures(Feature features) |
void |
StreamFeatureGroup.appendFeatures(Feature features)
Append a single feature to the schema of the stream feature group.
|
void |
FeatureGroup.appendFeatures(Feature features)
Append a single feature to the schema of the feature group.
|
void |
ExternalFeatureGroup.updateFeatures(Feature feature) |
void |
StreamFeatureGroup.updateFeatures(Feature feature)
Update the metadata of feature.
|
void |
FeatureGroup.updateFeatures(Feature feature)
Update the metadata of feature.
|
Modifier and Type | Method and Description |
---|---|
void |
ExternalFeatureGroup.appendFeatures(List<Feature> features) |
void |
StreamFeatureGroup.appendFeatures(List<Feature> features)
Append features to the schema of the stream feature group.
|
void |
FeatureGroup.appendFeatures(List<Feature> features)
Append features to the schema of the feature group.
|
Query |
ExternalFeatureGroup.selectExceptFeatures(List<Feature> features) |
Query |
StreamFeatureGroup.selectExceptFeatures(List<Feature> features)
Select all features including primary key and event time feature of the feature group except provided `features`
and return a query object.
|
Query |
FeatureGroup.selectExceptFeatures(List<Feature> features)
Select all features including primary key and event time feature of the feature group except provided `features`
and return a query object.
|
Query |
ExternalFeatureGroup.selectFeatures(List<Feature> features) |
Query |
StreamFeatureGroup.selectFeatures(List<Feature> features)
Select a subset of features of the feature group and return a query object.
|
Query |
FeatureGroup.selectFeatures(List<Feature> features)
Select a subset of features of the feature group and return a query object.
|
void |
ExternalFeatureGroup.updateFeatures(List<Feature> features) |
void |
StreamFeatureGroup.updateFeatures(List<Feature> features)
Update the metadata of multiple features.
|
void |
FeatureGroup.updateFeatures(List<Feature> features)
Update the metadata of multiple features.
|
Constructor and Description |
---|
ExternalFeatureGroup(FeatureStore featureStore,
@NonNull String name,
Integer version,
String query,
ExternalDataFormat dataFormat,
String path,
Map<String,String> options,
@NonNull StorageConnector storageConnector,
String description,
List<String> primaryKeys,
List<Feature> features,
StatisticsConfig statisticsConfig,
String eventTime,
boolean onlineEnabled,
String onlineTopicName) |
FeatureGroup(FeatureStore featureStore,
@NonNull String name,
Integer version,
String description,
List<String> primaryKeys,
List<String> partitionKeys,
String hudiPrecombineKey,
boolean onlineEnabled,
TimeTravelFormat timeTravelFormat,
List<Feature> features,
StatisticsConfig statisticsConfig,
String onlineTopicName,
String eventTime) |
FeatureGroup(Integer id,
String description,
List<Feature> features) |
StreamFeatureGroup(FeatureStore featureStore,
@NonNull String name,
Integer version,
String description,
List<String> primaryKeys,
List<String> partitionKeys,
String hudiPrecombineKey,
boolean onlineEnabled,
List<Feature> features,
StatisticsConfig statisticsConfig,
String onlineTopicName,
String eventTime) |
StreamFeatureGroup(Integer id,
String description,
List<Feature> features) |
Constructor and Description |
---|
Query(FeatureGroupBase leftFeatureGroup,
List<Feature> leftFeatures) |
Modifier and Type | Method and Description |
---|---|
List<Feature> |
SparkEngine.parseFeatureGroupSchema(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset,
TimeTravelFormat timeTravelFormat) |
Modifier and Type | Method and Description |
---|---|
<T extends FeatureGroupBase> |
FeatureGroupEngine.appendFeatures(FeatureGroupBase featureGroup,
List<Feature> features,
Class<T> fgClass) |
Copyright © 2023. All rights reserved.