part 1 建立DataStream类 package com.huaqin.hat; /** * creator:perfe wang * time:2016/6/28 * description:数据类，特用于json解析和打包，属性为json对象的key，属性值为json的内部类 * 其内部 ...
分类：
Web程序 时间：
2016-06-28 20:20:46
阅读次数：
356
Flink DataStream Join CoGroup scala...
分类：
其他好文 时间：
2016-06-24 15:14:13
阅读次数：
547
Flink DataStream EventTime...
分类：
Windows程序 时间：
2016-06-17 17:22:28
阅读次数：
1374
之前我们聊了Flink程序的source、sink就差transformation了。今天我们就来解读一下Flink的transformation。它们三者的关系如下图：当然这还是从Flink编程API的角度来看的（编程视角）。所谓的transformation，用于转换一个或多个DataStream从而形成一个新的DataStream对象。...
分类：
Web程序 时间：
2016-05-15 12:40:02
阅读次数：
274
网易视频云是网易倾力打造的一款基于云计算的分布式多媒体处理集群和专业音视频技术，提供稳定流畅、低时延、高并发的视频直播、录制、存储、转码及点播等音视频的PAAS服务，在线教育、远程医疗、娱乐秀场、在线金融等各行业及企业用户只需经过简单的开发即可打造在线音视频平台。现在，网易视频云的技术专家给大家分享一则技术文：HBase优化实战。
背景
Datastream一直以来在使用HBase...
分类：
其他好文 时间：
2016-05-11 23:54:41
阅读次数：
270
Example Program The following program is a complete, working example of streaming window word count application, that counts the words coming from a w... ...
官方文档参数解释：http://flume.apache.org/FlumeUserGuide.html#hdfs-sink需要注意：文件格式，fileType=DataStream 默认为SequenceFile，是hadoop的文件格式，改为DataStream就可直接读了（SqeuenceFi...
分类：
Web程序 时间：
2015-11-23 21:54:39
阅读次数：
225
一、对象序列化1.1、对象序列化被操作的对象需要实现Serializable接口1.2、对象序列化流ObjectOutputStream与ObjectInputStreamObjectInputStream 对以前使用 ObjectOutputStream 写入的基本数据和对象进行反序列化。Obje...
分类：
数据库 时间：
2015-10-14 00:07:27
阅读次数：
408
转载需注明出处：http://blog.csdn.net/minimicall，http://cloudtrade.top
我们之前说明了数据读者，数据槽。将数据读取到队列中，在算法主线程中需要使用DataFeed线程的数据。这是一个典型的读者-写着问题。
在主线程中和DataFeed打教导的事DataStream。下面我们看它的代码。说明在注释中说明了。
/*
* QUANTCONNEC...
分类：
其他好文 时间：
2015-06-21 02:06:51
阅读次数：
250
本文通过大量的示例，介绍和讲解了Java File操作。
1）创建文件 2）删除文件 3）判断文件是否存在 4）创建文件夹 5）文件类型判断 6）获取文件信息
7）获取目录下文件名 8）递归打印所有文件名 9）递归删除整个文件夹 10）Properties类
11）SequenceInputStream类：连接多个流 12）对象序列化实现Serializable接口 13）管道流
14）RandomAccessFile类 15）DataStream类 16)ByteArrayStr...
分类：
编程语言 时间：
2014-11-21 21:55:27
阅读次数：
288
