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&qualifer=first&valueType=java.lang.String&family=address&qualifer=number&valueType2=java.lang.Integer&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> </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> </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> </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> </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">