online-offline-arc-traing

Sampled Predictions

Elasticsearch

DynamoDB Model Repo

Deploy

OFFLINE

DynamoDB Feature Score

Preprocessing Engine

Business Micro Service

Hive/Hbase

System Metrics System／Tensorflow-Dashboard

Kinese

Hive／Elasticsearch

Trained Model

OutComes（Training Set）

Presto job／Airflow Job／Linux Cron／Spark

Training Algorithm

Performance Monitor（Tensorflow-Dashborad On Spark）

ONLINE

Streaming／Flink Engine

RealTime Predict Service

Batch Predict Service（Tensorflow-Spark）

Preprocessing Job

（Data Lake）MySql

Predictions

Batch Traing Job

Metrics