diff --git a/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/create-hbase-log-appender-admin-ui.png b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/create-hbase-log-appender-admin-ui.png new file mode 100644 index 0000000000..4158173625 Binary files /dev/null and b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/create-hbase-log-appender-admin-ui.png differ diff --git a/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config-zookeeper.png b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config-zookeeper.png new file mode 100644 index 0000000000..80451660ba Binary files /dev/null and b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config-zookeeper.png differ diff --git a/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config1.png b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config1.png new file mode 100644 index 0000000000..31a50b0b9f Binary files /dev/null and b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config1.png differ diff --git a/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config2.png b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config2.png new file mode 100644 index 0000000000..fbe4522575 Binary files /dev/null and b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/attach/hbase-log-appender-config2.png differ diff --git a/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/index.md b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/index.md new file mode 100644 index 0000000000..54be3a9c4c --- /dev/null +++ b/doc/Programming-guide/Key-platform-features/Data-collection/HBase-log-appender/index.md @@ -0,0 +1,119 @@ +* TOC +{:toc} + +The HBase log appender is used to transfer logs from the [Operations service]({{root_url}}Glossary/#operations-service) to the [HBase](https://hbase.apache.org/) database. This log appender was developed under HBase version 0.98.6. + +## Create HBase Log Appender + +To create an HBase log appender for your application using the [Administration UI]({{root_url}}Glossary/#administration-ui): + +1. Log in to the **Administration UI** page as a [tenant developer]({{root_url}}Glossary/#tenant-developer). + +2. Click **Applications** and open the **Log appenders** page of your application. +Click **Add log appender**. + +3. On the **Log appender details** page, enter the necessary information and set the **Type** field to **HBase**. + + ![Create hbase log appender](attach/create-hbase-log-appender-admin-ui.png) + +>**NOTE:** The field "Log metadata" is not currently working. +{:.note} + +4. Fill in the **Configuration** section for your log appender and click **Add**. +See [Configure log appender](#configure-log-appender). + + ![HBase log appender configuration](attach/hbase-log-appender-config1.png) + ![](attach/hbase-log-appender-config-zookeeper.png) + ![](attach/hbase-log-appender-config2.png) + +## Configure log appender + +The HBase log appender configuration must match [this Avro schema](/server/appenders/hbase-appender/src/main/avro/HBaseAppenderConfiguration.avsc). + +You can configure the following log appender settings: + +* **Zookeeper Quorum** -- list of Zookeeper hosts responsible for HBase cluster connection. For more than one host, use commas to separate the hosts. +* **Keyspace name** -- HBase namespace used to prefix the data table. The namespace can be previously set in HBase. If it is not, the log appender will create it. +* **Table name** -- HBase table name. +* **Column families** -- specify and configure column families for the HBase table. +* **Column mapping** -- mapping of specific log data to appropriate columns. Use the checkboxes to make any field part of the row key. + + +## Playing with HBase log appender +The example below uses the data collection demo from [My First Kaa Application](/doc/Programming-guide/Your-first-Kaa-application/index.md). However, it extends the number of fields in the log schema. The log appender will send data to Kaa and then persist it to HBase. Some selection queries will be demonstrated using the persisted data. + +Below is the log schema for the application. + +```json +{ + "type":"record", + "name":"Data", + "namespace":"org.kaaproject.kaa.scheme.sample", + "fields":[ + { + "name":"id", + "type":"String" + }, + { + "name":"temperature", + "type":"int" + }, + { + "name":"timestamp", + "type":"long" + }, + { + "name":"location", + "type":"String" + } + ], + "displayName":"Logging scheme" +} +``` +To play around with the HBase log appender: + +1. Follow the application instructions from [My First Kaa Application](/doc/Programming-guide/Your-first-Kaa-application/index.md) and use the log schema described above. + +2. Log in to the **Administration UI** as a tenant developer, open the **Log appenders** page of **My First Kaa Application** and click **Add log appender**. + +3. Follow the HBase log appender configuration settings presented on the figures from [Create HBase Log Appender](#create-hbase-log-appender). + +4. Run the application as described in [My First Kaa Application](/doc/Programming-guide/Your-first-Kaa-application/index.md). + +5. The console will display the following messages. + + My First Kaa Application started + Default sample period: 1 + Sampled temperature: 28 + Sampled temperature: 26 + Sampled temperature: 27 + Sampled temperature: 26 + Sampled temperature: 28 + ... + +6. To verify that your logs have been persisted to HBase, open the HBase shell from the terminal using the command below. + + ```bash + hbase shell + ``` + + Then run + + ```bash + scan 'kaa:myfirstapplication' + ``` + +7. The following output will be displayed. + + ```bash + ROW COLUMN+CELL + sensorID+1523616858341 column=info:loc, timestamp=1523616858753, value=sensor_location + sensorID+1523616858341 column=info:temp, timestamp=1523616858753, value=28 + sensorID+1523616858341 column=meta:id, timestamp=1523616858753, value=sensorID + sensorID+1523616858341 column=meta:ts, timestamp=1523616858753, value=1523616858341 + sensorID+1523616859327 column=info:loc, timestamp=1523616859578, value=sensor_location + sensorID+1523616859327 column=info:temp, timestamp=1523616859578, value=26 + sensorID+1523616859327 column=meta:id, timestamp=1523616859578, value=sensorID + sensorID+1523616859327 column=meta:ts, timestamp=1523616859578, value=1523616859327 + ... + ``` diff --git a/server/appenders/hbase-appender/.checkstyle b/server/appenders/hbase-appender/.checkstyle index 5783bc0d77..fcbbc6b7b7 100644 --- a/server/appenders/hbase-appender/.checkstyle +++ b/server/appenders/hbase-appender/.checkstyle @@ -1,7 +1,18 @@ - - - + + + + + + + + + + + + + + diff --git a/server/appenders/hbase-appender/pom.xml b/server/appenders/hbase-appender/pom.xml index 0315fefd38..2a92aa6ec8 100644 --- a/server/appenders/hbase-appender/pom.xml +++ b/server/appenders/hbase-appender/pom.xml @@ -25,8 +25,12 @@ UTF-8 ${basedir}/../../.. + 0.98.6-hadoop2 + 2.5.0 + 1.6 + @@ -68,39 +72,38 @@ org.apache.hbase hbase-client - 0.98.6-hadoop2 + ${hbase.version} org.apache.hbase hbase-common - 0.98.6-hadoop2 + ${hbase.version} org.apache.hbase hbase-protocol - 0.98.6-hadoop2 + ${hbase.version} org.apache.hadoop hadoop-common - 2.4.1 commons-configuration commons-configuration - 1.6 + ${commons-configuration.version} org.apache.hadoop hadoop-auth - 2.4.1 + ${hadoop.version} com.google.protobuf protobuf-java - 2.5.0 + ${protobuf.version} @@ -118,7 +121,7 @@ org.apache.avro avro-maven-plugin - 1.7.7 + ${avro.version} generate-sources @@ -136,8 +139,7 @@ - - + org.apache.maven.plugins maven-checkstyle-plugin diff --git a/server/appenders/hbase-appender/src/main/avro/HBaseAppenderConfiguration.avsc b/server/appenders/hbase-appender/src/main/avro/HBaseAppenderConfiguration.avsc index ee337e0c03..1e2916dabb 100644 --- a/server/appenders/hbase-appender/src/main/avro/HBaseAppenderConfiguration.avsc +++ b/server/appenders/hbase-appender/src/main/avro/HBaseAppenderConfiguration.avsc @@ -118,10 +118,10 @@ "type":"enum", "symbols":[ "NONE", - "DIFF", + "DIFF", "FAST_DIFF", "PREFIX", - "PREFIX_TREE" + "PREFIX_TREE" ] } }, @@ -137,8 +137,8 @@ "NONE", "GZ", "LZ4", - "LZO", - "SNAPPY" + "LZO", + "SNAPPY" ] } }, @@ -146,21 +146,21 @@ "name":"inMemory", "displayName":"In Memory", "weight":0.2, - "by_default":false, + "by_default":false, "type":"boolean" }, { "name":"keepDeletedCells", "displayName":"Keep Deleted Cells", "weight":0.2, - "by_default":false, + "by_default":false, "type":"boolean" }, { "name":"blockCache", "displayName":"Block Cache", "weight":0.2, - "by_default":true, + "by_default":true, "type":"boolean" } ] @@ -201,7 +201,7 @@ "FLOAT", "INT", "TEXT", - "ARRAY" + "ARRAY" ] } }, diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/appender/HBaseLogEventDao.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/appender/HBaseLogEventDao.java index 6f1b12818f..8829bab344 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/appender/HBaseLogEventDao.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/appender/HBaseLogEventDao.java @@ -83,8 +83,8 @@ public HBaseLogEventDao(HBaseAppenderConfiguration config) { LOG.info("HBase Admin Started"); - } catch (Exception e) { - LOG.error("Ops!", e); + } catch (Exception ex) { + LOG.error("ERROR - Unable to establish connection with HBase", ex); } } @@ -95,7 +95,7 @@ public String createHbTable() { //Get table and keyspace names String table = configuration.getTableName().toString().toLowerCase().trim(); String keyspace = configuration.getKeyspace().toString().toLowerCase().trim(); - LOG.info("Starting creation of table: {}",keyspace + ":" + table); + LOG.info("Starting creation of table: {}", keyspace + ":" + table); // Creates the namespace and/or table in case of not existing. @@ -131,8 +131,8 @@ public String createHbTable() { //Format of hbase tables - : namespacedTable = keyspace + ":" + table; - } catch (Exception e) { - LOG.error("Ops",e); + } catch (Exception ex) { + LOG.error("ERROR creating table",ex); } return namespacedTable; } diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Algorithm.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Algorithm.java index 0940d5181f..f632b3b1fa 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Algorithm.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Algorithm.java @@ -3,18 +3,11 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated public enum Algorithm { - NONE, GZ, LZ4, LZO, SNAPPY; - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":" - + "\"Algorithm\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase" - + ".config.gen\",\"symbols\":[\"NONE\",\"GZ\",\"LZ4\",\"LZO\",\"SNAPPY\"]}"); - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } + NONE, GZ, LZ4, LZO, SNAPPY ; + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":\"Algorithm\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"symbols\":[\"NONE\",\"GZ\",\"LZ4\",\"LZO\",\"SNAPPY\"]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } } diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/BloomFilterType.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/BloomFilterType.java index d9bcf34f6a..ca69dad08d 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/BloomFilterType.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/BloomFilterType.java @@ -3,19 +3,11 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated public enum BloomFilterType { - NONE, ROW, ROWCOL; - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":" - + "\"BloomFilterType\",\"namespace\":\"org.kaaproject.kaa.server.appenders." - + "hbase.config.gen\",\"symbols\":[\"NONE\",\"ROW\",\"ROWCOL\"]}"); - - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } + NONE, ROW, ROWCOL ; + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":\"BloomFilterType\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"symbols\":[\"NONE\",\"ROW\",\"ROWCOL\"]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } } diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnFamily.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnFamily.java index 029f5dbccf..19563c2175 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnFamily.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnFamily.java @@ -3,58 +3,20 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated - -public class ColumnFamily extends org.apache.avro.specific.SpecificRecordBase implements - org.apache.avro.specific.SpecificRecord { - - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":" - + "\"ColumnFamily\",\"namespace\":\"org.kaaproject.kaa.server.appenders" - + ".hbase.config.gen\",\"fields\":[{\"name\":\"cfName\",\"type\":\"string\"," - + "\"displayName\":\"Column Family name\",\"weight\":0.4},{\"name\":" - + "\"minVersion\",\"type\":\"int\",\"displayName\":\"Min Version\"," - + "\"weight\":0.2,\"by_default\":0},{\"name\":\"maxVersion\",\"type\":" - + "\"int\",\"displayName\":\"Max Version\",\"weight\":0.2,\"by_default\":1}," - + "{\"name\":\"ttl\",\"type\":[\"int\",\"null\"],\"displayName\":\"TTL\"," - + "\"optional\":true,\"weight\":0.2},{\"name\":\"blockSize\",\"type\":\"int\"," - + "\"displayName\":\"block Size\",\"weight\":0.2,\"by_default\":65536},{\"name\"" - + ":\"scope\",\"type\":\"int\",\"displayName\":\"Replication Scope\",\"weight\":0.2," - + "\"by_default\":0},{\"name\":\"bloomFilter\",\"type\":{\"type\":\"enum\",\"name\":" - + "\"BloomFilterType\",\"symbols\":[\"NONE\",\"ROW\",\"ROWCOL\"]}," - + "\"displayName\":\"Bloom Filter\",\"weight\":0.2,\"by_default\":\"ROW\"},{\"name\":" - + "\"dataBlockEncoding\"," - + "\"type\":{\"type\":\"enum\",\"name\":\"Encoding\",\"symbols\":[\"NONE\",\"DIFF\"," - + "\"FAST_DIFF\",\"PREFIX\",\"PREFIX_TREE\"]},\"displayName\":\"Data Block Encoding\"," - + "\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":\"compression\",\"type\":{\"type\":" - + "\"enum\",\"name\":\"Algorithm\",\"symbols\"" - + ":[\"NONE\",\"GZ\",\"LZ4\",\"LZO\",\"SNAPPY\"]}," - + "\"displayName\":\"Compression\",\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":" - + "\"inMemory\",\"type\":\"boolean\",\"displayName\":\"In Memory\",\"weight\":0.2," - + "\"by_default\":false},{\"name\":\"keepDeletedCells\",\"type\":" - + "\"boolean\",\"displayName\":" - + "\"Keep Deleted Cells\",\"weight\":0.2,\"by_default\":false},{\"name\":" - + "\"blockCache\",\"type\":" - + "\"boolean\",\"displayName\":\"Block Cache\",\"weight\":0.2,\"by_default\":true}]}"); - - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } - +public class ColumnFamily extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"ColumnFamily\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"fields\":[{\"name\":\"cfName\",\"type\":\"string\",\"displayName\":\"Column Family name\",\"weight\":0.4},{\"name\":\"minVersion\",\"type\":\"int\",\"displayName\":\"Min Version\",\"weight\":0.2,\"by_default\":0},{\"name\":\"maxVersion\",\"type\":\"int\",\"displayName\":\"Max Version\",\"weight\":0.2,\"by_default\":1},{\"name\":\"ttl\",\"type\":[\"int\",\"null\"],\"displayName\":\"TTL\",\"optional\":true,\"weight\":0.2},{\"name\":\"blockSize\",\"type\":\"int\",\"displayName\":\"block Size\",\"weight\":0.2,\"by_default\":65536},{\"name\":\"scope\",\"type\":\"int\",\"displayName\":\"Replication Scope\",\"weight\":0.2,\"by_default\":0},{\"name\":\"bloomFilter\",\"type\":{\"type\":\"enum\",\"name\":\"BloomFilterType\",\"symbols\":[\"NONE\",\"ROW\",\"ROWCOL\"]},\"displayName\":\"Bloom Filter\",\"weight\":0.2,\"by_default\":\"ROW\"},{\"name\":\"dataBlockEncoding\",\"type\":{\"type\":\"enum\",\"name\":\"Encoding\",\"symbols\":[\"NONE\",\"DIFF\",\"FAST_DIFF\",\"PREFIX\",\"PREFIX_TREE\"]},\"displayName\":\"Data Block Encoding\",\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":\"compression\",\"type\":{\"type\":\"enum\",\"name\":\"Algorithm\",\"symbols\":[\"NONE\",\"GZ\",\"LZ4\",\"LZO\",\"SNAPPY\"]},\"displayName\":\"Compression\",\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":\"inMemory\",\"type\":\"boolean\",\"displayName\":\"In Memory\",\"weight\":0.2,\"by_default\":false},{\"name\":\"keepDeletedCells\",\"type\":\"boolean\",\"displayName\":\"Keep Deleted Cells\",\"weight\":0.2,\"by_default\":false},{\"name\":\"blockCache\",\"type\":\"boolean\",\"displayName\":\"Block Cache\",\"weight\":0.2,\"by_default\":true}]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } @Deprecated public java.lang.CharSequence cfName; @Deprecated public int minVersion; @Deprecated public int maxVersion; @Deprecated public java.lang.Integer ttl; @Deprecated public int blockSize; @Deprecated public int scope; - @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen - .BloomFilterType bloomFilter; - @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen - .Encoding dataBlockEncoding; + @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType bloomFilter; + @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding dataBlockEncoding; @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm compression; @Deprecated public boolean inMemory; @Deprecated public boolean keepDeletedCells; @@ -70,15 +32,7 @@ public ColumnFamily() {} /** * All-args constructor. */ - public ColumnFamily(java.lang.CharSequence cfName, java.lang.Integer minVersion, - java.lang.Integer maxVersion, java.lang.Integer ttl, java.lang.Integer blockSize, - java.lang.Integer scope, - org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType bloomFilter, - org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding dataBlockEncoding, - org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm compression, - java.lang.Boolean inMemory, java.lang.Boolean keepDeletedCells, - java.lang.Boolean blockCache) { - + public ColumnFamily(java.lang.CharSequence cfName, java.lang.Integer minVersion, java.lang.Integer maxVersion, java.lang.Integer ttl, java.lang.Integer blockSize, java.lang.Integer scope, org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType bloomFilter, org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding dataBlockEncoding, org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm compression, java.lang.Boolean inMemory, java.lang.Boolean keepDeletedCells, java.lang.Boolean blockCache) { this.cfName = cfName; this.minVersion = minVersion; this.maxVersion = maxVersion; @@ -93,66 +47,42 @@ public ColumnFamily(java.lang.CharSequence cfName, java.lang.Integer minVersion, this.blockCache = blockCache; } - public org.apache.avro.Schema getSchema() { - return SCHEMA$; - } - + public org.apache.avro.Schema getSchema() { return SCHEMA$; } // Used by DatumWriter. Applications should not call. - /** - * Get Column Family fields. - */ - public java.lang.Object get(int field) { - switch (field) { - case 0: return cfName; - case 1: return minVersion; - case 2: return maxVersion; - case 3: return ttl; - case 4: return blockSize; - case 5: return scope; - case 6: return bloomFilter; - case 7: return dataBlockEncoding; - case 8: return compression; - case 9: return inMemory; - case 10: return keepDeletedCells; - case 11: return blockCache; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + public java.lang.Object get(int field$) { + switch (field$) { + case 0: return cfName; + case 1: return minVersion; + case 2: return maxVersion; + case 3: return ttl; + case 4: return blockSize; + case 5: return scope; + case 6: return bloomFilter; + case 7: return dataBlockEncoding; + case 8: return compression; + case 9: return inMemory; + case 10: return keepDeletedCells; + case 11: return blockCache; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } // Used by DatumReader. Applications should not call. - /** - * Put values. - */ - - @SuppressWarnings(value = "unchecked") - public void put(int field, java.lang.Object value) { - switch (field) { - case 0: cfName = (java.lang.CharSequence)value; - break; - case 1: minVersion = (java.lang.Integer)value; - break; - case 2: maxVersion = (java.lang.Integer)value; - break; - case 3: ttl = (java.lang.Integer)value; - break; - case 4: blockSize = (java.lang.Integer)value; - break; - case 5: scope = (java.lang.Integer)value; - break; - case 6: bloomFilter = (org.kaaproject.kaa.server.appenders.hbase.config.gen - .BloomFilterType)value; - break; - case 7: dataBlockEncoding = (org.kaaproject.kaa.server.appenders.hbase - .config.gen.Encoding)value; - break; - case 8: compression = (org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm)value; - break; - case 9: inMemory = (java.lang.Boolean)value; - break; - case 10: keepDeletedCells = (java.lang.Boolean)value; - break; - case 11: blockCache = (java.lang.Boolean)value; - break; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + @SuppressWarnings(value="unchecked") + public void put(int field$, java.lang.Object value$) { + switch (field$) { + case 0: cfName = (java.lang.CharSequence)value$; break; + case 1: minVersion = (java.lang.Integer)value$; break; + case 2: maxVersion = (java.lang.Integer)value$; break; + case 3: ttl = (java.lang.Integer)value$; break; + case 4: blockSize = (java.lang.Integer)value$; break; + case 5: scope = (java.lang.Integer)value$; break; + case 6: bloomFilter = (org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType)value$; break; + case 7: dataBlockEncoding = (org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding)value$; break; + case 8: compression = (org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm)value$; break; + case 9: inMemory = (java.lang.Boolean)value$; break; + case 10: keepDeletedCells = (java.lang.Boolean)value$; break; + case 11: blockCache = (java.lang.Boolean)value$; break; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } @@ -257,8 +187,7 @@ public org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType getB * Sets the value of the 'bloomFilter' field. * @param value the value to set. */ - public void setBloomFilter(org.kaaproject.kaa.server.appenders - .hbase.config.gen.BloomFilterType value) { + public void setBloomFilter(org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType value) { this.bloomFilter = value; } @@ -273,8 +202,7 @@ public org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding getDataBloc * Sets the value of the 'dataBlockEncoding' field. * @param value the value to set. */ - public void setDataBlockEncoding(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Encoding value) { + public void setDataBlockEncoding(org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding value) { this.dataBlockEncoding = value; } @@ -338,35 +266,26 @@ public void setBlockCache(java.lang.Boolean value) { this.blockCache = value; } - /** Creates a new ColumnFamily RecordBuilder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder newBuilder() { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder(); + /** Creates a new ColumnFamily RecordBuilder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder newBuilder() { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder(); } - - /** Creates a new ColumnFamily RecordBuilder by copying an existing Builder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.ColumnFamily.Builder other) { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder(other); + + /** Creates a new ColumnFamily RecordBuilder by copying an existing Builder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder other) { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder(other); } - - /** Creates a new ColumnFamily RecordBuilder by copying an existing ColumnFamily instance. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.ColumnFamily other) { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder(other); + + /** Creates a new ColumnFamily RecordBuilder by copying an existing ColumnFamily instance */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily other) { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder(other); } - + /** * RecordBuilder for ColumnFamily instances. */ - public static class Builder extends org.apache.avro.specific - .SpecificRecordBuilderBase - implements org.apache.avro.data.RecordBuilder { + public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase + implements org.apache.avro.data.RecordBuilder { private java.lang.CharSequence cfName; private int minVersion; @@ -381,14 +300,13 @@ public static class Builder extends org.apache.avro.specific private boolean keepDeletedCells; private boolean blockCache; - /** Creates a new Builder. */ + /** Creates a new Builder */ private Builder() { super(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.SCHEMA$); } - - /** Creates a Builder by copying an existing Builder. */ - private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder other) { + + /** Creates a Builder by copying an existing Builder */ + private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder other) { super(other); if (isValidValue(fields()[0], other.cfName)) { this.cfName = data().deepCopy(fields()[0].schema(), other.cfName); @@ -439,10 +357,10 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen fieldSetFlags()[11] = true; } } - - /** Creates a Builder by copying an existing ColumnFamily instance. */ + + /** Creates a Builder by copying an existing ColumnFamily instance */ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily other) { - super(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.SCHEMA$); + super(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.SCHEMA$); if (isValidValue(fields()[0], other.cfName)) { this.cfName = data().deepCopy(fields()[0].schema(), other.cfName); fieldSetFlags()[0] = true; @@ -493,323 +411,295 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamil } } - /** Gets the value of the 'cfName' field. */ + /** Gets the value of the 'cfName' field */ public java.lang.CharSequence getCfName() { return cfName; } - - /** Sets the value of the 'cfName' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setCfName(java.lang.CharSequence value) { + + /** Sets the value of the 'cfName' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setCfName(java.lang.CharSequence value) { validate(fields()[0], value); this.cfName = value; fieldSetFlags()[0] = true; return this; } - - /** Checks whether the 'cfName' field has been set. */ + + /** Checks whether the 'cfName' field has been set */ public boolean hasCfName() { return fieldSetFlags()[0]; } - - /** Clears the value of the 'cfName' field. */ + + /** Clears the value of the 'cfName' field */ public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearCfName() { cfName = null; fieldSetFlags()[0] = false; return this; } - /** Gets the value of the 'minVersion' field. */ + /** Gets the value of the 'minVersion' field */ public java.lang.Integer getMinVersion() { return minVersion; } - - /** Sets the value of the 'minVersion' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setMinVersion(int value) { + + /** Sets the value of the 'minVersion' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setMinVersion(int value) { validate(fields()[1], value); this.minVersion = value; fieldSetFlags()[1] = true; return this; } - - /** Checks whether the 'minVersion' field has been set. */ + + /** Checks whether the 'minVersion' field has been set */ public boolean hasMinVersion() { return fieldSetFlags()[1]; } - - /** Clears the value of the 'minVersion' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearMinVersion() { + + /** Clears the value of the 'minVersion' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearMinVersion() { fieldSetFlags()[1] = false; return this; } - /** Gets the value of the 'maxVersion' field. */ + /** Gets the value of the 'maxVersion' field */ public java.lang.Integer getMaxVersion() { return maxVersion; } - - /** Sets the value of the 'maxVersion' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setMaxVersion(int value) { + + /** Sets the value of the 'maxVersion' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setMaxVersion(int value) { validate(fields()[2], value); this.maxVersion = value; fieldSetFlags()[2] = true; return this; } - - /** Checks whether the 'maxVersion' field has been set. */ + + /** Checks whether the 'maxVersion' field has been set */ public boolean hasMaxVersion() { return fieldSetFlags()[2]; } - - /** Clears the value of the 'maxVersion' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearMaxVersion() { + + /** Clears the value of the 'maxVersion' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearMaxVersion() { fieldSetFlags()[2] = false; return this; } - /** Gets the value of the 'ttl' field. */ + /** Gets the value of the 'ttl' field */ public java.lang.Integer getTtl() { return ttl; } - - /** Sets the value of the 'ttl' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setTtl(java.lang.Integer value) { + + /** Sets the value of the 'ttl' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setTtl(java.lang.Integer value) { validate(fields()[3], value); this.ttl = value; fieldSetFlags()[3] = true; return this; } - - /** Checks whether the 'ttl' field has been set. */ + + /** Checks whether the 'ttl' field has been set */ public boolean hasTtl() { return fieldSetFlags()[3]; } - - /** Clears the value of the 'ttl' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearTtl() { + + /** Clears the value of the 'ttl' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearTtl() { ttl = null; fieldSetFlags()[3] = false; return this; } - /** Gets the value of the 'blockSize' field. */ + /** Gets the value of the 'blockSize' field */ public java.lang.Integer getBlockSize() { return blockSize; } - - /** Sets the value of the 'blockSize' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setBlockSize(int value) { + + /** Sets the value of the 'blockSize' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setBlockSize(int value) { validate(fields()[4], value); this.blockSize = value; fieldSetFlags()[4] = true; return this; } - - /** Checks whether the 'blockSize' field has been set. */ + + /** Checks whether the 'blockSize' field has been set */ public boolean hasBlockSize() { return fieldSetFlags()[4]; } - - /** Clears the value of the 'blockSize' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearBlockSize() { + + /** Clears the value of the 'blockSize' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearBlockSize() { fieldSetFlags()[4] = false; return this; } - /** Gets the value of the 'scope' field. */ + /** Gets the value of the 'scope' field */ public java.lang.Integer getScope() { return scope; } - - /** Sets the value of the 'scope' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setScope(int value) { + + /** Sets the value of the 'scope' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setScope(int value) { validate(fields()[5], value); this.scope = value; fieldSetFlags()[5] = true; return this; } - - /** Checks whether the 'scope' field has been set. */ + + /** Checks whether the 'scope' field has been set */ public boolean hasScope() { return fieldSetFlags()[5]; } - - /** Clears the value of the 'scope' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearScope() { + + /** Clears the value of the 'scope' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearScope() { fieldSetFlags()[5] = false; return this; } - /** Gets the value of the 'bloomFilter' field. */ + /** Gets the value of the 'bloomFilter' field */ public org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType getBloomFilter() { return bloomFilter; } - - /** Sets the value of the 'bloomFilter' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setBloomFilter(org.kaaproject.kaa.server.appenders - .hbase.config.gen.BloomFilterType value) { + + /** Sets the value of the 'bloomFilter' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setBloomFilter(org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType value) { validate(fields()[6], value); this.bloomFilter = value; fieldSetFlags()[6] = true; return this; } - - /** Checks whether the 'bloomFilter' field has been set. */ + + /** Checks whether the 'bloomFilter' field has been set */ public boolean hasBloomFilter() { return fieldSetFlags()[6]; } - - /** Clears the value of the 'bloomFilter' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearBloomFilter() { + + /** Clears the value of the 'bloomFilter' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearBloomFilter() { bloomFilter = null; fieldSetFlags()[6] = false; return this; } - /** Gets the value of the 'dataBlockEncoding' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .Encoding getDataBlockEncoding() { + /** Gets the value of the 'dataBlockEncoding' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding getDataBlockEncoding() { return dataBlockEncoding; } - - /** Sets the value of the 'dataBlockEncoding' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setDataBlockEncoding(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Encoding value) { + + /** Sets the value of the 'dataBlockEncoding' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setDataBlockEncoding(org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding value) { validate(fields()[7], value); this.dataBlockEncoding = value; fieldSetFlags()[7] = true; return this; } - - /** Checks whether the 'dataBlockEncoding' field has been set. */ + + /** Checks whether the 'dataBlockEncoding' field has been set */ public boolean hasDataBlockEncoding() { return fieldSetFlags()[7]; } - - /** Clears the value of the 'dataBlockEncoding' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearDataBlockEncoding() { + + /** Clears the value of the 'dataBlockEncoding' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearDataBlockEncoding() { dataBlockEncoding = null; fieldSetFlags()[7] = false; return this; } - /** Gets the value of the 'compression' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .Algorithm getCompression() { + /** Gets the value of the 'compression' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm getCompression() { return compression; } - - /** Sets the value of the 'compression' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setCompression(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Algorithm value) { + + /** Sets the value of the 'compression' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setCompression(org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm value) { validate(fields()[8], value); this.compression = value; fieldSetFlags()[8] = true; return this; } - - /** Checks whether the 'compression' field has been set. */ + + /** Checks whether the 'compression' field has been set */ public boolean hasCompression() { return fieldSetFlags()[8]; } - - /** Clears the value of the 'compression' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearCompression() { + + /** Clears the value of the 'compression' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearCompression() { compression = null; fieldSetFlags()[8] = false; return this; } - /** Gets the value of the 'inMemory' field. */ + /** Gets the value of the 'inMemory' field */ public java.lang.Boolean getInMemory() { return inMemory; } - - /** Sets the value of the 'inMemory' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setInMemory(boolean value) { + + /** Sets the value of the 'inMemory' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setInMemory(boolean value) { validate(fields()[9], value); this.inMemory = value; fieldSetFlags()[9] = true; return this; } - - /** Checks whether the 'inMemory' field has been set. */ + + /** Checks whether the 'inMemory' field has been set */ public boolean hasInMemory() { return fieldSetFlags()[9]; } - - /** Clears the value of the 'inMemory' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearInMemory() { + + /** Clears the value of the 'inMemory' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearInMemory() { fieldSetFlags()[9] = false; return this; } - /** Gets the value of the 'keepDeletedCells' field. */ + /** Gets the value of the 'keepDeletedCells' field */ public java.lang.Boolean getKeepDeletedCells() { return keepDeletedCells; } - - /** Sets the value of the 'keepDeletedCells' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setKeepDeletedCells(boolean value) { + + /** Sets the value of the 'keepDeletedCells' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setKeepDeletedCells(boolean value) { validate(fields()[10], value); this.keepDeletedCells = value; fieldSetFlags()[10] = true; return this; } - - /** Checks whether the 'keepDeletedCells' field has been set. */ + + /** Checks whether the 'keepDeletedCells' field has been set */ public boolean hasKeepDeletedCells() { return fieldSetFlags()[10]; } - - /** Clears the value of the 'keepDeletedCells' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearKeepDeletedCells() { + + /** Clears the value of the 'keepDeletedCells' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearKeepDeletedCells() { fieldSetFlags()[10] = false; return this; } - /** Gets the value of the 'blockCache' field. */ + /** Gets the value of the 'blockCache' field */ public java.lang.Boolean getBlockCache() { return blockCache; } - - /** Sets the value of the 'blockCache' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder setBlockCache(boolean value) { + + /** Sets the value of the 'blockCache' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder setBlockCache(boolean value) { validate(fields()[11], value); this.blockCache = value; fieldSetFlags()[11] = true; return this; } - - /** Checks whether the 'blockCache' field has been set. */ + + /** Checks whether the 'blockCache' field has been set */ public boolean hasBlockCache() { return fieldSetFlags()[11]; } - - /** Clears the value of the 'blockCache' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnFamily.Builder clearBlockCache() { + + /** Clears the value of the 'blockCache' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnFamily.Builder clearBlockCache() { fieldSetFlags()[11] = false; return this; } @@ -818,31 +708,18 @@ public boolean hasBlockCache() { public ColumnFamily build() { try { ColumnFamily record = new ColumnFamily(); - record.cfName = fieldSetFlags()[0] ? this.cfName : - (java.lang.CharSequence) defaultValue(fields()[0]); - record.minVersion = fieldSetFlags()[1] ? this.minVersion : - (java.lang.Integer) defaultValue(fields()[1]); - record.maxVersion = fieldSetFlags()[2] ? this.maxVersion : - (java.lang.Integer) defaultValue(fields()[2]); + record.cfName = fieldSetFlags()[0] ? this.cfName : (java.lang.CharSequence) defaultValue(fields()[0]); + record.minVersion = fieldSetFlags()[1] ? this.minVersion : (java.lang.Integer) defaultValue(fields()[1]); + record.maxVersion = fieldSetFlags()[2] ? this.maxVersion : (java.lang.Integer) defaultValue(fields()[2]); record.ttl = fieldSetFlags()[3] ? this.ttl : (java.lang.Integer) defaultValue(fields()[3]); - record.blockSize = fieldSetFlags()[4] ? this.blockSize : - (java.lang.Integer) defaultValue(fields()[4]); - record.scope = fieldSetFlags()[5] ? this.scope : - (java.lang.Integer) defaultValue(fields()[5]); - record.bloomFilter = fieldSetFlags()[6] ? this.bloomFilter : - (org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType) - defaultValue(fields()[6]); - record.dataBlockEncoding = fieldSetFlags()[7] ? this.dataBlockEncoding : - (org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding) defaultValue(fields()[7]); - record.compression = fieldSetFlags()[8] ? this.compression : - (org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm) - defaultValue(fields()[8]); - record.inMemory = fieldSetFlags()[9] ? this.inMemory : - (java.lang.Boolean) defaultValue(fields()[9]); - record.keepDeletedCells = fieldSetFlags()[10] ? this.keepDeletedCells : - (java.lang.Boolean) defaultValue(fields()[10]); - record.blockCache = fieldSetFlags()[11] ? this.blockCache : - (java.lang.Boolean) defaultValue(fields()[11]); + record.blockSize = fieldSetFlags()[4] ? this.blockSize : (java.lang.Integer) defaultValue(fields()[4]); + record.scope = fieldSetFlags()[5] ? this.scope : (java.lang.Integer) defaultValue(fields()[5]); + record.bloomFilter = fieldSetFlags()[6] ? this.bloomFilter : (org.kaaproject.kaa.server.appenders.hbase.config.gen.BloomFilterType) defaultValue(fields()[6]); + record.dataBlockEncoding = fieldSetFlags()[7] ? this.dataBlockEncoding : (org.kaaproject.kaa.server.appenders.hbase.config.gen.Encoding) defaultValue(fields()[7]); + record.compression = fieldSetFlags()[8] ? this.compression : (org.kaaproject.kaa.server.appenders.hbase.config.gen.Algorithm) defaultValue(fields()[8]); + record.inMemory = fieldSetFlags()[9] ? this.inMemory : (java.lang.Boolean) defaultValue(fields()[9]); + record.keepDeletedCells = fieldSetFlags()[10] ? this.keepDeletedCells : (java.lang.Boolean) defaultValue(fields()[10]); + record.blockCache = fieldSetFlags()[11] ? this.blockCache : (java.lang.Boolean) defaultValue(fields()[11]); return record; } catch (Exception e) { throw new org.apache.avro.AvroRuntimeException(e); diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnMappingElement.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnMappingElement.java index 88e18589b8..9b8b1247ff 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnMappingElement.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/ColumnMappingElement.java @@ -3,31 +3,12 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated -public class ColumnMappingElement extends org.apache.avro.specific.SpecificRecordBase - implements org.apache.avro.specific.SpecificRecord { - - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":" - + "\"ColumnMappingElement\",\"namespace\":\"org.kaaproject.kaa.server." - + "appenders.hbase.config.gen\",\"fields\":[{\"name\":\"value\",\"type\":" - + "\"string\",\"displayName\":\"Value\",\"weight\":0.2,\"by_default\":" - + "\"applicationToken\"},{\"name\":\"valueType\",\"type\":{\"type\":\"enum\"," - + "\"name\":\"Type\",\"symbols\":[\"BIGINT\",\"BLOB\",\"BOOLEAN\",\"DOUBLE\"," - + "\"FLOAT\",\"INT\",\"TEXT\",\"ARRAY\"]},\"displayName\":\"Type\",\"weight\":0.2," - + "\"by_default\":\"TEXT\"},{\"name\":\"cf\",\"type\":\"string\",\"displayName\":" - + "\"ColumnFamily\",\"weight\":0.2},{\"name\":\"columnName\",\"type\":\"string\"," - + "\"displayName\":\"Column\",\"weight\":0.2},{\"name\":\"rowKey\",\"type\":\"boolean\"," - + "\"displayName\":\"Is part of Row key?\",\"weight\":0.1,\"by_default\":false}]}"); - - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } - +public class ColumnMappingElement extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"ColumnMappingElement\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"fields\":[{\"name\":\"value\",\"type\":\"string\",\"displayName\":\"Value\",\"weight\":0.2,\"by_default\":\"applicationToken\"},{\"name\":\"valueType\",\"type\":{\"type\":\"enum\",\"name\":\"Type\",\"symbols\":[\"BIGINT\",\"BLOB\",\"BOOLEAN\",\"DOUBLE\",\"FLOAT\",\"INT\",\"TEXT\",\"ARRAY\"]},\"displayName\":\"Type\",\"weight\":0.2,\"by_default\":\"TEXT\"},{\"name\":\"cf\",\"type\":\"string\",\"displayName\":\"ColumnFamily\",\"weight\":0.2},{\"name\":\"columnName\",\"type\":\"string\",\"displayName\":\"Column\",\"weight\":0.2},{\"name\":\"rowKey\",\"type\":\"boolean\",\"displayName\":\"Is part of Row key?\",\"weight\":0.1,\"by_default\":false}]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } @Deprecated public java.lang.CharSequence value; @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen.Type valueType; @Deprecated public java.lang.CharSequence cf; @@ -44,10 +25,7 @@ public ColumnMappingElement() {} /** * All-args constructor. */ - public ColumnMappingElement(java.lang.CharSequence value, - org.kaaproject.kaa.server.appenders.hbase.config.gen.Type valueType, - java.lang.CharSequence cf, java.lang.CharSequence columnName, - java.lang.Boolean rowKey) { + public ColumnMappingElement(java.lang.CharSequence value, org.kaaproject.kaa.server.appenders.hbase.config.gen.Type valueType, java.lang.CharSequence cf, java.lang.CharSequence columnName, java.lang.Boolean rowKey) { this.value = value; this.valueType = valueType; this.cf = cf; @@ -55,44 +33,28 @@ public ColumnMappingElement(java.lang.CharSequence value, this.rowKey = rowKey; } - public org.apache.avro.Schema getSchema() { - return SCHEMA$; - } - // Used by DatumWriter. Applications should not call. - - /** - * Get column element fields. - */ - public java.lang.Object get(int field) { - switch (field) { - case 0: return value; - case 1: return valueType; - case 2: return cf; - case 3: return columnName; - case 4: return rowKey; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + public org.apache.avro.Schema getSchema() { return SCHEMA$; } + // Used by DatumWriter. Applications should not call. + public java.lang.Object get(int field$) { + switch (field$) { + case 0: return value; + case 1: return valueType; + case 2: return cf; + case 3: return columnName; + case 4: return rowKey; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } - // Used by DatumReader. Applications should not call. - - /** - * Put column element values. - */ - @SuppressWarnings(value = "unchecked") - public void put(int field, java.lang.Object value) { - switch (field) { - case 0: value = (java.lang.CharSequence)value; - break; - case 1: valueType = (org.kaaproject.kaa.server.appenders - .hbase.config.gen.Type)value; - break; - case 2: cf = (java.lang.CharSequence)value; - break; - case 3: columnName = (java.lang.CharSequence)value; - break; - case 4: rowKey = (java.lang.Boolean)value; - break; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + // Used by DatumReader. Applications should not call. + @SuppressWarnings(value="unchecked") + public void put(int field$, java.lang.Object value$) { + switch (field$) { + case 0: value = (java.lang.CharSequence)value$; break; + case 1: valueType = (org.kaaproject.kaa.server.appenders.hbase.config.gen.Type)value$; break; + case 2: cf = (java.lang.CharSequence)value$; break; + case 3: columnName = (java.lang.CharSequence)value$; break; + case 4: rowKey = (java.lang.Boolean)value$; break; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } @@ -171,36 +133,26 @@ public void setRowKey(java.lang.Boolean value) { this.rowKey = value; } - /** Creates a new ColumnMappingElement RecordBuilder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder newBuilder() { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder(); + /** Creates a new ColumnMappingElement RecordBuilder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder newBuilder() { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder(); } - - /** Creates a new ColumnMappingElement RecordBuilder by copying an existing Builder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.ColumnMappingElement.Builder other) { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder(other); + + /** Creates a new ColumnMappingElement RecordBuilder by copying an existing Builder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder other) { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder(other); } - - /** Creates a new ColumnMappingElement RecordBuilder by copying an existing - * ColumnMappingElement instance. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.ColumnMappingElement other) { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder(other); + + /** Creates a new ColumnMappingElement RecordBuilder by copying an existing ColumnMappingElement instance */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement other) { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder(other); } - + /** * RecordBuilder for ColumnMappingElement instances. */ - public static class Builder extends org.apache.avro.specific - .SpecificRecordBuilderBase - implements org.apache.avro.data.RecordBuilder { + public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase + implements org.apache.avro.data.RecordBuilder { private java.lang.CharSequence value; private org.kaaproject.kaa.server.appenders.hbase.config.gen.Type valueType; @@ -208,14 +160,13 @@ public static class Builder extends org.apache.avro.specific private java.lang.CharSequence columnName; private boolean rowKey; - /** Creates a new Builder. */ + /** Creates a new Builder */ private Builder() { super(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.SCHEMA$); } - - /** Creates a Builder by copying an existing Builder. */ - private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder other) { + + /** Creates a Builder by copying an existing Builder */ + private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder other) { super(other); if (isValidValue(fields()[0], other.value)) { this.value = data().deepCopy(fields()[0].schema(), other.value); @@ -238,11 +189,10 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen fieldSetFlags()[4] = true; } } - - /** Creates a Builder by copying an existing ColumnMappingElement instance. */ - private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement other) { - super(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.SCHEMA$); + + /** Creates a Builder by copying an existing ColumnMappingElement instance */ + private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement other) { + super(org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.SCHEMA$); if (isValidValue(fields()[0], other.value)) { this.value = data().deepCopy(fields()[0].schema(), other.value); fieldSetFlags()[0] = true; @@ -265,137 +215,126 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen } } - /** Gets the value of the 'value' field. */ + /** Gets the value of the 'value' field */ public java.lang.CharSequence getValue() { return value; } - - /** Sets the value of the 'value' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder setValue(java.lang.CharSequence value) { + + /** Sets the value of the 'value' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder setValue(java.lang.CharSequence value) { validate(fields()[0], value); this.value = value; fieldSetFlags()[0] = true; return this; } - - /** Checks whether the 'value' field has been set. */ + + /** Checks whether the 'value' field has been set */ public boolean hasValue() { return fieldSetFlags()[0]; } - - /** Clears the value of the 'value' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder clearValue() { + + /** Clears the value of the 'value' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder clearValue() { value = null; fieldSetFlags()[0] = false; return this; } - /** Gets the value of the 'valueType' field. */ + /** Gets the value of the 'valueType' field */ public org.kaaproject.kaa.server.appenders.hbase.config.gen.Type getValueType() { return valueType; } - - /** Sets the value of the 'valueType' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder setValueType(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Type value) { + + /** Sets the value of the 'valueType' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder setValueType(org.kaaproject.kaa.server.appenders.hbase.config.gen.Type value) { validate(fields()[1], value); this.valueType = value; fieldSetFlags()[1] = true; return this; } - - /** Checks whether the 'valueType' field has been set. */ + + /** Checks whether the 'valueType' field has been set */ public boolean hasValueType() { return fieldSetFlags()[1]; } - - /** Clears the value of the 'valueType' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder clearValueType() { + + /** Clears the value of the 'valueType' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder clearValueType() { valueType = null; fieldSetFlags()[1] = false; return this; } - /** Gets the value of the 'cf' field. */ + /** Gets the value of the 'cf' field */ public java.lang.CharSequence getCf() { return cf; } - - /** Sets the value of the 'cf' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder setCf(java.lang.CharSequence value) { + + /** Sets the value of the 'cf' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder setCf(java.lang.CharSequence value) { validate(fields()[2], value); this.cf = value; fieldSetFlags()[2] = true; return this; } - - /** Checks whether the 'cf' field has been set. */ + + /** Checks whether the 'cf' field has been set */ public boolean hasCf() { return fieldSetFlags()[2]; } - - /** Clears the value of the 'cf' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder clearCf() { + + /** Clears the value of the 'cf' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder clearCf() { cf = null; fieldSetFlags()[2] = false; return this; } - /** Gets the value of the 'columnName' field. */ + /** Gets the value of the 'columnName' field */ public java.lang.CharSequence getColumnName() { return columnName; } - - /** Sets the value of the 'columnName' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder setColumnName(java.lang.CharSequence value) { + + /** Sets the value of the 'columnName' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder setColumnName(java.lang.CharSequence value) { validate(fields()[3], value); this.columnName = value; fieldSetFlags()[3] = true; return this; } - - /** Checks whether the 'columnName' field has been set. */ + + /** Checks whether the 'columnName' field has been set */ public boolean hasColumnName() { return fieldSetFlags()[3]; } - - /** Clears the value of the 'columnName' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder clearColumnName() { + + /** Clears the value of the 'columnName' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder clearColumnName() { columnName = null; fieldSetFlags()[3] = false; return this; } - /** Gets the value of the 'rowKey' field. */ + /** Gets the value of the 'rowKey' field */ public java.lang.Boolean getRowKey() { return rowKey; } - - /** Sets the value of the 'rowKey' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder setRowKey(boolean value) { + + /** Sets the value of the 'rowKey' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder setRowKey(boolean value) { validate(fields()[4], value); this.rowKey = value; fieldSetFlags()[4] = true; return this; } - - /** Checks whether the 'rowKey' field has been set. */ + + /** Checks whether the 'rowKey' field has been set */ public boolean hasRowKey() { return fieldSetFlags()[4]; } - - /** Clears the value of the 'rowKey' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .ColumnMappingElement.Builder clearRowKey() { + + /** Clears the value of the 'rowKey' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.ColumnMappingElement.Builder clearRowKey() { fieldSetFlags()[4] = false; return this; } @@ -404,16 +343,11 @@ public boolean hasRowKey() { public ColumnMappingElement build() { try { ColumnMappingElement record = new ColumnMappingElement(); - record.value = fieldSetFlags()[0] ? this.value : - (java.lang.CharSequence) defaultValue(fields()[0]); - record.valueType = fieldSetFlags()[1] ? this.valueType : - (org.kaaproject.kaa.server.appenders.hbase.config.gen.Type) defaultValue(fields()[1]); - record.cf = fieldSetFlags()[2] ? this.cf : - (java.lang.CharSequence) defaultValue(fields()[2]); - record.columnName = fieldSetFlags()[3] ? this.columnName : - (java.lang.CharSequence) defaultValue(fields()[3]); - record.rowKey = fieldSetFlags()[4] ? this.rowKey : - (java.lang.Boolean) defaultValue(fields()[4]); + record.value = fieldSetFlags()[0] ? this.value : (java.lang.CharSequence) defaultValue(fields()[0]); + record.valueType = fieldSetFlags()[1] ? this.valueType : (org.kaaproject.kaa.server.appenders.hbase.config.gen.Type) defaultValue(fields()[1]); + record.cf = fieldSetFlags()[2] ? this.cf : (java.lang.CharSequence) defaultValue(fields()[2]); + record.columnName = fieldSetFlags()[3] ? this.columnName : (java.lang.CharSequence) defaultValue(fields()[3]); + record.rowKey = fieldSetFlags()[4] ? this.rowKey : (java.lang.Boolean) defaultValue(fields()[4]); return record; } catch (Exception e) { throw new org.apache.avro.AvroRuntimeException(e); diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Encoding.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Encoding.java index 20f75b589f..2fe499a059 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Encoding.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Encoding.java @@ -3,19 +3,11 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated public enum Encoding { - NONE, DIFF, FAST_DIFF, PREFIX, PREFIX_TREE; - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":" - + "\"Encoding\",\"namespace\":\"org.kaaproject.kaa.server.appenders" - + ".hbase.config.gen\",\"symbols\":[\"NONE\",\"DIFF\",\"FAST_DIFF\"," - + "\"PREFIX\",\"PREFIX_TREE\"]}"); - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } + NONE, DIFF, FAST_DIFF, PREFIX, PREFIX_TREE ; + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":\"Encoding\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"symbols\":[\"NONE\",\"DIFF\",\"FAST_DIFF\",\"PREFIX\",\"PREFIX_TREE\"]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } } diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/HBaseAppenderConfiguration.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/HBaseAppenderConfiguration.java index 4d45f70235..9224513e1b 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/HBaseAppenderConfiguration.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/HBaseAppenderConfiguration.java @@ -3,73 +3,17 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated -public class HBaseAppenderConfiguration extends org.apache.avro.specific.SpecificRecordBase - implements org.apache.avro.specific.SpecificRecord { - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":" - + "\"HBaseAppenderConfiguration\",\"namespace\":\"org.kaaproject.kaa.server" - + ".appenders.hbase.config.gen\",\"fields\":[{\"name\":\"server\",\"type\":" - + "{\"type\":\"record\",\"name\":\"Server\",\"fields\":[{\"name\":\"zkQuorum\"," - + "\"type\":\"string\",\"displayName\":\"Zookeeper Quorum\",\"weight\":0.75," - + "\"by_default\":\"localhost\"},{\"name\":\"port\",\"type\":\"string\"," - + "\"displayName\":\"Port\",\"weight\":0.25,\"by_default\":\"2181\"}]}," - + "\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\"," - + "\"displayName\":\"Zookeeper Quorum Configuration\"},{\"name\":\"keyspace\"," - + "\"type\":\"string\",\"displayName\":\"Keyspace name\"},{\"name\":" - + "\"tableName\",\"type\":\"string\",\"displayName\":\"Table name\"}," - + "{\"name\":\"columnFamilies\",\"type\":{\"type\":\"array\",\"items\":" - + "{\"type\":\"record\",\"name\":\"ColumnFamily\",\"fields\":[{\"name\":" - + "\"cfName\",\"type\":\"string\",\"displayName\":\"Column Family name\"," - + "\"weight\":0.4},{\"name\":\"minVersion\",\"type\":\"int\",\"displayName\":" - + "\"Min Version\",\"weight\":0.2,\"by_default\":0},{\"name\":\"maxVersion\"," - + "\"type\":\"int\",\"displayName\":\"Max Version\",\"weight\":0.2,\"by_default\":1}" - + ",{\"name\":\"ttl\",\"type\":[\"int\",\"null\"],\"displayName\":\"TTL\"," - + "\"optional\":true,\"weight\":0.2},{\"name\":\"blockSize\",\"type\":\"int\"," - + "\"displayName\":\"block Size\",\"weight\":0.2,\"by_default\":65536}," - + "{\"name\":\"scope\",\"type\":\"int\",\"displayName\":\"Replication Scope\"," - + "\"weight\":0.2,\"by_default\":0},{\"name\":\"bloomFilter\",\"type\":" - + "{\"type\":\"enum\",\"name\":\"BloomFilterType\",\"symbols\":[\"NONE\",\"ROW\"," - + "\"ROWCOL\"]},\"displayName\":\"Bloom Filter\",\"weight\":0.2,\"by_default\":\"ROW\"}," - + "{\"name\":\"dataBlockEncoding\",\"type\":{\"type\":\"enum\",\"name\":\"Encoding\"," - + "\"symbols\":[\"NONE\",\"DIFF\",\"FAST_DIFF\",\"PREFIX\",\"PREFIX_TREE\"]}," - + "\"displayName\":\"Data Block Encoding\",\"weight\":0.2,\"by_default\":\"NONE\"}," - + "{\"name\":\"compression\",\"type\":{\"type\":\"enum\",\"name\":\"Algorithm\"," - + "\"symbols\":[\"NONE\",\"GZ\",\"LZ4\",\"LZO\",\"SNAPPY\"]},\"displayName\":" - + "\"Compression\",\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":\"inMemory\"," - + "\"type\":\"boolean\",\"displayName\":\"In Memory\",\"weight\":0.2," - + "\"by_default\":false},{\"name\":\"keepDeletedCells\",\"type\":\"boolean\"," - + "\"displayName\":\"Keep Deleted Cells\",\"weight\":0.2,\"by_default\":false}," - + "{\"name\":\"blockCache\",\"type\":\"boolean\",\"displayName\":\"Block Cache\"," - + "\"weight\":0.2,\"by_default\":true}]}},\"displayName\":\"Column Families\"," - + "\"minRowCount\":1},{\"name\":\"columnMapping\",\"type\":{\"type\":\"array\"," - + "\"items\":{\"type\":\"record\",\"name\":\"ColumnMappingElement\",\"fields\":" - + "[{\"name\":\"value\",\"type\":\"string\",\"displayName\":\"Value\"," - + "\"weight\":0.2,\"by_default\":\"applicationToken\"},{\"name\":\"valueType\"," - + "\"type\":{\"type\":\"enum\",\"name\":\"Type\",\"symbols\":[\"BIGINT\"," - + "\"BLOB\",\"BOOLEAN\",\"DOUBLE\",\"FLOAT\",\"INT\",\"TEXT\",\"ARRAY\"]}," - + "\"displayName\":\"Type\",\"weight\":0.2,\"by_default\":\"TEXT\"}," - + "{\"name\":\"cf\",\"type\":\"string\",\"displayName\":\"ColumnFamily\"," - + "\"weight\":0.2},{\"name\":\"columnName\",\"type\":\"string\"," - + "\"displayName\":\"Column\",\"weight\":0.2},{\"name\":\"rowKey\"," - + "\"type\":\"boolean\",\"displayName\":\"Is part of Row key?\",\"weight\":0.1," - + "\"by_default\":false}]}},\"displayName\":\"Column Mapping\",\"minRowCount\":1}]}"); - - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } - +public class HBaseAppenderConfiguration extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"HBaseAppenderConfiguration\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"fields\":[{\"name\":\"server\",\"type\":{\"type\":\"record\",\"name\":\"Server\",\"fields\":[{\"name\":\"zkQuorum\",\"type\":\"string\",\"displayName\":\"Zookeeper Quorum\",\"weight\":0.75,\"by_default\":\"localhost\"},{\"name\":\"port\",\"type\":\"string\",\"displayName\":\"Port\",\"weight\":0.25,\"by_default\":\"2181\"}]},\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"displayName\":\"Zookeeper Quorum Configuration\"},{\"name\":\"keyspace\",\"type\":\"string\",\"displayName\":\"Keyspace name\"},{\"name\":\"tableName\",\"type\":\"string\",\"displayName\":\"Table name\"},{\"name\":\"columnFamilies\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ColumnFamily\",\"fields\":[{\"name\":\"cfName\",\"type\":\"string\",\"displayName\":\"Column Family name\",\"weight\":0.4},{\"name\":\"minVersion\",\"type\":\"int\",\"displayName\":\"Min Version\",\"weight\":0.2,\"by_default\":0},{\"name\":\"maxVersion\",\"type\":\"int\",\"displayName\":\"Max Version\",\"weight\":0.2,\"by_default\":1},{\"name\":\"ttl\",\"type\":[\"int\",\"null\"],\"displayName\":\"TTL\",\"optional\":true,\"weight\":0.2},{\"name\":\"blockSize\",\"type\":\"int\",\"displayName\":\"block Size\",\"weight\":0.2,\"by_default\":65536},{\"name\":\"scope\",\"type\":\"int\",\"displayName\":\"Replication Scope\",\"weight\":0.2,\"by_default\":0},{\"name\":\"bloomFilter\",\"type\":{\"type\":\"enum\",\"name\":\"BloomFilterType\",\"symbols\":[\"NONE\",\"ROW\",\"ROWCOL\"]},\"displayName\":\"Bloom Filter\",\"weight\":0.2,\"by_default\":\"ROW\"},{\"name\":\"dataBlockEncoding\",\"type\":{\"type\":\"enum\",\"name\":\"Encoding\",\"symbols\":[\"NONE\",\"DIFF\",\"FAST_DIFF\",\"PREFIX\",\"PREFIX_TREE\"]},\"displayName\":\"Data Block Encoding\",\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":\"compression\",\"type\":{\"type\":\"enum\",\"name\":\"Algorithm\",\"symbols\":[\"NONE\",\"GZ\",\"LZ4\",\"LZO\",\"SNAPPY\"]},\"displayName\":\"Compression\",\"weight\":0.2,\"by_default\":\"NONE\"},{\"name\":\"inMemory\",\"type\":\"boolean\",\"displayName\":\"In Memory\",\"weight\":0.2,\"by_default\":false},{\"name\":\"keepDeletedCells\",\"type\":\"boolean\",\"displayName\":\"Keep Deleted Cells\",\"weight\":0.2,\"by_default\":false},{\"name\":\"blockCache\",\"type\":\"boolean\",\"displayName\":\"Block Cache\",\"weight\":0.2,\"by_default\":true}]}},\"displayName\":\"Column Families\",\"minRowCount\":1},{\"name\":\"columnMapping\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ColumnMappingElement\",\"fields\":[{\"name\":\"value\",\"type\":\"string\",\"displayName\":\"Value\",\"weight\":0.2,\"by_default\":\"applicationToken\"},{\"name\":\"valueType\",\"type\":{\"type\":\"enum\",\"name\":\"Type\",\"symbols\":[\"BIGINT\",\"BLOB\",\"BOOLEAN\",\"DOUBLE\",\"FLOAT\",\"INT\",\"TEXT\",\"ARRAY\"]},\"displayName\":\"Type\",\"weight\":0.2,\"by_default\":\"TEXT\"},{\"name\":\"cf\",\"type\":\"string\",\"displayName\":\"ColumnFamily\",\"weight\":0.2},{\"name\":\"columnName\",\"type\":\"string\",\"displayName\":\"Column\",\"weight\":0.2},{\"name\":\"rowKey\",\"type\":\"boolean\",\"displayName\":\"Is part of Row key?\",\"weight\":0.1,\"by_default\":false}]}},\"displayName\":\"Column Mapping\",\"minRowCount\":1}]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } @Deprecated public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server server; @Deprecated public java.lang.CharSequence keyspace; @Deprecated public java.lang.CharSequence tableName; - @Deprecated public java.util.List columnFamilies; - @Deprecated public java.util.List columnMapping; + @Deprecated public java.util.List columnFamilies; + @Deprecated public java.util.List columnMapping; /** * Default constructor. Note that this does not initialize fields @@ -81,13 +25,7 @@ public HBaseAppenderConfiguration() {} /** * All-args constructor. */ - public HBaseAppenderConfiguration(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Server server, java.lang.CharSequence keyspace, - java.lang.CharSequence tableName, java.util.List columnFamilies, - java.util.List columnMapping) { - + public HBaseAppenderConfiguration(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server server, java.lang.CharSequence keyspace, java.lang.CharSequence tableName, java.util.List columnFamilies, java.util.List columnMapping) { this.server = server; this.keyspace = keyspace; this.tableName = tableName; @@ -95,46 +33,28 @@ public HBaseAppenderConfiguration(org.kaaproject.kaa.server.appenders this.columnMapping = columnMapping; } - public org.apache.avro.Schema getSchema() { - return SCHEMA$; - } - + public org.apache.avro.Schema getSchema() { return SCHEMA$; } // Used by DatumWriter. Applications should not call. - /** - * Get Configuration objects. - */ - public java.lang.Object get(int field) { - switch (field) { - case 0: return server; - case 1: return keyspace; - case 2: return tableName; - case 3: return columnFamilies; - case 4: return columnMapping; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + public java.lang.Object get(int field$) { + switch (field$) { + case 0: return server; + case 1: return keyspace; + case 2: return tableName; + case 3: return columnFamilies; + case 4: return columnMapping; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } // Used by DatumReader. Applications should not call. - - /** - * Get Configuration objects value. - */ - @SuppressWarnings(value = "unchecked") - public void put(int field, java.lang.Object value) { - switch (field) { - case 0: server = (org.kaaproject.kaa.server.appenders - .hbase.config.gen.Server)value; - break; - case 1: keyspace = (java.lang.CharSequence)value; - break; - case 2: tableName = (java.lang.CharSequence)value; - break; - case 3: columnFamilies = (java.util.List)value; - break; - case 4: columnMapping = (java.util.List)value; - break; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + @SuppressWarnings(value="unchecked") + public void put(int field$, java.lang.Object value$) { + switch (field$) { + case 0: server = (org.kaaproject.kaa.server.appenders.hbase.config.gen.Server)value$; break; + case 1: keyspace = (java.lang.CharSequence)value$; break; + case 2: tableName = (java.lang.CharSequence)value$; break; + case 3: columnFamilies = (java.util.List)value$; break; + case 4: columnMapping = (java.util.List)value$; break; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } @@ -186,8 +106,7 @@ public void setTableName(java.lang.CharSequence value) { /** * Gets the value of the 'columnFamilies' field. */ - public java.util.List getColumnFamilies() { + public java.util.List getColumnFamilies() { return columnFamilies; } @@ -195,16 +114,14 @@ public void setTableName(java.lang.CharSequence value) { * Sets the value of the 'columnFamilies' field. * @param value the value to set. */ - public void setColumnFamilies(java.util.List value) { + public void setColumnFamilies(java.util.List value) { this.columnFamilies = value; } /** * Gets the value of the 'columnMapping' field. */ - public java.util.List getColumnMapping() { + public java.util.List getColumnMapping() { return columnMapping; } @@ -212,59 +129,44 @@ public void setColumnFamilies(java.util.List value) { + public void setColumnMapping(java.util.List value) { this.columnMapping = value; } - /** Creates a new HBaseAppenderConfiguration RecordBuilder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder newBuilder() { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder(); + /** Creates a new HBaseAppenderConfiguration RecordBuilder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder newBuilder() { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder(); } - - /** Creates a new HBaseAppenderConfiguration RecordBuilder by copying an existing Builder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.HBaseAppenderConfiguration.Builder other) { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder(other); + + /** Creates a new HBaseAppenderConfiguration RecordBuilder by copying an existing Builder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder other) { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder(other); } - - /** Creates a new HBaseAppenderConfiguration RecordBuilder by copying an existing - * HBaseAppenderConfiguration instance. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.HBaseAppenderConfiguration other) { - return new org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder(other); + + /** Creates a new HBaseAppenderConfiguration RecordBuilder by copying an existing HBaseAppenderConfiguration instance */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration other) { + return new org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder(other); } - + /** * RecordBuilder for HBaseAppenderConfiguration instances. */ - public static class Builder extends org.apache.avro.specific - .SpecificRecordBuilderBase - implements org.apache.avro.data.RecordBuilder { + public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase + implements org.apache.avro.data.RecordBuilder { private org.kaaproject.kaa.server.appenders.hbase.config.gen.Server server; private java.lang.CharSequence keyspace; private java.lang.CharSequence tableName; - private java.util.List columnFamilies; - private java.util.List columnMapping; + private java.util.List columnFamilies; + private java.util.List columnMapping; - /** Creates a new Builder. */ + /** Creates a new Builder */ private Builder() { - super(org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.SCHEMA$); + super(org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.SCHEMA$); } - - /** Creates a Builder by copying an existing Builder. */ - private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder other) { + + /** Creates a Builder by copying an existing Builder */ + private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder other) { super(other); if (isValidValue(fields()[0], other.server)) { this.server = data().deepCopy(fields()[0].schema(), other.server); @@ -287,12 +189,10 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen fieldSetFlags()[4] = true; } } - - /** Creates a Builder by copying an existing HBaseAppenderConfiguration instance. */ - private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration other) { - super(org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.SCHEMA$); + + /** Creates a Builder by copying an existing HBaseAppenderConfiguration instance */ + private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration other) { + super(org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.SCHEMA$); if (isValidValue(fields()[0], other.server)) { this.server = data().deepCopy(fields()[0].schema(), other.server); fieldSetFlags()[0] = true; @@ -315,141 +215,126 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen } } - /** Gets the value of the 'server' field. */ + /** Gets the value of the 'server' field */ public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server getServer() { return server; } - - /** Sets the value of the 'server' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config - .gen.HBaseAppenderConfiguration.Builder setServer(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Server value) { + + /** Sets the value of the 'server' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder setServer(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server value) { validate(fields()[0], value); this.server = value; fieldSetFlags()[0] = true; return this; } - - /** Checks whether the 'server' field has been set. */ + + /** Checks whether the 'server' field has been set */ public boolean hasServer() { return fieldSetFlags()[0]; } - - /** Clears the value of the 'server' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder clearServer() { + + /** Clears the value of the 'server' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder clearServer() { server = null; fieldSetFlags()[0] = false; return this; } - /** Gets the value of the 'keyspace' field. */ + /** Gets the value of the 'keyspace' field */ public java.lang.CharSequence getKeyspace() { return keyspace; } - - /** Sets the value of the 'keyspace' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder setKeyspace(java.lang.CharSequence value) { + + /** Sets the value of the 'keyspace' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder setKeyspace(java.lang.CharSequence value) { validate(fields()[1], value); this.keyspace = value; fieldSetFlags()[1] = true; return this; } - - /** Checks whether the 'keyspace' field has been set. */ + + /** Checks whether the 'keyspace' field has been set */ public boolean hasKeyspace() { return fieldSetFlags()[1]; } - - /** Clears the value of the 'keyspace' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder clearKeyspace() { + + /** Clears the value of the 'keyspace' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder clearKeyspace() { keyspace = null; fieldSetFlags()[1] = false; return this; } - /** Gets the value of the 'tableName' field. */ + /** Gets the value of the 'tableName' field */ public java.lang.CharSequence getTableName() { return tableName; } - - /** Sets the value of the 'tableName' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder setTableName(java.lang.CharSequence value) { + + /** Sets the value of the 'tableName' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder setTableName(java.lang.CharSequence value) { validate(fields()[2], value); this.tableName = value; fieldSetFlags()[2] = true; return this; } - - /** Checks whether the 'tableName' field has been set. */ + + /** Checks whether the 'tableName' field has been set */ public boolean hasTableName() { return fieldSetFlags()[2]; } - - /** Clears the value of the 'tableName' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder clearTableName() { + + /** Clears the value of the 'tableName' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder clearTableName() { tableName = null; fieldSetFlags()[2] = false; return this; } - /** Gets the value of the 'columnFamilies' field. */ - public java.util.List getColumnFamilies() { + /** Gets the value of the 'columnFamilies' field */ + public java.util.List getColumnFamilies() { return columnFamilies; } - - /** Sets the value of the 'columnFamilies' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder setColumnFamilies(java.util - .List value) { + + /** Sets the value of the 'columnFamilies' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder setColumnFamilies(java.util.List value) { validate(fields()[3], value); this.columnFamilies = value; fieldSetFlags()[3] = true; return this; } - - /** Checks whether the 'columnFamilies' field has been set. */ + + /** Checks whether the 'columnFamilies' field has been set */ public boolean hasColumnFamilies() { return fieldSetFlags()[3]; } - - /** Clears the value of the 'columnFamilies' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder clearColumnFamilies() { + + /** Clears the value of the 'columnFamilies' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder clearColumnFamilies() { columnFamilies = null; fieldSetFlags()[3] = false; return this; } - /** Gets the value of the 'columnMapping' field. */ - public java.util.List getColumnMapping() { + /** Gets the value of the 'columnMapping' field */ + public java.util.List getColumnMapping() { return columnMapping; } - - /** Sets the value of the 'columnMapping' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder setColumnMapping(java.util - .List value) { + + /** Sets the value of the 'columnMapping' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder setColumnMapping(java.util.List value) { validate(fields()[4], value); this.columnMapping = value; fieldSetFlags()[4] = true; return this; } - - /** Checks whether the 'columnMapping' field has been set. */ + + /** Checks whether the 'columnMapping' field has been set */ public boolean hasColumnMapping() { return fieldSetFlags()[4]; } - - /** Clears the value of the 'columnMapping' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen - .HBaseAppenderConfiguration.Builder clearColumnMapping() { + + /** Clears the value of the 'columnMapping' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.HBaseAppenderConfiguration.Builder clearColumnMapping() { columnMapping = null; fieldSetFlags()[4] = false; return this; @@ -459,18 +344,11 @@ public boolean hasColumnMapping() { public HBaseAppenderConfiguration build() { try { HBaseAppenderConfiguration record = new HBaseAppenderConfiguration(); - record.server = fieldSetFlags()[0] ? this.server : - (org.kaaproject.kaa.server.appenders.hbase.config.gen.Server) defaultValue(fields()[0]); - record.keyspace = fieldSetFlags()[1] ? this.keyspace : - (java.lang.CharSequence) defaultValue(fields()[1]); - record.tableName = fieldSetFlags()[2] ? this.tableName : - (java.lang.CharSequence) defaultValue(fields()[2]); - record.columnFamilies = fieldSetFlags()[3] ? this.columnFamilies : - (java.util.List) defaultValue(fields()[3]); - record.columnMapping = fieldSetFlags()[4] ? this.columnMapping : - (java.util.List) defaultValue(fields()[4]); + record.server = fieldSetFlags()[0] ? this.server : (org.kaaproject.kaa.server.appenders.hbase.config.gen.Server) defaultValue(fields()[0]); + record.keyspace = fieldSetFlags()[1] ? this.keyspace : (java.lang.CharSequence) defaultValue(fields()[1]); + record.tableName = fieldSetFlags()[2] ? this.tableName : (java.lang.CharSequence) defaultValue(fields()[2]); + record.columnFamilies = fieldSetFlags()[3] ? this.columnFamilies : (java.util.List) defaultValue(fields()[3]); + record.columnMapping = fieldSetFlags()[4] ? this.columnMapping : (java.util.List) defaultValue(fields()[4]); return record; } catch (Exception e) { throw new org.apache.avro.AvroRuntimeException(e); diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Server.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Server.java index 2c09a7d80c..4abea7a412 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Server.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Server.java @@ -3,25 +3,12 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated -public class Server extends org.apache.avro.specific.SpecificRecordBase - implements org.apache.avro.specific.SpecificRecord { - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":" - + "\"Server\",\"namespace\":\"org.kaaproject.kaa.server.appenders" - + ".hbase.config.gen\",\"fields\":[{\"name\":\"zkQuorum\",\"type\":" - + "\"string\",\"displayName\":\"Zookeeper Quorum\",\"weight\":0.75," - + "\"by_default\":\"localhost\"},{\"name\":\"port\",\"type\":\"string\"" - + ",\"displayName\":\"Port\",\"weight\":0.25,\"by_default\":\"2181\"}]}"); - - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } - +public class Server extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"Server\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"fields\":[{\"name\":\"zkQuorum\",\"type\":\"string\",\"displayName\":\"Zookeeper Quorum\",\"weight\":0.75,\"by_default\":\"localhost\"},{\"name\":\"port\",\"type\":\"string\",\"displayName\":\"Port\",\"weight\":0.25,\"by_default\":\"2181\"}]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } @Deprecated public java.lang.CharSequence zkQuorum; @Deprecated public java.lang.CharSequence port; @@ -40,34 +27,22 @@ public Server(java.lang.CharSequence zkQuorum, java.lang.CharSequence port) { this.port = port; } - public org.apache.avro.Schema getSchema() { - return SCHEMA$; - } - // Used by DatumWriter. Applications should not call. - - /** - * Get Server object fields. - */ - public java.lang.Object get(int field) { - switch (field) { - case 0: return zkQuorum; - case 1: return port; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + public org.apache.avro.Schema getSchema() { return SCHEMA$; } + // Used by DatumWriter. Applications should not call. + public java.lang.Object get(int field$) { + switch (field$) { + case 0: return zkQuorum; + case 1: return port; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } - // Used by DatumReader. Applications should not call. - - /** - * Get Server object values. - */ - @SuppressWarnings(value = "unchecked") - public void put(int field, java.lang.Object value) { - switch (field) { - case 0: zkQuorum = (java.lang.CharSequence)value; - break; - case 1: port = (java.lang.CharSequence)value; - break; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); + // Used by DatumReader. Applications should not call. + @SuppressWarnings(value="unchecked") + public void put(int field$, java.lang.Object value$) { + switch (field$) { + case 0: zkQuorum = (java.lang.CharSequence)value$; break; + case 1: port = (java.lang.CharSequence)value$; break; + default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } } @@ -101,23 +76,18 @@ public void setPort(java.lang.CharSequence value) { this.port = value; } - /** Creates a new Server RecordBuilder. */ - public static org.kaaproject.kaa.server.appenders - .hbase.config.gen.Server.Builder newBuilder() { + /** Creates a new Server RecordBuilder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder newBuilder() { return new org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder(); } - /** Creates a new Server RecordBuilder by copying an existing Builder. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen.Server - .Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Server.Builder other) { + /** Creates a new Server RecordBuilder by copying an existing Builder */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder other) { return new org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder(other); } - /** Creates a new Server RecordBuilder by copying an existing Server instance. */ - public static org.kaaproject.kaa.server.appenders.hbase.config.gen.Server - .Builder newBuilder(org.kaaproject.kaa.server.appenders - .hbase.config.gen.Server other) { + /** Creates a new Server RecordBuilder by copying an existing Server instance */ + public static org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder newBuilder(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server other) { return new org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder(other); } @@ -125,17 +95,17 @@ public void setPort(java.lang.CharSequence value) { * RecordBuilder for Server instances. */ public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase - implements org.apache.avro.data.RecordBuilder { + implements org.apache.avro.data.RecordBuilder { private java.lang.CharSequence zkQuorum; private java.lang.CharSequence port; - /** Creates a new Builder. */ + /** Creates a new Builder */ private Builder() { super(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.SCHEMA$); } - /** Creates a Builder by copying an existing Builder. */ + /** Creates a Builder by copying an existing Builder */ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder other) { super(other); if (isValidValue(fields()[0], other.zkQuorum)) { @@ -148,7 +118,7 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Buil } } - /** Creates a Builder by copying an existing Server instance. */ + /** Creates a Builder by copying an existing Server instance */ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server other) { super(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.SCHEMA$); if (isValidValue(fields()[0], other.zkQuorum)) { @@ -161,52 +131,50 @@ private Builder(org.kaaproject.kaa.server.appenders.hbase.config.gen.Server othe } } - /** Gets the value of the 'zkQuorum' field. */ + /** Gets the value of the 'zkQuorum' field */ public java.lang.CharSequence getZkQuorum() { return zkQuorum; } - /** Sets the value of the 'zkQuorum' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server - .Builder setZkQuorum(java.lang.CharSequence value) { + /** Sets the value of the 'zkQuorum' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder setZkQuorum(java.lang.CharSequence value) { validate(fields()[0], value); this.zkQuorum = value; fieldSetFlags()[0] = true; return this; } - /** Checks whether the 'zkQuorum' field has been set. */ + /** Checks whether the 'zkQuorum' field has been set */ public boolean hasZkQuorum() { return fieldSetFlags()[0]; } - /** Clears the value of the 'zkQuorum' field. */ + /** Clears the value of the 'zkQuorum' field */ public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder clearZkQuorum() { zkQuorum = null; fieldSetFlags()[0] = false; return this; } - /** Gets the value of the 'port' field. */ + /** Gets the value of the 'port' field */ public java.lang.CharSequence getPort() { return port; } - /** Sets the value of the 'port' field. */ - public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server - .Builder setPort(java.lang.CharSequence value) { + /** Sets the value of the 'port' field */ + public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder setPort(java.lang.CharSequence value) { validate(fields()[1], value); this.port = value; fieldSetFlags()[1] = true; return this; } - /** Checks whether the 'port' field has been set. */ + /** Checks whether the 'port' field has been set */ public boolean hasPort() { return fieldSetFlags()[1]; } - /** Clears the value of the 'port' field. */ + /** Clears the value of the 'port' field */ public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder clearPort() { port = null; fieldSetFlags()[1] = false; @@ -217,10 +185,8 @@ public org.kaaproject.kaa.server.appenders.hbase.config.gen.Server.Builder clear public Server build() { try { Server record = new Server(); - record.zkQuorum = fieldSetFlags()[0] ? this.zkQuorum : - (java.lang.CharSequence) defaultValue(fields()[0]); - record.port = fieldSetFlags()[1] ? this.port : - (java.lang.CharSequence) defaultValue(fields()[1]); + record.zkQuorum = fieldSetFlags()[0] ? this.zkQuorum : (java.lang.CharSequence) defaultValue(fields()[0]); + record.port = fieldSetFlags()[1] ? this.port : (java.lang.CharSequence) defaultValue(fields()[1]); return record; } catch (Exception e) { throw new org.apache.avro.AvroRuntimeException(e); diff --git a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Type.java b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Type.java index e88627868f..d8bb884059 100644 --- a/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Type.java +++ b/server/appenders/hbase-appender/src/main/java/org/kaaproject/kaa/server/appenders/hbase/config/gen/Type.java @@ -3,20 +3,11 @@ * * DO NOT EDIT DIRECTLY */ - package org.kaaproject.kaa.server.appenders.hbase.config.gen; - @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated - public enum Type { - BIGINT, BLOB, BOOLEAN, DOUBLE, FLOAT, INT, TEXT, ARRAY; - public static final org.apache.avro.Schema SCHEMA$ = - new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\"" - + ":\"Type\",\"namespace\":\"org.kaaproject.kaa.server.appenders" - + ".hbase.config.gen\",\"symbols\":[\"BIGINT\",\"BLOB\",\"BOOLEAN\"" - + ",\"DOUBLE\",\"FLOAT\",\"INT\",\"TEXT\",\"ARRAY\"]}"); - public static org.apache.avro.Schema getClassSchema() { - return SCHEMA$; - } + BIGINT, BLOB, BOOLEAN, DOUBLE, FLOAT, INT, TEXT, ARRAY ; + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":\"Type\",\"namespace\":\"org.kaaproject.kaa.server.appenders.hbase.config.gen\",\"symbols\":[\"BIGINT\",\"BLOB\",\"BOOLEAN\",\"DOUBLE\",\"FLOAT\",\"INT\",\"TEXT\",\"ARRAY\"]}"); + public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } }