9 一流小风一

尚未进行身份认证

我要认证

凛冬将至!

等级
TA的排名 6w+

读hbase的region简单程序--67

import java.util.List;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HRegionInfo;import org.apache.hadoop.hbase.clien

2016-07-18 02:29:47

简单的hbase监控程序,用于监测hbase集群是否正常运行--66

package moniter;import java.io.IOException;public class hbasemoniter_new { public final static String url = "tcp://dsdfsd/sdfs"; // public static String config = null; // public static String s

2016-07-18 02:25:10

一些hadoop脚本用于hbase(mvn)--65

1.扫表#!/bin/bashsource /etc/profileif [ $# -ne 3 ];then echo "scan.sh table start end" exit 1fihadoop fs -rm -r /home/hbase/checker/a_$1hadoop jar ./hbase.aa-0.1.jar hbase.TabelScan -Dmapred

2016-07-18 02:13:56

一些hadoop脚本事例--64

1.用于启动jar包读hbase表数据到hdfs#!/bin/bashsource /etc/profileif [ $# -ne 1 ];then echo "aaa.sh table" exit 1fitable=$1hadoop fs -rm -r /user/ads/hbase_tests/$tablehadoop jar ./aasss.jar hbase.hfi

2016-07-18 02:09:31

Hbasebulkload方法--63

1.import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.Path;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.KeyValue;import org.apache.hadoop.h

2016-07-14 02:37:32

实用生成md5方法--62

/* *简单生成md5方法*/import java.security.MessageDigest;public class Utils { private static char hexDigits[] = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };

2016-07-14 02:18:34

Hbase练习事例--61

1.以前写的一些功能函数方法:public class dtest_test { public final static String url = "tcp://test_test"; @SuppressWarnings("deprecation") public static void main(String[] args) throws Exception { IHbas

2016-07-13 02:55:44

Hbase事例基本方法--60

package llf.com;import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.Path;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoo

2016-07-12 01:37:57

Hbase_shell底层源码乱砍乱伐--59

大约10个月没有更新博客了,一直在学习新的东西,忙的不可开胶,现在一边整理做过的事情,以便复习一下。白天要工作也只有后半夜才有时间看书了。------青春无悔下面的代码是关于Hbase shell脚本的源码的改写,屏蔽了一些功能,便于理解和安全操作。现在没时间逐一解释关键点的含义,以后有时间再改,替换掉集群中:hbase_home:/lib/ruby/shell.rb# She

2016-07-12 01:07:11

Hbase_shell底层源码乱砍乱伐--59

大约10个月没有更新博客了,一直在学习新的东西,忙的不可开胶,现在一边整理做过的事情,以便复习一下。白天要工作也只有后半夜才有时间看书了。------青春无悔下面的代码是关于Hbase shell脚本的源码的改写,屏蔽了一些功能,便于理解和安全操作。现在没时间逐一解释关键点的含义,以后有时间再改,替换掉集群中:hbase_home:/lib/ruby/shell.rb# She

2016-07-12 01:06:08

Streaming(Test改改 )

package llfimport java.io.{PrintWriter, OutputStreamWriter, IOException, BufferedOutputStream}import java.nio.ByteBufferimport java.nio.charset.Charsetimport java.util.concurrent.{TimeUnit, Execu

2015-09-11 15:11:07

Kafka + Streaming 测试 --57

1.producerpackage llfimport java.utilimport java.util.Propertiesimport org.apache.kafka.clients.producer.{ProducerConfig, KafkaProducer, ProducerRecord}/** * Created by root on 15-9-2. */obj

2015-09-08 16:53:19

Kafka集群简单操作--56

1.启动zookeeper集群:在quad101~quad105五台节点上分别启动 bin/zookeeper-server-start.sh config/zookeeper.properties(leader随机).2.启动kafka集群:在quad101~quad105五台节点上分别启动 bin/kafka-server-start.sh config/server.properties

2015-09-08 16:44:57

kafka--简介

一、入门    1、简介    Kafka is a distributed,partitioned,replicated commit logservice。它提供了类似于JMS的特性,但是在设计实现上完全不同,此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类,发送消息者成为Producer,消息接受者成为Consumer,此外kafka集群有多个kafka实例

2015-09-04 17:12:44

Zookeeper集群搭建+Kafka集群搭建--55

Zookeeper 是 一个分布式。开放源码的分布式应用程序协调服务,是Google Chubby的一个开源实现,大多数的分布式应用都需要Zookeeper的支持,这篇文章先简单的和大家分享如何搭建一个zookeeper集群。配置环境:5台Centos6.5系统的服务器第一步: 安装 JDK/JRE第二步:下载zookeeper : http://zookeeper.apache.

2015-08-25 23:01:06

Streaming测试用例(改)--54

package llfimport java.io.{PrintWriter, OutputStreamWriter, IOException, BufferedOutputStream}import java.util.concurrent.{TimeUnit, Executors}import java.net.ServerSocketimport spire.std.bytei

2015-08-06 22:55:50

sparkstreaming性能测试简单例子--53

package llfimport org.apache.spark.storage.StorageLevelimport org.apache.spark.streaming.{Seconds, StreamingContext}import org.apache.spark.{SparkContext, SparkConf}/** * Created by root on 15-

2015-07-31 11:28:01

Netty

原文地址:http://lippeng.iteye.com/blog/1907279Netty是什么? 本质:JBoss做的一个Jar包 目的:快速开发高性能、高可靠性的网络服务器和客户端程序 优点:提供异步的、事件驱动的网络应用程序框架和工具 通俗的说:一个好使的处理Socket的东东  如果没有Netty? 远古:java.net

2015-07-29 17:46:51

Jetty

原文地址:http://blog.csdn.net/pingyongpy/article/details/6904681原文地址:http://www.ibm.com/developerworks/cn/java/j-lo-jetty/index.htmlJetty简介Jetty 是一个用 Java 实现、开源、基于标准的,并且具有丰富功能的 Http 服务器和 Web 容器,

2015-07-29 15:42:49

Spark:K-Means||算法原理、K-Means++算法原理--52

K-Means||算法原理为:(在基于Spark MLlib中的K-Means算法初始化K个类簇中心时的方法之一,另一种是随机选取K个中心)1.为每个run的K-Means随机选择一个初中心点,然后再平均随机选择2k个点,每个点被选择的概率和该点到类簇中心的距离成正比;2.对选出的这2k个点做一次K-Means++,找出k个初始化类簇中心,在这2k个左右的点上基于k初始化类簇中心执行多次L

2015-07-06 20:50:37

查看更多

勋章 我的勋章
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!