org.apache.camel.component.hbase
Class HBaseEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.component.hbase.HBaseEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class HBaseEndpoint
- extends org.apache.camel.impl.DefaultEndpoint
Represents an HBase endpoint.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
HBaseEndpoint
public HBaseEndpoint(String uri,
HBaseComponent component,
org.apache.hadoop.hbase.client.HTablePool tablePool,
String tableName)
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
isSingleton
public boolean isSingleton()
getConfiguration
public org.apache.hadoop.conf.Configuration getConfiguration()
setConfiguration
public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
getAdmin
public org.apache.hadoop.hbase.client.HBaseAdmin getAdmin()
setAdmin
public void setAdmin(org.apache.hadoop.hbase.client.HBaseAdmin admin)
getMaxResults
public int getMaxResults()
setMaxResults
public void setMaxResults(int maxResults)
getFilters
public List<org.apache.hadoop.hbase.filter.Filter> getFilters()
setFilters
public void setFilters(List<org.apache.hadoop.hbase.filter.Filter> filters)
getOperation
public String getOperation()
setOperation
public void setOperation(String operation)
getCellMappingStrategyFactory
public CellMappingStrategyFactory getCellMappingStrategyFactory()
setCellMappingStrategyFactory
public void setCellMappingStrategyFactory(CellMappingStrategyFactory cellMappingStrategyFactory)
getMappingStrategyName
public String getMappingStrategyName()
setMappingStrategyName
public void setMappingStrategyName(String mappingStrategyName)
getMappingStrategyClassName
public String getMappingStrategyClassName()
setMappingStrategyClassName
public void setMappingStrategyClassName(String mappingStrategyClassName)
getRowModel
public HBaseRow getRowModel()
setRowModel
public void setRowModel(HBaseRow rowModel)
isRemove
public boolean isRemove()
setRemove
public void setRemove(boolean remove)
getRemoveHandler
public HBaseRemoveHandler getRemoveHandler()
setRemoveHandler
public void setRemoveHandler(HBaseRemoveHandler removeHandler)
getMaxMessagesPerPoll
public int getMaxMessagesPerPoll()
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
Apache CAMEL