Guest User

Untitled

a guest
Jun 2nd, 2018
132
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.36 KB | None | 0 0
  1. test.txt
  2. H,DatatypeCode,Description
  3. K,03099,Metric Expanded mple Size
  4. K,05307,Elapsed Day Factor
  5.  
  6. val customSchema=StructType(StructField(head_record,StringType,false), StructField(data_typ_cd,StringType,false), StructField(data_typ_desc,StringType,false))
  7.  
  8. var url =
  9.  
  10. jdbc:hive2://xxhive.xxx.com:10000/devl_ccc_chx_batch;principal=hive/xxhive.xxx.com@internal.xxxglobal.com;mapred.job.queue.name=opp;AuthMech=3;SSL=1;password=xxxx;user=xxxxx;
  11.  
  12. driverName=com.cloudera.hive.jdbc41.HS2Driver
  13.  
  14. val schema = StructType(List())
  15. val sc = sparkSession.sparkContext
  16. var readDF = sparkSession.createDataFrame(sc.emptyRDD[Row], schema)
  17.  
  18. readDF = sparkSession.read
  19. .format("com.databricks.spark.csv")
  20. .option("delimiter", ",")
  21. .option("header", "true")
  22. .schema(customSchema)
  23. .load("test.txt")
  24.  
  25. readDF=readDF.filter(col("head_record")===lit("K")).drop("head_record")
  26. readDF=readDF.withColumn("cyc_dt",lit("201867").cast(IntegerType))
  27. .withColumn("proc_dt",unix_timestamp(lit(current_timestamp()),"yyyy-MM-dd HH:mm:ss").cast("timestamp"))
  28.  
  29.  
  30.  
  31. val connectionProperties = new Properties()
  32. connectionProperties.put("user", xxxxxx)
  33. connectionProperties.put("password", xxxxxx)
  34.  
  35. dataFrame.createOrReplaceTempView("tmpTable")
  36.  
  37. sparkSession.sql("select * from tmpTable")
  38. .write
  39. .mode(SaveMode.Append) // <--- Append in existing table
  40. .option("driver", driverName)
  41. .option("header","false")
  42. .jdbc(url, "tableName", connectionProperties)
  43.  
  44. *org.apache.hadoop.hive.ql.parse.SemanticException:Expression of type TOK_FUNCTION not supported in insert/values:27:1, org.apache.hadoop.hive.ql.parse.SemanticAnalyzer:unparseExprForValuesClause:SemanticAnalyzer.java:914, org.apache.hadoop.hive.ql.parse.SemanticAnalyzer:genValuesTempTable:SemanticAnalyzer.java:842], sqlState:42000, errorCode:10293, errorMessage:Error while compiling statement: FAILED: SemanticException [Error 10293]: Unable to create temp file for insert values Expression of type TOK_FUNCTION not supported in insert/values), Query: INSERT INTO TABLE `devl_ca9_chx_batch`.`chx_data_typs_stg_dcp` VALUES ( '03099' , 'Volumetric Expanded Sample Size' , 201867 , CAST( '2018-06-02 21:25:41.0' AS TIMESTAMP) ) , ( '03307' , 'Elapsed Day Factor' , 201867 , CAST( '2018-06-02 21:25:41.0' AS TIMESTAMP) ).rnt... 18 morernnDriver stacktrace:"}
Add Comment
Please, Sign In to add comment