Repository: camel Updated Branches: refs/heads/master 678006152 -> f561a8b7e
CAMEL-7999: More components include documentation Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d39e91a0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d39e91a0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d39e91a0 Branch: refs/heads/master Commit: d39e91a059d1f95e351fc446be55400597cc0bf7 Parents: 6780061 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jan 4 11:47:59 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jan 4 11:47:59 2015 +0100 ---------------------------------------------------------------------- .../camel/component/hbase/HBaseComponent.java | 9 +++++++-- .../apache/camel/component/hbase/HBaseEndpoint.java | 16 ++++++++++++++++ 2 files changed, 23 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d39e91a0/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseComponent.java b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseComponent.java index 48d08fa..a402b6f 100644 --- a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseComponent.java +++ b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseComponent.java @@ -17,10 +17,11 @@ package org.apache.camel.component.hbase; import java.util.Map; + import org.apache.camel.Endpoint; import org.apache.camel.component.hbase.model.HBaseCell; import org.apache.camel.component.hbase.model.HBaseRow; -import org.apache.camel.impl.DefaultComponent; +import org.apache.camel.impl.UriEndpointComponent; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.client.HTablePool; @@ -28,12 +29,16 @@ import org.apache.hadoop.hbase.client.HTablePool; /** * Represents the component that manages {@link HBaseEndpoint}. */ -public class HBaseComponent extends DefaultComponent { +public class HBaseComponent extends UriEndpointComponent { private Configuration configuration; private HTablePool tablePool; private int poolMaxSize = 10; + public HBaseComponent() { + super(HBaseEndpoint.class); + } + @Override protected void doStart() throws Exception { if (configuration == null) { http://git-wip-us.apache.org/repos/asf/camel/blob/d39e91a0/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java index 7704200..ff547ef 100644 --- a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java +++ b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java @@ -17,12 +17,16 @@ package org.apache.camel.component.hbase; import java.util.List; + import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.component.hbase.mapping.CellMappingStrategyFactory; import org.apache.camel.component.hbase.model.HBaseRow; import org.apache.camel.impl.DefaultEndpoint; +import org.apache.camel.spi.UriEndpoint; +import org.apache.camel.spi.UriParam; +import org.apache.camel.spi.UriPath; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTablePool; @@ -31,23 +35,35 @@ import org.apache.hadoop.hbase.filter.Filter; /** * Represents an HBase endpoint. */ +@UriEndpoint(scheme = "hbase", consumerClass = HBaseConsumer.class, label = "hadoop") public class HBaseEndpoint extends DefaultEndpoint { private Configuration configuration; + @UriPath private final String tableName; private final HTablePool tablePool; private HBaseAdmin admin; //Operation properties. + @UriParam(defaultValue = "100") private int maxResults = 100; + @UriParam private List<Filter> filters; + @UriParam private String operation; + @UriParam(defaultValue = "true") private boolean remove = true; + @UriParam private String mappingStrategyName; + @UriParam private String mappingStrategyClassName; + @UriParam private CellMappingStrategyFactory cellMappingStrategyFactory = new CellMappingStrategyFactory(); + @UriParam private HBaseRemoveHandler removeHandler = new HBaseDeleteHandler(); + @UriParam private HBaseRow rowModel; + @UriParam private int maxMessagesPerPoll; public HBaseEndpoint(String uri, HBaseComponent component, HTablePool tablePool, String tableName) {
