Spark Streaming：缓存与持久化机制

缓存与持久化机制 与RDD相似，Spark Streaming也能够让开发人员手动控制，将数据流中的数据持久化到内存中。对 DStream调用 persist()方法，就能够让Spark Streaming自动将该数据流中的全部产生的RDD，都持久化到内存中。若是要对一个DStream屡次执行操做，那么，对DStream持久化是很是有用的。由于屡次操做，能够共享使用内存中的一份缓存数据。 对于基于

>>阅读原文<<