liyonghui160com
- 浏览: 775567 次
- 性别:
- 来自: 北京
-
最新评论
-
liyonghui160com：
RAYFUXK 写道您好，我最近也在使用Canal，但是遇到了 ...
canal使用配置详解 -
xinglianxlxl：
订阅发布对我有用
redis-2.8.13 jedis实现订阅发布-publish/subscribe -
liyonghui160com：
这个不能按照一条一条的读取数据。使用需要完善。
flume文件监控的source，支持断点续传功能 -
RAYFUXK：
您好，我最近也在使用Canal，但是遇到了一个问题。ERROR ...
canal使用配置详解 -
yicong：
非常感谢！发现github里面的log4net版本太 ...
Zookeeper .Net客户端代码
文章列表
自定义数据流组你可以通过实现backtype.storm.grouping.CustormStreamGrouping接口创建自定义数据流组，让你自己决定哪些bolt接收哪些元组。让我们修改单词计数器示例，使首字母相同的单词由同一个bolt接收。
public class ModuleGrouping mplents CustormStreamGrouping, Serializable{
int numTasks = 0;
@Override
public List<Integer> chooseTasks(L ...
实现了滑动窗口计数和TopN排序, 比较有意思, 具体分析一下代码Topology这是一个稍微复杂些的topology, 主要体现在使用不同的grouping方式, fieldsGrouping和globalGrouping
String spoutId = "wordGenerator";
String counterId = "counter";
...
作为storm的使用者，有两件事情要做以更好的利用storm的可靠性特征。 首先，在你生成一个新的tuple的时候要通知storm; 其次，完成处理一个tuple之后要通知storm。 这样storm就可以检测整个tuple树有没有完成处理，并且通知源spo ...
Java提供了线程类Thread来创建多线程的程序。其实，创建线程与创建普通的类的对象的操作是一样的，而线程就是Thread类或其子类的实例对象。每个Thread对象描述了一个单独的线程。要产生一个线程，有两种方法：◆需要从Java.lang.Thread类派生一个新的线程类，重载它的run()方法；◆实现Runnalbe接口，重载Runnalbe接口中的run()方法。在Java中，类仅支持单继承，也就是说，当定义一个新的类的时候，它只能扩展一个外部类.这样，如果创建自定义线程类的时候是通过扩展 Thread类的方法来实现的，那么这个自定义类就不能再去扩展其他的类，也就无法实现更加复杂 ...
MySQL 赋予用户权限命令的简单格式可概括为：grant 权限 on 数据库对象 to 用户grant 权限 on 数据库对象 to 用户 identified by "密码" ＝＝＝＝＝＝＝＝用户及权限管理：最常用操作实例＝＝＝＝＝＝＝＝(用户名：dba1,密码： ...
1， 安装准备 1.1 下载zookeeper1.2 安装jdk : 我的是jdk-1.6.0_141.3 系统： linux :centos-141.4 hadoop安装配置： 192.168.201.128 namenode 192.168.201.131 datanode 192.168.201.132 datanode 2，操作步骤2.1 复制以上文件到/usr/下2.2 解压后得到 ...
把文件所有者改指定用户:chown -R 用户名.组名 目录
常用方法如下： sudo chmod 600 ××× （只有所有者有读和写的权限） sudo chmod 644 ××× （所有者有读和写的权限，组用户只有读的权限） sudo chmod 700 ××× （只有所有者有读和写以及执行的权限） sudo chmod 666 ××× （每个人都有读和写的权限） sudo chmod 777 ××× （每个人都有读和写以及执行的权限） 其中×××指文件名（也可以是文件夹名，不过要在chmod后加-ld）。 解释一下，其实整个命令的形式是 sudo chmod -（代表类型）×××（所有者）×××（组用户）×××（其他用户） 三位数的每一 ...
LINUX下用用apt-get方法安装mysql5安装：sudo apt-get install mysql-server安装上mysql5我们刚安装上的MYSQL，只有一个系统默认的root用户，而且是没有密码的，此时我们一定要给MYSQL设置一个密码root。终端下输入：mysql -u root -pmysql> enter password: rootmysql>/q 退出mysqlmysql默认端口为3306本人得到的经验是：MYSQL安成功后，一定要先给它设个密码，这上步是不可少的。安装后使用mysql发现127.0.0.1可以连通数据库，远程连接不上mysql服务器。本 ...
Ubuntu防火墙 UFW 设置1.安装sudo apt-get install ufw2.启用sudo ufw enablesudo ufw default deny运行以上两条命令后，开启了防火墙，并在系统启动时自动开启。关闭所有外部对本机的访问，但本机访问外部正常。3.开启/禁用sudo ufw allow|deny [service]打开或关闭某个端口，例如：sudo ufw allow smtp 允许所有的外部IP访问本机的25/tcp (smtp)端口sudo ufw allow 22/tcp 允许所有的外部IP访问本机的22/tcp (ssh)端口sudo ufw allow 53 ...
默认只安装了客户端，服务端要自己安装
Ubuntu 下安装 OpenSSH Server需要的命令只有一条：sudo apt-get install openssh-server然后确认sshserver是否启动了：ps -e | grep ssh如果只有ssh-agent那ssh-server还没有启动，需要/etc/init.d/ssh start，如果看到sshd那说明ssh-server已经启动了。ssh-server配置文件位于/ etc/ssh/sshd_config，在这里可以定义SSH的服务端口，默认端口是22，你可以自己定义成其他端口号，如222。然后重启SSH ...
到 Sun 的官网下载http://www.oracle.com/technetwork/java/javase/downloads/jdk7-downloads-1880260.html 选择 accept license ，然后选择适合自己机型的JDK下载。解压文件，修改文件名$ sudo mkdir /usr/lib/jvm
$ sudo tar zxvf jdk-7u21-linux-i586.tar.gz -C /usr/lib/jvm
$ cd /usr/lib/jvm
$ sudo mv jdk1.7.0_21 java添加环境变量$ sudo vim ~/.bashr ...
讲述一下如何使用Thrift搭建C#版的客户端以及服务端通讯的程序
1. 先从官网下载Thrift安装包以及签出SVN源码：
官网下载地址：http://thrift.apache.org/download/
这里我下载了一个Thrift compiler for Windows版本的EXE文件(thrift-0.7.0.exe) ...
记录下以后使用方便进行java开发，首先要安装jdk，安装了jdk后还要进行环境变量配置：1、下载jdk（http://java.sun.com/javase/downloads/index.jsp），我下载的版本是：jdk-6u14-windows-i586.exe2、安装jdk-6u14-windows-i586.exe3、配置环境变量：右击“我的电脑”-->"高级"-->"环境变量"1）在系统变量里新建JAVA_HOME变量，变量值为：C:\Program Files\Java\jdk1.6.0_14（根据自己的安装路径填写）2） ...
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;namespace WinShowDown{ public partial class FrmMain : Form { public FrmMain() { Initial ...