rolling.hpp File Reference

APIs for computing rolling window aggregations over columns. More...

#include <cudf/aggregation.hpp>
#include <cudf/rolling/range_window_bounds.hpp>
#include <cudf/types.hpp>
#include <cudf/utilities/default_stream.hpp>
#include <cudf/utilities/export.hpp>
#include <cudf/utilities/memory_resource.hpp>
#include <cudf/utilities/span.hpp>
#include <rmm/resource_ref.hpp>
#include <memory>
#include <optional>
#include <span>
#include <variant>

Go to the source code of this file.

Classes
struct	cudf::bounded_closed
	Strongly typed wrapper for bounded closed rolling windows. More...
struct	cudf::bounded_open
	Strongly typed wrapper for bounded open rolling windows. More...
struct	cudf::unbounded
	Strongly typed wrapper for unbounded rolling windows. More...
struct	cudf::current_row
	Strongly typed wrapper for current_row rolling windows. More...
struct	cudf::rolling_request
	A request for a rolling aggregation on a column. More...
struct	cudf::window_bounds
	Abstraction for window boundary sizes. More...

Namespaces
	cudf
	cuDF interfaces

Typedefs
using	cudf::range_window_type = std::variant< unbounded, current_row, bounded_closed, bounded_open >
	The type of the range-based rolling window endpoint.

Functions
std::pair< std::unique_ptr< column >, std::unique_ptr< column > >	cudf::make_range_windows (table_view const &group_keys, column_view const &orderby, order order, null_order null_order, range_window_type preceding, range_window_type following, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Constructs preceding and following columns given window range specifications. More...
std::unique_ptr< column >	cudf::rolling_window (column_view const &input, size_type preceding_window, size_type following_window, size_type min_periods, rolling_aggregation const &agg, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a fixed-size rolling window function to the values in a column. More...
std::unique_ptr< column >	cudf::rolling_window (column_view const &input, column_view const &default_outputs, size_type preceding_window, size_type following_window, size_type min_periods, rolling_aggregation const &agg, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a fixed-size rolling window function to the values in a column. More...
std::unique_ptr< column >	cudf::grouped_rolling_window (table_view const &group_keys, column_view const &input, size_type preceding_window, size_type following_window, size_type min_periods, rolling_aggregation const &aggr, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a grouping-aware, fixed-size rolling window function to the values in a column. More...
std::unique_ptr< column >	cudf::grouped_rolling_window (table_view const &group_keys, column_view const &input, window_bounds preceding_window, window_bounds following_window, size_type min_periods, rolling_aggregation const &aggr, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a grouping-aware, fixed-size rolling window function to the values in a column. More...
std::unique_ptr< column >	cudf::grouped_rolling_window (table_view const &group_keys, column_view const &input, column_view const &default_outputs, size_type preceding_window, size_type following_window, size_type min_periods, rolling_aggregation const &aggr, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a grouping-aware, fixed-size rolling window function to the values in a column. More...
std::unique_ptr< column >	cudf::grouped_rolling_window (table_view const &group_keys, column_view const &input, column_view const &default_outputs, window_bounds preceding_window, window_bounds following_window, size_type min_periods, rolling_aggregation const &aggr, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a grouping-aware, fixed-size rolling window function to the values in a column. More...
std::unique_ptr< column >	cudf::grouped_range_rolling_window (table_view const &group_keys, column_view const &orderby_column, cudf::order const &order, column_view const &input, range_window_bounds const &preceding, range_window_bounds const &following, size_type min_periods, rolling_aggregation const &aggr, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a grouping-aware, value range-based rolling window function to the values in a column. More...
std::unique_ptr< table >	cudf::grouped_range_rolling_window (table_view const &group_keys, column_view const &orderby, order order, null_order null_order, range_window_type preceding, range_window_type following, std::span< rolling_request const > requests, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Apply a grouping-aware range-based rolling window function to a sequence of columns. More...
std::unique_ptr< table >	cudf::grouped_range_rolling_window (table_view const &group_keys, table_view const &orderby, host_span< order const > orders, host_span< null_order const > null_orders, range_window_type preceding, range_window_type following, host_span< rolling_request const > requests, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Apply a grouping-aware range-based rolling window function to a sequence of columns, using one or more sorted order-by columns to identify peer rows. More...
std::unique_ptr< column >	cudf::rolling_window (column_view const &input, column_view const &preceding_window, column_view const &following_window, size_type min_periods, rolling_aggregation const &agg, rmm::cuda_stream_view stream=cudf::get_default_stream(), rmm::device_async_resource_ref mr=cudf::get_current_device_resource_ref())
	Applies a variable-size rolling window function to the values in a column. More...
bool	cudf::is_valid_rolling_aggregation (data_type source, aggregation::Kind kind)
	Indicate if a rolling aggregation is supported for a source datatype. More...

Detailed Description

APIs for computing rolling window aggregations over columns.

Definition in file rolling.hpp.