RPC分布式系统离不开RPC远程调用，本文首先理一下什么是RPC。1.java本地方法调用假设你有一个Calculator，那么单体应用时，要调用Calculator的add方法来执行一个加运算，你可以方法中直接使用，因为在同一个地址空间，或者说在同一块内存，这个称为本地函数调用。java的本地方法调用中，每个方法会作为java虚拟机栈中的一个栈帧放入到java虚拟机栈中，方法调用的时候执行入栈操

接上篇：Application的start()和handleConfigurationEvent(MaterializedConfiguration conf)，handleConfigurationEvent方法是在启动时或者需要动态读取配置文件而配置文件发生变化时，会通过eventBus调用此方法。，该方法会先关闭所有组件再启动所有组件，因此，flume 所谓的动态加载并不是真正的动态，只

测试环境cdh5.4.8，hue3.7（1）进入hue界面，登录，这里重新建立一个oozie账户，使用默认的admin也可以。（2）新建任务（3）新建（4）将sqoop1拖到指定位置（5）在出来的界面中写上需要执行的sqoop语句，点击添加（6）

1.常用资源workload:pod,deployment,rc,replicaset,DaemonSet,Job,Cronjob服务发现及服务均衡:service,ingress.配置存储相关:volume.csi..configmap,secret,downwardApi集群级资源：namespace，node，role，clusterRole，RoleBinding，Clus...

1.kubectl get nodes 命令2.k8s中的常见资源：pod,service,replicaset,deployment,statefulset,daemonset,job,crontab,ingress,3.k8s中常用命令master默认是所有pod的污点（taints）。不调度到master上。使用kubectl describe node xxx可以...

flume的执行入口在flume-ng-node包下的Application类中，假如需要从kafka中读取数据，配置文件使用本地的配置文件：a1.sources = r1a1.sinks = k1a1.channels = c1a1.sources.r1.type = org.apache.flume.source.kafka.KafkaSourcea1.sources.r1.zo

标注为FunctionalInterface的接口被称为函数式接口，该接口只能有一个自定义方法，但是可以包括从object类继承而来的方法。如果一个接口只有一个方法，则编译器会认为这就是一个函数式接口。例如这样写：public interface FunctionalInterfaceTest {void test1();}如果在接口上面加入@FunctionalInterface注

java 1.5的时候增加foreach的增强for循环，然而这里的forEach并不是那个foreach，该处谈论的foreach是集合类的父接口iterable中在jdk1.8新增加的foreach循环函数式方法，先执行下面代码：package com.test.java8;import java.util.ArrayList;import java.util.List;impor

kafka 源码

spark基本的提交语句：./bin/spark-submit\ --class\ --master\ --deploy-mode\ --conf =\ ...# other options\[application-arguments]参数的含义:--class: 主函数所在的类。--master: master的url，后面会解释