Table of Contents - dataflow-rb-0.18.1 Documentation
Classes and Modules
- Dataflow
- Dataflow::Adapters
- Dataflow::Adapters::CsvAdapter
- Dataflow::Adapters::MongoDbAdapter
- Dataflow::Adapters::MysqlAdapter
- Dataflow::Adapters::PsqlAdapter
- Dataflow::Adapters::Settings
- Dataflow::Adapters::SqlAdapter
- Dataflow::ConstantizePatch
- Dataflow::Errors
- Dataflow::Errors::InvalidConfigurationError
- Dataflow::Errors::RemoteExecutionError
- Dataflow::EventMixin
- Dataflow::EventMixin::ClassMethods
- Dataflow::Executor
- Dataflow::Logger
- Dataflow::Logger::LoggerImpl
- Dataflow::Node
- Dataflow::Nodes
- Dataflow::Nodes::ComputeNode
- Dataflow::Nodes::DataNode
- Dataflow::Nodes::Export
- Dataflow::Nodes::Export::ToCsvNode
- Dataflow::Nodes::Filter
- Dataflow::Nodes::Filter::DropWhileNode
- Dataflow::Nodes::Filter::NewestNode
- Dataflow::Nodes::Filter::WhereNode
- Dataflow::Nodes::JoinNode
- Dataflow::Nodes::MapNode
- Dataflow::Nodes::MergeNode
- Dataflow::Nodes::Mixin
- Dataflow::Nodes::Mixin::AddInternalTimestamp
- Dataflow::Nodes::Mixin::RenameDottedFields
- Dataflow::Nodes::ReadOnlyDataNode
- Dataflow::Nodes::RuntimeQueryNode
- Dataflow::Nodes::SelectKeysNode
- Dataflow::Nodes::SnapshotNode
- Dataflow::Nodes::SqlQueryNode
- Dataflow::Nodes::Transformation
- Dataflow::Nodes::Transformation::ToTimeNode
- Dataflow::Nodes::UpsertNode
- Dataflow::PropertiesMixin
- Dataflow::PropertiesMixin::ClassMethods
- Dataflow::RemoteWorker
- Dataflow::SchemaMixin
- Mongo
- Mongo::Collection
- Mongo::Collection::View
- Object
Methods
- ::add_extensions — Dataflow::Adapters::SqlAdapter
- ::admin_client — Dataflow::Adapters::MongoDbAdapter
- ::await_execution_completion — Dataflow::Executor
- ::clear_tmp_datasets — Dataflow
- ::client — Dataflow::Adapters::MongoDbAdapter
- ::client — Dataflow::Adapters::SqlAdapter
- ::compute_node — Dataflow
- ::data_node — Dataflow
- ::data_node_opts — Dataflow::Nodes::ComputeNode
- ::dependency_opts — Dataflow::Nodes::ComputeNode
- ::disconnect_clients — Dataflow::Adapters::MongoDbAdapter
- ::disconnect_clients — Dataflow::Adapters::SqlAdapter
- ::ensure_data_node_exists — Dataflow::Nodes::ComputeNode
- ::ensure_dependencies — Dataflow::Nodes::ComputeNode
- ::execute — Dataflow::Executor
- ::execute — Dataflow::RemoteWorker
- ::execute_remote_computation — Dataflow::Executor
- ::export — Dataflow
- ::find — Dataflow::Node
- ::import — Dataflow
- ::included — Dataflow::Nodes::Mixin::AddInternalTimestamp
- ::included — Dataflow::Nodes::Mixin::RenameDottedFields
- ::logger — Dataflow::Executor
- ::logger — Dataflow::RemoteWorker
- ::make_execution_params — Dataflow::Executor
- ::new — Dataflow::Adapters::CsvAdapter
- ::new — Dataflow::Adapters::MongoDbAdapter
- ::new — Dataflow::Adapters::Settings
- ::new — Dataflow::Adapters::SqlAdapter
- ::new — Dataflow::Errors::RemoteExecutionError
- ::new — Dataflow::Logger
- ::open_communication_channel — Dataflow::Executor
- ::process — Dataflow::RemoteWorker
- ::send_execution_messages — Dataflow::Executor
- ::try_create_db — Dataflow::Adapters::SqlAdapter
- ::work — Dataflow::RemoteWorker
- #acquire_computing_lock! — Dataflow::Nodes::ComputeNode
- #add — Dataflow::Nodes::DataNode
- #add — Dataflow::Nodes::ReadOnlyDataNode
- #add — Dataflow::Nodes::SnapshotNode
- #add — Dataflow::Nodes::UpsertNode
- #add_internal_timestamp — Dataflow::Nodes::Mixin::AddInternalTimestamp
- #add_property — Dataflow::PropertiesMixin::ClassMethods
- #add_value_to_record — Dataflow::SchemaMixin
- #all — Dataflow::Adapters::CsvAdapter
- #all — Dataflow::Adapters::MongoDbAdapter
- #all — Dataflow::Adapters::SqlAdapter
- #all — Dataflow::Nodes::DataNode
- #all — Dataflow::Nodes::RuntimeQueryNode
- #all_dependencies — Dataflow::Nodes::ComputeNode
- #all_dependencies — Dataflow::Node
- #all_paginated — Dataflow::Adapters::MongoDbAdapter
- #all_paginated — Dataflow::Adapters::SqlAdapter
- #all_paginated — Dataflow::Nodes::DataNode
- #all_paginated — Dataflow::Nodes::RuntimeQueryNode
- #apply_query — Dataflow::Adapters::SqlAdapter
- #await_computing! — Dataflow::Nodes::ComputeNode
- #clear — Dataflow::Nodes::DataNode
- #clear — Dataflow::Nodes::ReadOnlyDataNode
- #compute — Dataflow::Nodes::ComputeNode
- #compute_batch — Dataflow::Nodes::ComputeNode
- #compute_batch — Dataflow::Nodes::Filter::WhereNode
- #compute_batch — Dataflow::Nodes::JoinNode
- #compute_batch — Dataflow::Nodes::MapNode
- #compute_batch — Dataflow::Nodes::SelectKeysNode
- #compute_batch — Dataflow::Nodes::Transformation::ToTimeNode
- #compute_impl — Dataflow::Nodes::ComputeNode
- #compute_impl — Dataflow::Nodes::Export::ToCsvNode
- #compute_impl — Dataflow::Nodes::Filter::DropWhileNode
- #compute_impl — Dataflow::Nodes::Filter::NewestNode
- #compute_impl — Dataflow::Nodes::JoinNode
- #compute_impl — Dataflow::Nodes::MergeNode
- #compute_impl — Dataflow::Nodes::SqlQueryNode
- #computed_query — Dataflow::Nodes::SqlQueryNode
- #connection_uri_or_default — Dataflow::Adapters::Settings
- #constantize — Dataflow::ConstantizePatch
- #convert_update_at_key — Dataflow::Nodes::SnapshotNode
- #count — Dataflow::Adapters::CsvAdapter
- #count — Dataflow::Adapters::MongoDbAdapter
- #count — Dataflow::Adapters::SqlAdapter
- #count — Dataflow::Nodes::DataNode
- #count — Dataflow::Nodes::RuntimeQueryNode
- #create_indexes — Dataflow::Adapters::CsvAdapter
- #create_indexes — Dataflow::Adapters::MongoDbAdapter
- #create_indexes — Dataflow::Adapters::SqlAdapter
- #create_non_unique_indexes — Dataflow::Nodes::DataNode
- #create_non_unique_indexes — Dataflow::Nodes::ReadOnlyDataNode
- #create_table — Dataflow::Adapters::SqlAdapter
- #create_unique_indexes — Dataflow::Nodes::DataNode
- #create_unique_indexes — Dataflow::Nodes::ReadOnlyDataNode
- #data_node — Dataflow::Nodes::ComputeNode
- #dataset_keys — Dataflow::Nodes::JoinNode
- #dataset_name_for_buffer — Dataflow::Nodes::DataNode
- #db_adapter — Dataflow::Nodes::DataNode
- #db_indexes — Dataflow::Nodes::DataNode
- #delete — Dataflow::Adapters::MongoDbAdapter
- #delete — Dataflow::Adapters::SqlAdapter
- #delete_file — Dataflow::Adapters::CsvAdapter
- #dependencies — Dataflow::Nodes::ComputeNode
- #disconnect_db_clients — Dataflow::Nodes::ComputeNode
- #drop_dataset — Dataflow::Adapters::MongoDbAdapter
- #drop_dataset — Dataflow::Adapters::SqlAdapter
- #drop_dataset! — Dataflow::Nodes::DataNode
- #drop_dataset! — Dataflow::Nodes::ReadOnlyDataNode
- #drop_while — Dataflow::Nodes::Filter::DropWhileNode
- #dump — Dataflow::Adapters::MongoDbAdapter
- #dump — Dataflow::Adapters::PsqlAdapter
- #dump_dataset — Dataflow::Nodes::DataNode
- #dump_dataset — Dataflow::Nodes::ReadOnlyDataNode
- #ensure_at_least_dependencies — Dataflow::Nodes::ComputeNode
- #ensure_at_most_dependencies — Dataflow::Nodes::ComputeNode
- #ensure_data_node_exists — Dataflow::Nodes::ComputeNode
- #ensure_exact_dependencies — Dataflow::Nodes::ComputeNode
- #ensure_keys_are_set — Dataflow::Nodes::ComputeNode
- #ensure_keys_are_set! — Dataflow::Nodes::Filter::NewestNode
- #ensure_no_cyclic_dependencies — Dataflow::Nodes::ComputeNode
- #ensure_no_cyclic_dependencies! — Dataflow::Nodes::ComputeNode
- #error — Dataflow::Logger
- #event — Dataflow::EventMixin::ClassMethods
- #execute_local_batch_computation — Dataflow::Nodes::ComputeNode
- #execute_local_computation — Dataflow::Nodes::ComputeNode
- #execute_query — Dataflow::Nodes::SqlQueryNode
- #execute_sql_join — Dataflow::Nodes::JoinNode
- #execution_valid? — Dataflow::Nodes::ComputeNode
- #explain_update — Dataflow::Nodes::ComputeNode
- #explain_update — Dataflow::Nodes::DataNode
- #export — Dataflow::Nodes::DataNode
- #export — Dataflow::Nodes::SelectKeysNode
- #field — Dataflow::PropertiesMixin::ClassMethods
- #file_parts — Dataflow::Adapters::CsvAdapter
- #file_path — Dataflow::Adapters::CsvAdapter
- #filter_by_newest — Dataflow::Nodes::Filter::NewestNode
- #find — Dataflow::Adapters::CsvAdapter
- #find — Dataflow::Adapters::MongoDbAdapter
- #find — Dataflow::Adapters::SqlAdapter
- #find — Dataflow::Nodes::DataNode
- #find — Dataflow::Nodes::RuntimeQueryNode
- #find_matching_record — Dataflow::Nodes::JoinNode
- #force_computing_lock_release! — Dataflow::Nodes::ComputeNode
- #format_index — Dataflow::Adapters::MongoDbAdapter
- #handle_dataset_settings_changed — Dataflow::Nodes::DataNode
- #handle_dataset_settings_changed — Dataflow::Nodes::ReadOnlyDataNode
- #has_dependency_in_hierarchy? — Dataflow::Nodes::ComputeNode
- #has_multiple_keys? — Dataflow::Nodes::JoinNode
- #import — Dataflow::Nodes::DataNode
- #import — Dataflow::Nodes::ReadOnlyDataNode
- #index_parameters — Dataflow::Adapters::SqlAdapter
- #infer_partial_schema — Dataflow::SchemaMixin
- #infer_schema — Dataflow::SchemaMixin
- #info — Dataflow::Nodes::DataNode
- #initial_query — Mongo::Collection::View
- #is_integer? — Dataflow::SchemaMixin
- #is_record_redundant? — Dataflow::Nodes::SnapshotNode
- #join — Dataflow::Nodes::JoinNode
- #locked_for_computing? — Dataflow::Nodes::ComputeNode
- #log — Dataflow::Logger
- #log — Dataflow::Logger::LoggerImpl
- #logger — Dataflow::Adapters::SqlAdapter
- #logger — Dataflow::Nodes::ComputeNode
- #logger — Dataflow::Nodes::DataNode
- #make_batch_params — Dataflow::Nodes::ComputeNode
- #make_batch_queries — Dataflow::Nodes::ComputeNode
- #map — Dataflow::Nodes::MapNode
- #map_record — Dataflow::Nodes::MapNode
- #merge_records — Dataflow::Nodes::MergeNode
- #metadata — Dataflow::Node
- #mongodb_default_connection_uri — Dataflow::Adapters::Settings
- #mysql_default_connection_uri — Dataflow::Adapters::Settings
- #needs_automatic_recomputing? — Dataflow::Nodes::ComputeNode
- #on_save_finished — Dataflow::Adapters::CsvAdapter
- #ordered_system_id_queries — Dataflow::Adapters::MongoDbAdapter
- #ordered_system_id_queries — Dataflow::Adapters::SqlAdapter
- #ordered_system_id_queries — Dataflow::Nodes::DataNode
- #parallel_each — Dataflow::Nodes::ComputeNode
- #postgresql_default_connection_uri — Dataflow::Adapters::Settings
- #pre_compute — Dataflow::Nodes::ComputeNode
- #process_group — Dataflow::Nodes::Filter::DropWhileNode
- #process_ids — Dataflow::Nodes::Filter::DropWhileNode
- #process_ids — Dataflow::Nodes::Filter::NewestNode
- #process_parallel — Dataflow::Nodes::ComputeNode
- #properties — Dataflow::PropertiesMixin::ClassMethods
- #raise_read_only_error! — Dataflow::Nodes::ReadOnlyDataNode
- #read_dataset_name — Dataflow::Adapters::MongoDbAdapter
- #read_dataset_name — Dataflow::Nodes::DataNode
- #read_dataset_name — Dataflow::Nodes::ReadOnlyDataNode
- #read_dataset_name= — Dataflow::Nodes::DataNode
- #read_dataset_name= — Dataflow::Nodes::ReadOnlyDataNode
- #recompute — Dataflow::Nodes::ComputeNode
- #recompute — Dataflow::Node
- #record_dig_tokens — Dataflow::SchemaMixin
- #record_value — Dataflow::SchemaMixin
- #recreate_dataset — Dataflow::Adapters::CsvAdapter
- #recreate_dataset — Dataflow::Adapters::MongoDbAdapter
- #recreate_dataset — Dataflow::Adapters::SqlAdapter
- #recreate_dataset — Dataflow::Nodes::DataNode
- #recreate_dataset — Dataflow::Nodes::ReadOnlyDataNode
- #regex_case_insensitive_op — Dataflow::Adapters::MysqlAdapter
- #regex_case_insensitive_op — Dataflow::Adapters::PsqlAdapter
- #regex_case_senstive_op — Dataflow::Adapters::MysqlAdapter
- #regex_case_senstive_op — Dataflow::Adapters::PsqlAdapter
- #release_computing_lock! — Dataflow::Nodes::ComputeNode
- #remove — Dataflow::Adapters::CsvAdapter
- #rename_dotted_fields — Dataflow::Nodes::Mixin::RenameDottedFields
- #required_by — Dataflow::Nodes::DataNode
- #required_by — Dataflow::Node
- #required_schema — Dataflow::Nodes::ComputeNode
- #required_schema — Dataflow::Nodes::JoinNode
- #restore — Dataflow::Adapters::MongoDbAdapter
- #restore — Dataflow::Adapters::PsqlAdapter
- #restore_dataset — Dataflow::Nodes::DataNode
- #restore_dataset — Dataflow::Nodes::ReadOnlyDataNode
- #retrieve_dataset_indexes — Dataflow::Adapters::MongoDbAdapter
- #retrieve_dataset_indexes — Dataflow::Adapters::SqlAdapter
- #safely_clear_write_dataset — Dataflow::Nodes::DataNode
- #sample_data — Dataflow::SchemaMixin
- #save — Dataflow::Adapters::CsvAdapter
- #save — Dataflow::Adapters::MongoDbAdapter
- #save — Dataflow::Adapters::SqlAdapter
- #schema — Dataflow::Nodes::ComputeNode
- #schema_inferrer — Dataflow::SchemaMixin
- #select_keys — Dataflow::Nodes::SelectKeysNode
- #send_heartbeat — Dataflow::Nodes::ComputeNode
- #set_defaults — Dataflow::Nodes::ComputeNode
- #set_defaults — Dataflow::Nodes::DataNode
- #set_defaults — Dataflow::Nodes::ReadOnlyDataNode
- #set_defaults — Dataflow::Nodes::SnapshotNode
- #set_defaults — Dataflow::Nodes::UpsertNode
- #set_last_compute_starting_time — Dataflow::Nodes::ComputeNode
- #set_mongodb_defaults_if_needed! — Dataflow::Adapters::Settings
- #set_mysql_defaults_if_needed! — Dataflow::Adapters::Settings
- #set_postgresql_defaults_if_needed! — Dataflow::Adapters::Settings
- #set_schema — Dataflow::Adapters::CsvAdapter
- #sql_default_connection_uri — Dataflow::Adapters::Settings
- #sql_join_query — Dataflow::Nodes::JoinNode
- #swap_read_write_datasets! — Dataflow::Nodes::DataNode
- #swap_read_write_datasets! — Dataflow::Nodes::ReadOnlyDataNode
- #to_msgpack — Object
- #trace_id — Dataflow::Logger
- #transform_fields — Dataflow::Nodes::Export::ToCsvNode
- #transform_index_key — Dataflow::Nodes::UpsertNode
- #transform_to_query — Dataflow::Adapters::MongoDbAdapter
- #transform_to_query — Dataflow::Adapters::SqlAdapter
- #traverse_and_rename_dotted_fields — Dataflow::Nodes::Mixin::RenameDottedFields
- #traverse_and_rename_dotted_fields_in_array — Dataflow::Nodes::Mixin::RenameDottedFields
- #try_cast_value — Dataflow::Adapters::MongoDbAdapter
- #update_schema — Dataflow::Nodes::DataNode
- #update_settings — Dataflow::Adapters::CsvAdapter
- #update_settings — Dataflow::Adapters::MongoDbAdapter
- #update_settings — Dataflow::Adapters::SqlAdapter
- #updated? — Dataflow::Nodes::ComputeNode
- #updated? — Dataflow::Nodes::DataNode
- #updated_at — Dataflow::Nodes::ComputeNode
- #updated_at= — Dataflow::Nodes::ComputeNode
- #usage — Dataflow::Adapters::MongoDbAdapter
- #usage — Dataflow::Adapters::MysqlAdapter
- #usage — Dataflow::Adapters::PsqlAdapter
- #use_symbols? — Dataflow::Nodes::DataNode
- #valid_dataset_names — Dataflow::Nodes::DataNode
- #valid_for_computation? — Dataflow::Nodes::ComputeNode
- #valid_for_computation? — Dataflow::Nodes::JoinNode
- #valid_for_computation? — Dataflow::Nodes::SqlQueryNode
- #valid_for_computation? — Dataflow::Nodes::Transformation::ToTimeNode
- #valid_for_computation? — Dataflow::Node
- #validate! — Dataflow::Node
- #where — Dataflow::Nodes::Filter::WhereNode
- #write_csv_part — Dataflow::Adapters::CsvAdapter
- #write_dataset_name — Dataflow::Adapters::MongoDbAdapter
- #write_dataset_name — Dataflow::Nodes::DataNode
- #write_single_csv — Dataflow::Adapters::CsvAdapter