和RDD相似,DStreams也允许开发者持久化流数据到内存中。在DStream上使用persist()
方法可以自动地持久化DStream中的RDD到内存中。如果DStream中的数据需要计算多次,这是非常有用的。像reduceByWindow
和reduceByKeyAndWindow
这种窗口操作、updateStateByKey
这种基于状态的操作,持久化是默认的,不需要开发者调用persist()
方法。
例如通过网络(如kafka,flume等)获取的输入数据流,默认的持久化策略是复制数据到两个不同的节点以容错。
注意,与RDD不同的是,DStreams默认持久化级别是存储序列化数据到内存中,这将在性能调优章节介绍。更多的信息请看rdd持久化
让我们在本章中了解如何创建查询。 创建更新查询您可以使用更新查询更改表中的数据,并且可以使用更新查询来输入条件以指定应更...
SQLite 的sqlite3命令被用来创建新的 SQLite 数据库。您不需要任何特殊的权限即可创建一个数据。语法sqlite3 命令的基本语法如下...
SQLite 的SELECT语句用于从 SQLite 数据库表中获取数据,以结果表的形式返回数据。这些结果表也被称为结果集。语法SQLite 的...
SQLite 的 GROUP BY子句用于与 SELECT 语句一起使用,来对相同的数据进行分组。 在 SELECT 语句中,GROUP BY 子句放在 WHER&...