Real-Time Stream Processing in Java

Ian Gray; Andrew John Wellings; Haitao Mei

Real-Time Stream Processing in Java

Ian Gray, Andrew John Wellings, Haitao Mei

Computer Science

Research output: Chapter in Book/Report/Conference proceeding › Conference contribution

Abstract

This paper presents a streaming data framework for the Real-Time Specification for Java, with the goal of levering as much as possible the Java 8 Stream processing framework whilst delivering bounded latency. Our approach is to buffer the incoming streaming data into micro batches which are then converted to collections for processing by the Java 8 infrastructure which is configured with a real-time ForkJoin thread pool. Deferrable servers are used to limit the impact of stream processing activity on hard real-time activities.

Original language	English
Title of host publication	21st Ada-Europe International Conference on Reliable Software Technologies, Ada-Europe 2016
Publisher	Springer
Pages	44-57
Number of pages	14
ISBN (Electronic)	978-3-319-39083-3
ISBN (Print)	978-3-319-39082-6
Publication status	Published - 31 May 2016

Publication series

Name	Lecture Notes in Computer Science

Access to Document

http://link.springer.com/chapter/10.1007%2F978-3-319-39083-3_4

Cite this

@inproceedings{7cb9ea24a01f4a31aea34031a7773e17,

title = "Real-Time Stream Processing in Java",

abstract = "This paper presents a streaming data framework for the Real-Time Specification for Java, with the goal of levering as much as possible the Java 8 Stream processing framework whilst delivering bounded latency. Our approach is to buffer the incoming streaming data into micro batches which are then converted to collections for processing by the Java 8 infrastructure which is configured with a real-time ForkJoin thread pool. Deferrable servers are used to limit the impact of stream processing activity on hard real-time activities.",

author = "Ian Gray and Wellings, {Andrew John} and Haitao Mei",

year = "2016",

month = may,

day = "31",

language = "English",

isbn = "978-3-319-39082-6",

series = " Lecture Notes in Computer Science",

publisher = "Springer",

pages = "44--57",

booktitle = "21st Ada-Europe International Conference on Reliable Software Technologies, Ada-Europe 2016",

address = "Germany",

}

TY - GEN

T1 - Real-Time Stream Processing in Java

AU - Gray, Ian

AU - Wellings, Andrew John

AU - Mei, Haitao

PY - 2016/5/31

Y1 - 2016/5/31

N2 - This paper presents a streaming data framework for the Real-Time Specification for Java, with the goal of levering as much as possible the Java 8 Stream processing framework whilst delivering bounded latency. Our approach is to buffer the incoming streaming data into micro batches which are then converted to collections for processing by the Java 8 infrastructure which is configured with a real-time ForkJoin thread pool. Deferrable servers are used to limit the impact of stream processing activity on hard real-time activities.

AB - This paper presents a streaming data framework for the Real-Time Specification for Java, with the goal of levering as much as possible the Java 8 Stream processing framework whilst delivering bounded latency. Our approach is to buffer the incoming streaming data into micro batches which are then converted to collections for processing by the Java 8 infrastructure which is configured with a real-time ForkJoin thread pool. Deferrable servers are used to limit the impact of stream processing activity on hard real-time activities.

M3 - Conference contribution

SN - 978-3-319-39082-6

T3 - Lecture Notes in Computer Science

SP - 44

EP - 57

BT - 21st Ada-Europe International Conference on Reliable Software Technologies, Ada-Europe 2016

PB - Springer

ER -