8 一流小风一

尚未进行身份认证

凛冬将至!

等级
TA的排名 5w+

读hbase的region简单程序--67

importjava.util.List;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.HRegionInfo;importorg.apache.hadoop.hbase.clien

2016-07-18 02:29:47

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

packagemoniter;importjava.io.IOException;publicclasshbasemoniter_new{ publicfinalstaticStringurl="tcp://dsdfsd/sdfs"; //publicstaticStringconfig=null; //publicstaticStrings

2016-07-18 02:25:10

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

1.扫表#!/bin/bashsource/etc/profileif[$#-ne3];thenecho"scan.shtablestartend"exit1fihadoopfs-rm-r/home/hbase/checker/a_$1hadoopjar./hbase.aa-0.1.jarhbase.TabelScan-Dmapred

2016-07-18 02:13:56

一些hadoop脚本事例--64

1.用于启动jar包读hbase表数据到hdfs#!/bin/bashsource/etc/profileif[$#-ne1];thenecho"aaa.shtable"exit1fitable=$1hadoopfs-rm-r/user/ads/hbase_tests/$tablehadoopjar./aasss.jarhbase.hfi

2016-07-18 02:09:31

Hbasebulkload方法--63

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

2016-07-14 02:37:32

实用生成md5方法--62

/**简单生成md5方法*/importjava.security.MessageDigest;publicclassUtils{ privatestaticcharhexDigits[]={'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.以前写的一些功能函数方法:publicclassdtest_test{ publicfinalstaticStringurl="tcp://test_test"; @SuppressWarnings("deprecation") publicstaticvoidmain(String[]args)throwsException{ IHbas

2016-07-13 02:55:44

Hbase事例基本方法--60

packagellf.com;importjava.io.IOException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.fs.Path;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoo

2016-07-12 01:37:57

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

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

2016-07-12 01:07:11

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

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

2016-07-12 01:06:08

Streaming(Test改改 )

packagellfimportjava.io.{PrintWriter,OutputStreamWriter,IOException,BufferedOutputStream}importjava.nio.ByteBufferimportjava.nio.charset.Charsetimportjava.util.concurrent.{TimeUnit,Execu

2015-09-11 15:11:07

Kafka + Streaming 测试 --57

1.producerpackagellfimportjava.utilimportjava.util.Propertiesimportorg.apache.kafka.clients.producer.{ProducerConfig,KafkaProducer,ProducerRecord}/***Createdbyrooton15-9-2.*/obj

2015-09-08 16:53:19

Kafka集群简单操作--56

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

2015-09-08 16:44:57

kafka--简介

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

2015-09-04 17:12:44

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

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

2015-08-25 23:01:06

Streaming测试用例(改)--54

packagellfimportjava.io.{PrintWriter,OutputStreamWriter,IOException,BufferedOutputStream}importjava.util.concurrent.{TimeUnit,Executors}importjava.net.ServerSocketimportspire.std.bytei

2015-08-06 22:55:50

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

packagellfimportorg.apache.spark.storage.StorageLevelimportorg.apache.spark.streaming.{Seconds,StreamingContext}importorg.apache.spark.{SparkContext,SparkConf}/***Createdbyrooton15-

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||算法原理为:(在基于SparkMLlib中的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博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!