1:Direct方式特点:
1)Direct的方式是会直接操作kafka底层的元数据信息,这样如果计算失败了,可以把数据重新读一下,重新处理。即数据一定会被处理
2)由于直接操作的是kafka,kafka就相当于你底层的文件系统。这个时候能保证严格的事务一致性,即一定会被处理,而且只会被处理一次。而Receiver的方式则不能保证,因为Receiver和ZK中的数据可能不同步,spark St...
分类:
其他好文 时间:
2016-05-13 03:17:41
阅读次数:
136
查看master的运行情况:[root@master] mysql -uroot -p************
[root@master] mysql> show master status \G;
*************************** 1. row ***************************
File: mysql-bin.00001...
分类:
数据库 时间:
2016-05-13 03:16:02
阅读次数:
225
一、zookeeper
Zookeeper 是 Google 的 Chubby一个开源的实现,是 Hadoop 的分布式协调服务,它包含一个简单的原语集,分布式应用程序可以基于它实现同步服务,配置维护和命名服务等
Zookeeper服务器集群规模不小于3个节点,要求各服务器之间系统时间要保持一致。ZooKeeper的搭建是为了后面HBase的使用。
二、集群模式搭建
我的集群是Hadoop...
分类:
其他好文 时间:
2016-05-13 03:14:19
阅读次数:
134
I/O复用使得程序能够同时监听多个文件描述符,对于提高程序性能至关重要。I/O复用不仅仅在网络程序中使用,但是我接触到的例子中,TCP网络编程那块使用I/O复用比较多,例如,TCP服务器同时处理监听socket和连接socket.
在了解I/O复用之前,我们需要先了解几个概念。
1,同步I/O与异步I/O
2,LT(水平触发)和ET(边缘触发)
POSIX把两个术语定义如下:
同...
分类:
其他好文 时间:
2016-05-13 03:05:18
阅读次数:
213
逻辑备库不复制数据库服务,在进行switchover或者failover时,连接主库服务的中间层将不能连接(因为服务的创建没有被复制),或者连接不正确的版本(因为服务属性的修改没有被复制)。
Oracle集群不复制管理逻辑备库的服务,必须手动对主库与备库进行同步,具体的详参Oracle集群管理和部署的相关内容。
一.逻辑备库的switchover操作
当进行switchover操...
分类:
数据库 时间:
2016-05-13 02:58:09
阅读次数:
276
这一章节我们来讨论一下由同步的synchronized (newobject()) 引起的异步现象。1.代码清单package com.ray.deepintothread.ch02.topic_14;
/**
*
* @author RayLee
*
*/
public class AsynchOfSynchWithUnSameObject {
public static void...
分类:
编程语言 时间:
2016-05-13 02:55:32
阅读次数:
170
在写这篇文章之前我看过一些关于多线程同步的文章,从他们的文章中总结了很多精华,也发现一些不足。很多文章都是从以下四个方面来分析的。
1、synchronized修饰一个非静态函数,例如synchronized method()
2、synchronized修饰一个静态函数,例如synchronized static method()
3、synchronized修饰一个对象,例如synchr...
分类:
编程语言 时间:
2016-05-13 02:46:10
阅读次数:
124
1.不归零码NRZ、双极性不归零码BNRZ
不归零码在一个码型传输过程中不会归零,用“高电平”表示1,“零电平”表示0;
双极性不归零码BNRZ同样是不归零码,用“高电平”表示1,“负电平”表示0;
上述编码信道密度高,但无法从码型中提取同步信息,需要外同步,否则会累积误差。
波形如下:
2.归零码RZ,BRZ
归零码RZ也使用“高电平”表示1,但在一个周期内,高电平需要归零,“零...
分类:
其他好文 时间:
2016-05-13 02:38:43
阅读次数:
318
一、why(为什么要用Hibernate缓存?)
Hibernate是一个持久层框架,经常访问物理数据库。
为了降低应用程序对物理数据源访问的频次,从而提高应用程序的运行性能。
缓存内的数据是对物理数据源中的数据的复制,应用程序在运行时从缓存读写数据,在特定的时刻或事件会同步缓存和物理数据源的数据。
二、what(Hibernate缓存原理是怎样的?)Hibern...
分类:
Web程序 时间:
2016-05-13 02:14:11
阅读次数:
218
先看最终的效果图:
serialPort的ReadByte()方法用于从System.IO.Ports.SerialPort输入缓冲区中同步读取一个字节。...