Repository: camel Updated Branches: refs/heads/master be05f73e0 -> dbaeb9d7a
RDD should be configurable on the component level. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/dbaeb9d7 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/dbaeb9d7 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/dbaeb9d7 Branch: refs/heads/master Commit: dbaeb9d7a720a5d2bb30e00eaca6d5fc414801f7 Parents: be05f73 Author: Henryk Konsek <hekon...@gmail.com> Authored: Fri Dec 11 13:03:28 2015 +0100 Committer: Henryk Konsek <hekon...@gmail.com> Committed: Fri Dec 11 13:03:28 2015 +0100 ---------------------------------------------------------------------- .../camel/component/spark/SparkComponent.java | 21 ++++++++++++++++++++ .../camel/component/spark/SparkEndpoint.java | 14 +++++++++++++ 2 files changed, 35 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/dbaeb9d7/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkComponent.java b/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkComponent.java index 08c34d6..d82798b 100644 --- a/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkComponent.java +++ b/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkComponent.java @@ -20,9 +20,14 @@ import java.util.Map; import org.apache.camel.Endpoint; import org.apache.camel.impl.UriEndpointComponent; +import org.apache.spark.api.java.AbstractJavaRDDLike; public class SparkComponent extends UriEndpointComponent { + private AbstractJavaRDDLike rdd; + + private RddCallback rddCallback; + public SparkComponent() { super(SparkEndpoint.class); } @@ -32,4 +37,20 @@ public class SparkComponent extends UriEndpointComponent { return new SparkEndpoint(uri, this, EndpointType.valueOf(remaining)); } + public AbstractJavaRDDLike getRdd() { + return rdd; + } + + public void setRdd(AbstractJavaRDDLike rdd) { + this.rdd = rdd; + } + + public RddCallback getRddCallback() { + return rddCallback; + } + + public void setRddCallback(RddCallback rddCallback) { + this.rddCallback = rddCallback; + } + } http://git-wip-us.apache.org/repos/asf/camel/blob/dbaeb9d7/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java b/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java index 54e8f54..40c86e1 100644 --- a/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java +++ b/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java @@ -58,6 +58,20 @@ public class SparkEndpoint extends DefaultEndpoint { this.endpointType = endpointType; } + // Life-cycle + + @Override + protected void doStart() throws Exception { + super.doStart(); + + if (rdd == null) { + rdd = getComponent().getRdd(); + } + if (rddCallback == null) { + rddCallback = getComponent().getRddCallback(); + } + } + // Overridden @Override
