你能告诉我newapihadooprdd对maven的依赖性吗。我的代码是:
JavaPairRDD<ImmutableBytesWritable, Result> hBaseRDD = ctx.newAPIHadoopRDD(
conf,
TextInputFormat.class,,
org.apache.hadoop.hbase.io.ImmutableBytesWritable.class,
org.apache.hadoop.hbase.client.Result.class);
事先谢谢你的帮助。
1条答案
按热度按时间dphi5xsq1#
您正在使用textinputformat。必须是tableinputformat。您使用的conf是sparkconf还是org.apache.hadoop.conf.configuration。?
maven依赖项。
代码: