Skip to content
This repository has been archived by the owner on Mar 7, 2018. It is now read-only.

Fix typos in column names #86

Merged
merged 1 commit into from Aug 15, 2017
Merged

Fix typos in column names #86

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
4 changes: 2 additions & 2 deletions ...ala/com/microsoft/partnercatalyst/fortis/spark/sinks/cassandra/CassandraEventSchema.scala
View file
Open in desktop
Expand Up @@ -118,7 +118,7 @@ object CassandraEventTopicSchema {
pipelinekey = item.pipelinekey,
eventid = item.eventid,
topic = kw.toLowerCase,
eventime = item.eventtime,
eventtime = item.eventtime,
insertiontime = new Date().getTime,
externalsourceid = item.externalsourceid
)
Expand All @@ -135,7 +135,7 @@ object CassandraEventPlacesSchema {
centroidlat = location.centroidlat,
centroidlon = location.centroidlon,
eventid = item.eventid,
eventime = item.eventtime,
eventtime = item.eventtime,
conjunctiontopic1 = ct._1,
conjunctiontopic2 = ct._2,
conjunctiontopic3 = ct._3,
Expand Down
4 changes: 2 additions & 2 deletions .../scala/com/microsoft/partnercatalyst/fortis/spark/sinks/cassandra/dto/FortisRecords.scala
View file
Open in desktop
Expand Up @@ -25,7 +25,7 @@ case class EventTopics(
insertiontime: Long,
eventid: String,
externalsourceid: String,
eventime: Long,
eventtime: Long,
topic: String) extends Serializable

case class EventPlaces(
Expand All @@ -38,7 +38,7 @@ case class EventPlaces(
conjunctiontopic2: String,
conjunctiontopic3: String,
externalsourceid: String,
eventime: Long,
eventtime: Long,
placeid: String) extends Serializable

case class PopularPlaceAggregate(
Expand Down