zhangtengjiao Goto Github PK

alink

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

demo_11.11_storm-spark-hadoop

hadoop_storm_spark结合实验的例子，模拟淘宝双11节，根据订单详细信息，汇总出总销售量，各个省份销售排行，以及后期的SQL分析，数据分析，数据挖掘等。 --------大概流程------- 第一阶段（storm实时报表） 第二阶段（离线报表）第三阶段（大规模订单即席查询,和多维度查询） 第四阶段（数据挖掘和图计算）

docker-flume

flink-recommandsystem-demo

:helicopter::rocket:基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。

flink-sql-demo

Demo: Build End-to-End Streaming Application using Flink SQL

flink-sql-submit

A simple project used to submit a Flink SQL script

flinksql

仿照阿里blink使用sql开发flink的实时程序

flinkstreamsql

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法

kafka-storm-starter

Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

kafkautils

kafka utils

kops

Kubernetes Operations (kops) - Production Grade K8s Installation, Upgrades, and Management

kubernetes

Production-Grade Container Scheduling and Management

repo1

resources

给大家的资料以后就放置在这个项目下了；希望能有帮助。

spark-util

:boom: :rocket: 封装spark读取kafka，sparkstreaming动态调节batch time；封装sparkstreaming 1.6 - kafka 010 用以支持 SSL；封装spark与其他组件;

spark_streaming_kafka_offset

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

sparkstreaming

Spark Streaming+Flume+Kafka+HBase+Hadoop+Zookeeper实现实时日志分析统计；SpringBoot+Echarts实现数据可视化展示

storm-contrib

A collection of spouts, bolts, serializers, DSLs, and other goodies to use with Storm

storm-documents

Apache Storm 官方文档译文