Hello Anon. E. Moose #1000171, Jenkins, I'd like you to reexamine a change. Please visit
https://asterix-gerrit.ics.uci.edu/2114 to look at the new patch set (#9). Change subject: [ASTERIXDB-2152][FUN][COMP] Enable specifying computation location ...................................................................... [ASTERIXDB-2152][FUN][COMP] Enable specifying computation location - user model changes: yes Add 'compiler.computation.location' as compiler option for specifying the computation locations for current query. - storage format changes: no - interface changes: no Details: 1. Add a new compiler option 'compiler.computation.location' for specifying computation location for current query. User can use SET `compiler.computation.location` "asterix_nc1;asterix_nc2"; to use specific nodes to compute current query. This option can be used together with the parallelism parameter. While both parameter are used, the parallel computation will be limited to the assigned locations. 2. Use both parameters in start feed query will enable computation in feed, i.e., UDF evaluation, to be evaluated on nodes in parallel.2. Use both parameters in start feed query will enable computation in feed, i.e., UDF evaluation, to be evaluated on nodes in parallel. SET `compiler.parallelism` "3"; SET `compiler.computation.location` "asterix_nc2"; start feed SyntheticTweetFeed; Change-Id: Id7eed5dac03c2f260507e16cf687162d65787bd1 --- M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRandomPartitioningFeedComputationRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.java M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/APIFramework.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/api/common/APIFrameworkTest.java M asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/external-library/return_invalid_type/return_invalid_type.4.query.sqlpp M asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feed-with-external-function/feed-with-external-function.3.update.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feeds_13/feeds_13.1.ddl.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feeds_13/feeds_13.2.lib.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feeds_13/feeds_13.3.update.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feeds_13/feeds_13.5.pollquery.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feeds_13/feeds_13.6.lib.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/feeds/feeds_13/feeds_13.7.ddl.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-sql-sugar/q01_pricing_summary_report_computation_location/q01_pricing_summary_report_computation_location.1.ddl.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-sql-sugar/q01_pricing_summary_report_computation_location/q01_pricing_summary_report_computation_location.2.update.sqlpp A asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-sql-sugar/q01_pricing_summary_report_computation_location/q01_pricing_summary_report_computation_location.3.query.sqlpp M asterixdb/asterix-app/src/test/resources/runtimets/results/api/cluster_state_1/cluster_state_1.1.regexadm M asterixdb/asterix-app/src/test/resources/runtimets/results/external-library/validate-default-library/validate-default-library.1.adm A asterixdb/asterix-app/src/test/resources/runtimets/results/feeds/feeds_13/feeds_13.1.adm M asterixdb/asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/config/CompilerProperties.java M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java M asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties M asterixdb/asterix-external-data/src/test/resources/library_descriptor.xml M asterixdb/asterix-installer/src/test/resources/integrationts/library/results/library-metadata/functionDataset/functionDataset.1.adm A asterixdb/asterix-installer/zk.pkg.tar M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java A asterixdb/asterix-yarn/ittest/results/library-functions/getCapital/getCapital.1.adm A asterixdb/asterix-yarn/ittest/results/library-functions/insert-from-select/insert-from-select.1.adm A asterixdb/asterix-yarn/ittest/results/library-functions/mysum/mysum.1.adm A asterixdb/asterix-yarn/ittest/results/library-functions/toUpper/toUpper.1.adm A asterixdb/asterix-yarn/ittest/results/library-metadata/functionDataset/functionDataset.1.adm M hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AssignPOperator.java M hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/properties/DefaultNodeGroupDomain.java 33 files changed, 478 insertions(+), 75 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/14/2114/9 -- To view, visit https://asterix-gerrit.ics.uci.edu/2114 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newpatchset Gerrit-Change-Id: Id7eed5dac03c2f260507e16cf687162d65787bd1 Gerrit-PatchSet: 9 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Xikui Wang <xkk...@gmail.com> Gerrit-Reviewer: Anon. E. Moose #1000171 Gerrit-Reviewer: Jenkins <jenk...@fulliautomatix.ics.uci.edu>