Flink 编程练习 1

基于Flink框架的数据处理实践，以纽约市出租车出行记录为分析对象

环境配置

本项目参考这里，setup。

首要步骤是确认已正确安装flink相关依赖，并从Github获取代码。

获取所需依赖数据，本次所用数据为纽约出租车数据集，可通过命令行工具完成下载：

    wget http://training.data-artisans.com/trainingData/nycTaxiRides.gz

    wget http://training.data-artisans.com/trainingData/nycTaxiFares.gz
    
    

鉴于本项目采用Java进行编译，而源代码文件为Scala编写，为避免因Scala语法引发的错误提示，此处需明确配置对应的Scala SDK。

![54449085480](http://wx2.sinaimg.cn/mw690/006