Index

A

add() (rialto.runner.reporting.bookkeeper.BookKeeper method) (rialto.runner.reporting.tracker.Tracker method) add_callable_to_module() (rialto.jobs.module_register.ModuleRegister class 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)

B

BookKeeper (class in rialto.runner.reporting.bookkeeper)

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) create_message() (rialto.runner.reporting.mailer.Mailer static method)

D

daily (rialto.metadata.enums.Schedule attribute) DataReader (class in rialto.common.table_reader) datasource() (in module rialto.jobs.decorators) date (rialto.runner.reporting.record.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) disable_job_decorators() (in module rialto.jobs.test_utils)

E

EnvLoader (class in rialto.common.env_yaml)

exception (rialto.runner.reporting.record.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)

fetch_schema_tables() (rialto.loader.pyspark_feature_loader.PysparkFeatureLoader method) find_callable() (rialto.jobs.module_register.ModuleRegister class method) find_dependency() (in module rialto.runner.utils) 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_custom_callable() (rialto.jobs.job_base.JobBase method) get_disable_version() (rialto.jobs.job_base.JobBase method) 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_job_metadata() (rialto.jobs.job_base.JobBase method) get_job_name() (rialto.jobs.job_base.JobBase 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_partitions() (in module rialto.runner.utils) get_pipelines_config() (in module rialto.runner.config_loader) get_schema() (rialto.runner.reporting.record.Record method) 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)

I

init_tools() (in module rialto.runner.utils)

J

job (rialto.runner.reporting.record.Record attribute)

job() (in module rialto.jobs.decorators) JobBase (class in rialto.jobs.job_base)

K

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

L

load_module() (in module rialto.runner.utils)

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

M

Mailer (class in rialto.runner.reporting.mailer) metadata() (rialto.maker.containers.FeatureFunction method) MetadataManager (class in rialto.metadata.metadata_manager) module rialto.common rialto.common.env_yaml rialto.common.table_reader rialto.common.utils rialto.jobs rialto.jobs.decorators rialto.jobs.job_base rialto.jobs.module_register rialto.jobs.resolver rialto.jobs.test_utils 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.config_overrides rialto.runner.date_manager rialto.runner.reporting rialto.runner.reporting.bookkeeper rialto.runner.reporting.mailer rialto.runner.reporting.record rialto.runner.reporting.tracker rialto.runner.runner rialto.runner.table rialto.runner.transformation rialto.runner.utils

ModuleRegister (class in rialto.jobs.module_register) 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)

override_config() (in module rialto.runner.config_overrides) owner (rialto.metadata.data_classes.group_metadata.GroupMetadata 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.reporting.record.Record attribute) Record (class in rialto.runner.reporting.record) records (rialto.runner.reporting.record.Record attribute) register_callable() (rialto.jobs.module_register.ModuleRegister class method) register_dependency() (rialto.jobs.module_register.ModuleRegister class method) register_dependency_callable() (in module rialto.jobs.module_register) register_dependency_module() (in module rialto.jobs.module_register) register_getter() (rialto.jobs.resolver.Resolver method) register_object() (rialto.jobs.resolver.Resolver method) remove_module() (rialto.jobs.module_register.ModuleRegister class method) report_by_mail() (rialto.runner.reporting.tracker.Tracker method) resolve() (rialto.jobs.resolver.Resolver method) Resolver (class in rialto.jobs.resolver) ResolverException rialto.common module rialto.common.env_yaml module rialto.common.table_reader module rialto.common.utils module rialto.jobs module rialto.jobs.decorators module rialto.jobs.job_base module rialto.jobs.module_register module rialto.jobs.resolver module rialto.jobs.test_utils 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.config_overrides module rialto.runner.date_manager module rialto.runner.reporting module rialto.runner.reporting.bookkeeper module rialto.runner.reporting.mailer module rialto.runner.reporting.record module rialto.runner.reporting.tracker module rialto.runner.runner module rialto.runner.table module rialto.runner.transformation module rialto.runner.utils module run() (rialto.jobs.job_base.JobBase method) (rialto.runner.transformation.Transformation method) run_dates() (rialto.runner.date_manager.DateManager static method) run_timestamp (rialto.runner.reporting.record.Record attribute) Runner (class in rialto.runner.runner)

S

Schedule (class in rialto.metadata.enums) send_mail() (rialto.runner.reporting.mailer.Mailer static method)

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

T

Table (class in rialto.runner.table) table_exists() (in module rialto.runner.utils) TableReader (class in rialto.common.table_reader) target (rialto.runner.reporting.record.Record attribute) template (rialto.metadata.data_classes.feature_metadata.FeatureMetadata attribute) template() (in module rialto.maker.wrappers)

time (rialto.runner.reporting.record.Record attribute) to_info_date() (rialto.runner.date_manager.DateManager static method) to_spark_row() (rialto.runner.reporting.record.Record method) to_tuple() (rialto.metadata.data_classes.feature_metadata.FeatureMetadata method) (rialto.metadata.data_classes.group_metadata.GroupMetadata method) Tracker (class in rialto.runner.reporting.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

yaml_constructors (rialto.common.env_yaml.EnvLoader attribute)

yaml_implicit_resolvers (rialto.common.env_yaml.EnvLoader attribute) yearly (rialto.metadata.enums.Schedule attribute)