土土的简书 - 简书

IP属地：安徽

SparkStreaming反压机制
SparkStreaming的开启反压机制其实就是给StreamingContext添加一个StreamingListener，在JobSche...

0.2 1133 0 3
SparkStreaming容错性
SparkStreaming实时流处理系统需要长时间接受并处理数据，对于SparkStreaming的容错性主要通过以下三种方式：第一、利用S...

809 0 0

Receiver的分发
一、Spark Streaming的数据源对于SparkStreaming中处理的数据无论是通过内部接口获取，还是通过Kafka、Flume、...

735 0 0
Spark Streaming消息通信过程
1、Spark Streaming消息通信总体流程在启动流处理引擎的过程中，将进行启动所有的流数据接受器Receiver和注册流数据接收器Re...

502 0 0
Spark Streaming运行架构
1、Spark Streaming总体运行架构 SparkStreaming分为Driver端和Client端，运行在Driver端的是St...

0.1 1187 0 3
JDK1.8源码阅读之Object
package java.lang; public class Object{ /** * 一个本地方法,具体是用C(C++)在DLL中实现...

310 0 1