From bed62353fb8e9aa6825d1be51671b70a7ad68ed9 Mon Sep 17 00:00:00 2001 From: Elliott Clark Date: Wed, 15 Jul 2015 15:15:25 -0700 Subject: [PATCH] HBASE-14094 Procedure.proto can't be compiled to C++ --- .../procedure2/store/wal/ProcedureWALFormat.java | 12 +-- .../store/wal/ProcedureWALFormatReader.java | 12 +-- .../hbase/protobuf/generated/ProcedureProtos.java | 86 +++++++++++----------- hbase-protocol/src/main/protobuf/Procedure.proto | 12 +-- 4 files changed, 61 insertions(+), 61 deletions(-) diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormat.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormat.java index c75c141..04c1b84 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormat.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormat.java @@ -120,7 +120,7 @@ public final class ProcedureWALFormat { // Write EOF Entry ProcedureWALEntry.newBuilder() - .setType(ProcedureWALEntry.Type.EOF) + .setType(ProcedureWALEntry.Type.EOF_T) .build().writeDelimitedTo(stream); // Write Tracker @@ -181,7 +181,7 @@ public final class ProcedureWALFormat { stream.seek(trailerOffset); ProcedureWALEntry entry = readEntry(stream); - if (entry.getType() != ProcedureWALEntry.Type.EOF) { + if (entry.getType() != ProcedureWALEntry.Type.EOF_T) { throw new InvalidWALDataException("Invalid Trailer begin"); } @@ -211,23 +211,23 @@ public final class ProcedureWALFormat { public static void writeInsert(ByteSlot slot, Procedure proc) throws IOException { - writeEntry(slot, ProcedureWALEntry.Type.INIT, proc, null); + writeEntry(slot, ProcedureWALEntry.Type.INIT_T, proc, null); } public static void writeInsert(ByteSlot slot, Procedure proc, Procedure[] subprocs) throws IOException { - writeEntry(slot, ProcedureWALEntry.Type.INSERT, proc, subprocs); + writeEntry(slot, ProcedureWALEntry.Type.INSERT_T, proc, subprocs); } public static void writeUpdate(ByteSlot slot, Procedure proc) throws IOException { - writeEntry(slot, ProcedureWALEntry.Type.UPDATE, proc, null); + writeEntry(slot, ProcedureWALEntry.Type.UPDATE_T, proc, null); } public static void writeDelete(ByteSlot slot, long procId) throws IOException { ProcedureWALEntry.Builder builder = ProcedureWALEntry.newBuilder(); - builder.setType(ProcedureWALEntry.Type.DELETE); + builder.setType(ProcedureWALEntry.Type.DELETE_T); builder.setProcId(procId); builder.build().writeDelimitedTo(slot); } diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java index 76c0554..0d9a32c 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java @@ -121,20 +121,20 @@ public class ProcedureWALFormatReader { break; } switch (entry.getType()) { - case INIT: + case INIT_T: readInitEntry(entry); break; - case INSERT: + case INSERT_T: readInsertEntry(entry); break; - case UPDATE: - case COMPACT: + case UPDATE_T: + case COMPACT_T: readUpdateEntry(entry); break; - case DELETE: + case DELETE_T: readDeleteEntry(entry); break; - case EOF: + case EOF_T: hasMore = false; break; default: diff --git a/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ProcedureProtos.java b/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ProcedureProtos.java index 89f6f1b..a530044 100644 --- a/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ProcedureProtos.java +++ b/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ProcedureProtos.java @@ -6419,67 +6419,67 @@ public final class ProcedureProtos { public enum Type implements com.google.protobuf.ProtocolMessageEnum { /** - * EOF = 1; + * EOF_T = 1; */ - EOF(0, 1), + EOF_T(0, 1), /** - * INIT = 2; + * INIT_T = 2; */ - INIT(1, 2), + INIT_T(1, 2), /** - * INSERT = 3; + * INSERT_T = 3; */ - INSERT(2, 3), + INSERT_T(2, 3), /** - * UPDATE = 4; + * UPDATE_T = 4; */ - UPDATE(3, 4), + UPDATE_T(3, 4), /** - * DELETE = 5; + * DELETE_T = 5; */ - DELETE(4, 5), + DELETE_T(4, 5), /** - * COMPACT = 6; + * COMPACT_T = 6; */ - COMPACT(5, 6), + COMPACT_T(5, 6), ; /** - * EOF = 1; + * EOF_T = 1; */ - public static final int EOF_VALUE = 1; + public static final int EOF_T_VALUE = 1; /** - * INIT = 2; + * INIT_T = 2; */ - public static final int INIT_VALUE = 2; + public static final int INIT_T_VALUE = 2; /** - * INSERT = 3; + * INSERT_T = 3; */ - public static final int INSERT_VALUE = 3; + public static final int INSERT_T_VALUE = 3; /** - * UPDATE = 4; + * UPDATE_T = 4; */ - public static final int UPDATE_VALUE = 4; + public static final int UPDATE_T_VALUE = 4; /** - * DELETE = 5; + * DELETE_T = 5; */ - public static final int DELETE_VALUE = 5; + public static final int DELETE_T_VALUE = 5; /** - * COMPACT = 6; + * COMPACT_T = 6; */ - public static final int COMPACT_VALUE = 6; + public static final int COMPACT_T_VALUE = 6; public final int getNumber() { return value; } public static Type valueOf(int value) { switch (value) { - case 1: return EOF; - case 2: return INIT; - case 3: return INSERT; - case 4: return UPDATE; - case 5: return DELETE; - case 6: return COMPACT; + case 1: return EOF_T; + case 2: return INIT_T; + case 3: return INSERT_T; + case 4: return UPDATE_T; + case 5: return DELETE_T; + case 6: return COMPACT_T; default: return null; } } @@ -6601,7 +6601,7 @@ public final class ProcedureProtos { } private void initFields() { - type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF; + type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF_T; procedure_ = java.util.Collections.emptyList(); procId_ = 0L; } @@ -6827,7 +6827,7 @@ public final class ProcedureProtos { public Builder clear() { super.clear(); - type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF; + type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF_T; bitField0_ = (bitField0_ & ~0x00000001); if (procedureBuilder_ == null) { procedure_ = java.util.Collections.emptyList(); @@ -6968,7 +6968,7 @@ public final class ProcedureProtos { private int bitField0_; // required .hbase.pb.ProcedureWALEntry.Type type = 1; - private org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF; + private org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF_T; /** * required .hbase.pb.ProcedureWALEntry.Type type = 1; */ @@ -6998,7 +6998,7 @@ public final class ProcedureProtos { */ public Builder clearType() { bitField0_ = (bitField0_ & ~0x00000001); - type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF; + type_ = org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type.EOF_T; onChanged(); return this; } @@ -7355,17 +7355,17 @@ public final class ProcedureProtos { "eTracker\0229\n\004node\030\001 \003(\0132+.hbase.pb.Proced" + "ureStoreTracker.TrackerNode\032A\n\013TrackerNo" + "de\022\020\n\010start_id\030\001 \002(\004\022\017\n\007updated\030\002 \003(\004\022\017\n" + - "\007deleted\030\003 \003(\004\"\310\001\n\021ProcedureWALEntry\022.\n\004", + "\007deleted\030\003 \003(\004\"\324\001\n\021ProcedureWALEntry\022.\n\004", "type\030\001 \002(\0162 .hbase.pb.ProcedureWALEntry." + "Type\022&\n\tprocedure\030\002 \003(\0132\023.hbase.pb.Proce" + - "dure\022\017\n\007proc_id\030\003 \001(\004\"J\n\004Type\022\007\n\003EOF\020\001\022\010" + - "\n\004INIT\020\002\022\n\n\006INSERT\020\003\022\n\n\006UPDATE\020\004\022\n\n\006DELE" + - "TE\020\005\022\013\n\007COMPACT\020\006*p\n\016ProcedureState\022\020\n\014I" + - "NITIALIZING\020\001\022\014\n\010RUNNABLE\020\002\022\013\n\007WAITING\020\003" + - "\022\023\n\017WAITING_TIMEOUT\020\004\022\016\n\nROLLEDBACK\020\005\022\014\n" + - "\010FINISHED\020\006BE\n*org.apache.hadoop.hbase.p" + - "rotobuf.generatedB\017ProcedureProtosH\001\210\001\001\240" + - "\001\001" + "dure\022\017\n\007proc_id\030\003 \001(\004\"V\n\004Type\022\t\n\005EOF_T\020\001" + + "\022\n\n\006INIT_T\020\002\022\014\n\010INSERT_T\020\003\022\014\n\010UPDATE_T\020\004" + + "\022\014\n\010DELETE_T\020\005\022\r\n\tCOMPACT_T\020\006*p\n\016Procedu" + + "reState\022\020\n\014INITIALIZING\020\001\022\014\n\010RUNNABLE\020\002\022" + + "\013\n\007WAITING\020\003\022\023\n\017WAITING_TIMEOUT\020\004\022\016\n\nROL" + + "LEDBACK\020\005\022\014\n\010FINISHED\020\006BE\n*org.apache.ha" + + "doop.hbase.protobuf.generatedB\017Procedure" + + "ProtosH\001\210\001\001\240\001\001" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { diff --git a/hbase-protocol/src/main/protobuf/Procedure.proto b/hbase-protocol/src/main/protobuf/Procedure.proto index bdcb2f5..ec29b92 100644 --- a/hbase-protocol/src/main/protobuf/Procedure.proto +++ b/hbase-protocol/src/main/protobuf/Procedure.proto @@ -105,12 +105,12 @@ message ProcedureStoreTracker { message ProcedureWALEntry { enum Type { - EOF = 1; - INIT = 2; - INSERT = 3; - UPDATE = 4; - DELETE = 5; - COMPACT = 6; + EOF_T = 1; + INIT_T = 2; + INSERT_T = 3; + UPDATE_T = 4; + DELETE_T = 5; + COMPACT_T = 6; } required Type type = 1; -- 2.4.3