Errata

Stream Processing with Apache Spark

Errata for Stream Processing with Apache Spark

Submit your own errata for this product.

The errata list is a list of errors and their corrections that were found after the product was released.

The following errata were submitted by our customers and have not yet been approved or disproved by the author or editor. They solely represent the opinion of the customer.

Color Key: Serious technical mistake Minor technical mistake Language or formatting error Typo Question Note Update

Version Location Description Submitted by Date submitted
CH12
Example 12-1. Computing totalized averages under "Defining Time-Based Windows"

"Continuing with our weather station scenario, in Example 12-1 we can compute the average pressure each 10 minutes totalized across all reporting stations."

$>val perMinuteAvg = timeStampEvents
.withWatermak("timestamp", "5 minutes")
.groupBy(window($"timestamp", "1 minute"))
.agg(avg($"pressure"))


The explanation is for grouping aggregation of 10 minute window,whereas code example stating for 1 minute window aggregation.

Please correct the "average pressure each 10 minutes" to average pressure each 1 minute".

 Rajesh Santha  Jun 18, 2019 
Printed Page 4
3rd paragraph, 3rd line (overlap to 4th)

Sentence reads:

"[...] professional environments<m-
dash>televisions, [...]"

The m-dash tag did not format properly into an em dash.

 William Autrey  Jul 08, 2019 
Printed Page 6
8th paragraph, last two words.

Last line of the 8th paragraph reads:

"[...] might face delays, resource constriction, of failure".

The "of" should be an "or".

 William Autrey  Jul 08, 2019