diff --git pom.xml pom.xml
index f471baa..7c154d0 100644
--- pom.xml
+++ pom.xml
@@ -270,6 +270,16 @@
maven-surefire-report-plugin
2.9
+
+ org.apache.avro
+ avro-maven-plugin
+ ${avro.version}
+
+
+ org.codehaus.mojo
+ build-helper-maven-plugin
+ 1.5
+
@@ -290,6 +300,23 @@
+ org.apache.avro
+ avro-maven-plugin
+
+
+ generate-avro-sources
+ generate-sources
+
+ schema
+ protocol
+
+
+
+
+ ${project.build.directory}/generated-sources/java
+
+
+
org.codehaus.mojo
xml-maven-plugin
1.0-beta-3
@@ -475,18 +502,18 @@
-
+
@@ -552,7 +579,7 @@
1.5
- add-jspc-source
+ jspcSource-packageInfo-Avro-source
generate-sources
add-source
@@ -560,18 +587,7 @@
${basedir}/target/jspc
-
-
-
-
- add-package-info
- generate-sources
-
- add-source
-
-
-
- ${project.build.directory}/generated-sources
+ ${project.build.directory}/generated-sources/java
@@ -625,7 +641,7 @@
1.6
- 1.4.1
+ 1.5.3
1.2
1.4
3.1
@@ -732,6 +748,11 @@
+ org.apache.avro
+ avro-ipc
+ ${avro.version}
+
+
org.apache.zookeeper
zookeeper
${zookeeper.version}
diff --git src/main/avro/hbase.avpr src/main/avro/hbase.avpr
new file mode 100644
index 0000000..68f3664
--- /dev/null
+++ src/main/avro/hbase.avpr
@@ -0,0 +1,609 @@
+{
+ "protocol" : "HBase",
+ "namespace" : "org.apache.hadoop.hbase.avro.generated",
+ "types" : [ {
+ "type" : "record",
+ "name" : "AServerAddress",
+ "fields" : [ {
+ "name" : "hostname",
+ "type" : "string"
+ }, {
+ "name" : "inetSocketAddress",
+ "type" : "string"
+ }, {
+ "name" : "port",
+ "type" : "int"
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "ARegionLoad",
+ "fields" : [ {
+ "name" : "memStoreSizeMB",
+ "type" : "int"
+ }, {
+ "name" : "name",
+ "type" : "bytes"
+ }, {
+ "name" : "storefileIndexSizeMB",
+ "type" : "int"
+ }, {
+ "name" : "storefiles",
+ "type" : "int"
+ }, {
+ "name" : "storefileSizeMB",
+ "type" : "int"
+ }, {
+ "name" : "stores",
+ "type" : "int"
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AServerLoad",
+ "fields" : [ {
+ "name" : "load",
+ "type" : "int"
+ }, {
+ "name" : "maxHeapMB",
+ "type" : "int"
+ }, {
+ "name" : "memStoreSizeInMB",
+ "type" : "int"
+ }, {
+ "name" : "numberOfRegions",
+ "type" : "int"
+ }, {
+ "name" : "numberOfRequests",
+ "type" : "int"
+ }, {
+ "name" : "regionsLoad",
+ "type" : {
+ "type" : "array",
+ "items" : "ARegionLoad"
+ }
+ }, {
+ "name" : "storefileIndexSizeInMB",
+ "type" : "int"
+ }, {
+ "name" : "storefiles",
+ "type" : "int"
+ }, {
+ "name" : "storefileSizeInMB",
+ "type" : "int"
+ }, {
+ "name" : "usedHeapMB",
+ "type" : "int"
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AServerInfo",
+ "fields" : [ {
+ "name" : "infoPort",
+ "type" : "int"
+ }, {
+ "name" : "load",
+ "type" : "AServerLoad"
+ }, {
+ "name" : "serverAddress",
+ "type" : "AServerAddress"
+ }, {
+ "name" : "serverName",
+ "type" : "string"
+ }, {
+ "name" : "startCode",
+ "type" : "long"
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AClusterStatus",
+ "fields" : [ {
+ "name" : "averageLoad",
+ "type" : "double"
+ }, {
+ "name" : "deadServerNames",
+ "type" : {
+ "type" : "array",
+ "items" : "string"
+ }
+ }, {
+ "name" : "deadServers",
+ "type" : "int"
+ }, {
+ "name" : "hbaseVersion",
+ "type" : "string"
+ }, {
+ "name" : "regionsCount",
+ "type" : "int"
+ }, {
+ "name" : "requestsCount",
+ "type" : "int"
+ }, {
+ "name" : "serverInfos",
+ "type" : {
+ "type" : "array",
+ "items" : "AServerInfo"
+ }
+ }, {
+ "name" : "servers",
+ "type" : "int"
+ } ]
+ }, {
+ "type" : "enum",
+ "name" : "ACompressionAlgorithm",
+ "symbols" : [ "LZO", "GZ", "NONE" ]
+ }, {
+ "type" : "record",
+ "name" : "AFamilyDescriptor",
+ "fields" : [ {
+ "name" : "name",
+ "type" : "bytes"
+ }, {
+ "name" : "compression",
+ "type" : [ "ACompressionAlgorithm", "null" ]
+ }, {
+ "name" : "maxVersions",
+ "type" : [ "int", "null" ]
+ }, {
+ "name" : "blocksize",
+ "type" : [ "int", "null" ]
+ }, {
+ "name" : "inMemory",
+ "type" : [ "boolean", "null" ]
+ }, {
+ "name" : "timeToLive",
+ "type" : [ "int", "null" ]
+ }, {
+ "name" : "blockCacheEnabled",
+ "type" : [ "boolean", "null" ]
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "ATableDescriptor",
+ "fields" : [ {
+ "name" : "name",
+ "type" : "bytes"
+ }, {
+ "name" : "families",
+ "type" : [ {
+ "type" : "array",
+ "items" : "AFamilyDescriptor"
+ }, "null" ]
+ }, {
+ "name" : "maxFileSize",
+ "type" : [ "long", "null" ]
+ }, {
+ "name" : "memStoreFlushSize",
+ "type" : [ "long", "null" ]
+ }, {
+ "name" : "rootRegion",
+ "type" : [ "boolean", "null" ]
+ }, {
+ "name" : "metaRegion",
+ "type" : [ "boolean", "null" ]
+ }, {
+ "name" : "metaTable",
+ "type" : [ "boolean", "null" ]
+ }, {
+ "name" : "readOnly",
+ "type" : [ "boolean", "null" ]
+ }, {
+ "name" : "deferredLogFlush",
+ "type" : [ "boolean", "null" ]
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AColumn",
+ "fields" : [ {
+ "name" : "family",
+ "type" : "bytes"
+ }, {
+ "name" : "qualifier",
+ "type" : [ "bytes", "null" ]
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "ATimeRange",
+ "fields" : [ {
+ "name" : "minStamp",
+ "type" : "long"
+ }, {
+ "name" : "maxStamp",
+ "type" : "long"
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AGet",
+ "fields" : [ {
+ "name" : "row",
+ "type" : "bytes"
+ }, {
+ "name" : "columns",
+ "type" : [ {
+ "type" : "array",
+ "items" : "AColumn"
+ }, "null" ]
+ }, {
+ "name" : "timestamp",
+ "type" : [ "long", "null" ]
+ }, {
+ "name" : "timerange",
+ "type" : [ "ATimeRange", "null" ]
+ }, {
+ "name" : "maxVersions",
+ "type" : [ "int", "null" ]
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AResultEntry",
+ "fields" : [ {
+ "name" : "family",
+ "type" : "bytes"
+ }, {
+ "name" : "qualifier",
+ "type" : "bytes"
+ }, {
+ "name" : "value",
+ "type" : "bytes"
+ }, {
+ "name" : "timestamp",
+ "type" : "long"
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AResult",
+ "fields" : [ {
+ "name" : "row",
+ "type" : "bytes"
+ }, {
+ "name" : "entries",
+ "type" : {
+ "type" : "array",
+ "items" : "AResultEntry"
+ }
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AColumnValue",
+ "fields" : [ {
+ "name" : "family",
+ "type" : "bytes"
+ }, {
+ "name" : "qualifier",
+ "type" : "bytes"
+ }, {
+ "name" : "value",
+ "type" : "bytes"
+ }, {
+ "name" : "timestamp",
+ "type" : [ "long", "null" ]
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "APut",
+ "fields" : [ {
+ "name" : "row",
+ "type" : "bytes"
+ }, {
+ "name" : "columnValues",
+ "type" : {
+ "type" : "array",
+ "items" : "AColumnValue"
+ }
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "ADelete",
+ "fields" : [ {
+ "name" : "row",
+ "type" : "bytes"
+ }, {
+ "name" : "columns",
+ "type" : [ {
+ "type" : "array",
+ "items" : "AColumn"
+ }, "null" ]
+ } ]
+ }, {
+ "type" : "record",
+ "name" : "AScan",
+ "fields" : [ {
+ "name" : "startRow",
+ "type" : [ "bytes", "null" ]
+ }, {
+ "name" : "stopRow",
+ "type" : [ "bytes", "null" ]
+ }, {
+ "name" : "columns",
+ "type" : [ {
+ "type" : "array",
+ "items" : "AColumn"
+ }, "null" ]
+ }, {
+ "name" : "timestamp",
+ "type" : [ "long", "null" ]
+ }, {
+ "name" : "timerange",
+ "type" : [ "ATimeRange", "null" ]
+ }, {
+ "name" : "maxVersions",
+ "type" : [ "int", "null" ]
+ } ]
+ }, {
+ "type" : "error",
+ "name" : "AIOError",
+ "fields" : [ {
+ "name" : "message",
+ "type" : "string"
+ } ]
+ }, {
+ "type" : "error",
+ "name" : "AIllegalArgument",
+ "fields" : [ {
+ "name" : "message",
+ "type" : "string"
+ } ]
+ }, {
+ "type" : "error",
+ "name" : "ATableExists",
+ "fields" : [ {
+ "name" : "message",
+ "type" : "string"
+ } ]
+ }, {
+ "type" : "error",
+ "name" : "AMasterNotRunning",
+ "fields" : [ {
+ "name" : "message",
+ "type" : "string"
+ } ]
+ } ],
+ "messages" : {
+ "getHBaseVersion" : {
+ "request" : [ ],
+ "response" : "string",
+ "errors" : [ "AIOError" ]
+ },
+ "getClusterStatus" : {
+ "request" : [ ],
+ "response" : "AClusterStatus",
+ "errors" : [ "AIOError" ]
+ },
+ "listTables" : {
+ "request" : [ ],
+ "response" : {
+ "type" : "array",
+ "items" : "ATableDescriptor"
+ },
+ "errors" : [ "AIOError" ]
+ },
+ "describeTable" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "ATableDescriptor",
+ "errors" : [ "AIOError" ]
+ },
+ "isTableEnabled" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "boolean",
+ "errors" : [ "AIOError" ]
+ },
+ "tableExists" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "boolean",
+ "errors" : [ "AIOError" ]
+ },
+ "describeFamily" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "family",
+ "type" : "bytes"
+ } ],
+ "response" : "AFamilyDescriptor",
+ "errors" : [ "AIOError" ]
+ },
+ "createTable" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "ATableDescriptor"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError", "AIllegalArgument", "ATableExists", "AMasterNotRunning" ]
+ },
+ "deleteTable" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "modifyTable" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "tableDescriptor",
+ "type" : "ATableDescriptor"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "enableTable" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "disableTable" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "flush" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "split" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "addFamily" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "family",
+ "type" : "AFamilyDescriptor"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "deleteFamily" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "family",
+ "type" : "bytes"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "modifyFamily" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "familyName",
+ "type" : "bytes"
+ }, {
+ "name" : "familyDescriptor",
+ "type" : "AFamilyDescriptor"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "get" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "get",
+ "type" : "AGet"
+ } ],
+ "response" : "AResult",
+ "errors" : [ "AIOError" ]
+ },
+ "exists" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "get",
+ "type" : "AGet"
+ } ],
+ "response" : "boolean",
+ "errors" : [ "AIOError" ]
+ },
+ "put" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "put",
+ "type" : "APut"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "delete" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "delete",
+ "type" : "ADelete"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError" ]
+ },
+ "incrementColumnValue" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "row",
+ "type" : "bytes"
+ }, {
+ "name" : "family",
+ "type" : "bytes"
+ }, {
+ "name" : "qualifier",
+ "type" : "bytes"
+ }, {
+ "name" : "amount",
+ "type" : "long"
+ }, {
+ "name" : "writeToWAL",
+ "type" : "boolean"
+ } ],
+ "response" : "long",
+ "errors" : [ "AIOError" ]
+ },
+ "scannerOpen" : {
+ "request" : [ {
+ "name" : "table",
+ "type" : "bytes"
+ }, {
+ "name" : "scan",
+ "type" : "AScan"
+ } ],
+ "response" : "int",
+ "errors" : [ "AIOError" ]
+ },
+ "scannerClose" : {
+ "request" : [ {
+ "name" : "scannerId",
+ "type" : "int"
+ } ],
+ "response" : "null",
+ "errors" : [ "AIOError", "AIllegalArgument" ]
+ },
+ "scannerGetRows" : {
+ "request" : [ {
+ "name" : "scannerId",
+ "type" : "int"
+ }, {
+ "name" : "numberOfRows",
+ "type" : "int"
+ } ],
+ "response" : {
+ "type" : "array",
+ "items" : "AResult"
+ },
+ "errors" : [ "AIOError", "AIllegalArgument" ]
+ }
+ }
+}
\ No newline at end of file
diff --git src/main/java/org/apache/hadoop/hbase/avro/AvroServer.java src/main/java/org/apache/hadoop/hbase/avro/AvroServer.java
index d98d71d..f45bbbd 100644
--- src/main/java/org/apache/hadoop/hbase/avro/AvroServer.java
+++ src/main/java/org/apache/hadoop/hbase/avro/AvroServer.java
@@ -26,7 +26,7 @@ import org.apache.avro.Schema;
import org.apache.avro.generic.GenericArray;
import org.apache.avro.generic.GenericData;
import org.apache.avro.ipc.HttpServer;
-import org.apache.avro.specific.SpecificResponder;
+import org.apache.avro.ipc.specific.SpecificResponder;
import org.apache.avro.util.Utf8;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AAlreadyExists.java src/main/java/org/apache/hadoop/hbase/avro/generated/AAlreadyExists.java
deleted file mode 100644
index 7f05f09..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AAlreadyExists.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AAlreadyExists extends org.apache.avro.specific.SpecificExceptionBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"error\",\"name\":\"AAlreadyExists\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}");
- public org.apache.avro.util.Utf8 message;
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return message;
- 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: message = (org.apache.avro.util.Utf8)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AClusterStatus.java src/main/java/org/apache/hadoop/hbase/avro/generated/AClusterStatus.java
deleted file mode 100644
index 5abd81e..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AClusterStatus.java
+++ /dev/null
@@ -1,49 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AClusterStatus extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AClusterStatus\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"averageLoad\",\"type\":\"double\"},{\"name\":\"deadServerNames\",\"type\":{\"type\":\"array\",\"items\":\"string\"}},{\"name\":\"deadServers\",\"type\":\"int\"},{\"name\":\"hbaseVersion\",\"type\":\"string\"},{\"name\":\"regionsCount\",\"type\":\"int\"},{\"name\":\"requestsCount\",\"type\":\"int\"},{\"name\":\"serverInfos\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AServerInfo\",\"fields\":[{\"name\":\"infoPort\",\"type\":\"int\"},{\"name\":\"load\",\"type\":{\"type\":\"record\",\"name\":\"AServerLoad\",\"fields\":[{\"name\":\"load\",\"type\":\"int\"},{\"name\":\"maxHeapMB\",\"type\":\"int\"},{\"name\":\"memStoreSizeInMB\",\"type\":\"int\"},{\"name\":\"numberOfRegions\",\"type\":\"int\"},{\"name\":\"numberOfRequests\",\"type\":\"int\"},{\"name\":\"regionsLoad\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ARegionLoad\",\"fields\":[{\"name\":\"memStoreSizeMB\",\"type\":\"int\"},{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"storefileIndexSizeMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeMB\",\"type\":\"int\"},{\"name\":\"stores\",\"type\":\"int\"}]}}},{\"name\":\"storefileIndexSizeInMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeInMB\",\"type\":\"int\"},{\"name\":\"usedHeapMB\",\"type\":\"int\"}]}},{\"name\":\"serverAddress\",\"type\":{\"type\":\"record\",\"name\":\"AServerAddress\",\"fields\":[{\"name\":\"hostname\",\"type\":\"string\"},{\"name\":\"inetSocketAddress\",\"type\":\"string\"},{\"name\":\"port\",\"type\":\"int\"}]}},{\"name\":\"serverName\",\"type\":\"string\"},{\"name\":\"startCode\",\"type\":\"long\"}]}}},{\"name\":\"servers\",\"type\":\"int\"}]}");
- public double averageLoad;
- public java.util.List deadServerNames;
- public int deadServers;
- public java.lang.CharSequence hbaseVersion;
- public int regionsCount;
- public int requestsCount;
- public java.util.List serverInfos;
- public int servers;
- 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 averageLoad;
- case 1: return deadServerNames;
- case 2: return deadServers;
- case 3: return hbaseVersion;
- case 4: return regionsCount;
- case 5: return requestsCount;
- case 6: return serverInfos;
- case 7: return servers;
- 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: averageLoad = (java.lang.Double)value$; break;
- case 1: deadServerNames = (java.util.List)value$; break;
- case 2: deadServers = (java.lang.Integer)value$; break;
- case 3: hbaseVersion = (java.lang.CharSequence)value$; break;
- case 4: regionsCount = (java.lang.Integer)value$; break;
- case 5: requestsCount = (java.lang.Integer)value$; break;
- case 6: serverInfos = (java.util.List)value$; break;
- case 7: servers = (java.lang.Integer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AColumn.java src/main/java/org/apache/hadoop/hbase/avro/generated/AColumn.java
deleted file mode 100644
index 3daf3ff..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AColumn.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AColumn extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AColumn\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":[\"bytes\",\"null\"]}]}");
- public java.nio.ByteBuffer family;
- public java.nio.ByteBuffer qualifier;
- 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 family;
- case 1: return qualifier;
- 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: family = (java.nio.ByteBuffer)value$; break;
- case 1: qualifier = (java.nio.ByteBuffer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AColumnFamilyDescriptor.java src/main/java/org/apache/hadoop/hbase/avro/generated/AColumnFamilyDescriptor.java
deleted file mode 100644
index e5b14ef..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AColumnFamilyDescriptor.java
+++ /dev/null
@@ -1,42 +0,0 @@
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AColumnFamilyDescriptor extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AColumnFamilyDescriptor\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"compression\",\"type\":{\"type\":\"enum\",\"name\":\"ACompressionAlgorithm\",\"symbols\":[\"LZO\",\"GZ\",\"NONE\"]}},{\"name\":\"maxVersions\",\"type\":\"int\"},{\"name\":\"blocksize\",\"type\":\"int\"},{\"name\":\"inMemory\",\"type\":\"boolean\"},{\"name\":\"timeToLive\",\"type\":\"int\"},{\"name\":\"blockCacheEnabled\",\"type\":\"boolean\"},{\"name\":\"bloomfilterEnabled\",\"type\":\"boolean\"}]}");
- public java.nio.ByteBuffer name;
- public org.apache.hadoop.hbase.avro.generated.ACompressionAlgorithm compression;
- public int maxVersions;
- public int blocksize;
- public boolean inMemory;
- public int timeToLive;
- public boolean blockCacheEnabled;
- public boolean bloomfilterEnabled;
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return name;
- case 1: return compression;
- case 2: return maxVersions;
- case 3: return blocksize;
- case 4: return inMemory;
- case 5: return timeToLive;
- case 6: return blockCacheEnabled;
- case 7: return bloomfilterEnabled;
- 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: name = (java.nio.ByteBuffer)value$; break;
- case 1: compression = (org.apache.hadoop.hbase.avro.generated.ACompressionAlgorithm)value$; break;
- case 2: maxVersions = (java.lang.Integer)value$; break;
- case 3: blocksize = (java.lang.Integer)value$; break;
- case 4: inMemory = (java.lang.Boolean)value$; break;
- case 5: timeToLive = (java.lang.Integer)value$; break;
- case 6: blockCacheEnabled = (java.lang.Boolean)value$; break;
- case 7: bloomfilterEnabled = (java.lang.Boolean)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AColumnValue.java src/main/java/org/apache/hadoop/hbase/avro/generated/AColumnValue.java
deleted file mode 100644
index 1fcc5ac..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AColumnValue.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AColumnValue extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AColumnValue\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]}]}");
- public java.nio.ByteBuffer family;
- public java.nio.ByteBuffer qualifier;
- public java.nio.ByteBuffer value;
- public java.lang.Long timestamp;
- 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 family;
- case 1: return qualifier;
- case 2: return value;
- case 3: return timestamp;
- 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: family = (java.nio.ByteBuffer)value$; break;
- case 1: qualifier = (java.nio.ByteBuffer)value$; break;
- case 2: value = (java.nio.ByteBuffer)value$; break;
- case 3: timestamp = (java.lang.Long)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/ACompressionAlgorithm.java src/main/java/org/apache/hadoop/hbase/avro/generated/ACompressionAlgorithm.java
deleted file mode 100644
index b6c0a41..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/ACompressionAlgorithm.java
+++ /dev/null
@@ -1,11 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public enum ACompressionAlgorithm {
- LZO, GZ, NONE
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/ADelete.java src/main/java/org/apache/hadoop/hbase/avro/generated/ADelete.java
deleted file mode 100644
index 377051b..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/ADelete.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class ADelete extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"ADelete\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"columns\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AColumn\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":[\"bytes\",\"null\"]}]}},\"null\"]}]}");
- public java.nio.ByteBuffer row;
- public java.util.List columns;
- 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 row;
- case 1: return columns;
- 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: row = (java.nio.ByteBuffer)value$; break;
- case 1: columns = (java.util.List)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AFamilyDescriptor.java src/main/java/org/apache/hadoop/hbase/avro/generated/AFamilyDescriptor.java
deleted file mode 100644
index 573219b..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AFamilyDescriptor.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AFamilyDescriptor extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AFamilyDescriptor\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"compression\",\"type\":[{\"type\":\"enum\",\"name\":\"ACompressionAlgorithm\",\"symbols\":[\"LZO\",\"GZ\",\"NONE\"]},\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]},{\"name\":\"blocksize\",\"type\":[\"int\",\"null\"]},{\"name\":\"inMemory\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"timeToLive\",\"type\":[\"int\",\"null\"]},{\"name\":\"blockCacheEnabled\",\"type\":[\"boolean\",\"null\"]}]}");
- public java.nio.ByteBuffer name;
- public org.apache.hadoop.hbase.avro.generated.ACompressionAlgorithm compression;
- public java.lang.Integer maxVersions;
- public java.lang.Integer blocksize;
- public java.lang.Boolean inMemory;
- public java.lang.Integer timeToLive;
- public java.lang.Boolean blockCacheEnabled;
- 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 name;
- case 1: return compression;
- case 2: return maxVersions;
- case 3: return blocksize;
- case 4: return inMemory;
- case 5: return timeToLive;
- case 6: return blockCacheEnabled;
- 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: name = (java.nio.ByteBuffer)value$; break;
- case 1: compression = (org.apache.hadoop.hbase.avro.generated.ACompressionAlgorithm)value$; break;
- case 2: maxVersions = (java.lang.Integer)value$; break;
- case 3: blocksize = (java.lang.Integer)value$; break;
- case 4: inMemory = (java.lang.Boolean)value$; break;
- case 5: timeToLive = (java.lang.Integer)value$; break;
- case 6: blockCacheEnabled = (java.lang.Boolean)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AGet.java src/main/java/org/apache/hadoop/hbase/avro/generated/AGet.java
deleted file mode 100644
index e69fa0e..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AGet.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AGet extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AGet\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"columns\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AColumn\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":[\"bytes\",\"null\"]}]}},\"null\"]},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]},{\"name\":\"timerange\",\"type\":[{\"type\":\"record\",\"name\":\"ATimeRange\",\"fields\":[{\"name\":\"minStamp\",\"type\":\"long\"},{\"name\":\"maxStamp\",\"type\":\"long\"}]},\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]}]}");
- public java.nio.ByteBuffer row;
- public java.util.List columns;
- public java.lang.Long timestamp;
- public org.apache.hadoop.hbase.avro.generated.ATimeRange timerange;
- public java.lang.Integer maxVersions;
- 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 row;
- case 1: return columns;
- case 2: return timestamp;
- case 3: return timerange;
- case 4: return maxVersions;
- 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: row = (java.nio.ByteBuffer)value$; break;
- case 1: columns = (java.util.List)value$; break;
- case 2: timestamp = (java.lang.Long)value$; break;
- case 3: timerange = (org.apache.hadoop.hbase.avro.generated.ATimeRange)value$; break;
- case 4: maxVersions = (java.lang.Integer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AIOError.java src/main/java/org/apache/hadoop/hbase/avro/generated/AIOError.java
deleted file mode 100644
index 16f1bec..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AIOError.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AIOError extends org.apache.avro.specific.SpecificExceptionBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"error\",\"name\":\"AIOError\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}");
- public java.lang.CharSequence message;
- 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 message;
- 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: message = (java.lang.CharSequence)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AIllegalArgument.java src/main/java/org/apache/hadoop/hbase/avro/generated/AIllegalArgument.java
deleted file mode 100644
index 1275cb9..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AIllegalArgument.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AIllegalArgument extends org.apache.avro.specific.SpecificExceptionBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"error\",\"name\":\"AIllegalArgument\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}");
- public java.lang.CharSequence message;
- 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 message;
- 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: message = (java.lang.CharSequence)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AMasterNotRunning.java src/main/java/org/apache/hadoop/hbase/avro/generated/AMasterNotRunning.java
deleted file mode 100644
index bbeb17c..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AMasterNotRunning.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AMasterNotRunning extends org.apache.avro.specific.SpecificExceptionBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"error\",\"name\":\"AMasterNotRunning\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}");
- public java.lang.CharSequence message;
- 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 message;
- 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: message = (java.lang.CharSequence)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/APut.java src/main/java/org/apache/hadoop/hbase/avro/generated/APut.java
deleted file mode 100644
index a725ec9..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/APut.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class APut extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"APut\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"columnValues\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AColumnValue\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]}]}}}]}");
- public java.nio.ByteBuffer row;
- public java.util.List columnValues;
- 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 row;
- case 1: return columnValues;
- 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: row = (java.nio.ByteBuffer)value$; break;
- case 1: columnValues = (java.util.List)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/ARegionLoad.java src/main/java/org/apache/hadoop/hbase/avro/generated/ARegionLoad.java
deleted file mode 100644
index 6dde86a..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/ARegionLoad.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class ARegionLoad extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"ARegionLoad\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"memStoreSizeMB\",\"type\":\"int\"},{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"storefileIndexSizeMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeMB\",\"type\":\"int\"},{\"name\":\"stores\",\"type\":\"int\"}]}");
- public int memStoreSizeMB;
- public java.nio.ByteBuffer name;
- public int storefileIndexSizeMB;
- public int storefiles;
- public int storefileSizeMB;
- public int stores;
- 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 memStoreSizeMB;
- case 1: return name;
- case 2: return storefileIndexSizeMB;
- case 3: return storefiles;
- case 4: return storefileSizeMB;
- case 5: return stores;
- 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: memStoreSizeMB = (java.lang.Integer)value$; break;
- case 1: name = (java.nio.ByteBuffer)value$; break;
- case 2: storefileIndexSizeMB = (java.lang.Integer)value$; break;
- case 3: storefiles = (java.lang.Integer)value$; break;
- case 4: storefileSizeMB = (java.lang.Integer)value$; break;
- case 5: stores = (java.lang.Integer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AResult.java src/main/java/org/apache/hadoop/hbase/avro/generated/AResult.java
deleted file mode 100644
index d5e8eca..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AResult.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AResult extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AResult\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"entries\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AResultEntry\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":\"long\"}]}}}]}");
- public java.nio.ByteBuffer row;
- public java.util.List entries;
- 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 row;
- case 1: return entries;
- 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: row = (java.nio.ByteBuffer)value$; break;
- case 1: entries = (java.util.List)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AResultEntry.java src/main/java/org/apache/hadoop/hbase/avro/generated/AResultEntry.java
deleted file mode 100644
index 703abb5..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AResultEntry.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AResultEntry extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AResultEntry\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":\"long\"}]}");
- public java.nio.ByteBuffer family;
- public java.nio.ByteBuffer qualifier;
- public java.nio.ByteBuffer value;
- public long timestamp;
- 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 family;
- case 1: return qualifier;
- case 2: return value;
- case 3: return timestamp;
- 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: family = (java.nio.ByteBuffer)value$; break;
- case 1: qualifier = (java.nio.ByteBuffer)value$; break;
- case 2: value = (java.nio.ByteBuffer)value$; break;
- case 3: timestamp = (java.lang.Long)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AScan.java src/main/java/org/apache/hadoop/hbase/avro/generated/AScan.java
deleted file mode 100644
index 7a15f50..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AScan.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AScan extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AScan\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"startRow\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"stopRow\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"columns\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AColumn\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":[\"bytes\",\"null\"]}]}},\"null\"]},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]},{\"name\":\"timerange\",\"type\":[{\"type\":\"record\",\"name\":\"ATimeRange\",\"fields\":[{\"name\":\"minStamp\",\"type\":\"long\"},{\"name\":\"maxStamp\",\"type\":\"long\"}]},\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]}]}");
- public java.nio.ByteBuffer startRow;
- public java.nio.ByteBuffer stopRow;
- public java.util.List columns;
- public java.lang.Long timestamp;
- public org.apache.hadoop.hbase.avro.generated.ATimeRange timerange;
- public java.lang.Integer maxVersions;
- 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 startRow;
- case 1: return stopRow;
- case 2: return columns;
- case 3: return timestamp;
- case 4: return timerange;
- case 5: return maxVersions;
- 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: startRow = (java.nio.ByteBuffer)value$; break;
- case 1: stopRow = (java.nio.ByteBuffer)value$; break;
- case 2: columns = (java.util.List)value$; break;
- case 3: timestamp = (java.lang.Long)value$; break;
- case 4: timerange = (org.apache.hadoop.hbase.avro.generated.ATimeRange)value$; break;
- case 5: maxVersions = (java.lang.Integer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AServerAddress.java src/main/java/org/apache/hadoop/hbase/avro/generated/AServerAddress.java
deleted file mode 100644
index 198e85d..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AServerAddress.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AServerAddress extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AServerAddress\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"hostname\",\"type\":\"string\"},{\"name\":\"inetSocketAddress\",\"type\":\"string\"},{\"name\":\"port\",\"type\":\"int\"}]}");
- public java.lang.CharSequence hostname;
- public java.lang.CharSequence inetSocketAddress;
- public int port;
- 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 hostname;
- case 1: return inetSocketAddress;
- case 2: return port;
- 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: hostname = (java.lang.CharSequence)value$; break;
- case 1: inetSocketAddress = (java.lang.CharSequence)value$; break;
- case 2: port = (java.lang.Integer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AServerInfo.java src/main/java/org/apache/hadoop/hbase/avro/generated/AServerInfo.java
deleted file mode 100644
index 8229bcc..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AServerInfo.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AServerInfo extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AServerInfo\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"infoPort\",\"type\":\"int\"},{\"name\":\"load\",\"type\":{\"type\":\"record\",\"name\":\"AServerLoad\",\"fields\":[{\"name\":\"load\",\"type\":\"int\"},{\"name\":\"maxHeapMB\",\"type\":\"int\"},{\"name\":\"memStoreSizeInMB\",\"type\":\"int\"},{\"name\":\"numberOfRegions\",\"type\":\"int\"},{\"name\":\"numberOfRequests\",\"type\":\"int\"},{\"name\":\"regionsLoad\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ARegionLoad\",\"fields\":[{\"name\":\"memStoreSizeMB\",\"type\":\"int\"},{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"storefileIndexSizeMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeMB\",\"type\":\"int\"},{\"name\":\"stores\",\"type\":\"int\"}]}}},{\"name\":\"storefileIndexSizeInMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeInMB\",\"type\":\"int\"},{\"name\":\"usedHeapMB\",\"type\":\"int\"}]}},{\"name\":\"serverAddress\",\"type\":{\"type\":\"record\",\"name\":\"AServerAddress\",\"fields\":[{\"name\":\"hostname\",\"type\":\"string\"},{\"name\":\"inetSocketAddress\",\"type\":\"string\"},{\"name\":\"port\",\"type\":\"int\"}]}},{\"name\":\"serverName\",\"type\":\"string\"},{\"name\":\"startCode\",\"type\":\"long\"}]}");
- public int infoPort;
- public org.apache.hadoop.hbase.avro.generated.AServerLoad load;
- public org.apache.hadoop.hbase.avro.generated.AServerAddress serverAddress;
- public java.lang.CharSequence serverName;
- public long startCode;
- 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 infoPort;
- case 1: return load;
- case 2: return serverAddress;
- case 3: return serverName;
- case 4: return startCode;
- 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: infoPort = (java.lang.Integer)value$; break;
- case 1: load = (org.apache.hadoop.hbase.avro.generated.AServerLoad)value$; break;
- case 2: serverAddress = (org.apache.hadoop.hbase.avro.generated.AServerAddress)value$; break;
- case 3: serverName = (java.lang.CharSequence)value$; break;
- case 4: startCode = (java.lang.Long)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/AServerLoad.java src/main/java/org/apache/hadoop/hbase/avro/generated/AServerLoad.java
deleted file mode 100644
index b0d9c5b..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/AServerLoad.java
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class AServerLoad extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"AServerLoad\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"load\",\"type\":\"int\"},{\"name\":\"maxHeapMB\",\"type\":\"int\"},{\"name\":\"memStoreSizeInMB\",\"type\":\"int\"},{\"name\":\"numberOfRegions\",\"type\":\"int\"},{\"name\":\"numberOfRequests\",\"type\":\"int\"},{\"name\":\"regionsLoad\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ARegionLoad\",\"fields\":[{\"name\":\"memStoreSizeMB\",\"type\":\"int\"},{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"storefileIndexSizeMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeMB\",\"type\":\"int\"},{\"name\":\"stores\",\"type\":\"int\"}]}}},{\"name\":\"storefileIndexSizeInMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeInMB\",\"type\":\"int\"},{\"name\":\"usedHeapMB\",\"type\":\"int\"}]}");
- public int load;
- public int maxHeapMB;
- public int memStoreSizeInMB;
- public int numberOfRegions;
- public int numberOfRequests;
- public java.util.List regionsLoad;
- public int storefileIndexSizeInMB;
- public int storefiles;
- public int storefileSizeInMB;
- public int usedHeapMB;
- 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 load;
- case 1: return maxHeapMB;
- case 2: return memStoreSizeInMB;
- case 3: return numberOfRegions;
- case 4: return numberOfRequests;
- case 5: return regionsLoad;
- case 6: return storefileIndexSizeInMB;
- case 7: return storefiles;
- case 8: return storefileSizeInMB;
- case 9: return usedHeapMB;
- 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: load = (java.lang.Integer)value$; break;
- case 1: maxHeapMB = (java.lang.Integer)value$; break;
- case 2: memStoreSizeInMB = (java.lang.Integer)value$; break;
- case 3: numberOfRegions = (java.lang.Integer)value$; break;
- case 4: numberOfRequests = (java.lang.Integer)value$; break;
- case 5: regionsLoad = (java.util.List)value$; break;
- case 6: storefileIndexSizeInMB = (java.lang.Integer)value$; break;
- case 7: storefiles = (java.lang.Integer)value$; break;
- case 8: storefileSizeInMB = (java.lang.Integer)value$; break;
- case 9: usedHeapMB = (java.lang.Integer)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java
deleted file mode 100644
index 97a534c..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java
+++ /dev/null
@@ -1,52 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class ATableDescriptor extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"ATableDescriptor\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"families\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AFamilyDescriptor\",\"fields\":[{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"compression\",\"type\":[{\"type\":\"enum\",\"name\":\"ACompressionAlgorithm\",\"symbols\":[\"LZO\",\"GZ\",\"NONE\"]},\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]},{\"name\":\"blocksize\",\"type\":[\"int\",\"null\"]},{\"name\":\"inMemory\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"timeToLive\",\"type\":[\"int\",\"null\"]},{\"name\":\"blockCacheEnabled\",\"type\":[\"boolean\",\"null\"]}]}},\"null\"]},{\"name\":\"maxFileSize\",\"type\":[\"long\",\"null\"]},{\"name\":\"memStoreFlushSize\",\"type\":[\"long\",\"null\"]},{\"name\":\"rootRegion\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"metaRegion\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"metaTable\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"readOnly\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"deferredLogFlush\",\"type\":[\"boolean\",\"null\"]}]}");
- public java.nio.ByteBuffer name;
- public java.util.List families;
- public java.lang.Long maxFileSize;
- public java.lang.Long memStoreFlushSize;
- public java.lang.Boolean rootRegion;
- public java.lang.Boolean metaRegion;
- public java.lang.Boolean metaTable;
- public java.lang.Boolean readOnly;
- public java.lang.Boolean deferredLogFlush;
- 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 name;
- case 1: return families;
- case 2: return maxFileSize;
- case 3: return memStoreFlushSize;
- case 4: return rootRegion;
- case 5: return metaRegion;
- case 6: return metaTable;
- case 7: return readOnly;
- case 8: return deferredLogFlush;
- 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: name = (java.nio.ByteBuffer)value$; break;
- case 1: families = (java.util.List)value$; break;
- case 2: maxFileSize = (java.lang.Long)value$; break;
- case 3: memStoreFlushSize = (java.lang.Long)value$; break;
- case 4: rootRegion = (java.lang.Boolean)value$; break;
- case 5: metaRegion = (java.lang.Boolean)value$; break;
- case 6: metaTable = (java.lang.Boolean)value$; break;
- case 7: readOnly = (java.lang.Boolean)value$; break;
- case 8: deferredLogFlush = (java.lang.Boolean)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java
deleted file mode 100644
index ac96c1c..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class ATableExists extends org.apache.avro.specific.SpecificExceptionBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"error\",\"name\":\"ATableExists\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}");
- public java.lang.CharSequence message;
- 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 message;
- 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: message = (java.lang.CharSequence)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java
deleted file mode 100644
index 61ee9ff..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class ATimeRange extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"ATimeRange\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"minStamp\",\"type\":\"long\"},{\"name\":\"maxStamp\",\"type\":\"long\"}]}");
- public long minStamp;
- public long maxStamp;
- 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 minStamp;
- case 1: return maxStamp;
- 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: minStamp = (java.lang.Long)value$; break;
- case 1: maxStamp = (java.lang.Long)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java
deleted file mode 100644
index d2efc95..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/**
- * Autogenerated by Avro
- *
- * DO NOT EDIT DIRECTLY
- */
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public interface HBase {
- public static final org.apache.avro.Protocol PROTOCOL = org.apache.avro.Protocol.parse("{\"protocol\":\"HBase\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"types\":[{\"type\":\"record\",\"name\":\"AServerAddress\",\"fields\":[{\"name\":\"hostname\",\"type\":\"string\"},{\"name\":\"inetSocketAddress\",\"type\":\"string\"},{\"name\":\"port\",\"type\":\"int\"}]},{\"type\":\"record\",\"name\":\"ARegionLoad\",\"fields\":[{\"name\":\"memStoreSizeMB\",\"type\":\"int\"},{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"storefileIndexSizeMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeMB\",\"type\":\"int\"},{\"name\":\"stores\",\"type\":\"int\"}]},{\"type\":\"record\",\"name\":\"AServerLoad\",\"fields\":[{\"name\":\"load\",\"type\":\"int\"},{\"name\":\"maxHeapMB\",\"type\":\"int\"},{\"name\":\"memStoreSizeInMB\",\"type\":\"int\"},{\"name\":\"numberOfRegions\",\"type\":\"int\"},{\"name\":\"numberOfRequests\",\"type\":\"int\"},{\"name\":\"regionsLoad\",\"type\":{\"type\":\"array\",\"items\":\"ARegionLoad\"}},{\"name\":\"storefileIndexSizeInMB\",\"type\":\"int\"},{\"name\":\"storefiles\",\"type\":\"int\"},{\"name\":\"storefileSizeInMB\",\"type\":\"int\"},{\"name\":\"usedHeapMB\",\"type\":\"int\"}]},{\"type\":\"record\",\"name\":\"AServerInfo\",\"fields\":[{\"name\":\"infoPort\",\"type\":\"int\"},{\"name\":\"load\",\"type\":\"AServerLoad\"},{\"name\":\"serverAddress\",\"type\":\"AServerAddress\"},{\"name\":\"serverName\",\"type\":\"string\"},{\"name\":\"startCode\",\"type\":\"long\"}]},{\"type\":\"record\",\"name\":\"AClusterStatus\",\"fields\":[{\"name\":\"averageLoad\",\"type\":\"double\"},{\"name\":\"deadServerNames\",\"type\":{\"type\":\"array\",\"items\":\"string\"}},{\"name\":\"deadServers\",\"type\":\"int\"},{\"name\":\"hbaseVersion\",\"type\":\"string\"},{\"name\":\"regionsCount\",\"type\":\"int\"},{\"name\":\"requestsCount\",\"type\":\"int\"},{\"name\":\"serverInfos\",\"type\":{\"type\":\"array\",\"items\":\"AServerInfo\"}},{\"name\":\"servers\",\"type\":\"int\"}]},{\"type\":\"enum\",\"name\":\"ACompressionAlgorithm\",\"symbols\":[\"LZO\",\"GZ\",\"NONE\"]},{\"type\":\"record\",\"name\":\"AFamilyDescriptor\",\"fields\":[{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"compression\",\"type\":[\"ACompressionAlgorithm\",\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]},{\"name\":\"blocksize\",\"type\":[\"int\",\"null\"]},{\"name\":\"inMemory\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"timeToLive\",\"type\":[\"int\",\"null\"]},{\"name\":\"blockCacheEnabled\",\"type\":[\"boolean\",\"null\"]}]},{\"type\":\"record\",\"name\":\"ATableDescriptor\",\"fields\":[{\"name\":\"name\",\"type\":\"bytes\"},{\"name\":\"families\",\"type\":[{\"type\":\"array\",\"items\":\"AFamilyDescriptor\"},\"null\"]},{\"name\":\"maxFileSize\",\"type\":[\"long\",\"null\"]},{\"name\":\"memStoreFlushSize\",\"type\":[\"long\",\"null\"]},{\"name\":\"rootRegion\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"metaRegion\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"metaTable\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"readOnly\",\"type\":[\"boolean\",\"null\"]},{\"name\":\"deferredLogFlush\",\"type\":[\"boolean\",\"null\"]}]},{\"type\":\"record\",\"name\":\"AColumn\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":[\"bytes\",\"null\"]}]},{\"type\":\"record\",\"name\":\"ATimeRange\",\"fields\":[{\"name\":\"minStamp\",\"type\":\"long\"},{\"name\":\"maxStamp\",\"type\":\"long\"}]},{\"type\":\"record\",\"name\":\"AGet\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"columns\",\"type\":[{\"type\":\"array\",\"items\":\"AColumn\"},\"null\"]},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]},{\"name\":\"timerange\",\"type\":[\"ATimeRange\",\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]}]},{\"type\":\"record\",\"name\":\"AResultEntry\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":\"long\"}]},{\"type\":\"record\",\"name\":\"AResult\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"entries\",\"type\":{\"type\":\"array\",\"items\":\"AResultEntry\"}}]},{\"type\":\"record\",\"name\":\"AColumnValue\",\"fields\":[{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]}]},{\"type\":\"record\",\"name\":\"APut\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"columnValues\",\"type\":{\"type\":\"array\",\"items\":\"AColumnValue\"}}]},{\"type\":\"record\",\"name\":\"ADelete\",\"fields\":[{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"columns\",\"type\":[{\"type\":\"array\",\"items\":\"AColumn\"},\"null\"]}]},{\"type\":\"record\",\"name\":\"AScan\",\"fields\":[{\"name\":\"startRow\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"stopRow\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"columns\",\"type\":[{\"type\":\"array\",\"items\":\"AColumn\"},\"null\"]},{\"name\":\"timestamp\",\"type\":[\"long\",\"null\"]},{\"name\":\"timerange\",\"type\":[\"ATimeRange\",\"null\"]},{\"name\":\"maxVersions\",\"type\":[\"int\",\"null\"]}]},{\"type\":\"error\",\"name\":\"AIOError\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]},{\"type\":\"error\",\"name\":\"AIllegalArgument\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]},{\"type\":\"error\",\"name\":\"ATableExists\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]},{\"type\":\"error\",\"name\":\"AMasterNotRunning\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}],\"messages\":{\"getHBaseVersion\":{\"request\":[],\"response\":\"string\",\"errors\":[\"AIOError\"]},\"getClusterStatus\":{\"request\":[],\"response\":\"AClusterStatus\",\"errors\":[\"AIOError\"]},\"listTables\":{\"request\":[],\"response\":{\"type\":\"array\",\"items\":\"ATableDescriptor\"},\"errors\":[\"AIOError\"]},\"describeTable\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"ATableDescriptor\",\"errors\":[\"AIOError\"]},\"isTableEnabled\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"boolean\",\"errors\":[\"AIOError\"]},\"tableExists\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"boolean\",\"errors\":[\"AIOError\"]},\"describeFamily\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"family\",\"type\":\"bytes\"}],\"response\":\"AFamilyDescriptor\",\"errors\":[\"AIOError\"]},\"createTable\":{\"request\":[{\"name\":\"table\",\"type\":\"ATableDescriptor\"}],\"response\":\"null\",\"errors\":[\"AIOError\",\"AIllegalArgument\",\"ATableExists\",\"AMasterNotRunning\"]},\"deleteTable\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"modifyTable\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"tableDescriptor\",\"type\":\"ATableDescriptor\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"enableTable\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"disableTable\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"flush\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"split\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"addFamily\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"family\",\"type\":\"AFamilyDescriptor\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"deleteFamily\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"family\",\"type\":\"bytes\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"modifyFamily\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"familyName\",\"type\":\"bytes\"},{\"name\":\"familyDescriptor\",\"type\":\"AFamilyDescriptor\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"get\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"get\",\"type\":\"AGet\"}],\"response\":\"AResult\",\"errors\":[\"AIOError\"]},\"exists\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"get\",\"type\":\"AGet\"}],\"response\":\"boolean\",\"errors\":[\"AIOError\"]},\"put\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"put\",\"type\":\"APut\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"delete\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"delete\",\"type\":\"ADelete\"}],\"response\":\"null\",\"errors\":[\"AIOError\"]},\"incrementColumnValue\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"row\",\"type\":\"bytes\"},{\"name\":\"family\",\"type\":\"bytes\"},{\"name\":\"qualifier\",\"type\":\"bytes\"},{\"name\":\"amount\",\"type\":\"long\"},{\"name\":\"writeToWAL\",\"type\":\"boolean\"}],\"response\":\"long\",\"errors\":[\"AIOError\"]},\"scannerOpen\":{\"request\":[{\"name\":\"table\",\"type\":\"bytes\"},{\"name\":\"scan\",\"type\":\"AScan\"}],\"response\":\"int\",\"errors\":[\"AIOError\"]},\"scannerClose\":{\"request\":[{\"name\":\"scannerId\",\"type\":\"int\"}],\"response\":\"null\",\"errors\":[\"AIOError\",\"AIllegalArgument\"]},\"scannerGetRows\":{\"request\":[{\"name\":\"scannerId\",\"type\":\"int\"},{\"name\":\"numberOfRows\",\"type\":\"int\"}],\"response\":{\"type\":\"array\",\"items\":\"AResult\"},\"errors\":[\"AIOError\",\"AIllegalArgument\"]}}}");
- java.lang.CharSequence getHBaseVersion() throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- org.apache.hadoop.hbase.avro.generated.AClusterStatus getClusterStatus() throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.util.List listTables() throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- org.apache.hadoop.hbase.avro.generated.ATableDescriptor describeTable(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- boolean isTableEnabled(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- boolean tableExists(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- org.apache.hadoop.hbase.avro.generated.AFamilyDescriptor describeFamily(java.nio.ByteBuffer table, java.nio.ByteBuffer family) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void createTable(org.apache.hadoop.hbase.avro.generated.ATableDescriptor table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError, org.apache.hadoop.hbase.avro.generated.AIllegalArgument, org.apache.hadoop.hbase.avro.generated.ATableExists, org.apache.hadoop.hbase.avro.generated.AMasterNotRunning;
- java.lang.Void deleteTable(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void modifyTable(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.ATableDescriptor tableDescriptor) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void enableTable(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void disableTable(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void flush(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void split(java.nio.ByteBuffer table) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void addFamily(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.AFamilyDescriptor family) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void deleteFamily(java.nio.ByteBuffer table, java.nio.ByteBuffer family) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void modifyFamily(java.nio.ByteBuffer table, java.nio.ByteBuffer familyName, org.apache.hadoop.hbase.avro.generated.AFamilyDescriptor familyDescriptor) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- org.apache.hadoop.hbase.avro.generated.AResult get(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.AGet get) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- boolean exists(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.AGet get) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void put(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.APut put) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void delete(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.ADelete delete) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- long incrementColumnValue(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, long amount, boolean writeToWAL) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- int scannerOpen(java.nio.ByteBuffer table, org.apache.hadoop.hbase.avro.generated.AScan scan) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError;
- java.lang.Void scannerClose(int scannerId) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError, org.apache.hadoop.hbase.avro.generated.AIllegalArgument;
- java.util.List scannerGetRows(int scannerId, int numberOfRows) throws org.apache.avro.ipc.AvroRemoteException, org.apache.hadoop.hbase.avro.generated.AIOError, org.apache.hadoop.hbase.avro.generated.AIllegalArgument;
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java
deleted file mode 100644
index 55cfa95..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class IOError extends org.apache.avro.specific.SpecificExceptionBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"error\",\"name\":\"IOError\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"message\",\"type\":\"string\"}]}");
- public org.apache.avro.util.Utf8 message;
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return message;
- 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: message = (org.apache.avro.util.Utf8)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java
deleted file mode 100644
index 602873e..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package org.apache.hadoop.hbase.avro.generated;
-
-@SuppressWarnings("all")
-public class TCell extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema.parse("{\"type\":\"record\",\"name\":\"TCell\",\"namespace\":\"org.apache.hadoop.hbase.avro.generated\",\"fields\":[{\"name\":\"value\",\"type\":\"bytes\"},{\"name\":\"timestamp\",\"type\":\"long\"}]}");
- public java.nio.ByteBuffer value;
- public long timestamp;
- public org.apache.avro.Schema getSchema() { return SCHEMA$; }
- public java.lang.Object get(int field$) {
- switch (field$) {
- case 0: return value;
- case 1: return timestamp;
- 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: value = (java.nio.ByteBuffer)value$; break;
- case 1: timestamp = (java.lang.Long)value$; break;
- default: throw new org.apache.avro.AvroRuntimeException("Bad index");
- }
- }
-}
diff --git src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr
deleted file mode 100644
index 68f3664..0000000
--- src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr
+++ /dev/null
@@ -1,609 +0,0 @@
-{
- "protocol" : "HBase",
- "namespace" : "org.apache.hadoop.hbase.avro.generated",
- "types" : [ {
- "type" : "record",
- "name" : "AServerAddress",
- "fields" : [ {
- "name" : "hostname",
- "type" : "string"
- }, {
- "name" : "inetSocketAddress",
- "type" : "string"
- }, {
- "name" : "port",
- "type" : "int"
- } ]
- }, {
- "type" : "record",
- "name" : "ARegionLoad",
- "fields" : [ {
- "name" : "memStoreSizeMB",
- "type" : "int"
- }, {
- "name" : "name",
- "type" : "bytes"
- }, {
- "name" : "storefileIndexSizeMB",
- "type" : "int"
- }, {
- "name" : "storefiles",
- "type" : "int"
- }, {
- "name" : "storefileSizeMB",
- "type" : "int"
- }, {
- "name" : "stores",
- "type" : "int"
- } ]
- }, {
- "type" : "record",
- "name" : "AServerLoad",
- "fields" : [ {
- "name" : "load",
- "type" : "int"
- }, {
- "name" : "maxHeapMB",
- "type" : "int"
- }, {
- "name" : "memStoreSizeInMB",
- "type" : "int"
- }, {
- "name" : "numberOfRegions",
- "type" : "int"
- }, {
- "name" : "numberOfRequests",
- "type" : "int"
- }, {
- "name" : "regionsLoad",
- "type" : {
- "type" : "array",
- "items" : "ARegionLoad"
- }
- }, {
- "name" : "storefileIndexSizeInMB",
- "type" : "int"
- }, {
- "name" : "storefiles",
- "type" : "int"
- }, {
- "name" : "storefileSizeInMB",
- "type" : "int"
- }, {
- "name" : "usedHeapMB",
- "type" : "int"
- } ]
- }, {
- "type" : "record",
- "name" : "AServerInfo",
- "fields" : [ {
- "name" : "infoPort",
- "type" : "int"
- }, {
- "name" : "load",
- "type" : "AServerLoad"
- }, {
- "name" : "serverAddress",
- "type" : "AServerAddress"
- }, {
- "name" : "serverName",
- "type" : "string"
- }, {
- "name" : "startCode",
- "type" : "long"
- } ]
- }, {
- "type" : "record",
- "name" : "AClusterStatus",
- "fields" : [ {
- "name" : "averageLoad",
- "type" : "double"
- }, {
- "name" : "deadServerNames",
- "type" : {
- "type" : "array",
- "items" : "string"
- }
- }, {
- "name" : "deadServers",
- "type" : "int"
- }, {
- "name" : "hbaseVersion",
- "type" : "string"
- }, {
- "name" : "regionsCount",
- "type" : "int"
- }, {
- "name" : "requestsCount",
- "type" : "int"
- }, {
- "name" : "serverInfos",
- "type" : {
- "type" : "array",
- "items" : "AServerInfo"
- }
- }, {
- "name" : "servers",
- "type" : "int"
- } ]
- }, {
- "type" : "enum",
- "name" : "ACompressionAlgorithm",
- "symbols" : [ "LZO", "GZ", "NONE" ]
- }, {
- "type" : "record",
- "name" : "AFamilyDescriptor",
- "fields" : [ {
- "name" : "name",
- "type" : "bytes"
- }, {
- "name" : "compression",
- "type" : [ "ACompressionAlgorithm", "null" ]
- }, {
- "name" : "maxVersions",
- "type" : [ "int", "null" ]
- }, {
- "name" : "blocksize",
- "type" : [ "int", "null" ]
- }, {
- "name" : "inMemory",
- "type" : [ "boolean", "null" ]
- }, {
- "name" : "timeToLive",
- "type" : [ "int", "null" ]
- }, {
- "name" : "blockCacheEnabled",
- "type" : [ "boolean", "null" ]
- } ]
- }, {
- "type" : "record",
- "name" : "ATableDescriptor",
- "fields" : [ {
- "name" : "name",
- "type" : "bytes"
- }, {
- "name" : "families",
- "type" : [ {
- "type" : "array",
- "items" : "AFamilyDescriptor"
- }, "null" ]
- }, {
- "name" : "maxFileSize",
- "type" : [ "long", "null" ]
- }, {
- "name" : "memStoreFlushSize",
- "type" : [ "long", "null" ]
- }, {
- "name" : "rootRegion",
- "type" : [ "boolean", "null" ]
- }, {
- "name" : "metaRegion",
- "type" : [ "boolean", "null" ]
- }, {
- "name" : "metaTable",
- "type" : [ "boolean", "null" ]
- }, {
- "name" : "readOnly",
- "type" : [ "boolean", "null" ]
- }, {
- "name" : "deferredLogFlush",
- "type" : [ "boolean", "null" ]
- } ]
- }, {
- "type" : "record",
- "name" : "AColumn",
- "fields" : [ {
- "name" : "family",
- "type" : "bytes"
- }, {
- "name" : "qualifier",
- "type" : [ "bytes", "null" ]
- } ]
- }, {
- "type" : "record",
- "name" : "ATimeRange",
- "fields" : [ {
- "name" : "minStamp",
- "type" : "long"
- }, {
- "name" : "maxStamp",
- "type" : "long"
- } ]
- }, {
- "type" : "record",
- "name" : "AGet",
- "fields" : [ {
- "name" : "row",
- "type" : "bytes"
- }, {
- "name" : "columns",
- "type" : [ {
- "type" : "array",
- "items" : "AColumn"
- }, "null" ]
- }, {
- "name" : "timestamp",
- "type" : [ "long", "null" ]
- }, {
- "name" : "timerange",
- "type" : [ "ATimeRange", "null" ]
- }, {
- "name" : "maxVersions",
- "type" : [ "int", "null" ]
- } ]
- }, {
- "type" : "record",
- "name" : "AResultEntry",
- "fields" : [ {
- "name" : "family",
- "type" : "bytes"
- }, {
- "name" : "qualifier",
- "type" : "bytes"
- }, {
- "name" : "value",
- "type" : "bytes"
- }, {
- "name" : "timestamp",
- "type" : "long"
- } ]
- }, {
- "type" : "record",
- "name" : "AResult",
- "fields" : [ {
- "name" : "row",
- "type" : "bytes"
- }, {
- "name" : "entries",
- "type" : {
- "type" : "array",
- "items" : "AResultEntry"
- }
- } ]
- }, {
- "type" : "record",
- "name" : "AColumnValue",
- "fields" : [ {
- "name" : "family",
- "type" : "bytes"
- }, {
- "name" : "qualifier",
- "type" : "bytes"
- }, {
- "name" : "value",
- "type" : "bytes"
- }, {
- "name" : "timestamp",
- "type" : [ "long", "null" ]
- } ]
- }, {
- "type" : "record",
- "name" : "APut",
- "fields" : [ {
- "name" : "row",
- "type" : "bytes"
- }, {
- "name" : "columnValues",
- "type" : {
- "type" : "array",
- "items" : "AColumnValue"
- }
- } ]
- }, {
- "type" : "record",
- "name" : "ADelete",
- "fields" : [ {
- "name" : "row",
- "type" : "bytes"
- }, {
- "name" : "columns",
- "type" : [ {
- "type" : "array",
- "items" : "AColumn"
- }, "null" ]
- } ]
- }, {
- "type" : "record",
- "name" : "AScan",
- "fields" : [ {
- "name" : "startRow",
- "type" : [ "bytes", "null" ]
- }, {
- "name" : "stopRow",
- "type" : [ "bytes", "null" ]
- }, {
- "name" : "columns",
- "type" : [ {
- "type" : "array",
- "items" : "AColumn"
- }, "null" ]
- }, {
- "name" : "timestamp",
- "type" : [ "long", "null" ]
- }, {
- "name" : "timerange",
- "type" : [ "ATimeRange", "null" ]
- }, {
- "name" : "maxVersions",
- "type" : [ "int", "null" ]
- } ]
- }, {
- "type" : "error",
- "name" : "AIOError",
- "fields" : [ {
- "name" : "message",
- "type" : "string"
- } ]
- }, {
- "type" : "error",
- "name" : "AIllegalArgument",
- "fields" : [ {
- "name" : "message",
- "type" : "string"
- } ]
- }, {
- "type" : "error",
- "name" : "ATableExists",
- "fields" : [ {
- "name" : "message",
- "type" : "string"
- } ]
- }, {
- "type" : "error",
- "name" : "AMasterNotRunning",
- "fields" : [ {
- "name" : "message",
- "type" : "string"
- } ]
- } ],
- "messages" : {
- "getHBaseVersion" : {
- "request" : [ ],
- "response" : "string",
- "errors" : [ "AIOError" ]
- },
- "getClusterStatus" : {
- "request" : [ ],
- "response" : "AClusterStatus",
- "errors" : [ "AIOError" ]
- },
- "listTables" : {
- "request" : [ ],
- "response" : {
- "type" : "array",
- "items" : "ATableDescriptor"
- },
- "errors" : [ "AIOError" ]
- },
- "describeTable" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "ATableDescriptor",
- "errors" : [ "AIOError" ]
- },
- "isTableEnabled" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "boolean",
- "errors" : [ "AIOError" ]
- },
- "tableExists" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "boolean",
- "errors" : [ "AIOError" ]
- },
- "describeFamily" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "family",
- "type" : "bytes"
- } ],
- "response" : "AFamilyDescriptor",
- "errors" : [ "AIOError" ]
- },
- "createTable" : {
- "request" : [ {
- "name" : "table",
- "type" : "ATableDescriptor"
- } ],
- "response" : "null",
- "errors" : [ "AIOError", "AIllegalArgument", "ATableExists", "AMasterNotRunning" ]
- },
- "deleteTable" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "modifyTable" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "tableDescriptor",
- "type" : "ATableDescriptor"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "enableTable" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "disableTable" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "flush" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "split" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "addFamily" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "family",
- "type" : "AFamilyDescriptor"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "deleteFamily" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "family",
- "type" : "bytes"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "modifyFamily" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "familyName",
- "type" : "bytes"
- }, {
- "name" : "familyDescriptor",
- "type" : "AFamilyDescriptor"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "get" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "get",
- "type" : "AGet"
- } ],
- "response" : "AResult",
- "errors" : [ "AIOError" ]
- },
- "exists" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "get",
- "type" : "AGet"
- } ],
- "response" : "boolean",
- "errors" : [ "AIOError" ]
- },
- "put" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "put",
- "type" : "APut"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "delete" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "delete",
- "type" : "ADelete"
- } ],
- "response" : "null",
- "errors" : [ "AIOError" ]
- },
- "incrementColumnValue" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "row",
- "type" : "bytes"
- }, {
- "name" : "family",
- "type" : "bytes"
- }, {
- "name" : "qualifier",
- "type" : "bytes"
- }, {
- "name" : "amount",
- "type" : "long"
- }, {
- "name" : "writeToWAL",
- "type" : "boolean"
- } ],
- "response" : "long",
- "errors" : [ "AIOError" ]
- },
- "scannerOpen" : {
- "request" : [ {
- "name" : "table",
- "type" : "bytes"
- }, {
- "name" : "scan",
- "type" : "AScan"
- } ],
- "response" : "int",
- "errors" : [ "AIOError" ]
- },
- "scannerClose" : {
- "request" : [ {
- "name" : "scannerId",
- "type" : "int"
- } ],
- "response" : "null",
- "errors" : [ "AIOError", "AIllegalArgument" ]
- },
- "scannerGetRows" : {
- "request" : [ {
- "name" : "scannerId",
- "type" : "int"
- }, {
- "name" : "numberOfRows",
- "type" : "int"
- } ],
- "response" : {
- "type" : "array",
- "items" : "AResult"
- },
- "errors" : [ "AIOError", "AIllegalArgument" ]
- }
- }
-}
\ No newline at end of file