org.apache.camel.component.hbase
Class HBaseEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by 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.


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
HBaseEndpoint(String uri, HBaseComponent component, org.apache.hadoop.hbase.client.HTablePool tablePool, String tableName)
           
 
Method Summary
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
 org.apache.camel.Producer createProducer()
           
 org.apache.hadoop.hbase.client.HBaseAdmin getAdmin()
           
 CellMappingStrategyFactory getCellMappingStrategyFactory()
           
 org.apache.hadoop.conf.Configuration getConfiguration()
           
 List<org.apache.hadoop.hbase.filter.Filter> getFilters()
           
 String getMappingStrategyClassName()
           
 String getMappingStrategyName()
           
 int getMaxMessagesPerPoll()
           
 int getMaxResults()
           
 String getOperation()
           
 HBaseRemoveHandler getRemoveHandler()
           
 HBaseRow getRowModel()
           
 boolean isRemove()
           
 boolean isSingleton()
           
 void setAdmin(org.apache.hadoop.hbase.client.HBaseAdmin admin)
           
 void setCellMappingStrategyFactory(CellMappingStrategyFactory cellMappingStrategyFactory)
           
 void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
           
 void setFilters(List<org.apache.hadoop.hbase.filter.Filter> filters)
           
 void setMappingStrategyClassName(String mappingStrategyClassName)
           
 void setMappingStrategyName(String mappingStrategyName)
           
 void setMaxMessagesPerPoll(int maxMessagesPerPoll)
           
 void setMaxResults(int maxResults)
           
 void setOperation(String operation)
           
 void setRemove(boolean remove)
           
 void setRemoveHandler(HBaseRemoveHandler removeHandler)
           
 void setRowModel(HBaseRow rowModel)
           
 
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 class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

HBaseEndpoint

public HBaseEndpoint(String uri,
                     HBaseComponent component,
                     org.apache.hadoop.hbase.client.HTablePool tablePool,
                     String tableName)
Method Detail

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