【问题标题】:Spark Dataset: Table data not exactly same as of view from which it s createdSpark 数据集:表数据与创建它的视图不完全相同
【发布时间】:2017-10-10 05:53:16
【问题描述】:

我的代码与此完全相同。此处仅更改了变量和表名。请忽略输入过程中的任何语法错误。原代码编译成功。

--------代码------

Dataset<Row> test = sqlContext.sql("select * from test_table");

test.createOrReplaceTempView("temp_view_test");

sqlContext.sql("drop table if exist new_table");
sqlContext.sql("create table new_table as select * from temp_view_test");

//Code to print counts

//count if dataset
System.out.println("test count:"+test.count());

//count of temp view
Dataset<Row> tempViewTestData = sqlContext.sql("select * from temp_view_test");
System.out.println("temp view count: "+tempViewTestData.count());

//count of newly created table
Dataset<Row> newTableData = sqlContext.sql("select * from new_table");
System.out.println("New Table count: "+newTableData .count());

-----输出----

测试计数:9422720 临时观看次数:9422720 新表数:9520364

-----问题-----

我的问题是为什么新表的计数与临时视图的计数不同。我应该怎么做才能使这两个计数相同。

【问题讨论】:

    标签: apache-spark hive apache-spark-sql apache-spark-dataset


    【解决方案1】:

    终于找到了解决办法。这是因为数据集中存在日文字符。如果出现类似问题,可以考虑这一点。

    【讨论】:

      猜你喜欢
      • 2017-05-15
      • 1970-01-01
      • 2017-11-09
      • 1970-01-01
      • 1970-01-01
      • 2020-03-11
      • 2016-12-11
      • 1970-01-01
      • 2012-05-28
      相关资源
      最近更新 更多