You might be using a feature of PhoenixHBaseStorage that I am not familiar with. When I use store to Phoenix, my "into" value is simply this:
… into 'hbase://MY_TABLE_NAME' … If one can specify specific column families and column names, I'd like to learn more about that myself. I saw no mention of it at http://phoenix.apache.org/pig_integration.html except for the loading. On Fri, Jul 25, 2014 at 9: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 > > > > >
