You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2014/04/02 23:10:37 UTC
svn commit: r1584188 [2/2] - in /hbase/branches/0.89-fb: ./ bin/
src/main/java/org/apache/hadoop/hbase/avro/
src/main/java/org/apache/hadoop/hbase/avro/generated/
src/test/java/org/apache/hadoop/hbase/avro/
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableDescriptor.java Wed Apr 2 21:10:36 2014
@@ -1,45 +0,0 @@
-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 org.apache.avro.generic.GenericArray<org.apache.hadoop.hbase.avro.generated.AFamilyDescriptor> 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$; }
- 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");
- }
- }
- @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 = (org.apache.avro.generic.GenericArray<org.apache.hadoop.hbase.avro.generated.AFamilyDescriptor>)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");
- }
- }
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATableExists.java Wed Apr 2 21:10:36 2014
@@ -1,21 +0,0 @@
-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 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");
- }
- }
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/ATimeRange.java Wed Apr 2 21:10:36 2014
@@ -1,24 +0,0 @@
-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$; }
- 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");
- }
- }
- @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");
- }
- }
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/HBase.java Wed Apr 2 21:10:36 2014
@@ -1,56 +0,0 @@
-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\"},{\"nam
e\":\"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\"]},{\"na
me\":\"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\":\"stop
Row\",\"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\":\"ATableDescri
ptor\"},\"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\":\"tableDesc
riptor\",\"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\":\"write
ToWAL\",\"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\"]}}}");
- org.apache.avro.util.Utf8 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;
- org.apache.avro.generic.GenericArray<org.apache.hadoop.hbase.avro.generated.ATableDescriptor> 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;
- org.apache.avro.generic.GenericArray<org.apache.hadoop.hbase.avro.generated.AResult> 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;
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/IOError.java Wed Apr 2 21:10:36 2014
@@ -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");
- }
- }
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/generated/TCell.java Wed Apr 2 21:10:36 2014
@@ -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");
- }
- }
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.avpr Wed Apr 2 21:10:36 2014
@@ -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
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.genavro
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.genavro?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.genavro (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/hbase.genavro Wed Apr 2 21:10:36 2014
@@ -1,271 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Avro protocol for a "gateway" service
- */
-@namespace("org.apache.hadoop.hbase.avro.generated")
-protocol HBase {
-
- //
- // TYPES
- //
-
- //
- // Cluster metadata
- //
- // TODO(hammer): Best way to represent java.net.InetSocketAddress?
- record AServerAddress {
- string hostname;
- string inetSocketAddress;
- int port;
- }
-
- record ARegionLoad {
- int memStoreSizeMB;
- bytes name;
- int storefileIndexSizeMB;
- int storefiles;
- int storefileSizeMB;
- int stores;
- }
-
- record AServerLoad {
- int load;
- int maxHeapMB;
- int memStoreSizeInMB;
- int numberOfRegions;
- int numberOfRequests;
- array<ARegionLoad> regionsLoad;
- int storefileIndexSizeInMB;
- int storefiles;
- int storefileSizeInMB;
- int usedHeapMB;
- }
-
- record AServerInfo {
- int infoPort;
- AServerLoad load;
- AServerAddress serverAddress;
- string serverName;
- long startCode;
- }
-
- // TODO(hammer): Implement reusable Writable to Avro record converter?
- record AClusterStatus {
- double averageLoad;
- array<string> deadServerNames;
- int deadServers;
- string hbaseVersion;
- int regionsCount;
- int requestsCount;
- array<AServerInfo> serverInfos;
- int servers;
- }
-
- //
- // Family metadata
- //
- // TODO(hammer): how to keep in sync with Java Enum?
- enum ACompressionAlgorithm {
- LZO, GZ, NONE
- }
-
- // TODO(hammer): include COLUMN_DESCRIPTOR_VERSION?
- // TODO(hammer): add new bloomfilter stuff
- record AFamilyDescriptor {
- bytes name;
- union { ACompressionAlgorithm, null } compression;
- union { int, null } maxVersions;
- union { int, null } blocksize;
- union { boolean, null } inMemory;
- union { int, null } timeToLive;
- union { boolean, null } blockCacheEnabled;
- }
-
- //
- // Table metadata
- //
- // TODO(hammer): include TABLE_DESCRIPTOR_VERSION?
- record ATableDescriptor {
- bytes name;
- union { array<AFamilyDescriptor>, null } families;
- union { long, null } maxFileSize;
- union { long, null } memStoreFlushSize;
- union { boolean, null } rootRegion;
- union { boolean, null } metaRegion;
- union { boolean, null } metaTable;
- union { boolean, null } readOnly;
- union { boolean, null } deferredLogFlush;
- }
-
- //
- // Single-Row DML (Get)
- //
- record AColumn {
- bytes family;
- union { bytes, null } qualifier;
- }
-
- record ATimeRange {
- long minStamp;
- long maxStamp;
- }
-
- // TODO(hammer): Add filter options
- record AGet {
- bytes row;
- union { array<AColumn>, null } columns;
- union { long, null } timestamp;
- union { ATimeRange, null } timerange;
- union { int, null } maxVersions;
- }
-
- record AResultEntry {
- bytes family;
- bytes qualifier;
- bytes value;
- long timestamp;
- }
-
- // Avro maps can't use non-string keys, so using an array for now
- record AResult {
- bytes row;
- array<AResultEntry> entries;
- }
-
- //
- // Single-Row DML (Put)
- //
- // TODO(hammer): Reuse a single KeyValue-style record for Get and Put?
- record AColumnValue {
- bytes family;
- bytes qualifier;
- bytes value;
- union { long, null } timestamp;
- }
-
- record APut {
- bytes row;
- array<AColumnValue> columnValues;
- }
-
- //
- // Single-Row DML (Delete)
- //
- // TODO(hammer): Add fields when API is rationalized (HBASE-2609)
- record ADelete {
- bytes row;
- union { array<AColumn>, null } columns;
- }
-
- //
- // Multi-Row DML (Scan)
- //
- record AScan {
- union { bytes, null } startRow;
- union { bytes, null } stopRow;
- union { array<AColumn>, null } columns;
- union { long, null } timestamp;
- union { ATimeRange, null } timerange;
- union { int, null } maxVersions;
- }
-
- //
- // ERRORS
- //
-
- /**
- * An AIOError error signals that an error occurred communicating
- * to the HBase master or a HBase region server. Also used to return
- * more general HBase error conditions.
- */
- error AIOError {
- string message;
- }
-
- /**
- * An AIllegalArgument error indicates an illegal or invalid
- * argument was passed into a procedure.
- */
- error AIllegalArgument {
- string message;
- }
-
- /**
- * An ATableExists error that a table with the specified
- * name already exists
- */
- error ATableExists {
- string message;
- }
-
- /**
- * An AMasterNotRunning error means we couldn't reach the Master.
- */
- error AMasterNotRunning {
- string message;
- }
-
- //
- // MESSAGES
- //
-
- // TODO(hammer): surgery tools
- // TODO(hammer): checkAndPut/flushCommits
- // TODO(hammer): MultiPut/Get/Delete
-
- // Cluster metadata
- string getHBaseVersion() throws AIOError;
- AClusterStatus getClusterStatus() throws AIOError;
- array<ATableDescriptor> listTables() throws AIOError;
-
- // Table metadata
- ATableDescriptor describeTable(bytes table) throws AIOError;
- boolean isTableEnabled(bytes table) throws AIOError;
- boolean tableExists(bytes table) throws AIOError;
-
- // Family metadata
- AFamilyDescriptor describeFamily(bytes table, bytes family) throws AIOError;
-
- // Table admin
- void createTable(ATableDescriptor table) throws AIOError, AIllegalArgument, ATableExists, AMasterNotRunning;
- void deleteTable(bytes table) throws AIOError;
- void modifyTable(bytes table, ATableDescriptor tableDescriptor) throws AIOError;
- void enableTable(bytes table) throws AIOError;
- void disableTable(bytes table) throws AIOError;
- void flush(bytes table) throws AIOError;
- void split(bytes table) throws AIOError;
-
- // Family admin
- void addFamily(bytes table, AFamilyDescriptor family) throws AIOError;
- void deleteFamily(bytes table, bytes family) throws AIOError;
- void modifyFamily(bytes table, bytes familyName, AFamilyDescriptor familyDescriptor) throws AIOError;
-
- // Single-row DML
- AResult get(bytes table, AGet get) throws AIOError;
- boolean exists(bytes table, AGet get) throws AIOError;
- void put(bytes table, APut put) throws AIOError;
- void delete(bytes table, ADelete delete) throws AIOError;
- long incrementColumnValue(bytes table, bytes row, bytes family, bytes qualifier, long amount, boolean writeToWAL) throws AIOError;
-
- // Multi-row DML (read-only)
- int scannerOpen(bytes table, AScan scan) throws AIOError;
- void scannerClose(int scannerId) throws AIOError, AIllegalArgument;
- array<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument;
-}
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/package.html
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/package.html?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/package.html (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/avro/package.html Wed Apr 2 21:10:36 2014
@@ -1,70 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 3.2 Final//EN">
-<html>
-
-<!--
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
--->
-
-<head />
-<body bgcolor="white">
-Provides an HBase <a href="http://avro.apache.org">Avro</a> service.
-
-This directory contains an Avro interface definition file for an HBase RPC
-service and a Java server implementation.
-
-<h2><a name="whatisavro">What is Avro?</a></h2>
-
-<p>Avro is a data serialization and RPC system. For more, see the
-<a href="http://avro.apache.org/docs/current/spec.html">current specification</a>.
-</p>
-
-<h2><a name="description">Description</a></h2>
-
-<p>The <a href="generated/HBase.html">HBase API</a> is defined in the
-file hbase.genavro. A server-side implementation of the API is in
-<code>org.apache.hadoop.hbase.avro.AvroServer</code>. The generated interfaces,
-types, and RPC utility files are checked into SVN under the
-<code>org.apache.hadoop.hbase.avro.generated</code> directory.
-
-</p>
-
-<p>The files were generated by running the commands:
-<pre>
- java -jar avro-tools-1.3.2.jar genavro hbase.genavro hbase.avpr
- java -jar avro-tools-1.3.2.jar compile protocol hbase.avro $HBASE_HOME/src/java
-</pre>
-</p>
-
-<p>The 'avro-tools-x.y.z.jar' jarfile is an Avro utility, and it is
-distributed as a part of the Avro package. Additionally, specific
-language runtime libraries are apart of the Avro package. A version of the
-Java runtime is listed as a dendency in Maven.
-</p>
-
-<p>To start AvroServer, use:
-<pre>
- ./bin/hbase avro start [--port=PORT]
-</pre>
-The default port is 9090.
-</p>
-
-<p>To stop, use:
-<pre>
- ./bin/hbase-daemon.sh stop avro
-</pre>
-</p>
-</body>
-</html>
Modified: hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/avro/TestAvroServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/avro/TestAvroServer.java?rev=1584188&r1=1584187&r2=1584188&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/avro/TestAvroServer.java (original)
+++ hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/avro/TestAvroServer.java Wed Apr 2 21:10:36 2014
@@ -1,227 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.hadoop.hbase.avro;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-
-import java.nio.ByteBuffer;
-
-import org.apache.hadoop.hbase.HBaseClusterTestCase;
-import org.apache.hadoop.hbase.HBaseTestingUtility;
-import org.apache.hadoop.hbase.MasterNotRunningException;
-import org.apache.hadoop.hbase.util.Bytes;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import org.apache.avro.Schema;
-import org.apache.avro.generic.GenericArray;
-import org.apache.avro.generic.GenericData;
-
-import org.apache.hadoop.hbase.avro.AvroServer.HBaseImpl;
-import org.apache.hadoop.hbase.avro.generated.AColumn;
-import org.apache.hadoop.hbase.avro.generated.AColumnValue;
-import org.apache.hadoop.hbase.avro.generated.AFamilyDescriptor;
-import org.apache.hadoop.hbase.avro.generated.AGet;
-import org.apache.hadoop.hbase.avro.generated.APut;
-import org.apache.hadoop.hbase.avro.generated.ATableDescriptor;
-
-/**
- * Unit testing for AvroServer.HBaseImpl, a part of the
- * org.apache.hadoop.hbase.avro package.
- */
-public class TestAvroServer {
- private final static HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();
-
- // Static names for tables, columns, rows, and values
- // TODO(hammer): Better style to define these in test method?
- private static ByteBuffer tableAname = ByteBuffer.wrap(Bytes.toBytes("tableA"));
- private static ByteBuffer tableBname = ByteBuffer.wrap(Bytes.toBytes("tableB"));
- private static ByteBuffer familyAname = ByteBuffer.wrap(Bytes.toBytes("FamilyA"));
- private static ByteBuffer qualifierAname = ByteBuffer.wrap(Bytes.toBytes("QualifierA"));
- private static ByteBuffer rowAname = ByteBuffer.wrap(Bytes.toBytes("RowA"));
- private static ByteBuffer valueA = ByteBuffer.wrap(Bytes.toBytes("ValueA"));
-
- /**
- * @throws java.lang.Exception
- */
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {
- TEST_UTIL.startMiniCluster(3);
- }
-
- /**
- * @throws java.lang.Exception
- */
- @AfterClass
- public static void tearDownAfterClass() throws Exception {
- TEST_UTIL.shutdownMiniCluster();
- }
-
- /**
- * @throws java.lang.Exception
- */
- @Before
- public void setUp() throws Exception {
- // Nothing to do.
- }
-
- /**
- * @throws java.lang.Exception
- */
- @After
- public void tearDown() throws Exception {
- // Nothing to do.
- }
-
- /**
- * Tests for creating, enabling, disabling, modifying, and deleting tables.
- *
- * @throws Exception
- */
- @Test
- public void testTableAdminAndMetadata() throws Exception {
- AvroServer.HBaseImpl impl = createAvroServer();
-
- assertEquals(impl.listTables().size(), 0);
-
- ATableDescriptor tableA = new ATableDescriptor();
- tableA.name = tableAname;
- impl.createTable(tableA);
- assertEquals(impl.listTables().size(), 1);
- assertTrue(impl.isTableEnabled(tableAname));
- assertTrue(impl.tableExists(tableAname));
-
- ATableDescriptor tableB = new ATableDescriptor();
- tableB.name = tableBname;
- impl.createTable(tableB);
- assertEquals(impl.listTables().size(), 2);
-
- impl.disableTable(tableBname);
- assertFalse(impl.isTableEnabled(tableBname));
-
- impl.deleteTable(tableBname);
- assertEquals(impl.listTables().size(), 1);
-
- impl.disableTable(tableAname);
- assertFalse(impl.isTableEnabled(tableAname));
-
- tableA.maxFileSize = 123456L;
- impl.modifyTable(tableAname, tableA);
- assertEquals((long) impl.describeTable(tableAname).maxFileSize, 123456L);
-
- impl.enableTable(tableAname);
- assertTrue(impl.isTableEnabled(tableAname));
- impl.disableTable(tableAname);
- impl.deleteTable(tableAname);
- }
-
- /**
- * Tests for creating, modifying, and deleting column families.
- *
- * @throws Exception
- */
- @Test
- public void testFamilyAdminAndMetadata() throws Exception {
- AvroServer.HBaseImpl impl = createAvroServer();
-
- ATableDescriptor tableA = new ATableDescriptor();
- tableA.name = tableAname;
- AFamilyDescriptor familyA = new AFamilyDescriptor();
- familyA.name = familyAname;
- Schema familyArraySchema = Schema.createArray(AFamilyDescriptor.SCHEMA$);
- GenericArray<AFamilyDescriptor> families = new GenericData.Array<AFamilyDescriptor>(1, familyArraySchema);
- families.add(familyA);
- tableA.families = families;
- impl.createTable(tableA);
- assertEquals(impl.describeTable(tableAname).families.size(), 1);
-
- impl.disableTable(tableAname);
- assertFalse(impl.isTableEnabled(tableAname));
-
- familyA.maxVersions = 123456;
- impl.modifyFamily(tableAname, familyAname, familyA);
- assertEquals((int) impl.describeFamily(tableAname, familyAname).maxVersions, 123456);
-
- impl.deleteFamily(tableAname, familyAname);
- assertEquals(impl.describeTable(tableAname).families.size(), 0);
-
- impl.disableTable(tableAname);
- impl.deleteTable(tableAname);
- }
-
- /**
- * Tests for adding, reading, and deleting data.
- *
- * @throws Exception
- */
- @Test
- public void testDML() throws Exception {
- AvroServer.HBaseImpl impl = createAvroServer();
-
- ATableDescriptor tableA = new ATableDescriptor();
- tableA.name = tableAname;
- AFamilyDescriptor familyA = new AFamilyDescriptor();
- familyA.name = familyAname;
- Schema familyArraySchema = Schema.createArray(AFamilyDescriptor.SCHEMA$);
- GenericArray<AFamilyDescriptor> families = new GenericData.Array<AFamilyDescriptor>(1, familyArraySchema);
- families.add(familyA);
- tableA.families = families;
- impl.createTable(tableA);
- assertEquals(impl.describeTable(tableAname).families.size(), 1);
-
- AGet getA = new AGet();
- getA.row = rowAname;
- Schema columnsSchema = Schema.createArray(AColumn.SCHEMA$);
- GenericArray<AColumn> columns = new GenericData.Array<AColumn>(1, columnsSchema);
- AColumn column = new AColumn();
- column.family = familyAname;
- column.qualifier = qualifierAname;
- columns.add(column);
- getA.columns = columns;
-
- assertFalse(impl.exists(tableAname, getA));
-
- APut putA = new APut();
- putA.row = rowAname;
- Schema columnValuesSchema = Schema.createArray(AColumnValue.SCHEMA$);
- GenericArray<AColumnValue> columnValues = new GenericData.Array<AColumnValue>(1, columnValuesSchema);
- AColumnValue acv = new AColumnValue();
- acv.family = familyAname;
- acv.qualifier = qualifierAname;
- acv.value = valueA;
- columnValues.add(acv);
- putA.columnValues = columnValues;
-
- impl.put(tableAname, putA);
- assertTrue(impl.exists(tableAname, getA));
-
- assertEquals(impl.get(tableAname, getA).entries.size(), 1);
-
- impl.disableTable(tableAname);
- impl.deleteTable(tableAname);
- }
-
- public HBaseImpl createAvroServer() throws MasterNotRunningException {
- return new AvroServer.HBaseImpl(TEST_UTIL.getConfiguration());
- }
-}