I'm trying to use streamBulkGet method in my Spark application. I want to
save the result of this streamBulkGet to a JavaDStream object, but I'm
unable to get the code compiled. I get error:
Required: org.apache....JavaDStream<String>
Found: void
Here is the code:
JavaDStream<String> x =
this.javaHBaseContext.streamBulkGet(TableName.valueOf("x"),
1000,
rowsRdd,
get -> {
return new Get(get);
}
,
result -> {
return Bytes.toString(result.getValue(Bytes.toBytes("c"),
Bytes.toBytes("y")));
});
Based on the method signature, it should return a JavaDStream object, but
the error message says otherwise.
I must be doing something wrong, can someone please help me figure how I can
get the JavaDStream result.
Thank you!
Bikrant
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Issue-with-Spark-HBase-connector-streamBulkGet-method-tp27613.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscr...@spark.apache.org
