我正在尝试使用spark从hbase获取数据。
JavaPairRDD<ImmutableBytesWritable, Result> javaPairRdd =
sc.newAPIHadoopRDD(hbaseConf,
TableInputFormat.class,ImmutableBytesWritable.class, Result.class);
但我需要从一个范围内获取元素。例如:第1000条记录到第2000条记录。
我正在尝试使用spark从hbase获取数据。
JavaPairRDD<ImmutableBytesWritable, Result> javaPairRdd =
sc.newAPIHadoopRDD(hbaseConf,
TableInputFormat.class,ImmutableBytesWritable.class, Result.class);
但我需要从一个范围内获取元素。例如:第1000条记录到第2000条记录。
暂无答案!
目前还没有任何答案,快来回答吧!