Spark应用开发实践性非常强,很多时候可能都会将时间花费在环境的搭建和运行上,如果有一个比较好的指导将会大大的缩短应用开发流程。
本篇主要讲述如何运行KafkaWordCount,这个需要涉及Kafka集群的搭建,还是说越仔细越好。
分类:
其他好文 时间:
2014-08-02 23:13:04
阅读次数:
267
将一些不重要的服务迁移到云服务上,有些下载什么的,为了防止带宽超了,python做了一个监控程序。用python3写的,由于和python2有些区别,特记录下来备查。代码如下:#this is for monitor qingcloud# coding=utf-8import base64impor...
分类:
编程语言 时间:
2014-08-02 20:41:13
阅读次数:
243
1.1 ColorTransform对RGB数值的操作及应用 flash.geom.ColorTransform是Flash内置的一个色彩变换类。它支持色彩通道值的线性变换。 所谓线性变换,是指一次函数模式的变换:dst = src * multiplier + offset。您可以将每个通道的值与...
分类:
其他好文 时间:
2014-08-02 18:09:43
阅读次数:
405
mmap() 和 munmap() - Unix的系统函数,更贴近底层 void* mmap(void* addr,size_t size,int prot,int flags, int fd, off_t offset) 参数addr可以指定映射的首地址,一般为0 交给内核指定。 size 就是分...
分类:
其他好文 时间:
2014-08-01 19:18:52
阅读次数:
206
openfire 访问 user service 插件 访问不到安照说明文档,我访问创建用户的url 如下http://127.0.0.1:9090/plugins/userservice/userservice?type=add&secret=bigsecret&username=kafka&pa...
分类:
其他好文 时间:
2014-08-01 10:46:01
阅读次数:
152
Kafka集群配置比较简单,为了更好的让大家理解,在这里要分别介绍下面三种配置
单节点:一个broker的集群单节点:多个broker的集群多节点:多broker集群
一、单节点单broker实例的配置
1.首先启动zookeeper服务
Kafka提供了一个简单的zookeeper配置文件来帮助启动zookeeper实例,用下面这个命令即可,首先进入Kafka的安装...
分类:
其他好文 时间:
2014-07-31 20:59:27
阅读次数:
334
(构造函数必须new出来)
* public String (char[] vaue) 将一个字符数组变成字符串(构造函数)
* public String (char[] vaue,int offset,int count) 将制定范围内的字符数组变为字符串(构造函数)
* public String (byte[],bytes)...
分类:
编程语言 时间:
2014-07-31 20:58:47
阅读次数:
207
#!/bin/shtraffic=10rm -rf test.txtdata=`sqlplus -S anoscfg/anoscfg <<EOFspool test.txtset pages 0 set feed offset heading off;set feedback off;set ve....
分类:
数据库 时间:
2014-07-31 16:14:46
阅读次数:
275
昨天写 Scala 的时候,使用 match(相当于 switch)时,运行结果很奇怪。var i: Int = 0while (i println("offset: " + items(i)) case logSize => println("logSize: " + items(i)) c...
分类:
其他好文 时间:
2014-07-31 12:11:36
阅读次数:
219
对于多线程共享资源的情况需要进行同步,以避免一个线程的改动被另一个线程的改动所覆盖。最普遍的同步方式就是synchronized。把代码声明为synchronized,有两个重要后果,通常是指该代码具有 原子性(atomicity)和 可见性(visibility)。
1、原子性强调的是执行,意味着个时刻,只有一个线程能够执行一段代码,这段代码通过一个monitor object保护。从而防止多...
分类:
编程语言 时间:
2014-07-30 01:03:12
阅读次数:
311