Description Usage Arguments Examples
Run Kinesis Consumer application
1 2 | kineric(initialize, processRecords, shutdown, checkpointing = TRUE, updater,
logfile = tempfile())
|
initialize |
optional function to be run on startup. Please note that the variables created inside of this function will not be available to eg |
processRecords |
function to process records taking a |
shutdown |
optional function to be run when finished processing all records in a shard |
checkpointing |
if set to |
updater |
optional list of list(s) including frequency (in minutes) and function to be run, most likely to update some objects in the parent or global namespace populated first in the |
logfile |
file path of the log file. To disable logging, set |
1 2 3 4 5 6 7 8 9 10 | ## Not run:
flog.threshold(FATAL)
kineRic::kineric(
initialize = function() flog.info('Loading some data'),
processRecords = function(records) flog.info('Received some records from Kinesis'),
updater = list(list(1, function() flog.info('Updating some data every minute')),
list(1/60, function() flog.info('This is a high frequency updater call')))
)
## End(Not run)
|
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.