在java中将数据从csv导入snappy数据时出错

Question

我在 Scala 中的表架构是

snSession.sql("创建表category_subscriber(id int, catId int,brandId int, domain int, osId int, rType int,rTime int, ctId int, icmpId int, setId int,rAt int, cyId int) 使用列选项(BUCKETS) '5',PARTITION_BY 'ID',OVERFLOW 'true',EVICTION_BY 'LRUHEAPPERCENT')");

我在java中的代码是

Statement statement = snappy.createStatement();

            statement.execute("CREATE EXTERNAL TABLE CATEGORY_SUBSCRIBER USING com.databricks.spark.csv OPTIONS(path '/home/sys1010/Desktop/category_sub.csv', header 'true', inferSchema 'true', nullValue 'NULL', maxCharsPerColumn '4096';");

将数据从 csv 通过 java 导入 snappydata 时出现错误

Answer 1

语句中有语法错误，更正的语句是：语句语句 = snappy.createStatement(); statement.execute("CREATE EXTERNAL TABLE CATEGORY_SUBSCRIBER USING com.databricks.spark.csv OPTIONS(path '/home/sys1010/Desktop/category_sub.csv', header 'true', inferSchema 'true', nullValue 'NULL', maxCharsPerColumn '第 4096 章

Answer 2

<name>使用 CSV options(....)创建外部表也应该有效。CSV 现在是一个内置的数据源。