Repository: asterixdb-bad Updated Branches: refs/heads/master 432355a90 -> e3cd0f6c0
Adapt to New SQL++ Model Change-Id: I8959f3ed2cfac508e6b1da6b2e500510d2798bda Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/e3cd0f6c Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/e3cd0f6c Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/e3cd0f6c Branch: refs/heads/master Commit: e3cd0f6c0575af0c108085b17fa5fbbaf38059e2 Parents: 432355a Author: Till Westmann <ti...@apache.org> Authored: Mon Aug 21 22:09:11 2017 -0700 Committer: Till Westmann <ti...@apache.org> Committed: Mon Aug 21 22:09:11 2017 -0700 ---------------------------------------------------------------------- .../asterix/bad/lang/statement/CreateChannelStatement.java | 2 +- .../resources/optimizerts/queries/channel/channel-create.sqlpp | 2 +- .../optimizerts/queries/channel/channel-subscribe.sqlpp | 2 +- .../optimizerts/queries/channel/channel-unsubscribe.sqlpp | 2 +- .../create_channel_check_datasets.1.ddl.sqlpp | 2 +- .../create_channel_check_metadata.1.ddl.sqlpp | 2 +- .../drop_channel_check_datasets.1.ddl.sqlpp | 2 +- .../drop_channel_check_datasets.3.query.sqlpp | 1 + .../drop_channel_check_metadata.1.ddl.sqlpp | 2 +- .../queries/channel/room_occupants/room_occupants.1.ddl.sqlpp | 6 +++--- .../channel/room_occupants/room_occupants.4.query.sqlpp | 1 + .../channel/room_occupants/room_occupants.8.query.sqlpp | 1 + .../subscribe_channel_check_subscriptions.1.ddl.sqlpp | 2 +- .../subscribe_channel_check_subscriptions.5.query.sqlpp | 3 ++- .../channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp | 2 +- .../procedure/delete_procedure/delete_procedure.1.ddl.sqlpp | 2 +- .../procedure/insert_procedure/insert_procedure.1.ddl.sqlpp | 2 +- .../procedure/query_procedure/query_procedure.1.ddl.sqlpp | 4 ++-- .../procedure/query_procedure/query_procedure.2.update.sqlpp | 1 + .../procedure/query_procedure/query_procedure.4.update.sqlpp | 2 +- .../repetitive_insert_procedure.1.ddl.sqlpp | 2 +- 21 files changed, 25 insertions(+), 20 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java index 83dd849..c6a72b6 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java @@ -207,7 +207,7 @@ public class CreateChannelStatement implements IExtensionStatement { Identifier resultsName, MetadataProvider metadataProvider, IHyracksClientConnection hcc, IHyracksDataset hdc, Stats stats, String dataverse) throws Exception { StringBuilder builder = new StringBuilder(); - builder.append("SET inline_with \"false\"\n"); + builder.append("SET inline_with \"false\";\n"); builder.append("insert into " + dataverse + "." + resultsName); builder.append(" as a (\n" + "with " + BADConstants.ChannelExecutionTime + " as current_datetime() \n"); builder.append("select result, "); http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-create.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-create.sqlpp b/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-create.sqlpp index 24d73e2..9192157 100644 --- a/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-create.sqlpp +++ b/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-create.sqlpp @@ -34,7 +34,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-subscribe.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-subscribe.sqlpp b/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-subscribe.sqlpp index 4a5cbbc..5a1832c 100644 --- a/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-subscribe.sqlpp +++ b/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-subscribe.sqlpp @@ -34,7 +34,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.sqlpp b/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.sqlpp index 508eaa2..c825006 100644 --- a/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.sqlpp +++ b/asterix-bad/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.sqlpp @@ -34,7 +34,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp index 5e1a742..8e20dcb 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp @@ -35,7 +35,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp index 69c3e3e..b85ba91 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp @@ -35,7 +35,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp index cd6db81..1c7fdcc 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp @@ -35,7 +35,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp index cde68a7..7a1c5a1 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp @@ -23,3 +23,4 @@ from Metadata.`Channel` result, Metadata.`Dataset` x where x.DatasetName = result.SubscriptionsDatasetName or x.DatasetName = result.ResultsDatasetName order by x.DatasetName +; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp index cd6db81..1c7fdcc 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp @@ -35,7 +35,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.1.ddl.sqlpp index 9febd43..fe1db99 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.1.ddl.sqlpp @@ -30,16 +30,16 @@ use channels; create type userLocation as { userId: int, roomNumber: int -} +}; create type watchedUser as { userId: int, name: string -} +}; create type roomSecurity as { roomNumber: int, securityGuardName: string, securityGuardNumber: string -} +}; create dataset watchedUsers(watchedUser) primary key userId; http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.4.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.4.query.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.4.query.sqlpp index de8d3e8..8612077 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.4.query.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.4.query.sqlpp @@ -28,3 +28,4 @@ use channels; select test.BrokerName, test.param0 from roomRecordsSubscriptions test order by test.BrokerName +; http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.8.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.8.query.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.8.query.sqlpp index 1f9851f..91473b9 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.8.query.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.8.query.sqlpp @@ -28,3 +28,4 @@ use channels; select result.result.userId from roomRecordsResults result order by result.result.userId +; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp index 52942ba..09a74e3 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp @@ -35,7 +35,7 @@ create type TweetMessageTypeuuid as closed { message_text: string, countA: int32, countB: int32 -} +}; create dataset TweetMessageuuids(TweetMessageTypeuuid) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp index ef6a39c..cd0510d 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp @@ -20,4 +20,5 @@ use channels; select value param1 from nearbyTweetChannelSubscriptions -order by param1 \ No newline at end of file +order by param1 +; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp index 8b0b05c..42fd4aa 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp @@ -30,7 +30,7 @@ use channels; create type userLocation as { userId: int, roomNumber: int -} +}; create dataset UserLocations(userLocation) primary key userId; http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure/delete_procedure.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure/delete_procedure.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure/delete_procedure.1.ddl.sqlpp index face703..7dbf136 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure/delete_procedure.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure/delete_procedure.1.ddl.sqlpp @@ -30,7 +30,7 @@ use channels; create type myLocation as { timeStamp: datetime, roomNumber: int -} +}; create dataset UserLocations(myLocation) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/procedure/insert_procedure/insert_procedure.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/procedure/insert_procedure/insert_procedure.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/procedure/insert_procedure/insert_procedure.1.ddl.sqlpp index 783aacb..0d3064b 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/procedure/insert_procedure/insert_procedure.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/procedure/insert_procedure/insert_procedure.1.ddl.sqlpp @@ -30,7 +30,7 @@ use channels; create type myLocation as { timeStamp: datetime, roomNumber: int -} +}; create dataset UserLocations(myLocation) http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.1.ddl.sqlpp index 8cdfc6a..0c43739 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.1.ddl.sqlpp @@ -30,7 +30,7 @@ use channels; create type myLocation as { timeStamp: datetime, roomNumber: int -} +}; create dataset UserLocations(myLocation) @@ -38,5 +38,5 @@ primary key timeStamp; create procedure findMe() { select roomNumber from UserLocations -order by timeStamp; +order by timeStamp }; http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.2.update.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.2.update.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.2.update.sqlpp index 28370e9..aaaaf8b 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.2.update.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.2.update.sqlpp @@ -28,3 +28,4 @@ use channels; insert into UserLocations([ {"timeStamp":current_datetime(), "roomNumber":222}] ) +; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.4.update.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.4.update.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.4.update.sqlpp index ef3184b..9b50f4b 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.4.update.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.4.update.sqlpp @@ -26,4 +26,4 @@ use channels; insert into UserLocations([ {"timeStamp":current_datetime(), "roomNumber":225}] -) +); http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/e3cd0f6c/asterix-bad/src/test/resources/runtimets/queries/procedure/repetitive_insert_procedure/repetitive_insert_procedure.1.ddl.sqlpp ---------------------------------------------------------------------- diff --git a/asterix-bad/src/test/resources/runtimets/queries/procedure/repetitive_insert_procedure/repetitive_insert_procedure.1.ddl.sqlpp b/asterix-bad/src/test/resources/runtimets/queries/procedure/repetitive_insert_procedure/repetitive_insert_procedure.1.ddl.sqlpp index b89d997..76f7f38 100644 --- a/asterix-bad/src/test/resources/runtimets/queries/procedure/repetitive_insert_procedure/repetitive_insert_procedure.1.ddl.sqlpp +++ b/asterix-bad/src/test/resources/runtimets/queries/procedure/repetitive_insert_procedure/repetitive_insert_procedure.1.ddl.sqlpp @@ -30,7 +30,7 @@ use channels; create type myLocation as { timeStamp: datetime, roomNumber: int -} +}; create dataset UserLocations(myLocation)
