Package: sparklyr.flint 0.2.2

Edgar Ruiz

sparklyr.flint: Sparklyr Extension for 'Flint'

This sparklyr extension makes 'Flint' time series library functionalities (<https://github.com/twosigma/flint>) easily accessible through R.

Authors:Yitao Li [aut], Edgar Ruiz [aut, cre]

sparklyr.flint_0.2.2.tar.gz
sparklyr.flint_0.2.2.zip(r-4.5)sparklyr.flint_0.2.2.zip(r-4.4)sparklyr.flint_0.2.2.zip(r-4.3)
sparklyr.flint_0.2.2.tgz(r-4.4-any)sparklyr.flint_0.2.2.tgz(r-4.3-any)
sparklyr.flint_0.2.2.tar.gz(r-4.5-noble)sparklyr.flint_0.2.2.tar.gz(r-4.4-noble)
sparklyr.flint_0.2.2.tgz(r-4.4-emscripten)sparklyr.flint_0.2.2.tgz(r-4.3-emscripten)
sparklyr.flint.pdf |sparklyr.flint.html
sparklyr.flint/json (API)
NEWS

# Install 'sparklyr.flint' in R:
install.packages('sparklyr.flint', repos = c('https://r-spark.r-universe.dev', 'https://cloud.r-project.org'))

Peer review:

Bug tracker:https://github.com/r-spark/sparklyr.flint/issues

On CRAN:

apache-sparkdata-analysisdata-miningdata-sciencedistributeddistributed-computingflintremote-clusterssparksparklyrstatistical-analysisstatisticsstatssummarizationsummary-statisticstime-seriestime-series-analysistwosigma-flint

41 exports 9 stars 2.10 score 39 dependencies 4 mentions 54 scripts 1.1k downloads

Last updated 3 years agofrom:1e2c164a76. Checks:OK: 7. Indexed: yes.

TargetResultDate
Doc / VignettesOKSep 17 2024
R-4.5-winOKSep 17 2024
R-4.5-linuxOKSep 17 2024
R-4.4-winOKSep 17 2024
R-4.4-macOKSep 17 2024
R-4.3-winOKSep 17 2024
R-4.3-macOKSep 17 2024

Exports:asof_future_left_joinasof_joinasof_left_joinfrom_rddfrom_sdffromRDDfromSDFin_futurein_pastols_regressionspark_connectionspark_dataframespark_jobjsummarize_avgsummarize_corrsummarize_corr2summarize_countsummarize_covarsummarize_dot_productsummarize_ema_half_lifesummarize_ewmasummarize_geometric_meansummarize_kurtosissummarize_maxsummarize_minsummarize_nth_central_momentsummarize_nth_momentsummarize_productsummarize_quantilesummarize_skewnesssummarize_stddevsummarize_sumsummarize_varsummarize_weighted_avgsummarize_weighted_corrsummarize_weighted_covarsummarize_z_scoreto_sdftoSDFtry_spark_connectts_rdd_builder

Dependencies:askpassblobclicodetoolsconfigcpp11curlDBIdbplyrdplyrfansigenericsglobalsgluehttrjsonlitelifecyclemagrittrmimeopensslpillarpkgconfigpurrrR6rlangrstudioapisparklyrstringistringrsystibbletidyrtidyselectutf8uuidvctrswithrxml2yaml

Importing time series data

Rendered fromimporting-time-series-data.Rmdusingknitr::rmarkdownon Sep 17 2024.

Last update: 2020-07-31
Started: 2020-07-14

Overview of sparklyr.flint

Rendered fromoverview.Rmdusingknitr::rmarkdownon Sep 17 2024.

Last update: 2020-07-14
Started: 2020-07-14

Working with TimeSeriesRDD

Rendered fromworking-with-time-series-rdd.Rmdusingknitr::rmarkdownon Sep 17 2024.

Last update: 2020-07-14
Started: 2020-07-14

Readme and manuals

Help Manual

Help pageTopics
Temporal future left joinasof_future_left_join
Temporal joinasof_join
Temporal left joinasof_left_join
Collect data from a TimeSeriesRDDcollect.ts_rdd
Construct a TimeSeriesRDD from a Spark RDD of rowsfromRDD from_rdd
Construct a TimeSeriesRDD from a Spark DataFramefromSDF from_sdf
Dependencies and initialization proceduresinit
OLS regressionols_regression
Utility functions for importing a Spark data frame into a TimeSeriesRDDsdf_utils
Retrieve Spark connection associated with an R objectspark_connection
Retrieve Spark connection associated with an R objectspark_connection.ts_rdd
Retrieve a Spark DataFramespark_dataframe
Retrieve a Spark DataFramespark_dataframe.ts_rdd
Retrieve a Spark JVM Object Referencespark_jobj
Retrieve a Spark JVM Object Referencespark_jobj.ts_rdd
Average summarizersummarize_avg
Correlation summarizersummarize_corr
Pairwise correlation summarizersummarize_corr2
Count summarizersummarize_count
Covariance summarizersummarize_covar
Dot product summarizersummarize_dot_product
EMA half-life summarizersummarize_ema_half_life
Exponential weighted moving average summarizersummarize_ewma
Geometric mean summarizersummarize_geometric_mean
Kurtosis summarizersummarize_kurtosis
Maximum value summarizersummarize_max
Minimum value summarizersummarize_min
N-th central moment summarizersummarize_nth_central_moment
N-th moment summarizersummarize_nth_moment
Product summarizersummarize_product
Quantile summarizersummarize_quantile
Skewness summarizersummarize_skewness
Standard deviation summarizersummarize_stddev
Sum summarizersummarize_sum
Variance summarizersummarize_var
Weighted average summarizersummarize_weighted_avg
Pearson weighted correlation summarizersummarize_weighted_corr
Weighted covariance summarizersummarize_weighted_covar
Z-score summarizersummarize_z_score
Wrapper functions for commonly used summarizer functionssummarizers
Export data from TimeSeriesRDD to a Spark dataframetoSDF to_sdf
Attempt to establish a Spark connectiontry_spark_connect
TimeSeriesRDD builder objectts_rdd_builder
Time window specificationsin_future in_past window_exprs