public class DataFrameSparkProducer
extends org.apache.camel.impl.DefaultProducer
Constructor and Description |
---|
DataFrameSparkProducer(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.sql.DataFrame |
resolveDataFrame(org.apache.camel.Exchange exchange) |
protected DataFrameCallback |
resolveDataFrameCallback(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 DataFrameSparkProducer(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.sql.DataFrame resolveDataFrame(org.apache.camel.Exchange exchange)
protected DataFrameCallback resolveDataFrameCallback(org.apache.camel.Exchange exchange)
Apache Camel