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 |