Method List

Classes Methods Files

Search:

#adapter_type Dataflow::Adapters::Settings
#add Dataflow::Nodes::UpsertNode
#add Dataflow::Nodes::DataNode
#add Dataflow::Nodes::ReadOnlyDataNode
#add Dataflow::Nodes::SnapshotNode
add_extensions Dataflow::Adapters::SqlAdapter
#add_internal_timestamp Dataflow::Nodes::Mixin::AddInternalTimestamp
#add_property Dataflow::PropertiesMixin::ClassMethods
admin_client Dataflow::Adapters::MongoDbAdapter
#all Dataflow::Adapters::SqlAdapter
#all Dataflow::Adapters::CsvAdapter
#all Dataflow::Nodes::RuntimeQueryNode
#all Dataflow::Nodes::DataNode
#all Dataflow::Adapters::MongoDbAdapter
#all_dependencies Dataflow::Node
#all_dependencies Dataflow::Nodes::ComputeNode
#all_paginated Dataflow::Nodes::DataNode
#all_paginated Dataflow::Adapters::SqlAdapter
#all_paginated Dataflow::Nodes::RuntimeQueryNode
#all_paginated Dataflow::Adapters::MongoDbAdapter
await_execution_completion Dataflow::Executor
#clear Dataflow::Nodes::DataNode
#clear Dataflow::Nodes::ReadOnlyDataNode
clear_tmp_datasets Dataflow
#client Dataflow::Adapters::MongoDbAdapter
client Dataflow::Adapters::MongoDbAdapter
#client Dataflow::Adapters::SqlAdapter
client Dataflow::Adapters::SqlAdapter
#compute Dataflow::Nodes::ComputeNode
#compute_batch Dataflow::Nodes::Transformation::ToTimeNode
#compute_impl Dataflow::Nodes::JoinNode
#compute_impl Dataflow::Nodes::Filter::DropWhileNode
#compute_impl Dataflow::Nodes::Export::ToCsvNode
compute_node Dataflow
#computed_query Dataflow::Nodes::SqlQueryNode
#connection_uri Dataflow::Adapters::Settings
#connection_uri_or_default Dataflow::Adapters::Settings
#constantize Dataflow::ConstantizePatch
#count Dataflow::Adapters::MongoDbAdapter
#count Dataflow::Nodes::RuntimeQueryNode
#count Dataflow::Adapters::CsvAdapter
#count Dataflow::Nodes::DataNode
#count Dataflow::Adapters::SqlAdapter
#create_indexes Dataflow::Adapters::SqlAdapter
#create_indexes Dataflow::Adapters::CsvAdapter
#create_indexes Dataflow::Adapters::MongoDbAdapter
#create_non_unique_indexes Dataflow::Nodes::ReadOnlyDataNode
#create_non_unique_indexes Dataflow::Nodes::DataNode
#create_unique_indexes Dataflow::Nodes::DataNode
#create_unique_indexes Dataflow::Nodes::ReadOnlyDataNode
#cursor Mongo::Collection::View
#data_node Dataflow::Nodes::ComputeNode
data_node Dataflow
data_node_opts Dataflow::Nodes::ComputeNode
#dataset_name Dataflow::Adapters::Settings
#db_host Dataflow::Adapters::Settings
#db_indexes Dataflow::Nodes::DataNode
#db_name Dataflow::Adapters::Settings
#db_password Dataflow::Adapters::Settings
#db_port Dataflow::Adapters::Settings
#db_user Dataflow::Adapters::Settings
#delete Dataflow::Adapters::MongoDbAdapter
#delete Dataflow::Adapters::SqlAdapter
#dependencies Dataflow::Nodes::ComputeNode
dependency_opts Dataflow::Nodes::ComputeNode
disconnect_clients Dataflow::Adapters::MongoDbAdapter
disconnect_clients Dataflow::Adapters::SqlAdapter
#drop_dataset Dataflow::Adapters::SqlAdapter
#drop_dataset Dataflow::Adapters::MongoDbAdapter
#drop_dataset! Dataflow::Nodes::DataNode
#drop_dataset! Dataflow::Nodes::ReadOnlyDataNode
#dump Dataflow::Adapters::PsqlAdapter
#dump Dataflow::Adapters::MongoDbAdapter
#dump_dataset Dataflow::Nodes::DataNode
#dump_dataset Dataflow::Nodes::ReadOnlyDataNode
ensure_data_node_exists Dataflow::Nodes::ComputeNode
ensure_dependencies Dataflow::Nodes::ComputeNode
#error Dataflow::Logger
#event Dataflow::EventMixin::ClassMethods
execute Dataflow::RemoteWorker
execute Dataflow::Executor
#execute_local_batch_computation Dataflow::Nodes::ComputeNode
#execute_local_computation Dataflow::Nodes::ComputeNode
#execute_query Dataflow::Nodes::SqlQueryNode
execute_remote_computation Dataflow::Executor
#execution_valid? Dataflow::Nodes::ComputeNode
#explain_update Dataflow::Nodes::DataNode
#explain_update Dataflow::Nodes::ComputeNode
#export Dataflow::Nodes::SelectKeysNode
#export Dataflow::Nodes::DataNode
export Dataflow
#field Dataflow::PropertiesMixin::ClassMethods
#find Dataflow::Nodes::DataNode
#find Dataflow::Adapters::SqlAdapter
find Dataflow::Node
#find Dataflow::Adapters::CsvAdapter
#find Dataflow::Adapters::MongoDbAdapter
#find Dataflow::Nodes::RuntimeQueryNode
#force_computing_lock_release! Dataflow::Nodes::ComputeNode
#handle_dataset_settings_changed Dataflow::Nodes::ReadOnlyDataNode
#handle_dataset_settings_changed Dataflow::Nodes::DataNode
#import Dataflow::Nodes::DataNode
import Dataflow
#import Dataflow::Nodes::ReadOnlyDataNode
included Dataflow::Nodes::Mixin::AddInternalTimestamp
included Dataflow::Nodes::Mixin::RenameDottedFields
#indexes Dataflow::Adapters::Settings
#infer_partial_schema Dataflow::SchemaMixin
#infer_schema Dataflow::SchemaMixin
#info Dataflow::Nodes::DataNode
#initial_query Mongo::Collection::View
#initialize Dataflow::Errors::RemoteExecutionError
#initialize Dataflow::Adapters::MongoDbAdapter
#initialize Dataflow::Adapters::Settings
#initialize Dataflow::Adapters::SqlAdapter
#initialize Dataflow::Logger
#initialize Dataflow::Adapters::CsvAdapter
#locked_for_computing? Dataflow::Nodes::ComputeNode
#log Dataflow::Logger::LoggerImpl
#log Dataflow::Logger
logger Dataflow::RemoteWorker
logger Dataflow::Executor
#make_batch_params Dataflow::Nodes::ComputeNode
make_execution_params Dataflow::Executor
#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
open_communication_channel Dataflow::Executor
#ordered_system_id_queries Dataflow::Adapters::MongoDbAdapter
#ordered_system_id_queries Dataflow::Nodes::DataNode
#ordered_system_id_queries Dataflow::Adapters::SqlAdapter
#postgresql_default_connection_uri Dataflow::Adapters::Settings
#prefix Dataflow::Logger
process Dataflow::RemoteWorker
#properties Dataflow::PropertiesMixin::ClassMethods
#read_dataset_name Dataflow::Adapters::Settings
#read_dataset_name Dataflow::Nodes::ReadOnlyDataNode
#read_dataset_name Dataflow::Nodes::DataNode
#read_dataset_name= Dataflow::Nodes::DataNode
#read_dataset_name= Dataflow::Nodes::ReadOnlyDataNode
#recompute Dataflow::Nodes::ComputeNode
#recompute Dataflow::Node
#recreate_dataset Dataflow::Nodes::DataNode
#recreate_dataset Dataflow::Adapters::CsvAdapter
#recreate_dataset Dataflow::Nodes::ReadOnlyDataNode
#recreate_dataset Dataflow::Adapters::MongoDbAdapter
#recreate_dataset Dataflow::Adapters::SqlAdapter
#regex_case_insensitive_op Dataflow::Adapters::MysqlAdapter
#regex_case_insensitive_op Dataflow::Adapters::PsqlAdapter
#regex_case_senstive_op Dataflow::Adapters::PsqlAdapter
#regex_case_senstive_op Dataflow::Adapters::MysqlAdapter
#remove Dataflow::Adapters::CsvAdapter
#rename_dotted_fields Dataflow::Nodes::Mixin::RenameDottedFields
#required_by Dataflow::Nodes::DataNode
#required_by Dataflow::Node
#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::SqlAdapter
#retrieve_dataset_indexes Dataflow::Adapters::MongoDbAdapter
#safely_clear_write_dataset Dataflow::Nodes::DataNode
#sample_data Dataflow::SchemaMixin
#save Dataflow::Adapters::SqlAdapter
#save Dataflow::Adapters::MongoDbAdapter
#save Dataflow::Adapters::CsvAdapter
#schema Dataflow::Adapters::Settings
#schema Dataflow::Nodes::ComputeNode
#schema_inferrer Dataflow::SchemaMixin
send_execution_messages Dataflow::Executor
#set_defaults Dataflow::Nodes::ComputeNode
#set_defaults Dataflow::Nodes::UpsertNode
#set_defaults Dataflow::Nodes::SnapshotNode
#set_defaults Dataflow::Nodes::ReadOnlyDataNode
#set_defaults Dataflow::Nodes::DataNode
#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
#settings Dataflow::Adapters::MongoDbAdapter
#settings Dataflow::Adapters::SqlAdapter
#settings Dataflow::Adapters::CsvAdapter
#sql_default_connection_uri Dataflow::Adapters::Settings
#swap_read_write_datasets! Dataflow::Nodes::ReadOnlyDataNode
#swap_read_write_datasets! Dataflow::Nodes::DataNode
#trace_id Dataflow::Logger
#transform_fields Dataflow::Nodes::Export::ToCsvNode
#transform_to_query Dataflow::Adapters::SqlAdapter
#transform_to_query Dataflow::Adapters::MongoDbAdapter
#traverse_and_rename_dotted_fields Dataflow::Nodes::Mixin::RenameDottedFields
#traverse_and_rename_dotted_fields_in_array Dataflow::Nodes::Mixin::RenameDottedFields
try_create_db Dataflow::Adapters::SqlAdapter
#update_schema Dataflow::Nodes::DataNode
#update_settings Dataflow::Adapters::SqlAdapter
#update_settings Dataflow::Adapters::CsvAdapter
#update_settings Dataflow::Adapters::MongoDbAdapter
#updated? Dataflow::Nodes::ComputeNode
#updated? Dataflow::Nodes::DataNode
#updated_at Dataflow::Nodes::ComputeNode
#updated_at= Dataflow::Nodes::ComputeNode
#usage Dataflow::Adapters::MysqlAdapter
#usage Dataflow::Adapters::PsqlAdapter
#usage Dataflow::Adapters::MongoDbAdapter
#use_notifications Dataflow::Logger
#use_symbols? Dataflow::Nodes::DataNode
#valid_for_computation? Dataflow::Nodes::SqlQueryNode
#valid_for_computation? Dataflow::Nodes::ComputeNode
#valid_for_computation? Dataflow::Nodes::JoinNode
#valid_for_computation? Dataflow::Node
#valid_for_computation? Dataflow::Nodes::Transformation::ToTimeNode
#validate! Dataflow::Node
work Dataflow::RemoteWorker
#write_dataset_name Dataflow::Adapters::Settings
#write_dataset_name Dataflow::Nodes::DataNode