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/06/26 22:41:02 UTC
asterixdb-bad git commit: Comment with channel body
Repository: asterixdb-bad
Updated Branches:
refs/heads/resultsFinalVersion d7e09a96c -> 501d878dc
Comment with channel body
Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/501d878d
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/501d878d
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/501d878d
Branch: refs/heads/resultsFinalVersion
Commit: 501d878dc8c19ae585d2a83762612fbcd1c3b6ba
Parents: d7e09a9
Author: Steven Glenn Jacobs <sj...@ucr.edu>
Authored: Tue Jun 26 15:40:16 2018 -0700
Committer: Steven Glenn Jacobs <sj...@ucr.edu>
Committed: Tue Jun 26 15:40:16 2018 -0700
----------------------------------------------------------------------
.../bad/lang/statement/CreateChannelStatement.java | 16 ++++++++++++++++
1 file changed, 16 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/501d878d/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 b2ffa1b..eecf937 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
@@ -241,6 +241,22 @@ public class CreateChannelStatement extends ExtensionStatement {
private JobSpecification createChannelJob(IStatementExecutor statementExecutor, MetadataProvider metadataProvider,
IHyracksClientConnection hcc, IHyracksDataset hdc, Stats stats) throws Exception {
+ /*
+ SET inline_with "false";
+ insert into channels.ChannelNameResults as a (
+ with channelExecutionTime as current_datetime()
+ select result, channelExecutionTime, sub.channelSubId as channelSubId,current_datetime() as deliveryTime,
+ (select b.BrokerEndPoint, bs.brokerSubId from
+ channels.ChannelNameBrokerSubscriptions bs,
+ Metadata.`Broker` b
+ where bs.BrokerName = b.BrokerName
+ and bs.DataverseName = b.DataverseName
+ and bs.channelSubId = sub.channelSubId
+ ) as brokerSubIds
+ from channels.ChannelNameChannelSubscriptions sub,
+ channels.ChannelFunctionName(sub.param0, sub.param1, ...) result
+ ) returning a;
+ */
StringBuilder builder = new StringBuilder();
builder.append("SET inline_with \"false\";\n");
if (!push) {