[
https://issues.apache.org/jira/browse/PHOENIX-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15015423#comment-15015423
]
Diego Fustes Villadóniga edited comment on PHOENIX-2435 at 11/20/15 8:45 AM:
-----------------------------------------------------------------------------
Hi [~jmahonin],
You approach works for me, thanks!
Before, I was trying to do the following:
{code}
val configuration = PerseusHBaseConfiguration.create()
val columns = List(RUN_NAME, ODOTICK, GLOBAL_SENSOR_NUMBER,
SHOT_POSITIONAL_ANGLE, MFL)
val whereClause = RUN_NAME + " = " + "\'" + runName + "\'"
val selectQuery = buildSelect(SHOT, columns.asJava, whereClause)
configuration.set(PhoenixConfigurationUtil.SELECT_STATEMENT, selectQuery)
val shotRDD = sc.phoenixTableAsRDD(SHOT, Seq(RUN_NAME, ODOTICK,
GLOBAL_SENSOR_NUMBER, SHOT_POSITIONAL_ANGLE, MFL), conf = configuration)
{code}
Could it be that the configuration is lost somewhere?
was (Author: diego.fustes):
Hi [~jmahonin],
You approach works for me, thanks!
Before, I was trying to do the following:
{code}
val columns = List(RUN_NAME, ODOTICK, GLOBAL_SENSOR_NUMBER,
SHOT_POSITIONAL_ANGLE, MFL)
val whereClause = RUN_NAME + " = " + "\'" + runName + "\'"
val selectQuery = buildSelect(SHOT, columns.asJava, whereClause)
configuration.set(PhoenixConfigurationUtil.SELECT_STATEMENT, selectQuery)
val shotRDD = sc.phoenixTableAsRDD(SHOT, Seq(RUN_NAME, ODOTICK,
GLOBAL_SENSOR_NUMBER, SHOT_POSITIONAL_ANGLE, MFL), conf = configuration)
{code}
Could it be that the configuration is lost somewhere?
> Where clause does not work for phoenix-spark create phoenix RDD
> ---------------------------------------------------------------
>
> Key: PHOENIX-2435
> URL: https://issues.apache.org/jira/browse/PHOENIX-2435
> Project: Phoenix
> Issue Type: Bug
> Affects Versions: 4.4.0
> Reporter: Diego Fustes Villadóniga
>
> I create a phoenix RDD by passing the next query:
> SELECT RN,ODO,GSN,ANG,MFL FROM SHOT WHERE RN = 'TUBFL04M0'
> It seems that the where clause is not taking effect and all rows are readed
> into the RDD
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
