Change in asterixdb[master]: [ASTERIXDB-2152][FUN][COMP] Enable specifying computation lo...

["Xikui Wang (Code Review)" <do...@asterixdb.incubator.apache.org>]

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 (#5).

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-app/src/main/java/org/apache/asterix/api/common/APIFramework.java
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/results/feeds/feeds_13/feeds_13.1.adm
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-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java
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
16 files changed, 266 insertions(+), 52 deletions(-)


  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/14/2114/5
-- 
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: 5
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Xikui Wang <xk...@gmail.com>
Gerrit-Reviewer: Anon. E. Moose #1000171
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>