reactive machine learning and functional programming

Reactive Machine Learning & Functional Programming

Problem

Machine Learning

Reactive Systems

Responsive

Resilient Elastic

Message-Driven

Responsive

Resilient

Elastic

Message-Driven

Responsive

Resilient Elastic

Message-Driven

ReplicationIsolation/

ContainmentSupervision/

Delegation

Replication

Isolation/Containment

Supervision/Delegation

ReplicationIsolation/

ContainmentSupervision/

Delegation

Example

Data Collection Events

Data Collection Events

Data Collection Events

Data Collection Events

Data Collection Events

Functional Transformations

Functional Transformations

Functional Transformations

Functional Transformations

Functional Transformations

Responsive

Resilient Elastic

Message-Driven

ReplicationIsolation/

ContainmentSupervision/

Delegation

Mario Pipelines

Mario Pipelines

Mario Pipelines

Default Models

Default Models

Default Models

Default Models

Default Models

Models as Pure Functions

Models as Pure Functions

Models as Pure Functions

Models as Pure Functions

Models as Pure Functions

Models as Pure Functions

Modeling Events

Modeling Events

Model Supervisor

Model Supervisor

Model Supervisor

French Bulldog Model

Model Supervisor

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

No one likes dogs!

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

No one likes dogs!

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

Model Supervisor

Lapdog Model

French Bulldog Model

Model Supervisor

No one likes dogs!

Lapdog Model

French Bulldog Model

Model Supervisor

No one likes dogs!

Greek Chorus Architecture

Reactive Machine Learning & Functional Programming

Responsive

Resilient Elastic

Message-Driven

ReplicationIsolation/

ContainmentSupervision/

Delegation

Results

reactivemachinelearning.com @jeffksmithjr

Resources• Reactive Persistence Interaction

• http://reactivemongo.org/

• http://websudos.github.io/phantom/

• https://github.com/softwaremill/reactive-kafka

Resources• Spark Pipelines

• https://github.com/intentmedia/mario

• http://blogs.aws.amazon.com/bigdata/post/Tx21LOP0UQ2ZA9N/Large-Scale-Machine-Learning-with-Spark-on-Amazon-EMR

• Reactive Microservices

• https://www.typesafe.com/activator/template/akka-http-microservice

Appendix

Service Hierarchy

Model Routing