Snappydata SQL WITH

Question

J'utilise Snappydata pour exécuter certaines requêtes, et utiliser le sql avec la déclaration:

WITH x AS (
    SELECT DISTINCT col_a, col_b 
    FROM table_a 
) 
INSERT INTO table_b 
SELECT x.col_a, x.col_b 
FROM x 
    JOIN table_c c ON x.col_a = c.col_a and x.col_b = c.col_b 

Ce code sql fonctionne très bien lors de l'exécution en mode local, mais lorsque je soumets le fichier jar compilé groupe Snappydata, il renvoie une erreur indiquant la table « APP.X » n'existe pas,

org.apache.spark.sql.TableNotFoundException: Table 'APP.X' not found; 

une idée pourquoi cela se produit?

Answer 1

essayer d'ajouter de x

WITH x AS (
    SELECT DISTINCT col_a, col_b 
    FROM table_a 
) 

INSERT 
    INTO table_b 
SELECT x.col_a, 
     x.col_b 
    FROM x 
    JOIN table_c c 
    ON x.col_a = c.col_a 
    AND x.col_b = c.col_b 

Answer 2

Ceci est une limitation connue en raison de la résolution approximative de la règle traitement des requêtes (AQP) qui tente de résoudre le nom prématurément. Nous l'avons vu lors de l'exécution de requêtes TPC-DS. Il est fixé sur le dernier maître AQP et le correctif sera disponible en version 1.0. Pour l'instant, il y a deux options:

a) Modifier la variante sous-requête normale:

INSERT INTO table_b 
SELECT x.col_a, x.col_b 
FROM (SELECT DISTINCT col_a, col_b FROM table_a) x 
    JOIN table_c c 
    ON x.col_a = c.col_a 
    AND x.col_b = c.col_b 

b) Ou sinon en utilisant des requêtes PAQ, alors vous pouvez sortir pot snappydata-PAQ du répertoire des pots de produits