public class HiveSparkProducer
extends org.apache.camel.impl.DefaultProducer
Constructor and Description |
---|
HiveSparkProducer(SparkEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
SparkEndpoint |
getEndpoint() |
void |
process(org.apache.camel.Exchange exchange) |
protected org.apache.spark.sql.hive.HiveContext |
resolveHiveContext() |
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 HiveSparkProducer(SparkEndpoint endpoint)
public SparkEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
protected org.apache.spark.sql.hive.HiveContext resolveHiveContext()
Apache Camel