Plasma Flux

A dataflow framework based on RxJava with a "Pipes and Filters" abstraction for multi-stage flows, composed of heterogeneous types and transformations of data

License

License

Plasma License
Categories

Categories

ASM Application Layer Libs Bytecode Manipulation
GroupId

GroupId

org.terrameta
ArtifactId

ArtifactId

plasma-flux
Last Version

Last Version

1.0.0
Release Date

Release Date

Type

Type

jar
Description

Description

Plasma Flux
A dataflow framework based on RxJava with a "Pipes and Filters" abstraction for multi-stage flows, composed of heterogeneous types and transformations of data
Source Code Management

Source Code Management

https://github.com/plasma-framework/plasma-flux

Download plasma-flux

How to add to project

<!-- https://jarcasting.com/artifacts/org.terrameta/plasma-flux/ -->
<dependency>
    <groupId>org.terrameta</groupId>
    <artifactId>plasma-flux</artifactId>
    <version>1.0.0</version>
</dependency>
// https://jarcasting.com/artifacts/org.terrameta/plasma-flux/
implementation 'org.terrameta:plasma-flux:1.0.0'
// https://jarcasting.com/artifacts/org.terrameta/plasma-flux/
implementation ("org.terrameta:plasma-flux:1.0.0")
'org.terrameta:plasma-flux:jar:1.0.0'
<dependency org="org.terrameta" name="plasma-flux" rev="1.0.0">
  <artifact name="plasma-flux" type="jar" />
</dependency>
@Grapes(
@Grab(group='org.terrameta', module='plasma-flux', version='1.0.0')
)
libraryDependencies += "org.terrameta" % "plasma-flux" % "1.0.0"
[org.terrameta/plasma-flux "1.0.0"]

Dependencies

compile (3)

Group / Artifact Type Version
log4j : log4j jar 1.2.9
commons-logging : commons-logging jar 1.1.1
io.reactivex.rxjava2 : rxjava jar 2.0.5

test (2)

Group / Artifact Type Version
junit : junit jar 4.12
org.testng : testng jar 6.9.8

Project Modules

There are no modules declared in this project.

plasma-flux

A dataflow framework based on RxJava with a "Pipes and Filters" abstraction facilitating multi-stage flows composed of heterogeneous types and transformations of data. RxJava alone is generally sufficient for composition of simple and some complex data flows. But when heterogeneous types of data along with various transformations and filters, and multiple threading or concurrent contexts are involved, pure RxJava functional expressions become cumbersome. Such complex multi-stage data flows typcially form large "tree", network or graph structures which are often found in execution engines, such as database (physical) operator execution.

Plasma Flux is a generic framework with does not prescribe the type(s) of data which compose a flow, but facilitates composition of complex flows using a "Pipes and Filters" abstraction where verious Producer and Consumer elements are linked through "Pipe" elements.

Versions

Version
1.0.0