Flow Functions

flow_call()

Implicit cache of a function and of the given call.

flow_dfg()

Group-wise caching of operations on data frame.

flow_dfr()

Row-wise caching of operations on data frame.

flow_file_source()

Creates a flow object that watches one or more files.

flow_fn()

Implicit cache of a function and of the given call.

flow_ns_sink()

Write a value to a namespace only if the value has changed.

default_flow_options() set_flow_options() get_flow_options()

flow options used to initialize or update an eddy.

make_flow_fn()

Explicit cache of a function.

collect(<R6Flow>) collect(<Element>)

Get the data from an R6Flow or an Element object.

element() `[`(<R6Flow>)

Extract an element from an R6Flow object.

is_flow()

Is the object a flow object or a flow element?

is_flow_fn()

Is the function a flow function (as returned by make_flow_fn)?

is_not_flow_fn()

Check if the function is NOT a flow function (as returned by make_flow_fn).

is_current()

Does the flow have a "current" state?

is_valid()

Is the current state valid (stored in the cache)?

Eddy Functions

delete_eddy()

Delete eddy and ALL its data from ALL cache layers (memory and/or disk).

get_current_eddy()

Get the current eddy for a given (or default) environment.

get_eddy()

Retrieves an eddy.

new_eddy()

Create a new eddy. Does not affect the current eddy.

set_current_eddy()

Set the current eddy to be used in future flow calls.

use_eddy()

Convenience function that creates a new eddy or re-uses it if present.

Cache Functions

cache_file()

Get the file only cache engine.

cache_memory()

Get the memory only cache engine.

cache_memory_file()

Get the memory-file cache engine.

default_cache()

Get the default cache engine.