You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by he...@apache.org on 2015/12/16 22:00:42 UTC
camel git commit: Improved logging.
Repository: camel
Updated Branches:
refs/heads/master b7ae8147b -> 26dbc438c
Improved logging.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/26dbc438
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/26dbc438
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/26dbc438
Branch: refs/heads/master
Commit: 26dbc438c4ecc0efa8a453c55aa0e51a4a6c4773
Parents: b7ae814
Author: Henryk Konsek <he...@gmail.com>
Authored: Wed Dec 16 22:00:37 2015 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Wed Dec 16 22:00:37 2015 +0100
----------------------------------------------------------------------
.../java/org/apache/camel/component/spark/SparkEndpoint.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/26dbc438/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 1d758c4..17ebc2a 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
@@ -28,6 +28,10 @@ import org.slf4j.Logger;
import static org.slf4j.LoggerFactory.getLogger;
+
+/**
+ * Spark endpoint can be used to create various type of producers, including RDD-, DataFrame- and Hive-based.
+ */
// @UriEndpoint(scheme = "spark", producerOnly = true, title = "Apache Spark", syntax = "spark:jobType", label = "bigdata,iot")
public class SparkEndpoint extends DefaultEndpoint {
@@ -84,10 +88,13 @@ public class SparkEndpoint extends DefaultEndpoint {
public Producer createProducer() throws Exception {
LOG.debug("Creating {} Spark producer.", endpointType);
if (endpointType == EndpointType.rdd) {
+ LOG.debug("About to create RDD producer.");
return new RddSparkProducer(this);
} else if (endpointType == EndpointType.dataframe) {
+ LOG.debug("About to create DataFrame producer.");
return new DataFrameSparkProducer(this);
} else {
+ LOG.debug("About to create Hive producer.");
return new HiveSparkProducer(this);
}
}
@@ -104,7 +111,6 @@ public class SparkEndpoint extends DefaultEndpoint {
// Setters & getters
-
@Override
public SparkComponent getComponent() {
return (SparkComponent) super.getComponent();