Data.Stream.Simulator: Data.Stream.Simulator

In frbl/OnlineSuperLearner: Online SuperLearner package

Description

Class that serves as a very basic simulator to fill a kafka stream with data.

Usage

Data.Stream.Simulator

Format

An object of class R6ClassGenerator of length 24.

Methods

new(kafka.host = 'imac.evionix.org:9092', kafka.stream = 'test', simulator.continuous = Simulator.Simple$new(), sleep = 1, iterations = Inf)

This method is used to create object of this class. It expects a host for a kafka cluster as input in the kafka.host, to which it can push the data. Secondly, it expects the stream on the kafka host to listen on (kafka.stream), then it needs a simulator from which it can retrieve messages to push to the stream, and lastly, between each observation it will sleep for sleep number of seconds. Note that this function is currently not implemented due to the fact that kafka streaming has been removed for compatibility reasons.

frbl/OnlineSuperLearner documentation built on Feb. 9, 2020, 9:28 p.m.