[
https://issues.apache.org/jira/browse/PHOENIX-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14559643#comment-14559643
]
Seth Brogan commented on PHOENIX-1999:
--------------------------------------
[[email protected]], sorry for the delay in my response. I ran an
example in my development environment, here are the steps and results:
In Phoenix:
[code]
CREATE TABLE IF NOT EXISTS "my_table" (rowkey VARCHAR PRIMARY KEY, "a" VARCHAR,
"my_id" VARCHAR);
CREATE TABLE IF NOT EXISTS "my_other_table" (rowkey VARCHAR PRIMARY KEY, "x"
VARCHAR, "my_id" VARCHAR);
UPSERT INTO "my_table" ("ROWKEY", "a", "my_id") VALUES ('abc|123', 'abc',
'123');
UPSERT INTO "my_other_table" ("ROWKEY", "x", "my_id") VALUES ('xyz|123', 'xyz',
'123');
[/code]
In a Grunt shell:
[code]
REGISTER s3n://my_bucket/hadoop/lib/phoenix-4.1.0-client-hadoop2.jar;
my_table = LOAD 'hbase://query/SELECT * FROM "my_table"' USING
org.apache.phoenix.pig.PhoenixHBaseLoader('localhost:/hbase');
DUMP my_table;
(abc|123,abc,123)
my_other_table = LOAD 'hbase://query/SELECT * FROM "my_other_table"' USING
org.apache.phoenix.pig.PhoenixHBaseLoader('localhost:/hbase');
DUMP my_other_table;
(xyz|123,xyz,123)
A = LOAD 'hbase://query/SELECT "t1"."a", "t2"."x" FROM "my_table" AS "t1" JOIN
"my_other_table" AS "t2" ON "t1"."my_id" = "t2"."my_id"' USING
org.apache.phoenix.pig.PhoenixHBaseLoader('localhost:/hbase');
DUMP A;
(,)
[/code]
> Phoenix Pig Loader does not return data when selecting from multiple tables
> in a query with a join
> --------------------------------------------------------------------------------------------------
>
> Key: PHOENIX-1999
> URL: https://issues.apache.org/jira/browse/PHOENIX-1999
> Project: Phoenix
> Issue Type: Bug
> Affects Versions: 4.1.0
> Environment: Pig 0.14.3, Hadoop 2.5.2
> Reporter: Seth Brogan
> Assignee: maghamravikiran
>
> The Phoenix Pig Loader does not return data in Pig when selecting specific
> columns from multiple tables in a join query.
> Example:
> {code}
> DESCRIBE my_table;
> my_table: {a: chararray, my_id: chararray}
> DUMP my_table;
> (abc, 123)
> DESCRIBE join_table;
> join_table: {x: chararray, my_id: chararray}
> DUMP join_table;
> (xyz, 123)
> A = LOAD 'hbase://query/SELECT "t1"."a", "t2"."x" FROM "my_table" AS "t1"
> JOIN "join_table" AS "t2" ON "t1"."my_id" = "t2"."my_id"' using
> org.apache.phoenix.pig.PhoenixHBaseLoader('localhost');
> DUMP A;
> (,)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
