本文主要介绍如何将Flink以本地模式运行在单机上。 下载 进入下载页面。如果你想让Flink与Hadoop进行交互(如HDFS或者HBase),请选择一个与你的Hadoop版本相匹配的Flink包。当你不确定或者只是想运行在本地文件系统上,请选择Hadoop 1.2.x对...

Continue reading

记一道C++题

in C++ read (794)

上学的时候就没好好学C++,之前有个学弟求助,帮忙做了一道题,运算符重载,友元函数什么的都忘了,得会有万能的百度 题目如下 代码: #include <iostream> #include <stdlib.h> using namespace s...

Continue reading

JAVA常用类

in Java read (759)

基本数据类型的包装类(Wrapper Class) 为什么需要包装类 Java并不是纯面向对象的语言.Java语言是一个面型对象的语言,但是Java中基本数据类型确实不面向对象的.但实际应用中经常需要将基本数据类型转化成对象,便于操作.比如:集合的操作中我们就需要将基本数据...

Continue reading

Fastjson为什么这么快?

in Java read (868)

一、Fastjson中Serialzie的优化实现 1、自行编写类似StringBuilder的工具类SerializeWriter 把java对象序列化成json文本,是不可能使用字符串直接拼接的,因为这样性能很差。比字符串拼接更好的办法是使用java.lang.Stri...

Continue reading

ZooKeeper数据模型与层次命名空间 树状结构 通过/分隔开路径名 每个路径代表一个节点Znode(zookeeper node) Znode 每个Znode有自身信息,数据、长度、创建时间、修改时间。 Znode维护数据、ACL(access contr...

Continue reading

Flink DataStream API

in Flink read (820)

Map 输入一个元素,输出一个元素 DataStream → DataStream DataStream<Integer> dataStream = //... dataStream.map(new MapFunction<Integer, Integer...

Continue reading

Zookeeper 简介(一)

in ZooKeeper read (792)

zookeeper是什么 官方说:Zookeeper 分布式服务框架是Apache Hadoop 的一个子项目,它主要是用来解决分布式应用中经常遇到的一些数据管理问题,如:统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等 zookeeper提供了什么 简单的说...

Continue reading

Matrix42

Record and Share!