CoolplaySpark
CoolplaySpark copied to clipboard
lw-lin
酷玩 Spark: Spark 源代码解析、Spark 类库等
这里是 [《3.1 Receiver 分发详解.md》](../blob/master/Spark%20Streaming%20源码解析系列/3.1%20Receiver%20分发详解.md) 讨论区。 如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！
这里是 [《2.2 JobGenerator 详解.md》](../blob/master/Spark%20Streaming%20源码解析系列/2.2%20JobGenerator%20详解.md) 讨论区。 如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！
这里是 [《1.2 DStream 生成 RDD 实例详解.md》](../blob/master/Spark%20Streaming%20源码解析系列/1.2%20DStream%20生成%20RDD%20实例详解.md) 讨论区。 如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！
您能否抽时间讲一下这三个之间的关系，从doc上看貌似只是说window duration和sliding duration都应该设为batch duration的倍数，而job的submit到底是参照的batch duration还是sliding duration，请您为我解惑
这里是 [《4.1 Executor 端长时容错详解.md》](../blob/master/Spark%20Streaming%20源码解析系列/4.1%20Executor%20端长时容错详解.md) 讨论区。 如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！
看到sparkStreaming官网上介绍的join Here, in each batch interval, the RDD generated by stream1 will be joined with the RDD generated by stream2. You can also do leftOuterJoin, rightOuterJoin, fullOuterJoin. Furthermore, it is...
如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！
如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！
如需要贴代码，请复制以下内容并修改： ```java public static final thisIsJavaCode; ``` ```scala val thisIsScalaCode ``` 谢谢！