Package: Streamer 1.53.0

Martin Morgan

Streamer: Enabling stream processing of large files

Large data files can be difficult to work with in R, where data generally resides in memory. This package encourages a style of programming where data is 'streamed' from disk into R via a `producer' and through a series of `consumers' that, typically reduce the original data to a manageable size. The package provides useful Producer and Consumer stream components for operations such as data input, sampling, indexing, and transformation; see package?Streamer for details.

Authors:Martin Morgan, Nishant Gopalakrishnan

Streamer_1.53.0.tar.gz
Streamer_1.53.0.zip(r-4.5)Streamer_1.53.0.zip(r-4.4)Streamer_1.53.0.zip(r-4.3)
Streamer_1.53.0.tgz(r-4.4-x86_64)Streamer_1.53.0.tgz(r-4.4-arm64)Streamer_1.53.0.tgz(r-4.3-x86_64)Streamer_1.53.0.tgz(r-4.3-arm64)
Streamer_1.53.0.tar.gz(r-4.5-noble)Streamer_1.53.0.tar.gz(r-4.4-noble)
Streamer_1.53.0.tgz(r-4.4-emscripten)Streamer_1.53.0.tgz(r-4.3-emscripten)
Streamer.pdf |Streamer.html
Streamer/json (API)

# Install 'Streamer' in R:
install.packages('Streamer', repos = c('https://bioc.r-universe.dev', 'https://cloud.r-project.org'))

Peer review:

On BioConductor:Streamer-1.53.0(bioc 3.21)Streamer-1.52.0(bioc 3.20)

This package does not link to any Github/Gitlab/R-forge repository. No issue tracker or development information is available.

infrastructuredataimport

3.30 score 2 scripts 258 downloads 1 mentions 27 exports 5 dependencies

Last updated 2 months agofrom:6658a0566b. Checks:OK: 1 NOTE: 8. Indexed: yes.

TargetResultDate
Doc / VignettesOKDec 19 2024
R-4.5-win-x86_64NOTEDec 19 2024
R-4.5-linux-x86_64NOTEDec 19 2024
R-4.4-win-x86_64NOTEDec 19 2024
R-4.4-mac-x86_64NOTEDec 19 2024
R-4.4-mac-aarch64NOTEDec 19 2024
R-4.3-win-x86_64NOTEDec 19 2024
R-4.3-mac-x86_64NOTEDec 19 2024
R-4.3-mac-aarch64NOTEDec 19 2024

Exports:close.ConnectionProducerDAGParamDAGTeamDownsampleFunctionConsumerFunctionProducerlapplyMulticoreParamplot.DAGParamplot.DAGTeamRawInputrawParserFactoryrawReaderFactoryRawToCharReadLinesProducerReadTableProducerReducerregisterresetRevsapplyScanProducerSeqstatusStreamTeamyield

Dependencies:BHBiocGenericsgenericsgraphRBGL

Streamer: A simple example

Rendered fromStreamer.Rnwusingutils::Sweaveon Dec 19 2024.

Last update: 2014-12-09
Started: 2013-11-01

Readme and manuals

Help Manual

Help pageTopics
Package to enable stream (iterative) processing of large dataStreamer-package Streamer Streamer-class
Producer classes to read file connectionsclose.ConnectionProducer ConnectionProducer ConnectionProducer-class ConnectionProducer-classes ReadLinesProducer ReadLinesProducer-class ReadTableProducer ReadTableProducer-class ScanProducer ScanProducer-class
Class defining methods for all consumersConsumer Consumer-class show,Consumer-method
Consumer classes for directed acyclic graph evaluationDAGParam DAGParam,data.frame-method DAGParam,graphNEL-method DAGParam,matrix-method DAGParam,missing-method DAGParam-class DAGTeam DAGTeam-class plot.DAGParam plot.DAGTeam
Consumer class to down-sample dataDownsample Downsample-class
Classes for user-defined Producers and ConsumersFunction* FunctionConsumer FunctionConsumer-class FunctionProducer FunctionProducer-class FunctionProducerConsumer-classes
Classes to configure parallel evaluationMulticoreParam MulticoreParam-class ParallelParam ParallelParam-class ParallelRegister-class register
Class defining methods for all Producerslapply,Producer-method Producer Producer-class sapply,Producer-method
Class "RawInput"RawInput RawInput-class rawParserFactory rawReaderFactory
Consumer class to combine successive recordsReducer Reducer-class
Function to reset a Stream, Producer, or Consumerreset reset,Streamer-method reset-methods
Producer class to generate (numeric) sequencesSeq Seq-class
Function to report current status of a streamstatus status,Streamer-method status-methods
Class to represent a Producer and zero or more Consumerslapply,Stream-method length,Stream-method sapply,Stream-method Stream Stream,Consumer-method Stream,Producer-method Stream-class Stream-methods [[,Stream,numeric-method
Consumer classes for parallel evaluationMulticoreTeam-class Team Team,missing-method Team,MulticoreParam-method Team-class
Consumer classes with simple functionality, e.g., RawToChar, RevRawToChar RawToChar-class Rev Rev-class Utility Utility-class Utility-classes
Function to yield one task from a Stream or Produceryield yield,Streamer-method yield-methods