我有一个方法测试,其中一个参数是hbase结果 org.apache.hadoop.hbase.client.Result
现在我有一些hbase结果数据,我已经保存在一个文件中,并为它创建了一个Dataframe并加载了它。
我想把这个Dataframe数据传递给我的方法来测试一些功能。但是,问题是,我需要通过它作为一个结果。
我需要帮助转换Spark Dataframe
到hbase org.apache.hadoop.hbase.client.Result
.
我有一个方法测试,其中一个参数是hbase结果 org.apache.hadoop.hbase.client.Result
现在我有一些hbase结果数据,我已经保存在一个文件中,并为它创建了一个Dataframe并加载了它。
我想把这个Dataframe数据传递给我的方法来测试一些功能。但是,问题是,我需要通过它作为一个结果。
我需要帮助转换Spark Dataframe
到hbase org.apache.hadoop.hbase.client.Result
.
1条答案
按热度按时间kqqjbcuj1#
我已经采取了一个Dataframe,并试图提取
org.apache.hadoop.hbase.client.Result
从那开始。这可以通过RDD完成。日志: