Package: dasklyr 0.1.1
Louis Li
dasklyr: R Interface to 'Dask'
Run 'dplyr' verbs on 'Dask' data frames from R. Connect to a local 'Dask' client or a remote scheduler, copy R data frames onto the cluster, read and write Parquet and CSV, and collect results as 'tibble' objects. Computation stays in Python workers through 'reticulate'; R only builds the graph. A Python installation with the 'dask' package is required.
Authors:
dasklyr_0.1.1.tar.gz
dasklyr_0.1.1.zip(r-4.7-any)dasklyr_0.1.1.zip(r-4.6-any)
dasklyr_0.1.1.tar.gz(r-4.7-any)dasklyr_0.1.1.tar.gz(r-4.6-any)
dasklyr_0.1.1.tgz(r-4.6-emscripten)
manual.pdf |manual.html✨
DESCRIPTION |NEWS
card.svg |card.png
dasklyr/json (API)
| # Install 'dasklyr' in R: |
| install.packages('dasklyr', repos = c('https://cran.r-universe.dev', 'https://cloud.r-project.org')) |
Bug tracker:https://github.com/hebian1994/dasklyr/issues
Last updated from:1485615fc3. Checks:6 OK. Indexed: yes.
| Target | Result | Time | Files | Syslog |
|---|---|---|---|---|
| linux-devel | OK | 117 | ||
| source / vignettes | OK | 213 | ||
| linux-release | OK | 139 | ||
| windows-devel | OK | 58 | ||
| windows-release | OK | 125 | ||
| wasm-release | OK | 97 |
Exports:copy_todask_availabledask_configdask_connectdask_connection_finddask_connection_is_opendask_dataframedask_disconnectdask_disconnect_alldask_invokedask_read_csvdask_read_parquetdask_webdask_write_csvdask_write_parquetddf_columnsddf_dimddf_ncolddf_npartitionsddf_nrowddf_persistddf_repartitionddf_schemasrc_tblstbl
Dependencies:clidplyrgenericsglueherejsonlitelatticelifecyclemagrittrMatrixpillarpkgconfigpngR6rappdirsRcppRcppTOMLreticulaterlangrprojroottibbletidyselectutf8vctrswithr
Readme and manuals
Help Manual
| Help page | Topics |
|---|---|
| Copy an R data frame to Dask | copy_to.dask_connection |
| Is Dask available to this R session? | dask_available |
| Runtime configuration for dasklyr | dask_config |
| Connect to Dask | dask_connect |
| Find an open Dask connection | dask_connection_find |
| Is a Dask connection still usable? | dask_connection_is_open |
| Underlying Dask DataFrame | dask_dataframe |
| Disconnect from Dask | dask_disconnect |
| Disconnect every open Dask connection | dask_disconnect_all |
| Invoke a Python method | dask_invoke dask_invoke.dask_connection dask_invoke.tbl_dask |
| Read CSV or Parquet into a Dask table | dask_read_csv dask_read_parquet |
| Dask dashboard URL | dask_web |
| Write a Dask table to Parquet or CSV | dask_write_csv dask_write_parquet |
| Table utilities for Dask DataFrames | ddf_columns ddf_dim ddf_ncol ddf_npartitions ddf_nrow ddf_persist ddf_repartition ddf_schema |
| Distributed Dask tables | collect.tbl_dask colnames.tbl_dask dim.tbl_dask head.tbl_dask names.tbl_dask print.tbl_dask tbl_dask |
| Retrieve a registered Dask table | tbl.dask_connection |