起初是同事在用spark sql时候反馈的一个问题，sql如下 %hive select 10900*now_pocket_limit_rate as d from dp_fk_tmp.dszx_88w_v2 where uid='41195' 这个now_pocket_limit_rate在表里的值为0.7，返回结果为： 7629.999999999999 此时脑海居然浮现出之...
Maven依赖 <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch-spark-20_2.11</artifactId> <version>6.2.4</version> </de...
打印窗口示例 import org.apache.spark.sql.streaming.{OutputMode, ProcessingTime} import org.apache.spark.sql.{DataFrame, SparkSession} import org.apache.spark.sql.functions._ object StructuredNetworkWind...
Flink Exactly-Once
Flink CheckPoint实现
A new version of content is available.
