Data.Stream: Data.Stream

In frbl/OnlineSuperLearner: Online SuperLearner package

Description

Class to provide the functionality to read data from an input stream.

Usage

Data.Stream

Format

An object of class R6ClassGenerator of length 24.

Methods

initialize(kafka.host = 'imac.evionix.org:2181', kafka.stream = 'test')

This method is used to create object of this class. It expects a host for a kafka cluster (or the coordinating zookeeper therof) as input in the kafka.host. Secondly, it also expects the stream on the kafka host to listen on (kafka.stream. Warning! This function is currently not implemented due to difficulties with the kafka R package (it needs java and rjava, which causes problems on some systmes). Although implementation is not a difficult task, it is currently removed for compatibility reasons. One can recreate this function / class when needed. @param kafka.host the host address for the kafka stream @param kafka.stream the particular stream to read from

getNext()

Currently not implemented (see initialize for reasons) Returns the next observation from the stream @return one row of the dataframe the stream yields

getNextN(n=1)

Currently not implemented (see initialize for reasons) Returns the next n observations from the stream @return data.table a number of n rows concatenated in a data.table

getNext()

Method to retrieve the next observation from the stream.

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