The ParallelConnector Consumer-class can be used to parallelize the computations done by blocks directly connected to the ParallelConnector and all blocks down-stream to the ParallelConnector. i.e Computations performed by the block directly connected up-stream to the ParallelConnector and all blocks connected down-stream to the ParallelConnector in a stream happen simultaneously.
ParallelConnectorConsumer级,可用于直接连接到下游ParallelConnectorParallelConnector和所有块的块进行并行计算。即块进行计算,直接连接了到ParallelConnector和所有块连接下游流同时发生ParallelConnector。
参数:...
Additional arguments to be passed to the constructor.
额外的参数传递给构造。
参数:yieldSize
The number of records the input parser is to yield.
输入分析器的记录数是屈服。
参数:verbose
logical(1) indicating whether class methods should report to the user.
logical(1)类的方法是否应该报告给用户。
构造----------Constructors----------
Use ParallelConnector to construct instances of this class.
使用ParallelConnector建设这个类的实例。
领域----------Fields----------
.upstream: Object of class ANY. The output of a call to the parallel function from the multicore-package. This field is internal to the ParallelConnector class and will be populated by a call to the stream method or the connect function used to connect the ParallelConnector to other blocks in a
.upstream类ANY的对象。输出一个parallelmulticore包的功能调用。这一领域ParallelConnector类是内部的,将通过调用填充stream方法connect函数用于连接ParallelConnector在其它块
方法----------Methods----------
initialize(...): Initializes the fields of the
initialize(...):初始化的字段
yield(): Reads data from the child processes and converts the result (which must be a list of raw) into a vector of
yield():从子进程读取数据,并将其转换结果(必须是一个raw列表)成一个向量
finalize(): Collects results from the parallel processes and
finalize():收集从并行进程的结果,