草捏子最近开始学习Kafka。在学习前,给自己确定了下学习的范围,大致如下:理解Kafka的相关概念;掌握Kafka的基本API使用;了解Kafka的背后原理。后续将在这学习范围内输出一些相关文章。那么本文作为Kafka系列的第一篇文章,将从“理解Kafka的相关概念”说起。首先Kafka是什么。Kafka起初是由LinkedIn公司采用Scala语言开发的一个多分区、多副本且基于ZooKeepe
分类:
其他好文 时间:
2020-10-27 11:52:25
阅读次数:
31
一.Zookeeper基本概念 分布式系统是同时跨越多个物理主机,独立运行的多个软件所组成的系统。分布式系统的协调工作就是通过某种方式,让某个节点的信息能够同步和共享。这依赖于服务进程之间的通信。通信方式有两种: 通过网络进行信息共享 通过共享存储 Zookeeper是作为分布式系统的分布式协同服务 ...
ThreadLocal 是什么呢? 定义:提供线程局部变量; 一个线程局部变量在多个线程中,分别有独立的值(副本)。 特点:简单(开箱即用)、快速(无额外开销)、安全(线程安全)。 场景: 多线程场景(资源持有、线程一致性、并发计算、线程安全等场景)。 ThreadLocal 基本API 构造函数T ...
一、Activiti7 的组成部分 Activiti Core 作为Activiti 的核心部分,Activiti Cloud 主要是利用云服务来实现分布式业务流程开发。 二、Activiti 新的 API 介绍 Activiti7 为了简化对工作流的操作,特别在原有 API 的基础上再次进行封闭, ...
Flink使用 DataSet 和 DataStream 代表数据集。DateSet 用于批处理,代表数据是有限的,而 DataStream 用于流数据,代表数据是无界的。数据集中的数据是不可以变的,也就是说不能对其中的元素增加或删除。我们通过数据源创建 DataSet 或者 DataStream ...
numpy的基本拼接、拆分、添加、删除API iwehdio的博客园:https://www.cnblogs.com/iwehdio/ 1、np.concatenate((a, b), axis=0) np.concatenate方法沿现有的轴拼接一系列数组。输入数组(a、b、c)等要以元组形式输入 ...
numpy的基本索引API iwehdio的博客园:https://www.cnblogs.com/iwehdio/ 1、单个元素的索引 对于一维数组,索引方式与内置的List相同。正索引从0开始,负索引从-1开始。 >>> x = np.arange(10)>>> xarray([0, 1, 2, ...
一、基本api操作1、获取HDFS对象的两种方式:方式1:publicstaticFileSysteminitFileSystem1()throwsIOException{//获取配置对象Configurationconf=newConfiguration();//指定namenode地址conf.set("fs.defaultFS","hdfs://bigdata121:9000");//获取h
本文只是抛砖引玉地讲解了注解的基本概念,注解的作用,几种元注解的功用以及使用方法,并通过一个简单的例子讲解了一下注解的处理,并不全面,文中通过Field讲解了注解的基本Api,但注解还可以修饰类、构造器、方法等,也有相对应的注解处理方法,大家可自行查一下API手册相关内容,大同小异,有不对之处,请批... ...
分类:
编程语言 时间:
2019-10-05 18:05:23
阅读次数:
142