DataKernel: DataStreams

Composable asynchronous/reactive streams with powerful data processing capabilities.

License

License

Categories

Categories

Data
GroupId

GroupId

io.datakernel
ArtifactId

ArtifactId

datakernel-datastreams
Last Version

Last Version

2.5.13
Release Date

Release Date

Type

Type

jar
Description

Description

DataKernel: DataStreams
Composable asynchronous/reactive streams with powerful data processing capabilities.
Project URL

Project URL

http://datakernel.io/datakernel-datastreams/

Download datakernel-datastreams

How to add to project

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

Dependencies

compile (5)

Group / Artifact Type Version
io.datakernel : datakernel-eventloop jar 2.5.13
io.datakernel : datakernel-serializer jar 2.5.13
com.google.code.gson : gson Optional jar 2.8.1
net.jpountz.lz4 : lz4 Optional jar 1.3.0
org.slf4j : slf4j-api jar 1.7.12

test (4)

Group / Artifact Type Version
io.datakernel : datakernel-test jar 2.5.13
junit : junit jar 4.12
ch.qos.logback : logback-classic jar 1.1.3
org.jmock : jmock-junit4 jar 2.8.1

Project Modules

There are no modules declared in this project.

Maven Central Apache license Twitter

Project status

Please note that DataKernel framework was massively improved and restructured into a new project named ActiveJ. Now it's even more streamlined, convenient, and powerful! We highly recommend you to migrate to ActiveJ.

Introduction

DataKernel is a full-featured alternative web and big data Java framework built from the ground up. It does not use Netty, Jetty, Spring/Guice DI, RxJava, etc. Instead, it features a full application stack: Event Loop, Promises, HTTP, DI, and others, including decentralized big-data technologies and map-reduce algorithms.

No overhead of intermediate abstractions, legacy standards and third-party libraries makes the framework minimalistic, streamlined and lightning-fast!

Getting started

Just insert this snippet to your terminal...

mvn archetype:generate -DarchetypeGroupId=io.datakernel -DarchetypeArtifactId=archetype-http -DarchetypeVersion=3.1.0

... and open project in your favourite IDE. Then, build the application and run it. Open your browser on localhost:8080 to see the "Hello World" message.

To learn more about DataKernel, visit datakernel.io or follow our 5-minute getting-started guide.

Examples

Basic HTTP server in less than 15 lines of code:

public final class HelloWorldExample { 
    public static void main(String[] args) throws IOException {
        Eventloop eventloop = Eventloop.create();
        AsyncHttpServer server = AsyncHttpServer.create(eventloop,
                request -> Promise.of(
                        HttpResponse.ok200()
                                .withPlainText("Hello, World!")))
                .withListenPort(8080);
        server.listen();
        eventloop.run();
    }
}

AsyncHttpServer is a built-in implementation of an HTTP server that runs asynchronously in a Node.js-inspired Event Loop.

Full-featured embedded web application server with Dependency Injection:

public final class HttpHelloWorldExample extends HttpServerLauncher { 
    @Provides
    AsyncServlet servlet() { 
        return request -> HttpResponse.ok200().withPlainText("Hello, World!");
    }

    public static void main(String[] args) throws Exception {
        Launcher launcher = new HttpHelloWorldExample();
        launcher.launch(args); 
    }
}

HttpServerLauncher - a predefined DataKernel Launcher that takes care of the application lifecycle and provides needed components for our server

@Provides - one of the DataKernel DI annotations

AsyncServlet - asynchronous servlet interface

Promise - Node.js-inspired async single-threaded Promises, an alternative to CompletableFuture

  • The JAR file size of this example is only 1.4 MB. In comparison, minimal Spring web app size is 17 MB
  • This example utilizes quite a few components - Eventloop, DI, Promise, HTTP, Launcher. Yet, it builds and starts in 0.65 sec.
  • DataKernel DI is 5.5 times faster than Guice and 100s times faster than Spring.
  • DataKernel Promise is 7 times faster than Java CompletableFuture.

Lightning-fast RPC server:

public RpcServer rpcServer(Eventloop eventloop) {
    return RpcServer.create(eventloop)
            .withStreamProtocol(...)
            .withMessageTypes(Integer.class)
            .withHandler(Integer.class, Integer.class, req -> Promise.of(req * 2));
}
  • This RPC server handles up to 15M requests per second on a single CPU core.

Documentation

See the docs, examples, and tutorials on our website.

Need help or found a bug?

Feel free to open a GitHub issue.

Communication

io.datakernel

SoftIndex, LLC

Versions

Version
2.5.13
2.5.12
2.5.11
2.5.10