Add push-based channels and improve broker notifications
authorSteven Glenn Jacobs <sjaco002@ucr.edu>
Thu, 12 Apr 2018 20:19:50 +0000 (13:19 -0700)
committerSteven Glenn Jacobs <sjaco002@ucr.edu>
Thu, 12 Apr 2018 20:19:50 +0000 (13:19 -0700)
commit345b0f5729d3a6ed0564707ec25b56750c5366ec
treeed2c7571e66fce226a69d40b3de767f0dcb7e734
parent9e13d72552e9499458cd6d95e7459462198b5e2a
Add push-based channels and improve broker notifications

Change-Id: Ie3c7cae0f015d6bc01dd912499565bb12c15abc3
asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/rules/InsertBrokerNotifierForChannelRule.java
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerOperator.java
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerPOperator.java
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java
asterix-bad/src/main/resources/lang-extension/lang.txt
asterix-bad/src/test/resources/optimizerts/queries/channel/channel-push.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/channel/channel-push.plan [new file with mode: 0644]