vianel
/ catalog.json
Created
June 28, 2021 18:46
This file contains 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
| { | |
| "streams": [ | |
| { | |
| "stream": "beers", | |
| "tap_stream_id": "beers", | |
| "schema": { | |
| "type": "object", | |
| "properties": { | |
| "beer_event_id": { | |
| "type": [ |
This file contains 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
| from matplotlib import cm #For the colors | |
| import numpy as np | |
| import matplotlib.pyplot as plt | |
| def f(x,y): | |
| return x**2 + y**2 | |
| def derivate(point_with_increment, point, h): | |
| return (f(point_with_increment[0], point_with_increment[1]) - f(point[0], point[1])) / h |
vianel
/ MapSourceToFlow.scala
Created
August 8, 2018 02:48
Simple sample how to connect a Flow to Source and keep going the stream using Akka Stream
This file contains 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 main | |
| import akka.actor.ActorSystem | |
| import akka.stream.{ActorMaterializer, ClosedShape} | |
| import akka.stream.scaladsl.{Flow, GraphDSL, RunnableGraph, Sink, Source} | |
| import GraphDSL.Implicits._ | |
| import com.typesafe.config.{ Config, ConfigFactory } | |
| object SrcToFlow extends App { |