Merge pull request #13 from riv/master

Changed GetString back to GetInteger for EventId

ghinsights/USQL/ProcessDaily.usql

@@ -270,7 +270,7 @@ WHERE RowNumber == 1;
 //  60
 
 @NewRawEvent =
-SELECT   GHInsights.USql.Utility.GetString(Data, "id") AS EventId 
+SELECT   GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId 
         ,Data
         ,GHInsights.USql.Utility.GetString(Data, "_id") AS EtlSourceId
         ,DateTime.Parse(IngestDate, null, System.Globalization.DateTimeStyles.AssumeUniversal).ToUniversalTime() AS EtlIngestDate

ghinsights/USQL/ProcessEvent.usql

@@ -3,7 +3,7 @@ REFERENCE ASSEMBLY [GHInsights.USql];
 REFERENCE ASSEMBLY [Newtonsoft.Json];
 
 @Event =
-SELECT	 GHInsights.USql.Utility.GetString(Data, "id") AS EventId
+SELECT	 GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId
 		,GHInsights.USql.Utility.GetInteger(Data, "actor.id") AS ActorId
 		,GHInsights.USql.Utility.GetString(Data, "actor.login") AS ActorLogin
 		,GHInsights.USql.Utility.GetDateTime(Data, "created_at") AS CreatedAt

ghinsights/USQL/ProcessEventPayloadCommit.usql

@@ -3,7 +3,7 @@ REFERENCE ASSEMBLY [GHInsights.USql];
 REFERENCE ASSEMBLY [Newtonsoft.Json];
 
 @RawEvent =
-SELECT   GHInsights.USql.Utility.GetString(Data, "id") AS EventId 
+SELECT   GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId 
         ,Data
         ,GHInsights.USql.Utility.GetString(Data, "_id") AS EtlSourceId
         ,DateTime.Parse(IngestDate, null, System.Globalization.DateTimeStyles.AssumeUniversal).ToUniversalTime() AS EtlIngestDate

ghinsights/USQL/ProcessEventPayloadIssueLabel.usql

@@ -4,7 +4,7 @@ REFERENCE ASSEMBLY [Newtonsoft.Json];
 
 
 @RawEventPayloadIssueLabel =
-SELECT  GHInsights.USql.Utility.GetString(Data, "id") AS EventId 
+SELECT  GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId 
         ,Data
         ,GHInsights.USql.Utility.GetString(Data, "_id") AS EtlSourceId
         ,DateTime.Parse(IngestDate, null, System.Globalization.DateTimeStyles.AssumeUniversal).ToUniversalTime() AS EtlIngestDate

ghinsights/USQL/ProcessEventPayloadPage.usql

@@ -3,7 +3,7 @@ REFERENCE ASSEMBLY [GHInsights.USql];
 REFERENCE ASSEMBLY [Newtonsoft.Json];
 
 @RawEventPayloadPage =
-SELECT  GHInsights.USql.Utility.GetString(Data, "id") AS EventId 
+SELECT  GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId 
         ,Data
         ,GHInsights.USql.Utility.GetString(Data, "_id") AS EtlSourceId
         ,DateTime.Parse(IngestDate, null, System.Globalization.DateTimeStyles.AssumeUniversal).ToUniversalTime() AS EtlIngestDate

ghinsights/USQL/ProcessEventPayloadPullRequest.usql

@@ -3,7 +3,7 @@ REFERENCE ASSEMBLY [GHInsights.USql];
 REFERENCE ASSEMBLY [Newtonsoft.Json];
 
 @Event =
-SELECT	 GHInsights.USql.Utility.GetString(Data, "id") AS EventId
+SELECT	 GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId
         ,GHInsights.USql.Utility.GetInteger(Data, "payload.pull_request.id") AS EventPayloadPullRequestId
 		,GHInsights.USql.Utility.GetInteger(Data, "payload.pull_request.additions") AS Additions
 		,GHInsights.USql.Utility.GetInteger(Data, "payload.pull_request.assignee.id") AS AssigneeId

ghinsights/USQL/ProcessEventPayloadReleaseAsset.usql

@@ -3,7 +3,7 @@ REFERENCE ASSEMBLY [GHInsights.USql];
 REFERENCE ASSEMBLY [Newtonsoft.Json];
 
 @RawEventPayloadReleaseAsset =
-SELECT  GHInsights.USql.Utility.GetString(Data, "id") AS EventId 
+SELECT  GHInsights.USql.Utility.GetInteger(Data, "id") AS EventId 
         ,Data
         ,GHInsights.USql.Utility.GetString(Data, "_id") AS EtlSourceId
         ,DateTime.Parse(IngestDate, null, System.Globalization.DateTimeStyles.AssumeUniversal).ToUniversalTime() AS EtlIngestDate

ghinsights/USQL/StageData.usql

@@ -31,4 +31,4 @@ SELECT  EventName
 FROM @ExtractedData
 WHERE IngestDate == @IngestDate;
 
-END;
+END;