Index

A

add() (rialto.runner.tracker.Tracker method) add_features() (rialto.metadata.data_classes.group_metadata.GroupMetadata method)

add_group() (rialto.metadata.data_classes.feature_metadata.FeatureMetadata method) all_dates() (rialto.runner.date_manager.DateManager static method)

C

cast_decimals_to_floats() (in module rialto.common.utils) check_dates_have_partition() (rialto.runner.runner.Runner method)

check_dependencies() (rialto.runner.runner.Runner method) class_to_catalog_name() (in module rialto.metadata.utils) config_parser() (in module rialto.jobs.decorators)

D

daily (rialto.metadata.enums.Schedule attribute) DataReader (class in rialto.common.table_reader) datasource() (in module rialto.jobs.decorators) date (rialto.runner.tracker.Record attribute) date_subtract() (rialto.runner.date_manager.DateManager static method)

DateManager (class in rialto.runner.date_manager) depends() (in module rialto.maker.wrappers) desc() (in module rialto.maker.wrappers) description (rialto.metadata.data_classes.feature_metadata.FeatureMetadata attribute) (rialto.metadata.data_classes.group_metadata.GroupMetadata attribute) df (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader.KeyMap attribute)

E

exception (rialto.runner.tracker.Record attribute)

F

feature() (in module rialto.maker.wrappers) feature_name() (in module rialto.maker.utils) FeatureFunction (class in rialto.maker.containers) FeatureHolder (class in rialto.maker.containers) FeatureLoaderInterface (class in rialto.loader.interfaces)

FeatureMetadata (class in rialto.metadata.data_classes.feature_metadata) features (rialto.metadata.data_classes.group_metadata.GroupMetadata attribute) frequency (rialto.metadata.data_classes.group_metadata.GroupMetadata attribute) from_spark() (rialto.metadata.data_classes.feature_metadata.FeatureMetadata class method) (rialto.metadata.data_classes.group_metadata.GroupMetadata class method) fs_name (rialto.metadata.data_classes.group_metadata.GroupMetadata attribute)

G

get_caller_module() (in module rialto.common.utils) get_feature() (rialto.loader.interfaces.FeatureLoaderInterface method) (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) (rialto.metadata.metadata_manager.MetadataManager method) get_feature_config() (in module rialto.loader.config_loader) get_feature_metadata() (rialto.loader.interfaces.FeatureLoaderInterface method) (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) get_feature_name() (rialto.maker.containers.FeatureFunction method) get_features_from_cfg() (rialto.loader.interfaces.FeatureLoaderInterface method) (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) get_group() (rialto.loader.interfaces.FeatureLoaderInterface method) (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) (rialto.metadata.metadata_manager.MetadataManager method) get_group_fs_name() (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method)

get_group_metadata() (rialto.loader.interfaces.FeatureLoaderInterface method) (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) get_latest() (rialto.common.table_reader.DataReader method) (rialto.common.table_reader.TableReader method) get_metadata() (rialto.maker.containers.FeatureHolder method) get_metadata_from_cfg() (rialto.loader.interfaces.FeatureLoaderInterface method) (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) get_pipelines_config() (in module rialto.runner.config_loader) get_schema_path() (rialto.runner.table.Table method) get_table() (rialto.common.table_reader.DataReader method) (rialto.common.table_reader.TableReader method) get_table_path() (rialto.runner.table.Table method) get_type() (rialto.maker.containers.FeatureFunction method) group (rialto.metadata.data_classes.feature_metadata.FeatureMetadata attribute) GroupMetadata (class in rialto.metadata.data_classes.group_metadata)

J

job (rialto.runner.tracker.Record attribute)

job() (in module rialto.jobs.decorators)

K

key (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader.KeyMap attribute) (rialto.metadata.data_classes.group_metadata.GroupMetadata attribute)

L

load_yaml() (in module rialto.common.utils)

M

metadata() (rialto.maker.containers.FeatureFunction method) MetadataManager (class in rialto.metadata.metadata_manager) module rialto.common rialto.common.table_reader rialto.common.utils rialto.jobs rialto.jobs.decorators rialto.loader rialto.loader.config_loader rialto.loader.interfaces rialto.loader.pyspark_feature_loader rialto.maker rialto.maker.containers rialto.maker.feature_maker rialto.maker.utils rialto.maker.wrappers rialto.metadata rialto.metadata.data_classes rialto.metadata.data_classes.feature_metadata rialto.metadata.data_classes.group_metadata rialto.metadata.enums rialto.metadata.metadata_manager rialto.metadata.utils rialto.runner rialto.runner.config_loader rialto.runner.date_manager rialto.runner.runner rialto.runner.table rialto.runner.tracker rialto.runner.transformation

monthly (rialto.metadata.enums.Schedule attribute)

N

name (rialto.metadata.data_classes.feature_metadata.FeatureMetadata attribute) (rialto.metadata.data_classes.group_metadata.GroupMetadata attribute)

nominal (rialto.metadata.enums.ValueType attribute) numerical (rialto.metadata.enums.ValueType attribute)

O

ordinal (rialto.metadata.enums.ValueType attribute)

P

param() (in module rialto.maker.wrappers)

PysparkFeatureLoader (class in rialto.loader.pyspark_feature_loader) PysparkFeatureLoader.KeyMap (class in rialto.loader.pyspark_feature_loader)

R

read_group() (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) reason (rialto.runner.tracker.Record attribute) Record (class in rialto.runner.tracker) records (rialto.runner.tracker.Record attribute) report() (rialto.runner.tracker.Tracker method) rialto.common module rialto.common.table_reader module rialto.common.utils module rialto.jobs module rialto.jobs.decorators module rialto.loader module rialto.loader.config_loader module rialto.loader.interfaces module rialto.loader.pyspark_feature_loader module rialto.maker module rialto.maker.containers module rialto.maker.feature_maker module rialto.maker.utils module rialto.maker.wrappers module

rialto.metadata module rialto.metadata.data_classes module rialto.metadata.data_classes.feature_metadata module rialto.metadata.data_classes.group_metadata module rialto.metadata.enums module rialto.metadata.metadata_manager module rialto.metadata.utils module rialto.runner module rialto.runner.config_loader module rialto.runner.date_manager module rialto.runner.runner module rialto.runner.table module rialto.runner.tracker module rialto.runner.transformation module run() (rialto.runner.transformation.Transformation method) run_dates() (rialto.runner.date_manager.DateManager static method) Runner (class in rialto.runner.runner)

S

Schedule (class in rialto.metadata.enums)

status (rialto.runner.tracker.Record attribute) str_to_date() (rialto.runner.date_manager.DateManager static method)

T

Table (class in rialto.runner.table) TableReader (class in rialto.common.table_reader) target (rialto.runner.tracker.Record attribute) time (rialto.runner.tracker.Record attribute)

to_info_date() (rialto.runner.date_manager.DateManager static method) to_tuple() (rialto.metadata.data_classes.feature_metadata.FeatureMetadata method) (rialto.metadata.data_classes.group_metadata.GroupMetadata method) Tracker (class in rialto.runner.tracker) Transformation (class in rialto.runner.transformation)

U

unscheduled (rialto.metadata.enums.Schedule attribute)

update() (rialto.metadata.metadata_manager.MetadataManager method)

V

value_type (rialto.metadata.data_classes.feature_metadata.FeatureMetadata attribute)

ValueType (class in rialto.metadata.enums)

W

weekly (rialto.metadata.enums.Schedule attribute)

Y

yearly (rialto.metadata.enums.Schedule attribute)