@UriEndpoint(firstVersion="2.19.0",
scheme="drill",
title="Drill",
syntax="drill:host",
producerOnly=true,
label="database,sql")
public class DrillEndpoint
extends org.apache.camel.impl.DefaultPollingEndpoint
Constructor and Description |
---|
DrillEndpoint(String uri,
DrillComponent component)
creates a drill endpoint
|
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
String |
getClusterId() |
String |
getDirectory() |
String |
getHost() |
DrillConnectionMode |
getMode()
Connection mode: zk: Zookeeper drillbit: Drillbit direct connection
https://drill.apache.org/docs/using-the-jdbc-driver/
|
Integer |
getPort() |
boolean |
isSingleton() |
List<?> |
queryForList(ResultSet rs) |
void |
setClusterId(String clusterId)
Cluster ID
https://drill.apache.org/docs/using-the-jdbc-driver/#determining-the-cluster-id
|
void |
setDirectory(String directory)
Drill directory in ZooKeeper
|
void |
setHost(String host)
ZooKeeper host name or IP address.
|
void |
setMode(DrillConnectionMode mode) |
void |
setPort(Integer port)
ZooKeeper port number
|
String |
toJDBCUri() |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public DrillEndpoint(String uri, DrillComponent component)
uri
- the endpoint uricomponent
- the componentpublic org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
createConsumer
in class org.apache.camel.impl.DefaultPollingEndpoint
Exception
public boolean isSingleton()
public String toJDBCUri()
public List<?> queryForList(ResultSet rs) throws SQLException
SQLException
public String getHost()
public void setHost(String host)
host
- public Integer getPort()
public void setPort(Integer port)
port
- public String getDirectory()
public void setDirectory(String directory)
directory
- public String getClusterId()
public void setClusterId(String clusterId)
clusterId
- public DrillConnectionMode getMode()
public void setMode(DrillConnectionMode mode)
Apache Camel