Spark-2447 : Spark on HBase

[tmalaska]

Add common solution for sending upsert actions to HBase (put, deletes,
and increment)

This is the first pull request: mainly to test the review process, but there are still a number of things that I plan to add this week.

1. Clean up the pom file
2. Add unit tests for the HConnectionStaticCache

If I have time I will also add the following:

1. Support for Java
2. Additional unit tests for Java
3. Additional unit tests for Spark Streaming

[witgo]

Two spaces for indentation

[SparkQA]

QA tests have started for PR 1608. This patch merges cleanly.
View progress: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/17237/consoleFull

[SparkQA]

QA results for PR 1608:
- This patch FAILED unit tests.
- This patch merges cleanly
- This patch adds the following public classes (experimental):
@serializable class HBaseContext(@transient sc: SparkContext,
protected class hconnectionCleanerTask extends TimerTask {

For more information see test ouptut:
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/17237/consoleFull

[srowen]

You shouldn't specify versions in the children poms. In fact, you can't, since this one in particular has to be overridden by hadoop.version. You can remove all <version> in this file. In fact there is already an hbase.version defined in the parent, which affects the code examples. You may also have to harmonize the examples with the newer HBase.

[SparkQA]

QA tests have started for PR 1608. This patch merges cleanly.
View progress: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/17316/consoleFull

[SparkQA]

QA results for PR 1608:
- This patch PASSES unit tests.
- This patch merges cleanly
- This patch adds the following public classes (experimental):
@serializable class HBaseContext(@transient sc: SparkContext,
protected class hconnectionCleanerTask extends TimerTask {

For more information see test ouptut:
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/17316/consoleFull

[rxin]

Does HBase have some sort of schema information? If yes, maybe we can add it as a data source in SchemaRDD?

[SparkQA]

QA tests have started for PR 1608. This patch merges cleanly.
View progress: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/17382/consoleFull

[SparkQA]

QA results for PR 1608:
- This patch FAILED unit tests.
- This patch merges cleanly
- This patch adds the following public classes (experimental):
@serializable class HBaseContext(@transient sc: SparkContext,
protected class hconnectionCleanerTask extends TimerTask {

For more information see test ouptut:
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/17382/consoleFull

[tdas]

Is there a need for this constructor? Better to do the following.

class HBaseContext(@transient sc: Sparkcontext, @transient config: Configuration) extends Serializable {
    val broadcastConf = sc.broadcast(new SerializableWritable(config))
}