Hi, The phoenix-spark module allows passing in a custom 'predicate', as long as no aggregation functions are used. You can see examples here: https://github.com/apache/phoenix/blob/master/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala#L215-L234
Re: offsetting, once you have the RDD (or DataFrame), you can skip rows there, but there's no way to pass in an offset to the original query. Josh On Tue, Aug 4, 2015 at 11:13 AM, Hafiz Mujadid <[email protected]> wrote: > > Hi all! > > How can we pass custom query to spark phoenix load method? do we have > some way to skip first n rows in result just like in sql we have offset > keyword to skip first n records. > > Thanks >
