Index

A

AbstractClient (class in butterfree.clients) (class in butterfree.clients.abstract_client) AbstractWriteConfig (class in butterfree.configs.db) (class in butterfree.configs.db.abstract_config) ADD (butterfree.migrations.database_migration.database_migration.Diff.Kind attribute) (butterfree.migrations.database_migration.Diff.Kind attribute) add_post_hook() (butterfree.hooks.hookable_component.HookableComponent method) (butterfree.hooks.HookableComponent method) add_pre_hook() (butterfree.hooks.hookable_component.HookableComponent method) (butterfree.hooks.HookableComponent method) add_table_partitions() (butterfree.clients.spark_client.SparkClient method) (butterfree.clients.SparkClient method) agg_column (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) AggregatedFeatureSet (class in butterfree.transform.aggregated_feature_set) AggregatedTransform (class in butterfree.transform.transformations) (class in butterfree.transform.transformations.aggregated_transform)

aggregation (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) aggregations (butterfree.transform.transformations.aggregated_transform.AggregatedTransform property) (butterfree.transform.transformations.AggregatedTransform property) ALTER_KEY (butterfree.migrations.database_migration.database_migration.Diff.Kind attribute) (butterfree.migrations.database_migration.Diff.Kind attribute) ALTER_TYPE (butterfree.migrations.database_migration.database_migration.Diff.Kind attribute) (butterfree.migrations.database_migration.Diff.Kind attribute) apply_migration() (butterfree.migrations.database_migration.database_migration.DatabaseMigration method) ARRAY_BIGINT (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) ARRAY_FLOAT (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) ARRAY_STRING (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) assert_column_equality() (in module butterfree.testing.dataframe) assert_dataframe_equality() (in module butterfree.testing.dataframe)

B

BasicValidation (class in butterfree.validations) (class in butterfree.validations.basic_validaton) BIGINT (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) BINARY (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) BOOLEAN (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) build() (butterfree.extract.readers.reader.Reader method) butterfree module butterfree.clients module butterfree.clients.abstract_client module butterfree.clients.cassandra_client module butterfree.clients.spark_client module butterfree.configs module butterfree.configs.db module butterfree.configs.db.abstract_config module butterfree.configs.db.cassandra_config module butterfree.configs.db.kafka_config module butterfree.configs.db.metastore_config module butterfree.configs.environment module butterfree.configs.logger module butterfree.constants module butterfree.constants.columns module butterfree.constants.data_type module butterfree.constants.migrations module butterfree.constants.spark_constants module butterfree.constants.window_definitions module butterfree.dataframe_service module butterfree.dataframe_service.incremental_strategy module butterfree.dataframe_service.partitioning module butterfree.dataframe_service.repartition module butterfree.extract module butterfree.extract.pre_processing module butterfree.extract.pre_processing.explode_json_column_transform module butterfree.extract.pre_processing.filter_transform module butterfree.extract.pre_processing.forward_fill_transform module butterfree.extract.pre_processing.pivot_transform module butterfree.extract.pre_processing.replace_transform module butterfree.extract.readers module butterfree.extract.readers.file_reader module butterfree.extract.readers.kafka_reader module butterfree.extract.readers.reader module butterfree.extract.readers.table_reader module butterfree.extract.source module butterfree.hooks module butterfree.hooks.hook module butterfree.hooks.hookable_component module

butterfree.hooks.schema_compatibility module butterfree.hooks.schema_compatibility.cassandra_table_schema_compatibility_hook module butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook module butterfree.load module butterfree.load.processing module butterfree.load.processing.json_transform module butterfree.load.sink module butterfree.load.writers module butterfree.load.writers.historical_feature_store_writer module butterfree.load.writers.online_feature_store_writer module butterfree.load.writers.writer module butterfree.migrations module butterfree.migrations.database_migration module butterfree.migrations.database_migration.cassandra_migration module butterfree.migrations.database_migration.database_migration module butterfree.migrations.database_migration.metastore_migration module butterfree.pipelines module butterfree.pipelines.feature_set_pipeline module butterfree.reports module butterfree.reports.metadata module butterfree.testing module butterfree.testing.dataframe module butterfree.transform module butterfree.transform.aggregated_feature_set module butterfree.transform.feature_set module butterfree.transform.features module butterfree.transform.features.feature module butterfree.transform.features.key_feature module butterfree.transform.features.timestamp_feature module butterfree.transform.transformations module butterfree.transform.transformations.aggregated_transform module butterfree.transform.transformations.custom_transform module butterfree.transform.transformations.h3_transform module butterfree.transform.transformations.spark_function_transform module butterfree.transform.transformations.sql_expression_transform module butterfree.transform.transformations.stack_transform module butterfree.transform.transformations.transform_component module butterfree.transform.utils module butterfree.transform.utils.date_range module butterfree.transform.utils.function module butterfree.transform.utils.window_spec module butterfree.validations module butterfree.validations.basic_validaton module butterfree.validations.validation module

C

cassandra_client (butterfree.hooks.schema_compatibility.cassandra_table_schema_compatibility_hook.CassandraTableSchemaCompatibilityHook attribute) (butterfree.hooks.schema_compatibility.CassandraTableSchemaCompatibilityHook attribute) CassandraClient (class in butterfree.clients) (class in butterfree.clients.cassandra_client) CassandraColumn (class in butterfree.clients.cassandra_client) CassandraConfig (class in butterfree.configs.db) (class in butterfree.configs.db.cassandra_config) CassandraMigration (class in butterfree.migrations.database_migration) (class in butterfree.migrations.database_migration.cassandra_migration) CassandraTableSchemaCompatibilityHook (class in butterfree.hooks.schema_compatibility) (class in butterfree.hooks.schema_compatibility.cassandra_table_schema_compatibility_hook) check() (butterfree.validations.basic_validaton.BasicValidation method) (butterfree.validations.BasicValidation method) (butterfree.validations.validation.Validation method) check_schema() (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter method) (butterfree.load.writers.HistoricalFeatureStoreWriter method) (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter method) (butterfree.load.writers.OnlineFeatureStoreWriter method) (butterfree.load.writers.writer.Writer method) column (butterfree.dataframe_service.incremental_strategy.IncrementalStrategy attribute) (butterfree.dataframe_service.IncrementalStrategy attribute) (butterfree.migrations.database_migration.database_migration.Diff attribute) (butterfree.migrations.database_migration.Diff attribute) column_name (butterfree.clients.cassandra_client.CassandraColumn attribute) columns (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet property) columns_names (butterfree.transform.transformations.stack_transform.StackTransform attribute) (butterfree.transform.transformations.StackTransform attribute)

conn (butterfree.clients.abstract_client.AbstractClient property) (butterfree.clients.AbstractClient property) (butterfree.clients.cassandra_client.CassandraClient property) (butterfree.clients.CassandraClient property) (butterfree.clients.spark_client.SparkClient property) (butterfree.clients.SparkClient property) connection_string (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) construct() (butterfree.extract.Source method) (butterfree.extract.source.Source method) (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet method) (butterfree.transform.feature_set.FeatureSet method) (butterfree.transform.FeatureSet method) consume() (butterfree.extract.readers.file_reader.FileReader method) (butterfree.extract.readers.FileReader method) (butterfree.extract.readers.kafka_reader.KafkaReader method) (butterfree.extract.readers.KafkaReader method) (butterfree.extract.readers.reader.Reader method) (butterfree.extract.readers.table_reader.TableReader method) (butterfree.extract.readers.TableReader method) create_df_from_collection() (in module butterfree.testing.dataframe) create_query() (butterfree.migrations.database_migration.database_migration.DatabaseMigration method) create_table() (butterfree.clients.cassandra_client.CassandraClient method) (butterfree.clients.CassandraClient method) create_temporary_view() (butterfree.clients.spark_client.SparkClient static method) (butterfree.clients.SparkClient static method) CustomTransform (class in butterfree.transform.transformations) (class in butterfree.transform.transformations.custom_transform)

D

data_type (butterfree.transform.utils.Function attribute) (butterfree.transform.utils.Function property) (butterfree.transform.utils.function.Function attribute) (butterfree.transform.utils.function.Function property) database (butterfree.configs.db.abstract_config.AbstractWriteConfig property) (butterfree.configs.db.AbstractWriteConfig property) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig property) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig property) (butterfree.configs.db.metastore_config.MetastoreConfig property) (butterfree.configs.db.MetastoreConfig property) (butterfree.extract.readers.table_reader.TableReader attribute) (butterfree.extract.readers.TableReader attribute) (butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook.SparkTableSchemaCompatibilityHook attribute) (butterfree.hooks.schema_compatibility.SparkTableSchemaCompatibilityHook attribute) (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) DatabaseMigration (class in butterfree.migrations.database_migration.database_migration) dataframe (butterfree.validations.basic_validaton.BasicValidation attribute) (butterfree.validations.BasicValidation attribute) (butterfree.validations.validation.Validation attribute) (in module butterfree.extract.pre_processing), [1] (in module butterfree.extract.pre_processing.forward_fill_transform) (in module butterfree.extract.pre_processing.pivot_transform) DataType (class in butterfree.constants) (class in butterfree.constants.data_type) DATE (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) db_config (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter attribute) (butterfree.load.writers.OnlineFeatureStoreWriter attribute) debug_mode (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter attribute) (butterfree.load.writers.OnlineFeatureStoreWriter attribute)

DECIMAL (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) DEFAULT_SLIDE_DURATION (butterfree.transform.utils.Window attribute) (butterfree.transform.utils.window_spec.Window attribute) DEFAULT_VALIDATION_THRESHOLD (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) define_h3() (in module butterfree.transform.transformations.h3_transform) define_start_date() (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet method) (butterfree.transform.feature_set.FeatureSet method) (butterfree.transform.FeatureSet method) description (butterfree.transform.feature_set.FeatureSet attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.features.Feature attribute) (butterfree.transform.features.feature.Feature attribute) (butterfree.transform.features.key_feature.KeyFeature attribute) (butterfree.transform.features.KeyFeature attribute) (butterfree.transform.FeatureSet attribute) (butterfree.transform.FeatureSet property) Diff (class in butterfree.migrations.database_migration) (class in butterfree.migrations.database_migration.database_migration) Diff.Kind (class in butterfree.migrations.database_migration) (class in butterfree.migrations.database_migration.database_migration) DOUBLE (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) DROP (butterfree.migrations.database_migration.database_migration.Diff.Kind attribute) (butterfree.migrations.database_migration.Diff.Kind attribute) dtype (butterfree.transform.features.Feature attribute) (butterfree.transform.features.Feature property) (butterfree.transform.features.feature.Feature attribute) (butterfree.transform.features.feature.Feature property) (butterfree.transform.features.key_feature.KeyFeature attribute) (butterfree.transform.features.KeyFeature attribute)

E

enable_post_hooks (butterfree.hooks.hookable_component.HookableComponent attribute) (butterfree.hooks.hookable_component.HookableComponent property) (butterfree.hooks.HookableComponent attribute) (butterfree.hooks.HookableComponent property) enable_pre_hooks (butterfree.hooks.hookable_component.HookableComponent attribute) (butterfree.hooks.hookable_component.HookableComponent property) (butterfree.hooks.HookableComponent attribute) (butterfree.hooks.HookableComponent property) entity (butterfree.transform.feature_set.FeatureSet attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet attribute) (butterfree.transform.FeatureSet property)

explode_json_column() (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.explode_json_column_transform) expression (butterfree.transform.transformations.sql_expression_transform.SQLExpressionTransform attribute) (butterfree.transform.transformations.SQLExpressionTransform attribute) extract_partition_values() (in module butterfree.dataframe_service) (in module butterfree.dataframe_service.partitioning)

F

Feature (class in butterfree.transform.features) (class in butterfree.transform.features.feature) feature_set (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline attribute) (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline property) (butterfree.pipelines.FeatureSetPipeline attribute) (butterfree.pipelines.FeatureSetPipeline property) features (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet property) (butterfree.transform.feature_set.FeatureSet attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet attribute) (butterfree.transform.FeatureSet property) features_columns (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet property) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet property) FeatureSet (class in butterfree.transform) (class in butterfree.transform.feature_set) FeatureSetPipeline (class in butterfree.pipelines) (class in butterfree.pipelines.feature_set_pipeline) file_system (butterfree.configs.db.metastore_config.MetastoreConfig attribute) (butterfree.configs.db.metastore_config.MetastoreConfig property) (butterfree.configs.db.MetastoreConfig attribute) (butterfree.configs.db.MetastoreConfig property) FileReader (class in butterfree.extract.readers) (class in butterfree.extract.readers.file_reader) fill_column (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.forward_fill_transform) filled_column (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.forward_fill_transform) filter() (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.filter_transform) filter_expression (butterfree.transform.transformations.aggregated_transform.AggregatedTransform attribute) (butterfree.transform.transformations.AggregatedTransform attribute) filter_latest() (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter static method) (butterfree.load.writers.OnlineFeatureStoreWriter static method) filter_with_incremental_strategy() (butterfree.dataframe_service.incremental_strategy.IncrementalStrategy method) (butterfree.dataframe_service.IncrementalStrategy method) FLOAT (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) flush() (butterfree.load.Sink method) (butterfree.load.sink.Sink method) format (butterfree.extract.readers.file_reader.FileReader attribute) (butterfree.extract.readers.FileReader attribute) format_ (butterfree.configs.db.abstract_config.AbstractWriteConfig property) (butterfree.configs.db.AbstractWriteConfig property) (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) (butterfree.configs.db.metastore_config.MetastoreConfig attribute) (butterfree.configs.db.metastore_config.MetastoreConfig property) (butterfree.configs.db.MetastoreConfig attribute) (butterfree.configs.db.MetastoreConfig property)

format_options (butterfree.extract.readers.file_reader.FileReader attribute) (butterfree.extract.readers.FileReader attribute) forward_fill() (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.forward_fill_transform) FrameBoundaries (class in butterfree.transform.utils.window_spec) from_column (butterfree.transform.features.Feature attribute) (butterfree.transform.features.Feature property) (butterfree.transform.features.feature.Feature attribute) (butterfree.transform.features.feature.Feature property) (butterfree.transform.features.key_feature.KeyFeature attribute) (butterfree.transform.features.KeyFeature attribute) (butterfree.transform.features.timestamp_feature.TimestampFeature attribute) (butterfree.transform.features.TimestampFeature attribute) from_milliseconds() (butterfree.dataframe_service.incremental_strategy.IncrementalStrategy method) (butterfree.dataframe_service.IncrementalStrategy method) from_ms (butterfree.transform.features.timestamp_feature.TimestampFeature attribute) (butterfree.transform.features.TimestampFeature attribute) from_string() (butterfree.dataframe_service.incremental_strategy.IncrementalStrategy method) (butterfree.dataframe_service.IncrementalStrategy method) from_year_month_day_partitions() (butterfree.dataframe_service.incremental_strategy.IncrementalStrategy method) (butterfree.dataframe_service.IncrementalStrategy method) func (butterfree.transform.utils.Function attribute) (butterfree.transform.utils.Function property) (butterfree.transform.utils.function.Function attribute) (butterfree.transform.utils.function.Function property) function (butterfree.transform.transformations.spark_function_transform.SparkFunctionTransform attribute) (butterfree.transform.transformations.SparkFunctionTransform attribute) Function (class in butterfree.transform.utils) (class in butterfree.transform.utils.function) functions (butterfree.transform.transformations.aggregated_transform.AggregatedTransform attribute) (butterfree.transform.transformations.AggregatedTransform attribute)

G

get() (butterfree.transform.utils.Window method) (butterfree.transform.utils.window_spec.FrameBoundaries method) (butterfree.transform.utils.window_spec.Window method) get_date_range() (in module butterfree.transform.utils.date_range) get_db_schema() (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter method) (butterfree.load.writers.OnlineFeatureStoreWriter method) get_expression() (butterfree.dataframe_service.incremental_strategy.IncrementalStrategy method) (butterfree.dataframe_service.IncrementalStrategy method) get_name() (butterfree.transform.utils.Window method) (butterfree.transform.utils.window_spec.Window method) get_options() (butterfree.configs.db.cassandra_config.CassandraConfig method) (butterfree.configs.db.CassandraConfig method) (butterfree.configs.db.kafka_config.KafkaConfig method) (butterfree.configs.db.KafkaConfig method) (butterfree.configs.db.metastore_config.MetastoreConfig method) (butterfree.configs.db.MetastoreConfig method)

get_output_columns() (butterfree.transform.features.Feature method) (butterfree.transform.features.feature.Feature method) get_path_with_partitions() (butterfree.configs.db.metastore_config.MetastoreConfig method) (butterfree.configs.db.MetastoreConfig method) get_schema() (butterfree.clients.abstract_client.AbstractClient method) (butterfree.clients.AbstractClient method) (butterfree.clients.cassandra_client.CassandraClient method) (butterfree.clients.CassandraClient method) (butterfree.clients.spark_client.SparkClient method) (butterfree.clients.SparkClient method) (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet method) (butterfree.transform.feature_set.FeatureSet method) (butterfree.transform.FeatureSet method) get_variable() (in module butterfree.configs.environment) group_by_columns (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform)

H

h3_resolutions (butterfree.transform.transformations.h3_transform.H3HashTransform attribute) H3HashTransform (class in butterfree.transform.transformations.h3_transform) HistoricalFeatureStoreWriter (class in butterfree.load.writers) (class in butterfree.load.writers.historical_feature_store_writer) Hook (class in butterfree.hooks) (class in butterfree.hooks.hook) HookableComponent (class in butterfree.hooks) (class in butterfree.hooks.hookable_component)

host (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute) (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property)

I

id (butterfree.extract.readers.file_reader.FileReader attribute) (butterfree.extract.readers.FileReader attribute) (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) (butterfree.extract.readers.reader.Reader attribute) (butterfree.extract.readers.table_reader.TableReader attribute) (butterfree.extract.readers.TableReader attribute)

IncrementalStrategy (class in butterfree.dataframe_service) (class in butterfree.dataframe_service.incremental_strategy) input() (butterfree.validations.validation.Validation method) INTEGER (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) is_regex (butterfree.transform.transformations.stack_transform.StackTransform attribute) (butterfree.transform.transformations.StackTransform attribute)

J

json_transform() (in module butterfree.load.processing) (in module butterfree.load.processing.json_transform)

K

KAFKA_COLUMNS (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) kafka_connection_string (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) kafka_topic (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) KafkaConfig (class in butterfree.configs.db) (class in butterfree.configs.db.kafka_config) KafkaReader (class in butterfree.extract.readers) (class in butterfree.extract.readers.kafka_reader) KeyFeature (class in butterfree.transform.features) (class in butterfree.transform.features.key_feature)

keys (butterfree.transform.feature_set.FeatureSet attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet attribute) (butterfree.transform.FeatureSet property) keys_columns (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet property) keyspace (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute) (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) kind (butterfree.migrations.database_migration.database_migration.Diff attribute) (butterfree.migrations.database_migration.Diff attribute)

L

lat (in module butterfree.transform.transformations.h3_transform) lat_column (butterfree.transform.transformations.h3_transform.H3HashTransform attribute) lng (in module butterfree.transform.transformations.h3_transform)

lng_column (butterfree.transform.transformations.h3_transform.H3HashTransform attribute) local_dc (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig property)

M

mask (butterfree.transform.features.timestamp_feature.TimestampFeature attribute) (butterfree.transform.features.TimestampFeature attribute) Metadata (class in butterfree.reports) (class in butterfree.reports.metadata) MetastoreConfig (class in butterfree.configs.db) (class in butterfree.configs.db.metastore_config) MetastoreMigration (class in butterfree.migrations.database_migration) (class in butterfree.migrations.database_migration.metastore_migration) mock_type (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) mock_value (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) mode (butterfree.configs.db.abstract_config.AbstractWriteConfig property) (butterfree.configs.db.AbstractWriteConfig property) (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) (butterfree.configs.db.metastore_config.MetastoreConfig attribute) (butterfree.configs.db.metastore_config.MetastoreConfig property) (butterfree.configs.db.MetastoreConfig attribute) (butterfree.configs.db.MetastoreConfig property) module butterfree butterfree.clients butterfree.clients.abstract_client butterfree.clients.cassandra_client butterfree.clients.spark_client butterfree.configs butterfree.configs.db butterfree.configs.db.abstract_config butterfree.configs.db.cassandra_config butterfree.configs.db.kafka_config butterfree.configs.db.metastore_config butterfree.configs.environment butterfree.configs.logger butterfree.constants butterfree.constants.columns butterfree.constants.data_type butterfree.constants.migrations butterfree.constants.spark_constants butterfree.constants.window_definitions butterfree.dataframe_service butterfree.dataframe_service.incremental_strategy butterfree.dataframe_service.partitioning butterfree.dataframe_service.repartition butterfree.extract butterfree.extract.pre_processing butterfree.extract.pre_processing.explode_json_column_transform butterfree.extract.pre_processing.filter_transform butterfree.extract.pre_processing.forward_fill_transform butterfree.extract.pre_processing.pivot_transform butterfree.extract.pre_processing.replace_transform butterfree.extract.readers butterfree.extract.readers.file_reader butterfree.extract.readers.kafka_reader butterfree.extract.readers.reader butterfree.extract.readers.table_reader butterfree.extract.source butterfree.hooks butterfree.hooks.hook butterfree.hooks.hookable_component butterfree.hooks.schema_compatibility butterfree.hooks.schema_compatibility.cassandra_table_schema_compatibility_hook butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook butterfree.load butterfree.load.processing butterfree.load.processing.json_transform butterfree.load.sink butterfree.load.writers butterfree.load.writers.historical_feature_store_writer butterfree.load.writers.online_feature_store_writer butterfree.load.writers.writer butterfree.migrations butterfree.migrations.database_migration butterfree.migrations.database_migration.cassandra_migration butterfree.migrations.database_migration.database_migration butterfree.migrations.database_migration.metastore_migration butterfree.pipelines butterfree.pipelines.feature_set_pipeline butterfree.reports butterfree.reports.metadata butterfree.testing butterfree.testing.dataframe butterfree.transform butterfree.transform.aggregated_feature_set butterfree.transform.feature_set butterfree.transform.features butterfree.transform.features.feature butterfree.transform.features.key_feature butterfree.transform.features.timestamp_feature butterfree.transform.transformations butterfree.transform.transformations.aggregated_transform butterfree.transform.transformations.custom_transform butterfree.transform.transformations.h3_transform butterfree.transform.transformations.spark_function_transform butterfree.transform.transformations.sql_expression_transform butterfree.transform.transformations.stack_transform butterfree.transform.transformations.transform_component butterfree.transform.utils butterfree.transform.utils.date_range butterfree.transform.utils.function butterfree.transform.utils.window_spec butterfree.validations butterfree.validations.basic_validaton butterfree.validations.validation

N

name (butterfree.transform.feature_set.FeatureSet attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.features.Feature attribute) (butterfree.transform.features.feature.Feature attribute) (butterfree.transform.features.key_feature.KeyFeature attribute) (butterfree.transform.features.KeyFeature attribute) (butterfree.transform.FeatureSet attribute) (butterfree.transform.FeatureSet property)

num_partitions (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute)

O

OnlineFeatureStoreWriter (class in butterfree.load.writers) (class in butterfree.load.writers.online_feature_store_writer) order_by (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.forward_fill_transform) output_columns (butterfree.transform.transformations.aggregated_transform.AggregatedTransform property) (butterfree.transform.transformations.AggregatedTransform property) (butterfree.transform.transformations.custom_transform.CustomTransform property) (butterfree.transform.transformations.CustomTransform property) (butterfree.transform.transformations.h3_transform.H3HashTransform property) (butterfree.transform.transformations.spark_function_transform.SparkFunctionTransform property) (butterfree.transform.transformations.SparkFunctionTransform property) (butterfree.transform.transformations.sql_expression_transform.SQLExpressionTransform property) (butterfree.transform.transformations.SQLExpressionTransform property) (butterfree.transform.transformations.stack_transform.StackTransform property) (butterfree.transform.transformations.StackTransform property) (butterfree.transform.transformations.transform_component.TransformComponent property) (butterfree.transform.transformations.TransformComponent property)

P

parent (butterfree.transform.transformations.transform_component.TransformComponent attribute) (butterfree.transform.transformations.transform_component.TransformComponent property) (butterfree.transform.transformations.TransformComponent attribute) (butterfree.transform.transformations.TransformComponent property) PARTITION_BY (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) partition_by (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.forward_fill_transform) password (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute) (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) path (butterfree.configs.db.metastore_config.MetastoreConfig attribute) (butterfree.configs.db.metastore_config.MetastoreConfig property) (butterfree.configs.db.MetastoreConfig attribute) (butterfree.configs.db.MetastoreConfig property) (butterfree.extract.readers.file_reader.FileReader attribute) (butterfree.extract.readers.FileReader attribute)

pipeline (butterfree.reports.Metadata attribute) (butterfree.reports.metadata.Metadata attribute) pivot() (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) pivot_column (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) post_hooks (butterfree.hooks.hookable_component.HookableComponent attribute) (butterfree.hooks.hookable_component.HookableComponent property) (butterfree.hooks.HookableComponent attribute) (butterfree.hooks.HookableComponent property) pre_hooks (butterfree.hooks.hookable_component.HookableComponent attribute) (butterfree.hooks.hookable_component.HookableComponent property) (butterfree.hooks.HookableComponent attribute) (butterfree.hooks.HookableComponent property) primary_key (butterfree.clients.cassandra_client.CassandraColumn attribute)

Q

query (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute) (butterfree.extract.Source attribute) (butterfree.extract.source.Source attribute)

R

read() (butterfree.clients.spark_client.SparkClient method) (butterfree.clients.SparkClient method) read_consistency_level (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) read_table() (butterfree.clients.spark_client.SparkClient method) (butterfree.clients.SparkClient method) Reader (class in butterfree.extract.readers.reader) readers (butterfree.extract.Source attribute) (butterfree.extract.source.Source attribute) repartition_df() (in module butterfree.dataframe_service) (in module butterfree.dataframe_service.repartition) repartition_sort_df() (in module butterfree.dataframe_service) (in module butterfree.dataframe_service.repartition) replace() (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.replace_transform)

resolution (in module butterfree.transform.transformations.h3_transform) run() (butterfree.hooks.Hook method) (butterfree.hooks.hook.Hook method) (butterfree.hooks.schema_compatibility.cassandra_table_schema_compatibility_hook.CassandraTableSchemaCompatibilityHook method) (butterfree.hooks.schema_compatibility.CassandraTableSchemaCompatibilityHook method) (butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook.SparkTableSchemaCompatibilityHook method) (butterfree.hooks.schema_compatibility.SparkTableSchemaCompatibilityHook method) (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline method) (butterfree.pipelines.FeatureSetPipeline method) run_for_date() (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline method) (butterfree.pipelines.FeatureSetPipeline method) run_post_hooks() (butterfree.hooks.hookable_component.HookableComponent method) (butterfree.hooks.HookableComponent method) run_pre_hooks() (butterfree.hooks.hookable_component.HookableComponent method) (butterfree.hooks.HookableComponent method)

S

save (butterfree.reports.Metadata attribute) (butterfree.reports.metadata.Metadata attribute) schema (butterfree.extract.readers.file_reader.FileReader attribute) (butterfree.extract.readers.FileReader attribute) sink (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline attribute) (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline property) (butterfree.pipelines.FeatureSetPipeline attribute) (butterfree.pipelines.FeatureSetPipeline property) Sink (class in butterfree.load) (class in butterfree.load.sink) source (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline attribute) (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline property) (butterfree.pipelines.FeatureSetPipeline attribute) (butterfree.pipelines.FeatureSetPipeline property) Source (class in butterfree.extract) (class in butterfree.extract.source) spark_client (butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook.SparkTableSchemaCompatibilityHook attribute) (butterfree.hooks.schema_compatibility.SparkTableSchemaCompatibilityHook attribute) (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline attribute) (butterfree.pipelines.feature_set_pipeline.FeatureSetPipeline property) (butterfree.pipelines.FeatureSetPipeline attribute) (butterfree.pipelines.FeatureSetPipeline property) SparkClient (class in butterfree.clients) (class in butterfree.clients.spark_client) SparkFunctionTransform (class in butterfree.transform.transformations) (class in butterfree.transform.transformations.spark_function_transform) SparkTableSchemaCompatibilityHook (class in butterfree.hooks.schema_compatibility) (class in butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook) sql() (butterfree.clients.abstract_client.AbstractClient method) (butterfree.clients.AbstractClient method) (butterfree.clients.cassandra_client.CassandraClient method) (butterfree.clients.CassandraClient method) (butterfree.clients.spark_client.SparkClient method) (butterfree.clients.SparkClient method)

SQLExpressionTransform (class in butterfree.transform.transformations) (class in butterfree.transform.transformations.sql_expression_transform) StackTransform (class in butterfree.transform.transformations) (class in butterfree.transform.transformations.stack_transform) stream (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) stream_checkpoint_path (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) stream_output_mode (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) stream_processing_time (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) (butterfree.configs.db.kafka_config.KafkaConfig attribute) (butterfree.configs.db.kafka_config.KafkaConfig property) (butterfree.configs.db.KafkaConfig attribute) (butterfree.configs.db.KafkaConfig property) STRING (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute)

T

table (butterfree.clients.abstract_client.AbstractClient attribute) (butterfree.clients.AbstractClient attribute) (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute) (butterfree.clients.spark_client.SparkClient attribute) (butterfree.clients.SparkClient attribute) (butterfree.extract.readers.table_reader.TableReader attribute) (butterfree.extract.readers.TableReader attribute) (butterfree.hooks.schema_compatibility.cassandra_table_schema_compatibility_hook.CassandraTableSchemaCompatibilityHook attribute) (butterfree.hooks.schema_compatibility.CassandraTableSchemaCompatibilityHook attribute) (butterfree.hooks.schema_compatibility.spark_table_schema_compatibility_hook.SparkTableSchemaCompatibilityHook attribute) (butterfree.hooks.schema_compatibility.SparkTableSchemaCompatibilityHook attribute) TableReader (class in butterfree.extract.readers) (class in butterfree.extract.readers.table_reader) TIMESTAMP (butterfree.constants.data_type.DataType attribute) (butterfree.constants.DataType attribute) timestamp (butterfree.transform.feature_set.FeatureSet attribute) (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet attribute) (butterfree.transform.FeatureSet property) timestamp_column (butterfree.transform.feature_set.FeatureSet property) (butterfree.transform.FeatureSet property) TimestampFeature (class in butterfree.transform.features) (class in butterfree.transform.features.timestamp_feature) to_json() (butterfree.reports.Metadata method) (butterfree.reports.metadata.Metadata method) to_markdown() (butterfree.reports.Metadata method) (butterfree.reports.metadata.Metadata method) topic (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) topic_options (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) transform() (butterfree.transform.features.Feature method) (butterfree.transform.features.feature.Feature method) (butterfree.transform.features.timestamp_feature.TimestampFeature method) (butterfree.transform.features.TimestampFeature method) (butterfree.transform.transformations.aggregated_transform.AggregatedTransform method) (butterfree.transform.transformations.AggregatedTransform method) (butterfree.transform.transformations.custom_transform.CustomTransform method) (butterfree.transform.transformations.CustomTransform method) (butterfree.transform.transformations.h3_transform.H3HashTransform method) (butterfree.transform.transformations.spark_function_transform.SparkFunctionTransform method) (butterfree.transform.transformations.SparkFunctionTransform method) (butterfree.transform.transformations.sql_expression_transform.SQLExpressionTransform method) (butterfree.transform.transformations.SQLExpressionTransform method) (butterfree.transform.transformations.stack_transform.StackTransform method) (butterfree.transform.transformations.StackTransform method) (butterfree.transform.transformations.transform_component.TransformComponent method) (butterfree.transform.transformations.TransformComponent method)

transformation (butterfree.transform.features.Feature attribute) (butterfree.transform.features.Feature property) (butterfree.transform.features.feature.Feature attribute) (butterfree.transform.features.feature.Feature property) (butterfree.transform.features.key_feature.KeyFeature attribute) (butterfree.transform.features.KeyFeature attribute) (butterfree.transform.features.timestamp_feature.TimestampFeature attribute) (butterfree.transform.features.TimestampFeature attribute) transformations (butterfree.extract.readers.KafkaReader attribute) (butterfree.extract.readers.reader.Reader attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) TransformComponent (class in butterfree.transform.transformations) (class in butterfree.transform.transformations.transform_component) transformer (butterfree.transform.transformations.custom_transform.CustomTransform attribute) (butterfree.transform.transformations.custom_transform.CustomTransform property) (butterfree.transform.transformations.CustomTransform attribute) (butterfree.transform.transformations.CustomTransform property) translate() (butterfree.configs.db.abstract_config.AbstractWriteConfig method) (butterfree.configs.db.AbstractWriteConfig method) (butterfree.configs.db.cassandra_config.CassandraConfig method) (butterfree.configs.db.CassandraConfig method) (butterfree.configs.db.kafka_config.KafkaConfig method) (butterfree.configs.db.KafkaConfig method) (butterfree.configs.db.metastore_config.MetastoreConfig method) (butterfree.configs.db.MetastoreConfig method) type (butterfree.clients.cassandra_client.CassandraColumn attribute)

U

UnspecifiedVariableError user (butterfree.clients.cassandra_client.CassandraClient attribute) (butterfree.clients.CassandraClient attribute)

username (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property)

V

validate() (butterfree.load.Sink method) (butterfree.load.sink.Sink method) (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter method) (butterfree.load.writers.HistoricalFeatureStoreWriter method) (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter method) (butterfree.load.writers.OnlineFeatureStoreWriter method) (butterfree.load.writers.writer.Writer method) validate_column_ts() (butterfree.validations.basic_validaton.BasicValidation method) (butterfree.validations.BasicValidation method) validate_df_is_empty() (butterfree.validations.basic_validaton.BasicValidation method) (butterfree.validations.BasicValidation method) validate_df_is_spark_df() (butterfree.validations.basic_validaton.BasicValidation method) (butterfree.validations.BasicValidation method)

validation (butterfree.load.Sink attribute) (butterfree.load.Sink property) (butterfree.load.sink.Sink attribute) (butterfree.load.sink.Sink property) Validation (class in butterfree.validations.validation) validation_threshold (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter attribute) (butterfree.load.writers.HistoricalFeatureStoreWriter attribute) value (butterfree.migrations.database_migration.database_migration.Diff attribute) (butterfree.migrations.database_migration.Diff attribute) value_schema (butterfree.extract.readers.kafka_reader.KafkaReader attribute) (butterfree.extract.readers.KafkaReader attribute) variable_name (butterfree.configs.environment.UnspecifiedVariableError attribute)

W

Window (class in butterfree.transform.utils) (class in butterfree.transform.utils.window_spec) window_size (butterfree.transform.utils.window_spec.FrameBoundaries property) window_unit (butterfree.transform.utils.window_spec.FrameBoundaries property) with_() (butterfree.extract.readers.reader.Reader method) (butterfree.load.writers.writer.Writer method) with_distinct() (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet method) with_forward_fill (in module butterfree.extract.pre_processing) (in module butterfree.extract.pre_processing.pivot_transform) with_incremental_strategy() (butterfree.extract.readers.reader.Reader method) with_pivot() (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet method) with_stack() (butterfree.transform.transformations.h3_transform.H3HashTransform method) with_window() (butterfree.transform.transformations.spark_function_transform.SparkFunctionTransform method) (butterfree.transform.transformations.SparkFunctionTransform method) with_windows() (butterfree.transform.aggregated_feature_set.AggregatedFeatureSet method) write() (butterfree.load.writers.historical_feature_store_writer.HistoricalFeatureStoreWriter method) (butterfree.load.writers.HistoricalFeatureStoreWriter method) (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter method) (butterfree.load.writers.OnlineFeatureStoreWriter method) (butterfree.load.writers.writer.Writer method)

write_consistency_level (butterfree.configs.db.cassandra_config.CassandraConfig attribute) (butterfree.configs.db.cassandra_config.CassandraConfig property) (butterfree.configs.db.CassandraConfig attribute) (butterfree.configs.db.CassandraConfig property) write_dataframe() (butterfree.clients.spark_client.SparkClient static method) (butterfree.clients.SparkClient static method) write_stream() (butterfree.clients.spark_client.SparkClient method) (butterfree.clients.SparkClient method) write_table() (butterfree.clients.spark_client.SparkClient static method) (butterfree.clients.SparkClient static method) write_to_entity (butterfree.load.writers.online_feature_store_writer.OnlineFeatureStoreWriter attribute) (butterfree.load.writers.OnlineFeatureStoreWriter attribute) Writer (class in butterfree.load.writers.writer) writers (butterfree.load.Sink attribute) (butterfree.load.Sink property) (butterfree.load.sink.Sink attribute) (butterfree.load.sink.Sink property)