hops.featurestore_impl.query_planner package

Submodules

hops.featurestore_impl.query_planner.f_query module

class hops.featurestore_impl.query_planner.f_query.FeatureQuery(feature, featurestore_metadata, featurestore, featuregroup, featuregroup_version)

Bases: hops.featurestore_impl.query_planner.fs_query.FeaturestoreQuery

Represents a user-query for a single feature in the featurestore

__init__(feature, featurestore_metadata, featurestore, featuregroup, featuregroup_version)

Initializes the query object with user-supplied data

Args:
feature:the feature to get from the featurestore
featurestore_metadata:
 the metadata of the featurestore
featurestore:the featurestore to query
featuregroup:the featuregroup where the feature resides (optional)
featuregroup_version:
 the version of the featuregroup (defaults to 1)
class hops.featurestore_impl.query_planner.f_query.FeaturesQuery(features, featurestore_metadata, featurestore, featuregroups_version_dict, join_key)

Bases: hops.featurestore_impl.query_planner.fs_query.FeaturestoreQuery

Represents a user query for a list of features from the featurestore

__init__(features, featurestore_metadata, featurestore, featuregroups_version_dict, join_key)

Initializes the query object from user-supplied data

Args:
features:the list of features to get
featurestore_metadata:
 the metadata of the featurestore to query
featurestore:the featurestore to query
featuregroups_version_dict:
 a dict of featuregroups and their versions to get the features from (optional)
join_key:the join key to join features together (optional)

hops.featurestore_impl.query_planner.fg_query module

class hops.featurestore_impl.query_planner.fg_query.FeaturegroupQuery(featuregroup, featurestore, featuregroup_version)

Bases: hops.featurestore_impl.query_planner.fs_query.FeaturestoreQuery

Represents a user query to get a feature group from the feature store

__init__(featuregroup, featurestore, featuregroup_version)

Initializes the query object from user-supplied data

Args:
featuregroup:the featuregroup to get
featurestore:the featurestore to query
featuregroup_version:
 the version of the featuregroup (defaults to 1)

hops.featurestore_impl.query_planner.fs_query module

class hops.featurestore_impl.query_planner.fs_query.FeaturestoreQuery

Bases: object

Represents an abstract query to the feature store

hops.featurestore_impl.query_planner.logical_query_plan module

class hops.featurestore_impl.query_planner.logical_query_plan.LogicalQueryPlan(fs_query)

Bases: object

Represents a logical query plan for getting features from the feature store hive database

__init__(fs_query)

Initializes the query plan from a feature store query

Args:
fs_query:the user query
construct_sql()

Constructs a HiveSQL query from the logical plan

Returns:
None
create_logical_plan()

Creates a logical plan from a user query

Returns:
None

hops.featurestore_impl.query_planner.query_planner module

Query Planner functions for inferring how to perform user queries to the featurestore

Module contents