spark sql 怎样处理日期类型

时间：2015-07-17 12:17:59 阅读：520 评论：0 收藏：0 [点我收藏+]

标签：

spark sql 怎样处理日期类型、时间类型

json 每个对象不能换行

##问题描述

json File 日期类型怎样处理？怎样从字符型，转换为Date或DateTime类型？

json文件如下，有字符格式的日期类型

```

{ "name" : "Andy", "age" : 30, "time" :"2015-03-03T08:25:55.769Z"}

{ "name" : "Justin", "age" : 19, "time" : "2015-04-04T08:25:55.769Z" }

{ "name" : "pan", "age" : 49, "time" : "2015-05-05T08:25:55.769Z" }

{ "name" : "penny", "age" : 29, "time" : "2015-05-05T08:25:55.769Z" }

```

默认推测的Schema：

```

root

|-- _corrupt_record: string (nullable = true)

|-- age: long (nullable = true)

|-- name: string (nullable = true)

|-- time200: string (nullable = true)

```

测试代码

```

val fileName = "person.json"

val sc = SparkUtils.getScLocal("json file 测试")

val sqlContext = new org.apache.spark.sql.SQLContext(sc)

val jsonFile = sqlContext.read.json(fileName)

jsonFile.printSchema()

```

##解决方案

### 方案一、json数据时间为 long 秒或毫秒

### 方案二、自定义schema

```

val fileName = "person.json"

val sc = SparkUtils.getScLocal("json file 测试")

val sqlContext = new org.apache.spark.sql.SQLContext(sc)

val schema: StructType = StructType(mutable.ArraySeq(

StructField("name", StringType, true),

StructField("age", StringType, true),

StructField("time", TimestampType, true)));

val jsonFile = sqlContext.read.schema(schema).json(fileName)

jsonFile.printSchema()

jsonFile.registerTempTable("person")

val now: Timestamp = new Timestamp(System.currentTimeMillis())

val teenagers = sqlContext.sql("SELECT * FROM person WHERE age >= 20 AND age <= 30 AND time <=‘" +now+"‘")

teenagers.foreach(println)

val dataFrame = sqlContext.sql("SELECT * FROM person WHERE age >= 20 AND age <= 30 AND time <=‘2015-03-03 16:25:55.769‘")

dataFrame.foreach(println)

```

###方案三、sql建表

创建表sql

```

CREATE TEMPORARY TABLE person IF NOT EXISTS

[(age: long ,name:string ,time:Timestamp)]

USING org.apache.spark.sql.json

OPTIONS ( path ‘person.json‘)

语法

CREATE [TEMPORARY] TABLE [IF NOT EXISTS]

　　 [(col-name data-type [, …])]

　　USING [OPTIONS ...]

　　[AS ]

```

### 方案四、用textfile convert

来自为知笔记(Wiz)

spark sql 怎样处理日期类型

标签：

原文地址：http://my.oschina.net/itnms/blog/479641

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行