Запрос hbase с использованием искры - PullRequest
Новая
       12

Запрос hbase с использованием искры

0 голосов
/ 28 апреля 2020

У меня есть список строк строк, и мне нужно получить данные из hbase на основе этих ключей. У меня есть код ниже 

Configuration conf = HBaseConfiguration.create();
conf.set(TableInputFormat.INPUT_TABLE, "table_name");
Scan scan =new Scan();
        scan.setRowPrefixFilter(Bytes.toBytes("d3a97e8f02234371a014e89bacdb3c4f"));
conf.set(TableInputFormat.SCAN, convertScanToString(scan));
JavaSparkContext jsc = new JavaSparkContext(new SparkConf());
JavaPairRDD<ImmutableBytesWritable, Result> source = jsc
                .newAPIHadoopRDD(conf, TableInputFormat.class,
                        ImmutableBytesWritable.class, Result.class);
Result result = Result.EMPTY_RESULT;

У меня есть потоковое задание, которое получает ключи от kafka, и мне нужно посмотреть up hbase на основе этих ключей для получения дополнительных данных.

Может ли кто-нибудь помочь с извлечением данных из hbase несколькими ключами строки?

...