Package com.c12e.cortex.profiles.featurecatalog

Class DefaultCortexFeatureCatalog

java.lang.Object

com.c12e.cortex.profiles.featurecatalog.DefaultCortexFeatureCatalog

All Implemented Interfaces:

FeatureCatalog

public class DefaultCortexFeatureCatalog
extends java.lang.Object
implements FeatureCatalog

Constructor Summary

Constructors

Constructor	Description
DefaultCortexFeatureCatalog(com.c12e.cortex.phoenix.Catalog catalog, FeatureReportCalculator featureCalculator)

Method Summary

Modifier and Type	Method	Description
java.util.List<com.c12e.cortex.phoenix.Feature>	queryFeatures(java.lang.String project, java.lang.String sourceName)	Get the list of features associated to the DataSource with the given name
java.util.List<com.c12e.cortex.phoenix.Feature>	updateFeatureCatalog(java.lang.String project, java.lang.String sourceName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> sourceDf, java.lang.Boolean performCalculations)	Updates the set of Feature's associated with the DataSource

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCortexFeatureCatalog

@Inject
public DefaultCortexFeatureCatalog(com.c12e.cortex.phoenix.Catalog catalog,
                                   FeatureReportCalculator featureCalculator)

Method Detail

queryFeatures

public java.util.List<com.c12e.cortex.phoenix.Feature> queryFeatures(java.lang.String project,
                                                                     java.lang.String sourceName)

Description copied from interface: FeatureCatalog

Get the list of features associated to the DataSource with the given name

Specified by:

queryFeatures in interface FeatureCatalog

Parameters:

project - project the DataSource belongs to

sourceName - DataSource name

Returns:

list of features

updateFeatureCatalog

public java.util.List<com.c12e.cortex.phoenix.Feature> updateFeatureCatalog(java.lang.String project,
                                                                            java.lang.String sourceName,
                                                                            org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> sourceDf,
                                                                            java.lang.Boolean performCalculations)

Description copied from interface: FeatureCatalog

Updates the set of Feature's associated with the DataSource

Specified by:

updateFeatureCatalog in interface FeatureCatalog

Parameters:

project - project the DataSource belongs to

sourceName - Cortex DataSource name

sourceDf - data to infer the feature properties from

performCalculations - perform analytic calculations

Returns:

list of features