|
actualize_join_plan()
|
Execute an ordered sequence of left joins. |
|
affine_transform()
|
Implement an affine transformaton |
|
apply_right(<relop>)
|
Execute pipeline treating pipe_left_arg as local data to
be copied into database. |
|
apply_right_S4(<ANY>,<rquery_db_info>)
|
Apply pipeline to a database. |
|
apply_right_S4(<data.frame>,<relop_arrow>)
|
S4 dispatch method for apply_right. |
|
apply_right_S4(<relop_arrow>,<relop_arrow>)
|
S4 dispatch method for apply_right. |
|
arrow()
|
Data arrow |
|
assign_slice()
|
Assign a value to a slice of data (set of rows meeting a condition, and specified set of columns). |
|
build_join_plan()
|
Build a join plan. |
|
column_names()
|
Return column names |
|
columns_used()
|
Return columns used |
|
commencify()
|
Hyderdrive (science fiction show) synonym for execute |
|
complete_design()
|
Complete an experimental design. |
|
convert_yaml_to_pipeline()
|
Convert a series of simple objects (from YAML deserializaton) to an rquery pipeline. |
|
count_null_cols()
|
Count NULLs per row for given column set. |
|
db_td() dbi_table()
|
Construct a table description from a database source. |
|
describe_tables()
|
Build a nice description of a table. |
|
drop_columns()
|
Make a drop columns node (not a relational operation). |
|
ex()
|
Execute a wrapped execution pipeline. |
|
execute()
|
Execute an operator tree, bringing back the result to memory. |
|
expand_grid()
|
Cross product vectors in database. |
|
extend() extend_nse()
|
Extend data by adding more columns. |
|
extend_se()
|
Extend data by adding more columns. |
|
format_node()
|
Format a single node for printing. |
|
getDBOption()
|
Get a database connection option. |
|
graph_join_plan()
|
Build a draw-able specification of the join diagram |
|
if_else_block()
|
Build a sequence of statements simulating an if/else block-if(){}else{}. |
|
if_else_op()
|
Build a relop node simulating a per-row block-if(){}else{}. |
|
inspect_join_plan()
|
check that a join plan is consistent with table descriptions. |
|
key_inspector_all_cols()
|
Return all columns as guess of preferred primary keys. |
|
key_inspector_postgresql()
|
Return all primary key columns as guess at preferred primary keys for a PostgreSQL handle. |
|
key_inspector_sqlite()
|
Return all primary key columns as guess at preferred primary keys for a SQLite handle. |
|
local_td()
|
Construct a table description of a local data.frame. |
|
lookup_by_column()
|
Use one column to pick values from other columns. |
|
make_assignments()
|
Make a list of assignments, applying many functions to many columns. |
|
map_column_values()
|
Remap values in a set of columns. |
|
mark_null_cols()
|
Indicate NULLs per row for given column set. |
|
materialize()
|
Materialize an optree as a table. |
|
materialize_node()
|
Create a materialize node. |
|
mk_td() table_source()
|
Make a table description directly. |
|
natural_join()
|
Make a natural_join node. |
|
non_sql_node()
|
Wrap a non-SQL node. |
|
normalize_cols()
|
Build an optree pipeline that normalizes a set of columns so each column sums to one in each partition. |
|
null_replace()
|
Create a null_replace node. |
|
op_diagram()
|
Build a diagram of a optree pipeline. |
|
order_expr() order_expr_nse()
|
Make a order_expr node. |
|
order_expr_se()
|
Make a order_expr node. |
|
order_rows()
|
Make an orderby node (not a relational operation). |
|
orderby()
|
Make an orderby node (not a relational operation). |
|
pick_top_k()
|
Build an optree pipeline that selects up to the top k rows from each group in the given order. |
|
pre_sql_sub_expr()
|
pre_sql_sub_expr |
|
project() project_nse() aggregate_nse()
|
project data by grouping, and adding aggregate columns. |
|
project_se() aggregate_se()
|
project data by grouping, and adding aggregate columns. |
|
quantile_cols()
|
Compute quantiles of specified columns
(without interpolation, needs a database with window functions). |
|
quantile_node()
|
Compute quantiles over non-NULL values
(without interpolation, needs a database with window functions). |
|
quote_identifier()
|
Quote an identifier. |
|
quote_literal()
|
Quote a value |
|
quote_string()
|
Quote a string |
|
quote_table_name()
|
Quote a table name. |
|
rename_columns()
|
Make a rename columns node (copies columns not renamed). |
|
row_counts()
|
Build an optree pipeline counts rows. |
|
rq_colnames()
|
List table column names. |
|
rq_coltypes()
|
Get column types by example values as a data.frame. |
|
rq_connection_advice()
|
Get advice for a DB connection (beyond tests). |
|
rq_connection_name()
|
Build a canonical name for a db connection class. |
|
rq_connection_tests()
|
Try and test database for some option settings. |
|
rq_copy_to()
|
Copy local R table to remote data handle. |
|
rq_execute()
|
Execute a query, typically an update that is not supposed to return results. |
|
rq_get_query()
|
Execute a get query, typically a non-update that is supposed to return results. |
|
rq_head()
|
Get head of db table |
|
rq_nrow()
|
Count rows and return as numeric |
|
rq_remove_table()
|
Remove table |
|
rq_table_exists()
|
Check if a table exists. |
|
rquery
|
rquery: Relational Query Generator for Data Manipulation
|
|
rquery_apply_to_data_frame()
|
Execute optree in an environment where d is the only data. |
|
rquery_db_info()
|
Build a db information stand-in |
|
rquery_default_db_info()
|
An example rquery_db_info object useful for formatting SQL without a database connection. |
|
rstr() rlook()
|
Quick look at remote data |
|
rsummary()
|
Compute usable summary of columns of remote table. |
|
rsummary_node()
|
Create an rsumary relop operator node. |
|
select_columns()
|
Make a select columns node (not a relational operation). |
|
select_rows() select_rows_nse()
|
Make a select rows node. |
|
select_rows_se()
|
Make a select rows node. |
|
setDBOpt()
|
Set a database connection option. |
|
setDBOption()
|
Set a database connection option. |
|
set_indicator()
|
Make a set indicator node. |
|
sql_expr_set()
|
Build a query that applies a SQL expression to a set of columns. |
|
sql_node()
|
Make a general SQL node. |
|
tables_used()
|
Return vector of table names used. |
|
theta_join() theta_join_nse()
|
Make a theta_join node. |
|
theta_join_se()
|
Make a theta_join node. |
|
to_sql()
|
Return SQL implementation of operation tree. |
|
to_transport_representation()
|
Convert an rquery op diagram to a simple representation, appropriate for conversion to YAML. |
|
topo_sort_tables()
|
Topologically sort join plan so values are available before uses. |
|
unionall()
|
Make an unionall node (not a relational operation). |
|
wrap()
|
Wrap a data frame for later execution. |