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