# flink

**Repository Path**: athletic/flink

## Basic Information

- **Project Name**: flink
- **Description**: java实现flink数据计算的工程代码
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 7
- **Created**: 2020-06-25
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# flink任务工程范例

#### Description
java实现flink数据计算的工程代码

#### 开发环境安装
1. 启动flink
    ````
    ./bin/start-cluster.sh
    ````
1. 停止flink
    ````
    ./bin/stop-cluster.sh
    ````
1. 在mac安装kafka    
    ````
    brew install kafka
    ````
1. 启动zookeeper
    ````
    zkServer start
    ````
1. 启动kafka
    ````
    nohup kafka-server-start /usr/local/etc/kafka/server.properties &
    ````
#### 基础架构

1. flink任务调度策略
![flink 任务调度策略](document/pic03.png "flink任务调度策略")
1. flink计算层次模型
![flink 计算模型](document/pic02.png "flink计算模型")
1. flink任务基本编程架构
![flink任务基本编程架构](document/pic04.png "flink任务基本编程架构")
1. flink并行任务执行链
![flink并行任务执行链](document/pic05.png "flink并行任务执行链")
1. java实现flink任务的工程模板架构
![整体架构图](document/pic01.png "整体架构图")