Added parameterized procedures
authorSteven Glenn Jacobs <sjaco002@ucr.edu>
Tue, 14 Nov 2017 18:21:43 +0000 (10:21 -0800)
committerSteven Glenn Jacobs <sjaco002@ucr.edu>
Tue, 14 Nov 2017 18:21:43 +0000 (10:21 -0800)
commit8b53ce556eaac45c6698e448687f9e77eecc85e8
treee304dde3ef12579f0be189d01e4a6c53f55f2b10
parent1f36ec759df1a97156db05897962ead20a41a4aa
Added parameterized procedures

Add tests, including concurrent/parameterized execution
delete and query procedures can both use parameters
these will use Asterix job parameters to assign at runtime
Add timeStamp index to channel results
Cleanup result code for query procedures
Prevent repetitive jobs from executing
multiple iterations concurrently

Change-Id: I999879b1cae0de179a1d3c232fa940228979f4fe
46 files changed:
asterix-bad/pom.xml
asterix-bad/src/main/java/org/apache/asterix/bad/BADConstants.java
asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/metadata/PrecompiledJobEventListener.java with 86% similarity]
asterix-bad/src/main/resources/asterix-build-configuration.xml [moved from asterix-bad/src/test/resources/conf/asterix-build-configuration.xml with 100% similarity]
asterix-bad/src/main/resources/lang-extension/lang.txt
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADAsterixHyracksIntegrationUtil.java [new file with mode: 0644]
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADExecutionTest.java
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADOptimizerTest.java
asterix-bad/src/test/resources/optimizerts/queries/channel/channel-advanced.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan
asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan
asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.4.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.6.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp
asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.4.sleep.sqlpp
asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.5.query.sqlpp
asterix-bad/src/test/resources/runtimets/queries/procedure/concurrent_procedure/concurrent_procedure.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/concurrent_procedure/concurrent_procedure.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/concurrent_procedure/concurrent_procedure.3.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/concurrent_procedure/concurrent_procedure.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure_with_parameters/delete_procedure_with_parameters.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure_with_parameters/delete_procedure_with_parameters.2.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure_with_parameters/delete_procedure_with_parameters.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/delete_procedure_with_parameters/delete_procedure_with_parameters.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/channel/disasters_with_friends/disasters_with_friends.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/procedure/concurrent_procedure/concurrent_procedure.4.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/procedure/delete_procedure_with_parameters/delete_procedure_with_parameters.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/procedure/delete_procedure_with_parameters/delete_procedure_with_parameters.2.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/procedure/query_procedure_with_parameters/query_procedure_with_parameters.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/procedure/query_procedure_with_parameters/query_procedure_with_parameters.2.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/testsuite.xml