public class RddSparkProducer
extends org.apache.camel.impl.DefaultProducer
Constructor and Description |
---|
RddSparkProducer(SparkEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
collectResults(org.apache.camel.Exchange exchange,
Object result) |
SparkEndpoint |
getEndpoint() |
void |
process(org.apache.camel.Exchange exchange) |
protected org.apache.spark.api.java.JavaRDDLike |
resolveRdd(org.apache.camel.Exchange exchange) |
protected RddCallback |
resolveRddCallback(org.apache.camel.Exchange exchange) |
createExchange, createExchange, createExchange, doStart, doStop, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public RddSparkProducer(SparkEndpoint endpoint)
public SparkEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
protected void collectResults(org.apache.camel.Exchange exchange, Object result)
protected org.apache.spark.api.java.JavaRDDLike resolveRdd(org.apache.camel.Exchange exchange)
protected RddCallback resolveRddCallback(org.apache.camel.Exchange exchange)
Apache Camel