Hi Martin,
I noticed phoenix-3.0.0-incubating-client.jar doesn't have the feature
of passing explicit column names during STORE. I did a download from
http://phoenix.apache.org/download.html and checked it.
So please try,
STORE LoadProducts INTO 'hbase://SCHEMA.TABLE' using
org.apache.phoenix.pig.PhoenixHBaseStorage('$zk','-batchSize 5000');
Please let me know how it goes.
Regards
Ravi
On Fri, Jul 25, 2014 at 7:19 AM, Randy Martin <[email protected]>
wrote:
> I am getting the following error when issuing a Store command in Pig:
>
>
>
> Caused by: java.io.IOException: Location must use the hbase protocol,
> hbase://tableName[/columnList]. Supplied
> location=file:/tmp/temp-172455017/tmp1219147161
>
>
>
> The code is very simple, loading from a file and storing to a Phoenix
> table.
>
>
>
>
>
> REGISTER phoenix-3.0.0-incubating-client.jar
>
>
>
> set hbase.zookeeper.quorum ='$zk';
>
> Staging = LOAD '$filename' USING PigStorage('|') as (Column1:int);
>
>
>
> TempStaging = LIMIT Staging 1;
>
>
>
> LoadProducts = FOREACH TempStaging GENERATE (int)Column1 AS Column1:int,
> CurrentTime() AS UpdateTime:datetime;
>
>
>
> --DUMP Loading;
>
> STORE LoadProducts
>
> INTO 'hbase://SCHEMA.TABLE/COLUMN1,CF.COLUMN2'
>
> using org.apache.phoenix.pig.PhoenixHBaseStorage('$zk','-batchSize
> 5000');
>
>
>
>
>
> Search points to SetStoreLocation, where it is evaluating the URI on the
> INTO clause. The error implies that I gave SetStoreLocation the Load
> location not the Store location.
>
>
>
> Any help would be appreciated.
>
> Randy
>
>
>
>
>
