public class HdfsProducer
extends org.apache.camel.impl.DefaultProducer
Modifier and Type | Class and Description |
---|---|
static class |
HdfsProducer.SplitStrategy |
static class |
HdfsProducer.SplitStrategyType |
Constructor and Description |
---|
HdfsProducer(HdfsEndpoint endpoint,
HdfsConfiguration config) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
HdfsEndpoint |
getEndpoint() |
void |
process(org.apache.camel.Exchange exchange) |
createExchange, createExchange, createExchange, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public HdfsProducer(HdfsEndpoint endpoint, HdfsConfiguration config)
public HdfsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
Apache Camel