Learn R Programming

RDruid

Druid connector for R

Quick Start

To install the latest version of RDruid, it's easiest to use the devtools package:

if (!require("devtools")) install.packages("devtools")
devtools::install_github("druid-io/RDruid")

Documentation

Package documentation
See our wiki for more documentation and examples.

Copy Link

Version

Version

0.2.3

License

Apache License (== 2.0)

Maintainer

Xavier Laut

Last Published

February 15th, 2017

Functions in RDruid (0.2.3)

druid.filter.not

Construct a `not' filter of the given filter

Constructs a count aggregator

Defines a reference to a Druid aggregation

druid.build.postaggregator

Creates a Druid post-aggregator

druid.build.aggregation

Construct an arbitrary Druid aggregator using the given parameters

druid.filter.or

Construct an `or' filter of the given filters

Creates a Druid dimension object

druid.filter.javascript

Construct a JavaScript filter for a given dimension

druid.filter.and

Construct an `and' filter of the given filters

Constructs a cardinality aggregator for the given Druid columns

druid.postagg.fieldAccess

Creates a fieldAccess post-aggregator

druid.having.or

Construct an `or' having of the given havingspecs

druid.postagg.arithmetic

Creates an arithmetic post-aggregator

druid.groupBytodf

Convert Druid groupBy query result to a data frame

druid.query.dataSources

Query Druid data sources

druid.having.not

Construct a `not' having of the given havingspec

druid.filter.regex

Construct a regex filter for a given dimension

druid.having.and

Construct an `and' having of the given havingspecs

druid.query.dimensions

Query data source dimensions

druid.postagg.constant

Creates a constant post-aggregator

druid.query.groupBy

druid.resulttodf

Converts JSON from Druid into a data frame

druid.query.segmentMetadata

Query segment metadata

druid.query.topN

Query to find the topN dimension values of a datasource

Construct the URL for a druid endpoint.

druid.query.timeseries

Query time series data

druid.query.timeBoundary

Query data source time boundaries

==.druid.aggregation

Construct an equalTo having clause for a given aggregation

==.druid.dimension

Construct a selector filter for a given dimension

druid.query.metrics

Query data source metrics

Construct an equalTo having clause of the given named arguments

%~%.druid.dimension

Construct a regex filter for a given dimension

Creates a fieldAccess post-aggregator

>=.druid.aggregation

Construct a greaterThan having clause for a given aggregation

Creates a Druid query granularity object

Convert an ISO 8601 string to a POSIXct object

Construct a regex filter

%=%.druid.dimension

Construct a selector filter for a given dimension

Constructs a hyperUnique aggregator over the given Druid metric

Construct a selector filter

calls toJSON with a default set of arguments

Constructs a JavaScript aggregator for the given Druid columns

Constructs a longSum aggregator over the given Druid metric

max.druid.metric

Constructs a max aggregator over the given Druid metric

<=.druid.aggregation

Construct a lessThan having clause for a given aggregation

longSum.druid.metric

Constructs a longSum aggregator over the given Druid metric

+.druid.postaggregator

Define a post-aggregator by adding aggregators, post-aggregators or constants

Defines a reference to a Druid metric

min.druid.metric

Constructs a min aggregator over the given Druid metric

Send a JSON query to Druid

sum.druid.metric

Constructs a doubleSum aggregator over the given Druid metric

Convert a list of objects to their ISO 8601 string representation

Convert a POSIX timestamp to its ISO 8601 string representation

sum.druid.postaggregator

Sum of Druid post-aggregators

R interface to Druid

Convert a Interval object to its ISO 8601 string representation

Convert an object to its ISO 8601 string representation

Rename aggregators based on their list name

Convert a POSIX* object to its ISO 8601 string representation

helper function to wrap constants in formulas

Construct a selector filter of the given named arguments

/.druid.postaggregator

Define a post-aggregator by dividing aggregators, post-aggregators or constants

toISO.character

toISO leaves strings as is without checking for ISO 8601 validity

*.druid.postaggregator

Define a post-aggregator by multiplying aggregators, post-aggregators or constants