ime(Bytes.toLong(v1._2.getValue(
>>>
>>> Bytes.toBytes("si"), Bytes.toBytes("at";
>>>
>>> return person;
>>> }
>>>
t; JavaSchemaRDD schemaPeople = sqlCtx.applySchema(people, Person.class);
>> schemaPeople.registerAsTable("people");
>>
>> // SQL can be run over RDDs that have been registered as
>> tables.
>> JavaSchemaRDD t
ark using start-all.sh script with 2 workers
Any pointers will be of a great help
Regards,
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Hbase-job-taking-long-time-tp11541.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
-
