Man pages for sparklyr.flint
Sparklyr Extension for 'Flint'
| asof_future_left_join | Temporal future left join |
| asof_join | Temporal join |
| asof_left_join | Temporal left join |
| collect.ts_rdd | Collect data from a TimeSeriesRDD |
| from_rdd | Construct a TimeSeriesRDD from a Spark RDD of rows |
| from_sdf | Construct a TimeSeriesRDD from a Spark DataFrame |
| init | Dependencies and initialization procedures |
| ols_regression | OLS regression |
| sdf_utils | Utility functions for importing a Spark data frame into a... |
| spark_connection | Retrieve Spark connection associated with an R object |
| spark_connection.ts_rdd | Retrieve Spark connection associated with an R object |
| spark_dataframe | Retrieve a Spark DataFrame |
| spark_dataframe.ts_rdd | Retrieve a Spark DataFrame |
| spark_jobj | Retrieve a Spark JVM Object Reference |
| spark_jobj.ts_rdd | Retrieve a Spark JVM Object Reference |
| summarize_avg | Average summarizer |
| summarize_corr | Correlation summarizer |
| summarize_corr2 | Pairwise correlation summarizer |
| summarize_count | Count summarizer |
| summarize_covar | Covariance summarizer |
| summarize_dot_product | Dot product summarizer |
| summarize_ema_half_life | EMA half-life summarizer |
| summarize_ewma | Exponential weighted moving average summarizer |
| summarize_geometric_mean | Geometric mean summarizer |
| summarize_kurtosis | Kurtosis summarizer |
| summarize_max | Maximum value summarizer |
| summarize_min | Minimum value summarizer |
| summarize_nth_central_moment | N-th central moment summarizer |
| summarize_nth_moment | N-th moment summarizer |
| summarize_product | Product summarizer |
| summarize_quantile | Quantile summarizer |
| summarizers | Wrapper functions for commonly used summarizer functions |
| summarize_skewness | Skewness summarizer |
| summarize_stddev | Standard deviation summarizer |
| summarize_sum | Sum summarizer |
| summarize_var | Variance summarizer |
| summarize_weighted_avg | Weighted average summarizer |
| summarize_weighted_corr | Pearson weighted correlation summarizer |
| summarize_weighted_covar | Weighted covariance summarizer |
| summarize_z_score | Z-score summarizer |
| to_sdf | Export data from TimeSeriesRDD to a Spark dataframe |
| try_spark_connect | Attempt to establish a Spark connection |
| ts_rdd_builder | TimeSeriesRDD builder object |
| window_exprs | Time window specifications |
