spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From BiksN <bikrantneup...@gmail.com>
Subject Issue with Spark HBase connector streamBulkGet method
Date Mon, 29 Aug 2016 03:57:13 GMT
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-unsubscribe@spark.apache.org


Mime
View raw message