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 <[email protected]> Authored: Tue Jul 31 12:28:04 2018 -0700 Committer: Steven Glenn Jacobs <[email protected]> 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 {
