Kafka原理图JAVA源代码之kafka生产者,本次客户端使用kafka的console命令行,消费,生产者使用代码编码。看了好多生产者代码都带有props.put("zk.connect", "n2:2181/jafka");...
阅读(95) 评论(0)
Mavne项目构建的时候,需要引入本地其他非maven项目工程A的包,这个时候A由于属于“三无”包,缺少GAV,这个时候在maven项目构建就会有问题。   备注: GAV,也就是下面英文字母的首写,也叫做Maven坐标,是用...
阅读(95) 评论(0)
elasticsearch-sql.就是通过sql语句去操作es集群.就是将sql语句给转成了es的查询语法.感觉非常好用.这里分享一下安装过程,注意:插件在国内被和谐了。需要想办法下载,附件给出2.1.1版本的SQL插件供下载。...
阅读(96) 评论(0)
import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.ObjectInputStream;import java.io.Object...
阅读(93) 评论(0)
ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎,基于RESTful web接口。Elasticsearch是用Java开发的,并作为Apache许可条款下的开放源码发布,是第二...
阅读(89) 评论(0)
本例子主要演示,storm中的HelloWorld,从Spout不断的随机产生单词,然后在Bolt中进行组装输出。完整代码见附件。 详细代码如下: // 实例化TopologyBuilder类        TopologyBui...
阅读(103) 评论(0)
Storm命令行参数研究       [root@node1 ~]# stormCommands:        activate        classpath        deactivate        dev-z...
阅读(88) 评论(0)
操作步骤: 1. 搭建Zookeeper;2. 下载并解压Storm发布版本;4. 修改storm.yaml配置文件;5. 启动Storm各个后台进程。备注:storm高版本以后,不需要安装zeroMQ,JzMQ 等一堆繁杂的组件,...
阅读(231) 评论(0)
触发器是一种与表操作有关的数据库对象,当触发器所在表上出现指定事件时,将调用该对象,即表的操作事件触发表上的触发器的执行。   1、触发器的固定格式 create trigger triggerNameafter/before...
阅读(97) 评论(0)
Hadoop文件操作之HDFS,创建。删除目录,读写文件,追加写文件   package hadoop.hadoop_demo;import java.io.InputStream;import java.io.OutputStr...
阅读(91) 评论(0)
1、进程差异 新版本HadoopSecondaryNameNode  NodeManager   NameNode  DataNode  ResourceManager 旧版本Hadoop SecondaryNamenode,J...
阅读(109) 评论(0)
java代码操作HDFS文件   /** <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hado...
阅读(94) 评论(0)
核心意图:将抽象部分和实现部分分离,使它们都可以独立的变化。解决了继承关系的复杂性。该模式的目标是通过把高层的抽象和底层的实现分开,分别构建自己的类层次结构,并通过实现部分的接口将两部分进行桥接,从而达到高层抽象和底层实现可以独立的方...
阅读(98) 评论(0)
LVS 是一个开源的软件,可以实现LINUX平台下的简单负载均衡。首先简单介绍一下LVS (Linux Virtual Server)到底是什么东西,其实它是一种集群(Cluster)技术,采用IP负载均衡技术和基于内容请求分发技术...
阅读(106) 评论(0)
一、查询当前数据库的优化方式show parameter optimizer_mode; 默认条件下,CBO将SQL语句的吞吐量作为优化目标,而在一些条件下,需要将相应时间作为优化目标,此时返回一行或者前几行数据1) ALL_ROW...
阅读(98) 评论(0)
1、启动安装zookeeper [root@node1 bin]# ./zkServer.sh  JMX enabled by default Using config: /opt/bigdata/zookeeper/bin/....
阅读(146) 评论(0)