Stream - (Software|Library)

Event Centric Thinking

About

Software, Library around the notion of stream

Distributed stream processing

Distributed stream processing frameworks such as:

IO - built-in streams

These streams are built into the application itself: IO - Standard streams (stdin, stdout, stderr)

Example

Node.js

Node.js stream uses the pipe function to connect the source to the destination

src.pipe(dst)

.pipe(dst) returns dst so that you can chain together multiple .pipe calls together:

a.pipe(b).pipe(c).pipe(d)

which is the same as:

a.pipe(b);
b.pipe(c);
c.pipe(d);

which is the same as with the shell command-line pipe:

a | b | c | d

Java

Java Stream (Map reduce implementation, only one source then)

int sum = widgets.stream()
                      .filter(b -> b.getColor() == RED)
                      .mapToInt(b -> b.getWeight())
                      .sum();

Implementation

Stream - Interface

Documentation / Reference





Discover More
Card Puncher Data Processing
Dos - Cmd (Command interpreter)

Cmd starts a new instance of the Windows command interpreter More info: The switches must be on one line but for the purpose of clarity we have put one switch by line. where: /Q turns echo off...
Javascript - Stream

substack/stream-handbook
Process States
Process - Inter Process Communication (IPC)

An Inter Process Communication (IPC) describes the fact that two or more processes exchange information. IPC is used not just for communication between processes on the same system, but also on different...
Event Centric Thinking
Stream - Processing

Stream processing is the reactive design of data processing. Something happened (Event), Subscribe to it (Streams) Streaming Processing is also known as : Incremental Processing. or reactive...



Share this page:
Follow us:
Task Runner