You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bu...@apache.org on 2014/03/17 03:21:09 UTC

svn commit: r901916 - in /websites/production/camel/content: cache/main.pageCache hbase.html

Author: buildbot
Date: Mon Mar 17 02:21:08 2014
New Revision: 901916

Log:
Production update by buildbot for camel

Modified:
    websites/production/camel/content/cache/main.pageCache
    websites/production/camel/content/hbase.html

Modified: websites/production/camel/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.

Modified: websites/production/camel/content/hbase.html
==============================================================================
--- websites/production/camel/content/hbase.html (original)
+++ websites/production/camel/content/hbase.html Mon Mar 17 02:21:08 2014
@@ -217,7 +217,7 @@
 <script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[hbase:mutable?family=name&amp;qualifer=first&amp;valueType=java.lang.String&amp;family=address&amp;qualifer=number&amp;valueType2=java.lang.Integer&amp;rowType=java.lang.Long
 ]]></script>
 </div></div><p>The example above will create a model object that is consisted of the specified fields and the scan results will populate the model object with values. Finally the mapping strategy will be used to map this model to the camel message.</p><h4 id="hbase-SupportedURIoptionsonconsumer">Supported URI options on consumer</h4><div class="confluenceTableSmall">
-<table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p> Name </p></th><th colspan="1" rowspan="1" class="confluenceTh"><p> Default Value </p></th><th colspan="1" rowspan="1" class="confluenceTh"><p> Description </p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>initialDelay</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>1000</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> Milliseconds before the first polling starts. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>delay</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>500</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> Milliseconds before the next poll. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>useFixedDelay</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>true</code> </p></td><td colsp
 an="1" rowspan="1" class="confluenceTd"><p> Controls if fixed delay or fixed rate is used. See <a shape="rect" class="external-link" href="http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/ScheduledExecutorService.html" rel="nofollow">ScheduledExecutorService</a> in JDK for details. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> timeUnit </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>TimeUnit.MILLISECONDS</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> time unit for <code>initialDelay</code> and <code>delay</code> options. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>runLoggingLevel</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>TRACE</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <strong>Camel 2.8:</strong> The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for tha
 t. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>operation</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>CamelHBasePut</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The HBase operation to perform. <strong>Supported values</strong>: <code>CamelHBasePut</code>, <code>CamelHBaseGet</code>, <code>CamelHBaseDelete</code>, and <code>CamelHBaseScan</code>. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>maxResults</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>100</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The maximum number of rows to scan. <strong>Supported operations:</strong> <code>CamelHBaseScan</code>. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>mappingStrategyName</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>header</code> </p></td><td colspan="1" rowspan="1"
  class="confluenceTd"><p> The strategy to use for mapping Camel messages to HBase columns. Supported values: <code>header</code>, or <code>body</code>. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>mappingStrategyClassName</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>null</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The class name of a custom mapping strategy implementation. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>filters</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>null</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> A list of filters. <strong>Supported operations</strong>: <code>CamelHBaseScan</code> </p></td></tr></tbody></table>
+<table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p> Name </p></th><th colspan="1" rowspan="1" class="confluenceTh"><p> Default Value </p></th><th colspan="1" rowspan="1" class="confluenceTh"><p> Description </p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>initialDelay</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>1000</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> Milliseconds before the first polling starts. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>delay</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>500</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> Milliseconds before the next poll. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>useFixedDelay</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>true</code> </p></td><td colsp
 an="1" rowspan="1" class="confluenceTd"><p> Controls if fixed delay or fixed rate is used. See <a shape="rect" class="external-link" href="http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/ScheduledExecutorService.html" rel="nofollow">ScheduledExecutorService</a> in JDK for details. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> timeUnit </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>TimeUnit.MILLISECONDS</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> time unit for <code>initialDelay</code> and <code>delay</code> options. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>runLoggingLevel</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>TRACE</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <strong>Camel 2.8:</strong> The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for tha
 t. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>operation</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>CamelHBasePut</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The HBase operation to perform. <strong>Supported values</strong>: <code>CamelHBasePut</code>, <code>CamelHBaseGet</code>, <code>CamelHBaseDelete</code>, and <code>CamelHBaseScan</code>. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>maxResults</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>100</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The maximum number of rows to scan. <strong>Supported operations:</strong> <code>CamelHBaseScan</code>. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>mappingStrategyName</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>header</code> </p></td><td colspan="1" rowspan="1"
  class="confluenceTd"><p> The strategy to use for mapping Camel messages to HBase columns. Supported values: <code>header</code>, or <code>body</code>. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>mappingStrategyClassName</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>null</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The class name of a custom mapping strategy implementation. </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>filters</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>null</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> A list of filters. <strong>Supported operations</strong>: <code>CamelHBaseScan</code> </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>remove</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>true</code> </p></td><td colspan="1" rowspan="1" class=
 "confluenceTd"><p> If the option is true, Camel HBase Consumer will remove the rows which it processes.</p></td></tr></tbody></table>
 </div><p>Header mapping options:</p><div class="confluenceTableSmall">
 <table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p> Name </p></th><th colspan="1" rowspan="1" class="confluenceTh"><p> Default Value </p></th><th colspan="1" rowspan="1" class="confluenceTh"><p> Description </p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>rowId</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The id of the row. This has limited use as the row usually changes per Exchange.</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>rowType</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> String </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The type to covert row id to. <strong>Supported operations</strong>: CamelHBaseScan </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>family</code> </p></td><td colspan="1" rowspan="1" class="conflu
 enceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The column family. *upports a number suffix for referring to more than one columns </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>qualifier</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The column qualifier. *Supports a number suffix for referring to more than one columns </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>value</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> The value. Supports a number suffix for referring to more than one columns </p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p> <code>rowModel</code> </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> String </p></td><td colspan="1" rowspan="1" class="confluenceTd"><p> An inst
 ance of org.apache.camel.component.hbase.model.HBaseRow which describes how each row should be modeled </p></td></tr></tbody></table>
 </div><p>If the role of the rowModel is not clear, it allows you to construct the HBaseRow modle programmatically instead of "describing" it with uri options (such as family, qualifier, type etc).</p><h3 id="hbase-HBaseIdempotentrepository">HBase Idempotent repository</h3><p>The camel-hbase component also provides an idempotent repository which can be used when you want to make sure that each message is processed only once. The HBase idempotent repository is configured with a table, a column family and a column qualifier and will create to that table a row per message.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">