You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by sj...@apache.org on 2018/08/03 20:13:22 UTC
[12/14] asterixdb-bad git commit: Commented with the query that we
want
Commented with the query that we want
Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/18d43920
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/18d43920
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/18d43920
Branch: refs/heads/resultsFinalVersion
Commit: 18d43920952757c8ca47d66f759662d31c2a9d3b
Parents: bf1da24
Author: Steven Glenn Jacobs <sj...@ucr.edu>
Authored: Tue Jul 31 12:28:04 2018 -0700
Committer: Steven Glenn Jacobs <sj...@ucr.edu>
Committed: Tue Jul 31 12:28:04 2018 -0700
----------------------------------------------------------------------
.../bad/lang/statement/CreateChannelStatement.java | 17 ++++++++---------
1 file changed, 8 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/18d43920/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 e77d098..76e3e82 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
@@ -256,19 +256,18 @@ public class CreateChannelStatement extends ExtensionStatement {
* ) returning a;
*
* push version:
- * set inline_with "false";
- * select value {"payload": {"result":result, "subscriptionIds": brokerSubIds}} from (
+ * SET inline_with "false";
+ * select value {"payload": {"result":r, "subscriptionId": brokerSubId}} from (
* with channelExecutionTime as current_datetime()
- * select b.BrokerEndPoint, result, bs.brokerSubId as brokerSubId, channelExecutionTime
- * from channels.EmergenciesNearMeChannelChannelSubscriptions sub,
- * channels.EmergenciesNearMe(sub.param0,sub.param1) result
- * channels.EmergenciesNearMeChannelBrokerSubscriptions bs,
- * Metadata.Broker b
+ * select b.BrokerEndPoint, result as r, bs.brokerSubId as brokerSubId, channelExecutionTime
+ * from steven.EmergencyChannelChannelSubscriptions sub,
+ * steven.RecentEmergenciesNearUser(sub.param0) result,
+ * steven.EmergencyChannelBrokerSubscriptions bs,
+ * steven.Broker b
* where bs.BrokerName = b.BrokerName
* and bs.DataverseName = b.DataverseName
* and bs.channelSubId = sub.channelSubId
- * ) results
- * group by BrokerEndPoint,result, channelExecutionTime group as brokerSubIds (brokerSubId as subscriptionId);
+ * ) results;
*/
private JobSpecification createChannelJob(IStatementExecutor statementExecutor, MetadataProvider metadataProvider,
IHyracksClientConnection hcc, IHyracksDataset hdc, Stats stats) throws Exception {