Hi team,
I am very new to SPARK, actually today is my first day.
I have a nested json string which contains timestamp and lot of
other details. I have json messages from which I need to write multiple
aggregation but for now I need to write one aggregation. If code structure
is already there then kindly post if or give some pointers to start. Quick
inputs will help me lot.
Sample Requirement example:
*Requirement: How many Stock dispatched in last 1 hour*
[
{
"name":"Stock dispatched",
*"timestamp":"2015-04-14T10:03:10.000Z",*
"component":"Work Order",
"sessionID":"4324--52-3-52-46-3-46-3-75",
"properties":{
"Priority":"3",
"Appliance Manufacturer":"XXX game",
"Appliance Model":"HJ 10",
"Appliance Model Year":"2012"
}
},
{
"name":"Stock dispatched",
* "timestamp":"2015-04-14T10:04:10.000Z",*
"component":"Work Order",
"sessionID":"4324--52-3-52-46-3-46-3-75",
"properties":{
"Priority":"3",
"Appliance Manufacturer":"XXX game",
"Appliance Model":"DJ 15",
"Appliance Model Year":"2012"
}
}
]
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Aggregate-by-timestamp-from-json-message-tp24147.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
