Sparklyr Extension for 'Flint'
![[R logo]](../../../doc/html/Rlogo.svg)
![[Up]](../../../doc/html/left.jpg)
![[Top]](../../../doc/html/up.jpg)
Documentation for package ‘sparklyr.flint’ version 0.2.2
Help Pages
| 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 |
| fromRDD | Construct a TimeSeriesRDD from a Spark RDD of rows |
| fromSDF | Construct a TimeSeriesRDD from a Spark DataFrame |
| 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 |
| in_future | Time window specifications |
| in_past | Time window specifications |
| ols_regression | OLS regression |
| sdf_utils | Utility functions for importing a Spark data frame into a TimeSeriesRDD |
| 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 |
| summarizers | Wrapper functions for commonly used summarizer functions |
| 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 |
| 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 |
| toSDF | Export data from TimeSeriesRDD to a Spark dataframe |
| 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 |