Jeroen Rosenberg jeroenr
jeroenr
/ RainClutterPartitioner.scala
Last active
December 6, 2019 15:42
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.github.jeroenr.rain.radar | |
| import cloudflow.akkastream._ | |
| import cloudflow.akkastream.util.scaladsl._ | |
| import cloudflow.streamlets._ | |
| import cloudflow.streamlets.avro._ | |
| class RainClutterPartitioner extends AkkaStreamlet { | |
| val in = AvroInlet[PrecipitationData]("in") | |
| val clutter = AvroOutlet[Clutter]("clutter").withPartitioner(RoundRobinPartitioner) |
jeroenr
/ JsonFormats.scala
Last active
December 4, 2019 20:47
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.github.jeroenr.rain.radar | |
| import java.time.Instant | |
| import spray.json._ | |
| trait InstantJsonSupport extends DefaultJsonProtocol { | |
| implicit object InstantFormat extends JsonFormat[Instant] { | |
| def write(instant: Instant) = JsNumber(instant.toEpochMilli) |
jeroenr
/ PrecipitationDataHttpIngress.scala
Created
December 4, 2019 13:53
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.github.jeroenr.rain.radar | |
| import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._ | |
| import cloudflow.akkastream._ | |
| import cloudflow.akkastream.util.scaladsl._ | |
| import cloudflow.streamlets._ | |
| import cloudflow.streamlets.avro._ | |
| import com.github.jeroenr.rain.radar.PrecipitationDataJsonSupport._ | |
| class PrecipitationDataHttpIngress extends AkkaServerStreamlet { |
jeroenr
/ Clutter.avsc
Created
December 4, 2019 13:26
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "namespace": "com.github.jeroenr.rain.radar", | |
| "type": "record", | |
| "name": "Clutter", | |
| "fields":[ | |
| { | |
| "name": "timestamp", | |
| "type": { | |
| "type": "long", | |
| "logicalType": "timestamp-millis" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "namespace": "com.github.jeroenr.rain.radar", | |
| "type": "record", | |
| "name": "Rain", | |
| "fields":[ | |
| { | |
| "name": "timestamp", | |
| "type": { | |
| "type": "long", | |
| "logicalType": "timestamp-millis" |
jeroenr
/ Location.avsc
Created
December 4, 2019 13:24
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "namespace": "com.github.jeroenr.rain.radar", | |
| "type": "record", | |
| "name": "Location", | |
| "fields":[ | |
| { | |
| "name": "lat", "type": "double" | |
| }, | |
| { | |
| "name": "lng", "type": "double" |
jeroenr
/ PrecipitationData.avsc
Created
December 4, 2019 12:45
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "namespace": "com.github.jeroenr.rain.radar", | |
| "type": "record", | |
| "name": "PrecipitationData", | |
| "fields":[ | |
| { | |
| "name": "timestamp", | |
| "type": { | |
| "type": "long", | |
| "logicalType": "timestamp-millis" |
jeroenr
/ cloudflow-plugins.sbt
Created
December 4, 2019 12:30
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| resolvers += Resolver.url("lightbend-oss", url("https://lightbend.bintray.com/cloudflow"))(Resolver.ivyStylePatterns) | |
| resolvers += "Akka Snapshots" at "https://repo.akka.io/snapshots/" | |
| addSbtPlugin("com.lightbend.cloudflow" % "sbt-cloudflow" % "1.3.0-M1") |
jeroenr
/ pitfall_10_fix.java
Created
November 28, 2019 14:23
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| interface Service { | |
| Flux<String> observe(); | |
| Mono<Void> save(String s); | |
| } | |
| class Foo { | |
| private final Service service; | |
| void longRunningProblem() { | |
| service.observe() | |
| .flatMap(service::save, 10) |
jeroenr
/ pitfall_10.java
Last active
November 28, 2019 14:24
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| interface Service { | |
| Flux<String> observe(); | |
| Mono<Void> save(String s); | |
| } | |
| class Foo { | |
| private final Service service; | |
| void longRunningProblem() { | |
| service.observe() | |
| .flatMap(service::save, 10) |