3
python-apiでQualiferFilterのようなフィルタを使用してHBaseから行を取得したいとします。
私はHBaseからコードのような行を取得する方法を知っています。Spark:python-apiでQualaseFilterなどのHBaseフィルタを使用する方法
host = 'localhost'
keyConv = "org.apache.spark.examples.pythonconverters.ImmutableBytesWritableToStringConverter"
valueConv = "org.apache.spark.examples.pythonconverters.HBaseResultToStringConverter"
conf = {"hbase.zookeeper.quorum": host, "hbase.mapreduce.inputtable": "user",
"hbase.mapreduce.scan.columns": "u:uid",
"hbase.mapreduce.scan.row.start": "1", "hbase.mapreduce.scan.row.stop": "100"}
rdd = sc.newAPIHadoopRDD("org.apache.hadoop.hbase.mapreduce.TableInputFormat",
"org.apache.hadoop.hbase.io.ImmutableBytesWritable",
"org.apache.hadoop.hbase.client.Result",
keyConverter=keyConv, valueConverter=valueConv, conf=conf)
しかし、フィルタを使用して行を取得したいと考えています。
追加する必要があるコードのタイプは何ですか?
あなたがこれを行う方法を見つけ出すのですか? – void
解決策が見つかりませんでした。結局、私はScala APIを使用します。私は、Python APIは本番環境ではまだ使用できないと思います。 – penlight