flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From br...@apache.org
Subject [2/3] FLUME-1586: File Channel should support verifying integrity of individual events.
Date Thu, 13 Jun 2013 00:36:33 GMT
http://git-wip-us.apache.org/repos/asf/flume/blob/c57ebd1d/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java
----------------------------------------------------------------------
diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java
index 4860ac2..6885832 100644
--- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java
+++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java
@@ -28,29 +28,29 @@ public final class ProtosFactory {
   }
   public interface CheckpointOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required sfixed32 version = 1;
     boolean hasVersion();
     int getVersion();
-
+    
     // required sfixed64 writeOrderID = 2;
     boolean hasWriteOrderID();
     long getWriteOrderID();
-
+    
     // required sfixed32 queueSize = 3;
     boolean hasQueueSize();
     int getQueueSize();
-
+    
     // required sfixed32 queueHead = 4;
     boolean hasQueueHead();
     int getQueueHead();
-
+    
     // repeated .ActiveLog activeLogs = 5;
-    java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog>
+    java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog> 
         getActiveLogsList();
     org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog getActiveLogs(int index);
     int getActiveLogsCount();
-    java.util.List<? extends org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder>
+    java.util.List<? extends org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder> 
         getActiveLogsOrBuilderList();
     org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder getActiveLogsOrBuilder(
         int index);
@@ -63,26 +63,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private Checkpoint(boolean noInit) {}
-
+    
     private static final Checkpoint defaultInstance;
     public static Checkpoint getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public Checkpoint getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Checkpoint_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Checkpoint_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required sfixed32 version = 1;
     public static final int VERSION_FIELD_NUMBER = 1;
@@ -93,7 +93,7 @@ public final class ProtosFactory {
     public int getVersion() {
       return version_;
     }
-
+    
     // required sfixed64 writeOrderID = 2;
     public static final int WRITEORDERID_FIELD_NUMBER = 2;
     private long writeOrderID_;
@@ -103,7 +103,7 @@ public final class ProtosFactory {
     public long getWriteOrderID() {
       return writeOrderID_;
     }
-
+    
     // required sfixed32 queueSize = 3;
     public static final int QUEUESIZE_FIELD_NUMBER = 3;
     private int queueSize_;
@@ -113,7 +113,7 @@ public final class ProtosFactory {
     public int getQueueSize() {
       return queueSize_;
     }
-
+    
     // required sfixed32 queueHead = 4;
     public static final int QUEUEHEAD_FIELD_NUMBER = 4;
     private int queueHead_;
@@ -123,14 +123,14 @@ public final class ProtosFactory {
     public int getQueueHead() {
       return queueHead_;
     }
-
+    
     // repeated .ActiveLog activeLogs = 5;
     public static final int ACTIVELOGS_FIELD_NUMBER = 5;
     private java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog> activeLogs_;
     public java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog> getActiveLogsList() {
       return activeLogs_;
     }
-    public java.util.List<? extends org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder>
+    public java.util.List<? extends org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder> 
         getActiveLogsOrBuilderList() {
       return activeLogs_;
     }
@@ -144,7 +144,7 @@ public final class ProtosFactory {
         int index) {
       return activeLogs_.get(index);
     }
-
+    
     private void initFields() {
       version_ = 0;
       writeOrderID_ = 0L;
@@ -156,7 +156,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasVersion()) {
         memoizedIsInitialized = 0;
         return false;
@@ -182,7 +182,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -203,12 +203,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -234,14 +234,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -308,14 +308,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -329,17 +329,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Checkpoint_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Checkpoint_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -352,7 +352,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         version_ = 0;
@@ -371,20 +371,20 @@ public final class ProtosFactory {
         }
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint build() {
         org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint result = buildPartial();
         if (!result.isInitialized()) {
@@ -392,7 +392,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint result = buildPartial();
@@ -402,7 +402,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint result = new org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint(this);
         int from_bitField0_ = bitField0_;
@@ -436,7 +436,7 @@ public final class ProtosFactory {
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint)other);
@@ -445,7 +445,7 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.getDefaultInstance()) return this;
         if (other.hasVersion()) {
@@ -478,7 +478,7 @@ public final class ProtosFactory {
               activeLogsBuilder_ = null;
               activeLogs_ = other.activeLogs_;
               bitField0_ = (bitField0_ & ~0x00000010);
-              activeLogsBuilder_ =
+              activeLogsBuilder_ = 
                 com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
                    getActiveLogsFieldBuilder() : null;
             } else {
@@ -489,33 +489,33 @@ public final class ProtosFactory {
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasVersion()) {
-
+          
           return false;
         }
         if (!hasWriteOrderID()) {
-
+          
           return false;
         }
         if (!hasQueueSize()) {
-
+          
           return false;
         }
         if (!hasQueueHead()) {
-
+          
           return false;
         }
         for (int i = 0; i < getActiveLogsCount(); i++) {
           if (!getActiveLogs(i).isInitialized()) {
-
+            
             return false;
           }
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -568,9 +568,9 @@ public final class ProtosFactory {
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required sfixed32 version = 1;
       private int version_ ;
       public boolean hasVersion() {
@@ -591,7 +591,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed64 writeOrderID = 2;
       private long writeOrderID_ ;
       public boolean hasWriteOrderID() {
@@ -612,7 +612,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed32 queueSize = 3;
       private int queueSize_ ;
       public boolean hasQueueSize() {
@@ -633,7 +633,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed32 queueHead = 4;
       private int queueHead_ ;
       public boolean hasQueueHead() {
@@ -654,7 +654,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // repeated .ActiveLog activeLogs = 5;
       private java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog> activeLogs_ =
         java.util.Collections.emptyList();
@@ -664,10 +664,10 @@ public final class ProtosFactory {
           bitField0_ |= 0x00000010;
          }
       }
-
+      
       private com.google.protobuf.RepeatedFieldBuilder<
           org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder> activeLogsBuilder_;
-
+      
       public java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog> getActiveLogsList() {
         if (activeLogsBuilder_ == null) {
           return java.util.Collections.unmodifiableList(activeLogs_);
@@ -805,7 +805,7 @@ public final class ProtosFactory {
           return activeLogsBuilder_.getMessageOrBuilder(index);
         }
       }
-      public java.util.List<? extends org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder>
+      public java.util.List<? extends org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder> 
            getActiveLogsOrBuilderList() {
         if (activeLogsBuilder_ != null) {
           return activeLogsBuilder_.getMessageOrBuilderList();
@@ -822,12 +822,12 @@ public final class ProtosFactory {
         return getActiveLogsFieldBuilder().addBuilder(
             index, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.getDefaultInstance());
       }
-      public java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder>
+      public java.util.List<org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder> 
            getActiveLogsBuilderList() {
         return getActiveLogsFieldBuilder().getBuilderList();
       }
       private com.google.protobuf.RepeatedFieldBuilder<
-          org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder>
+          org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder, org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder> 
           getActiveLogsFieldBuilder() {
         if (activeLogsBuilder_ == null) {
           activeLogsBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
@@ -840,25 +840,25 @@ public final class ProtosFactory {
         }
         return activeLogsBuilder_;
       }
-
+      
       // @@protoc_insertion_point(builder_scope:Checkpoint)
     }
-
+    
     static {
       defaultInstance = new Checkpoint(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:Checkpoint)
   }
-
+  
   public interface ActiveLogOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required sfixed32 logFileID = 1;
     boolean hasLogFileID();
     int getLogFileID();
-
+    
     // required sfixed32 count = 2;
     boolean hasCount();
     int getCount();
@@ -871,26 +871,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private ActiveLog(boolean noInit) {}
-
+    
     private static final ActiveLog defaultInstance;
     public static ActiveLog getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public ActiveLog getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_ActiveLog_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_ActiveLog_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required sfixed32 logFileID = 1;
     public static final int LOGFILEID_FIELD_NUMBER = 1;
@@ -901,7 +901,7 @@ public final class ProtosFactory {
     public int getLogFileID() {
       return logFileID_;
     }
-
+    
     // required sfixed32 count = 2;
     public static final int COUNT_FIELD_NUMBER = 2;
     private int count_;
@@ -911,7 +911,7 @@ public final class ProtosFactory {
     public int getCount() {
       return count_;
     }
-
+    
     private void initFields() {
       logFileID_ = 0;
       count_ = 0;
@@ -920,7 +920,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasLogFileID()) {
         memoizedIsInitialized = 0;
         return false;
@@ -932,7 +932,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -944,12 +944,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -963,14 +963,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -1037,14 +1037,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -1058,17 +1058,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_ActiveLog_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_ActiveLog_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -1080,7 +1080,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         logFileID_ = 0;
@@ -1089,20 +1089,20 @@ public final class ProtosFactory {
         bitField0_ = (bitField0_ & ~0x00000002);
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog build() {
         org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog result = buildPartial();
         if (!result.isInitialized()) {
@@ -1110,7 +1110,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog result = buildPartial();
@@ -1120,7 +1120,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog result = new org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog(this);
         int from_bitField0_ = bitField0_;
@@ -1137,7 +1137,7 @@ public final class ProtosFactory {
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog)other);
@@ -1146,7 +1146,7 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.getDefaultInstance()) return this;
         if (other.hasLogFileID()) {
@@ -1158,19 +1158,19 @@ public final class ProtosFactory {
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasLogFileID()) {
-
+          
           return false;
         }
         if (!hasCount()) {
-
+          
           return false;
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -1207,9 +1207,9 @@ public final class ProtosFactory {
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required sfixed32 logFileID = 1;
       private int logFileID_ ;
       public boolean hasLogFileID() {
@@ -1230,7 +1230,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed32 count = 2;
       private int count_ ;
       public boolean hasCount() {
@@ -1251,46 +1251,46 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // @@protoc_insertion_point(builder_scope:ActiveLog)
     }
-
+    
     static {
       defaultInstance = new ActiveLog(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:ActiveLog)
   }
-
+  
   public interface LogFileMetaDataOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required sfixed32 version = 1;
     boolean hasVersion();
     int getVersion();
-
+    
     // required sfixed32 logFileID = 2;
     boolean hasLogFileID();
     int getLogFileID();
-
+    
     // required sfixed64 checkpointPosition = 3;
     boolean hasCheckpointPosition();
     long getCheckpointPosition();
-
+    
     // required sfixed64 checkpointWriteOrderID = 4;
     boolean hasCheckpointWriteOrderID();
     long getCheckpointWriteOrderID();
-
+    
     // optional .LogFileEncryption encryption = 5;
     boolean hasEncryption();
     org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption getEncryption();
     org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder getEncryptionOrBuilder();
-
+    
     // optional sfixed64 backupCheckpointPosition = 6;
     boolean hasBackupCheckpointPosition();
     long getBackupCheckpointPosition();
-
+    
     // optional sfixed64 backupCheckpointWriteOrderID = 7;
     boolean hasBackupCheckpointWriteOrderID();
     long getBackupCheckpointWriteOrderID();
@@ -1303,26 +1303,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private LogFileMetaData(boolean noInit) {}
-
+    
     private static final LogFileMetaData defaultInstance;
     public static LogFileMetaData getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public LogFileMetaData getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileMetaData_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileMetaData_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required sfixed32 version = 1;
     public static final int VERSION_FIELD_NUMBER = 1;
@@ -1333,7 +1333,7 @@ public final class ProtosFactory {
     public int getVersion() {
       return version_;
     }
-
+    
     // required sfixed32 logFileID = 2;
     public static final int LOGFILEID_FIELD_NUMBER = 2;
     private int logFileID_;
@@ -1343,7 +1343,7 @@ public final class ProtosFactory {
     public int getLogFileID() {
       return logFileID_;
     }
-
+    
     // required sfixed64 checkpointPosition = 3;
     public static final int CHECKPOINTPOSITION_FIELD_NUMBER = 3;
     private long checkpointPosition_;
@@ -1353,7 +1353,7 @@ public final class ProtosFactory {
     public long getCheckpointPosition() {
       return checkpointPosition_;
     }
-
+    
     // required sfixed64 checkpointWriteOrderID = 4;
     public static final int CHECKPOINTWRITEORDERID_FIELD_NUMBER = 4;
     private long checkpointWriteOrderID_;
@@ -1363,7 +1363,7 @@ public final class ProtosFactory {
     public long getCheckpointWriteOrderID() {
       return checkpointWriteOrderID_;
     }
-
+    
     // optional .LogFileEncryption encryption = 5;
     public static final int ENCRYPTION_FIELD_NUMBER = 5;
     private org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption encryption_;
@@ -1376,7 +1376,7 @@ public final class ProtosFactory {
     public org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder getEncryptionOrBuilder() {
       return encryption_;
     }
-
+    
     // optional sfixed64 backupCheckpointPosition = 6;
     public static final int BACKUPCHECKPOINTPOSITION_FIELD_NUMBER = 6;
     private long backupCheckpointPosition_;
@@ -1386,7 +1386,7 @@ public final class ProtosFactory {
     public long getBackupCheckpointPosition() {
       return backupCheckpointPosition_;
     }
-
+    
     // optional sfixed64 backupCheckpointWriteOrderID = 7;
     public static final int BACKUPCHECKPOINTWRITEORDERID_FIELD_NUMBER = 7;
     private long backupCheckpointWriteOrderID_;
@@ -1396,7 +1396,7 @@ public final class ProtosFactory {
     public long getBackupCheckpointWriteOrderID() {
       return backupCheckpointWriteOrderID_;
     }
-
+    
     private void initFields() {
       version_ = 0;
       logFileID_ = 0;
@@ -1410,7 +1410,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasVersion()) {
         memoizedIsInitialized = 0;
         return false;
@@ -1436,7 +1436,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -1463,12 +1463,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -1502,14 +1502,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -1576,14 +1576,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -1597,17 +1597,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileMetaData_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileMetaData_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -1620,7 +1620,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         version_ = 0;
@@ -1643,20 +1643,20 @@ public final class ProtosFactory {
         bitField0_ = (bitField0_ & ~0x00000040);
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData build() {
         org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData result = buildPartial();
         if (!result.isInitialized()) {
@@ -1664,7 +1664,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData result = buildPartial();
@@ -1674,7 +1674,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData result = new org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData(this);
         int from_bitField0_ = bitField0_;
@@ -1715,7 +1715,7 @@ public final class ProtosFactory {
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData)other);
@@ -1724,7 +1724,7 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.getDefaultInstance()) return this;
         if (other.hasVersion()) {
@@ -1751,33 +1751,33 @@ public final class ProtosFactory {
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasVersion()) {
-
+          
           return false;
         }
         if (!hasLogFileID()) {
-
+          
           return false;
         }
         if (!hasCheckpointPosition()) {
-
+          
           return false;
         }
         if (!hasCheckpointWriteOrderID()) {
-
+          
           return false;
         }
         if (hasEncryption()) {
           if (!getEncryption().isInitialized()) {
-
+            
             return false;
           }
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -1843,9 +1843,9 @@ public final class ProtosFactory {
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required sfixed32 version = 1;
       private int version_ ;
       public boolean hasVersion() {
@@ -1866,7 +1866,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed32 logFileID = 2;
       private int logFileID_ ;
       public boolean hasLogFileID() {
@@ -1887,7 +1887,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed64 checkpointPosition = 3;
       private long checkpointPosition_ ;
       public boolean hasCheckpointPosition() {
@@ -1908,7 +1908,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed64 checkpointWriteOrderID = 4;
       private long checkpointWriteOrderID_ ;
       public boolean hasCheckpointWriteOrderID() {
@@ -1929,7 +1929,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // optional .LogFileEncryption encryption = 5;
       private org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption encryption_ = org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.getDefaultInstance();
       private com.google.protobuf.SingleFieldBuilder<
@@ -2007,7 +2007,7 @@ public final class ProtosFactory {
         }
       }
       private com.google.protobuf.SingleFieldBuilder<
-          org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption, org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder, org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder>
+          org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption, org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder, org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder> 
           getEncryptionFieldBuilder() {
         if (encryptionBuilder_ == null) {
           encryptionBuilder_ = new com.google.protobuf.SingleFieldBuilder<
@@ -2019,7 +2019,7 @@ public final class ProtosFactory {
         }
         return encryptionBuilder_;
       }
-
+      
       // optional sfixed64 backupCheckpointPosition = 6;
       private long backupCheckpointPosition_ ;
       public boolean hasBackupCheckpointPosition() {
@@ -2040,7 +2040,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // optional sfixed64 backupCheckpointWriteOrderID = 7;
       private long backupCheckpointWriteOrderID_ ;
       public boolean hasBackupCheckpointWriteOrderID() {
@@ -2061,29 +2061,29 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // @@protoc_insertion_point(builder_scope:LogFileMetaData)
     }
-
+    
     static {
       defaultInstance = new LogFileMetaData(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:LogFileMetaData)
   }
-
+  
   public interface LogFileEncryptionOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required string cipherProvider = 1;
     boolean hasCipherProvider();
     String getCipherProvider();
-
+    
     // required string keyAlias = 2;
     boolean hasKeyAlias();
     String getKeyAlias();
-
+    
     // optional bytes parameters = 3;
     boolean hasParameters();
     com.google.protobuf.ByteString getParameters();
@@ -2096,26 +2096,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private LogFileEncryption(boolean noInit) {}
-
+    
     private static final LogFileEncryption defaultInstance;
     public static LogFileEncryption getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public LogFileEncryption getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileEncryption_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileEncryption_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required string cipherProvider = 1;
     public static final int CIPHERPROVIDER_FIELD_NUMBER = 1;
@@ -2128,7 +2128,7 @@ public final class ProtosFactory {
       if (ref instanceof String) {
         return (String) ref;
       } else {
-        com.google.protobuf.ByteString bs =
+        com.google.protobuf.ByteString bs = 
             (com.google.protobuf.ByteString) ref;
         String s = bs.toStringUtf8();
         if (com.google.protobuf.Internal.isValidUtf8(bs)) {
@@ -2140,7 +2140,7 @@ public final class ProtosFactory {
     private com.google.protobuf.ByteString getCipherProviderBytes() {
       java.lang.Object ref = cipherProvider_;
       if (ref instanceof String) {
-        com.google.protobuf.ByteString b =
+        com.google.protobuf.ByteString b = 
             com.google.protobuf.ByteString.copyFromUtf8((String) ref);
         cipherProvider_ = b;
         return b;
@@ -2148,7 +2148,7 @@ public final class ProtosFactory {
         return (com.google.protobuf.ByteString) ref;
       }
     }
-
+    
     // required string keyAlias = 2;
     public static final int KEYALIAS_FIELD_NUMBER = 2;
     private java.lang.Object keyAlias_;
@@ -2160,7 +2160,7 @@ public final class ProtosFactory {
       if (ref instanceof String) {
         return (String) ref;
       } else {
-        com.google.protobuf.ByteString bs =
+        com.google.protobuf.ByteString bs = 
             (com.google.protobuf.ByteString) ref;
         String s = bs.toStringUtf8();
         if (com.google.protobuf.Internal.isValidUtf8(bs)) {
@@ -2172,7 +2172,7 @@ public final class ProtosFactory {
     private com.google.protobuf.ByteString getKeyAliasBytes() {
       java.lang.Object ref = keyAlias_;
       if (ref instanceof String) {
-        com.google.protobuf.ByteString b =
+        com.google.protobuf.ByteString b = 
             com.google.protobuf.ByteString.copyFromUtf8((String) ref);
         keyAlias_ = b;
         return b;
@@ -2180,7 +2180,7 @@ public final class ProtosFactory {
         return (com.google.protobuf.ByteString) ref;
       }
     }
-
+    
     // optional bytes parameters = 3;
     public static final int PARAMETERS_FIELD_NUMBER = 3;
     private com.google.protobuf.ByteString parameters_;
@@ -2190,7 +2190,7 @@ public final class ProtosFactory {
     public com.google.protobuf.ByteString getParameters() {
       return parameters_;
     }
-
+    
     private void initFields() {
       cipherProvider_ = "";
       keyAlias_ = "";
@@ -2200,7 +2200,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasCipherProvider()) {
         memoizedIsInitialized = 0;
         return false;
@@ -2212,7 +2212,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -2227,12 +2227,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -2250,14 +2250,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -2324,14 +2324,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -2345,17 +2345,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileEncryption_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_LogFileEncryption_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -2367,7 +2367,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         cipherProvider_ = "";
@@ -2378,20 +2378,20 @@ public final class ProtosFactory {
         bitField0_ = (bitField0_ & ~0x00000004);
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption build() {
         org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption result = buildPartial();
         if (!result.isInitialized()) {
@@ -2399,7 +2399,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption result = buildPartial();
@@ -2409,7 +2409,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption result = new org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption(this);
         int from_bitField0_ = bitField0_;
@@ -2430,7 +2430,7 @@ public final class ProtosFactory {
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption)other);
@@ -2439,7 +2439,7 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.getDefaultInstance()) return this;
         if (other.hasCipherProvider()) {
@@ -2454,19 +2454,19 @@ public final class ProtosFactory {
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasCipherProvider()) {
-
+          
           return false;
         }
         if (!hasKeyAlias()) {
-
+          
           return false;
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -2508,9 +2508,9 @@ public final class ProtosFactory {
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required string cipherProvider = 1;
       private java.lang.Object cipherProvider_ = "";
       public boolean hasCipherProvider() {
@@ -2546,7 +2546,7 @@ public final class ProtosFactory {
         cipherProvider_ = value;
         onChanged();
       }
-
+      
       // required string keyAlias = 2;
       private java.lang.Object keyAlias_ = "";
       public boolean hasKeyAlias() {
@@ -2582,7 +2582,7 @@ public final class ProtosFactory {
         keyAlias_ = value;
         onChanged();
       }
-
+      
       // optional bytes parameters = 3;
       private com.google.protobuf.ByteString parameters_ = com.google.protobuf.ByteString.EMPTY;
       public boolean hasParameters() {
@@ -2606,29 +2606,29 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // @@protoc_insertion_point(builder_scope:LogFileEncryption)
     }
-
+    
     static {
       defaultInstance = new LogFileEncryption(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:LogFileEncryption)
   }
-
+  
   public interface TransactionEventHeaderOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required sfixed32 type = 1;
     boolean hasType();
     int getType();
-
+    
     // required sfixed64 transactionID = 2;
     boolean hasTransactionID();
     long getTransactionID();
-
+    
     // required sfixed64 writeOrderID = 3;
     boolean hasWriteOrderID();
     long getWriteOrderID();
@@ -2641,26 +2641,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private TransactionEventHeader(boolean noInit) {}
-
+    
     private static final TransactionEventHeader defaultInstance;
     public static TransactionEventHeader getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public TransactionEventHeader getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_TransactionEventHeader_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_TransactionEventHeader_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required sfixed32 type = 1;
     public static final int TYPE_FIELD_NUMBER = 1;
@@ -2671,7 +2671,7 @@ public final class ProtosFactory {
     public int getType() {
       return type_;
     }
-
+    
     // required sfixed64 transactionID = 2;
     public static final int TRANSACTIONID_FIELD_NUMBER = 2;
     private long transactionID_;
@@ -2681,7 +2681,7 @@ public final class ProtosFactory {
     public long getTransactionID() {
       return transactionID_;
     }
-
+    
     // required sfixed64 writeOrderID = 3;
     public static final int WRITEORDERID_FIELD_NUMBER = 3;
     private long writeOrderID_;
@@ -2691,7 +2691,7 @@ public final class ProtosFactory {
     public long getWriteOrderID() {
       return writeOrderID_;
     }
-
+    
     private void initFields() {
       type_ = 0;
       transactionID_ = 0L;
@@ -2701,7 +2701,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasType()) {
         memoizedIsInitialized = 0;
         return false;
@@ -2717,7 +2717,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -2732,12 +2732,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -2755,14 +2755,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -2829,14 +2829,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -2850,17 +2850,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_TransactionEventHeader_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_TransactionEventHeader_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -2872,7 +2872,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         type_ = 0;
@@ -2883,20 +2883,20 @@ public final class ProtosFactory {
         bitField0_ = (bitField0_ & ~0x00000004);
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader build() {
         org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader result = buildPartial();
         if (!result.isInitialized()) {
@@ -2904,7 +2904,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader result = buildPartial();
@@ -2914,7 +2914,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader result = new org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader(this);
         int from_bitField0_ = bitField0_;
@@ -2935,7 +2935,7 @@ public final class ProtosFactory {
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader)other);
@@ -2944,7 +2944,7 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.getDefaultInstance()) return this;
         if (other.hasType()) {
@@ -2959,23 +2959,23 @@ public final class ProtosFactory {
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasType()) {
-
+          
           return false;
         }
         if (!hasTransactionID()) {
-
+          
           return false;
         }
         if (!hasWriteOrderID()) {
-
+          
           return false;
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -3017,9 +3017,9 @@ public final class ProtosFactory {
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required sfixed32 type = 1;
       private int type_ ;
       public boolean hasType() {
@@ -3040,7 +3040,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed64 transactionID = 2;
       private long transactionID_ ;
       public boolean hasTransactionID() {
@@ -3061,7 +3061,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed64 writeOrderID = 3;
       private long writeOrderID_ ;
       public boolean hasWriteOrderID() {
@@ -3082,25 +3082,29 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // @@protoc_insertion_point(builder_scope:TransactionEventHeader)
     }
-
+    
     static {
       defaultInstance = new TransactionEventHeader(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:TransactionEventHeader)
   }
-
+  
   public interface PutOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required .FlumeEvent event = 1;
     boolean hasEvent();
     org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent getEvent();
     org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder getEventOrBuilder();
+    
+    // optional sfixed64 checksum = 2;
+    boolean hasChecksum();
+    long getChecksum();
   }
   public static final class Put extends
       com.google.protobuf.GeneratedMessage
@@ -3110,26 +3114,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private Put(boolean noInit) {}
-
+    
     private static final Put defaultInstance;
     public static Put getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public Put getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Put_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Put_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required .FlumeEvent event = 1;
     public static final int EVENT_FIELD_NUMBER = 1;
@@ -3143,15 +3147,26 @@ public final class ProtosFactory {
     public org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder getEventOrBuilder() {
       return event_;
     }
-
+    
+    // optional sfixed64 checksum = 2;
+    public static final int CHECKSUM_FIELD_NUMBER = 2;
+    private long checksum_;
+    public boolean hasChecksum() {
+      return ((bitField0_ & 0x00000002) == 0x00000002);
+    }
+    public long getChecksum() {
+      return checksum_;
+    }
+    
     private void initFields() {
       event_ = org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.getDefaultInstance();
+      checksum_ = 0L;
     }
     private byte memoizedIsInitialized = -1;
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasEvent()) {
         memoizedIsInitialized = 0;
         return false;
@@ -3163,38 +3178,45 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         output.writeMessage(1, event_);
       }
+      if (((bitField0_ & 0x00000002) == 0x00000002)) {
+        output.writeSFixed64(2, checksum_);
+      }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
           .computeMessageSize(1, event_);
       }
-      size += getUnknownFields().getSerializedSize();
+      if (((bitField0_ & 0x00000002) == 0x00000002)) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeSFixed64Size(2, checksum_);
+      }
+      size += getUnknownFields().getSerializedSize();
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.Put parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -3261,14 +3283,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.Put prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -3282,17 +3304,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Put_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Put_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.Put.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -3305,7 +3327,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         if (eventBuilder_ == null) {
@@ -3314,22 +3336,24 @@ public final class ProtosFactory {
           eventBuilder_.clear();
         }
         bitField0_ = (bitField0_ & ~0x00000001);
+        checksum_ = 0L;
+        bitField0_ = (bitField0_ & ~0x00000002);
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Put.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Put getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Put.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Put build() {
         org.apache.flume.channel.file.proto.ProtosFactory.Put result = buildPartial();
         if (!result.isInitialized()) {
@@ -3337,7 +3361,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.Put buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.Put result = buildPartial();
@@ -3347,7 +3371,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Put buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.Put result = new org.apache.flume.channel.file.proto.ProtosFactory.Put(this);
         int from_bitField0_ = bitField0_;
@@ -3360,11 +3384,15 @@ public final class ProtosFactory {
         } else {
           result.event_ = eventBuilder_.build();
         }
+        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+          to_bitField0_ |= 0x00000002;
+        }
+        result.checksum_ = checksum_;
         result.bitField0_ = to_bitField0_;
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.Put) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.Put)other);
@@ -3373,28 +3401,31 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.Put other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.Put.getDefaultInstance()) return this;
         if (other.hasEvent()) {
           mergeEvent(other.getEvent());
         }
+        if (other.hasChecksum()) {
+          setChecksum(other.getChecksum());
+        }
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasEvent()) {
-
+          
           return false;
         }
         if (!getEvent().isInitialized()) {
-
+          
           return false;
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -3427,12 +3458,17 @@ public final class ProtosFactory {
               setEvent(subBuilder.buildPartial());
               break;
             }
+            case 17: {
+              bitField0_ |= 0x00000002;
+              checksum_ = input.readSFixed64();
+              break;
+            }
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required .FlumeEvent event = 1;
       private org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent event_ = org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.getDefaultInstance();
       private com.google.protobuf.SingleFieldBuilder<
@@ -3510,7 +3546,7 @@ public final class ProtosFactory {
         }
       }
       private com.google.protobuf.SingleFieldBuilder<
-          org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent, org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder, org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder>
+          org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent, org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder, org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder> 
           getEventFieldBuilder() {
         if (eventBuilder_ == null) {
           eventBuilder_ = new com.google.protobuf.SingleFieldBuilder<
@@ -3522,25 +3558,46 @@ public final class ProtosFactory {
         }
         return eventBuilder_;
       }
-
+      
+      // optional sfixed64 checksum = 2;
+      private long checksum_ ;
+      public boolean hasChecksum() {
+        return ((bitField0_ & 0x00000002) == 0x00000002);
+      }
+      public long getChecksum() {
+        return checksum_;
+      }
+      public Builder setChecksum(long value) {
+        bitField0_ |= 0x00000002;
+        checksum_ = value;
+        onChanged();
+        return this;
+      }
+      public Builder clearChecksum() {
+        bitField0_ = (bitField0_ & ~0x00000002);
+        checksum_ = 0L;
+        onChanged();
+        return this;
+      }
+      
       // @@protoc_insertion_point(builder_scope:Put)
     }
-
+    
     static {
       defaultInstance = new Put(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:Put)
   }
-
+  
   public interface TakeOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required sfixed32 fileID = 1;
     boolean hasFileID();
     int getFileID();
-
+    
     // required sfixed32 offset = 2;
     boolean hasOffset();
     int getOffset();
@@ -3553,26 +3610,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private Take(boolean noInit) {}
-
+    
     private static final Take defaultInstance;
     public static Take getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public Take getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Take_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Take_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required sfixed32 fileID = 1;
     public static final int FILEID_FIELD_NUMBER = 1;
@@ -3583,7 +3640,7 @@ public final class ProtosFactory {
     public int getFileID() {
       return fileID_;
     }
-
+    
     // required sfixed32 offset = 2;
     public static final int OFFSET_FIELD_NUMBER = 2;
     private int offset_;
@@ -3593,7 +3650,7 @@ public final class ProtosFactory {
     public int getOffset() {
       return offset_;
     }
-
+    
     private void initFields() {
       fileID_ = 0;
       offset_ = 0;
@@ -3602,7 +3659,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasFileID()) {
         memoizedIsInitialized = 0;
         return false;
@@ -3614,7 +3671,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -3626,12 +3683,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -3645,14 +3702,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.Take parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -3719,14 +3776,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.Take prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -3740,17 +3797,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Take_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Take_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.Take.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -3762,7 +3819,7 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         fileID_ = 0;
@@ -3771,20 +3828,20 @@ public final class ProtosFactory {
         bitField0_ = (bitField0_ & ~0x00000002);
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Take.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Take getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Take.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Take build() {
         org.apache.flume.channel.file.proto.ProtosFactory.Take result = buildPartial();
         if (!result.isInitialized()) {
@@ -3792,7 +3849,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.Take buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.Take result = buildPartial();
@@ -3802,7 +3859,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Take buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.Take result = new org.apache.flume.channel.file.proto.ProtosFactory.Take(this);
         int from_bitField0_ = bitField0_;
@@ -3819,7 +3876,7 @@ public final class ProtosFactory {
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.Take) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.Take)other);
@@ -3828,7 +3885,7 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.Take other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.Take.getDefaultInstance()) return this;
         if (other.hasFileID()) {
@@ -3840,19 +3897,19 @@ public final class ProtosFactory {
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         if (!hasFileID()) {
-
+          
           return false;
         }
         if (!hasOffset()) {
-
+          
           return false;
         }
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -3889,9 +3946,9 @@ public final class ProtosFactory {
           }
         }
       }
-
+      
       private int bitField0_;
-
+      
       // required sfixed32 fileID = 1;
       private int fileID_ ;
       public boolean hasFileID() {
@@ -3912,7 +3969,7 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // required sfixed32 offset = 2;
       private int offset_ ;
       public boolean hasOffset() {
@@ -3933,18 +3990,18 @@ public final class ProtosFactory {
         onChanged();
         return this;
       }
-
+      
       // @@protoc_insertion_point(builder_scope:Take)
     }
-
+    
     static {
       defaultInstance = new Take(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:Take)
   }
-
+  
   public interface RollbackOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
   }
@@ -3956,61 +4013,61 @@ public final class ProtosFactory {
       super(builder);
     }
     private Rollback(boolean noInit) {}
-
+    
     private static final Rollback defaultInstance;
     public static Rollback getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public Rollback getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Rollback_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Rollback_fieldAccessorTable;
     }
-
+    
     private void initFields() {
     }
     private byte memoizedIsInitialized = -1;
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       size += getUnknownFields().getSerializedSize();
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.Rollback parseFrom(
         com.google.protobuf.ByteString data)
         throws com.google.protobuf.InvalidProtocolBufferException {
@@ -4077,14 +4134,14 @@ public final class ProtosFactory {
       return newBuilder().mergeFrom(input, extensionRegistry)
                .buildParsed();
     }
-
+    
     public static Builder newBuilder() { return Builder.create(); }
     public Builder newBuilderForType() { return newBuilder(); }
     public static Builder newBuilder(org.apache.flume.channel.file.proto.ProtosFactory.Rollback prototype) {
       return newBuilder().mergeFrom(prototype);
     }
     public Builder toBuilder() { return newBuilder(this); }
-
+    
     @java.lang.Override
     protected Builder newBuilderForType(
         com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@@ -4098,17 +4155,17 @@ public final class ProtosFactory {
           getDescriptor() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Rollback_descriptor;
       }
-
+      
       protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
           internalGetFieldAccessorTable() {
         return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Rollback_fieldAccessorTable;
       }
-
+      
       // Construct using org.apache.flume.channel.file.proto.ProtosFactory.Rollback.newBuilder()
       private Builder() {
         maybeForceBuilderInitialization();
       }
-
+      
       private Builder(BuilderParent parent) {
         super(parent);
         maybeForceBuilderInitialization();
@@ -4120,25 +4177,25 @@ public final class ProtosFactory {
       private static Builder create() {
         return new Builder();
       }
-
+      
       public Builder clear() {
         super.clear();
         return this;
       }
-
+      
       public Builder clone() {
         return create().mergeFrom(buildPartial());
       }
-
+      
       public com.google.protobuf.Descriptors.Descriptor
           getDescriptorForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Rollback.getDescriptor();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Rollback getDefaultInstanceForType() {
         return org.apache.flume.channel.file.proto.ProtosFactory.Rollback.getDefaultInstance();
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Rollback build() {
         org.apache.flume.channel.file.proto.ProtosFactory.Rollback result = buildPartial();
         if (!result.isInitialized()) {
@@ -4146,7 +4203,7 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       private org.apache.flume.channel.file.proto.ProtosFactory.Rollback buildParsed()
           throws com.google.protobuf.InvalidProtocolBufferException {
         org.apache.flume.channel.file.proto.ProtosFactory.Rollback result = buildPartial();
@@ -4156,13 +4213,13 @@ public final class ProtosFactory {
         }
         return result;
       }
-
+      
       public org.apache.flume.channel.file.proto.ProtosFactory.Rollback buildPartial() {
         org.apache.flume.channel.file.proto.ProtosFactory.Rollback result = new org.apache.flume.channel.file.proto.ProtosFactory.Rollback(this);
         onBuilt();
         return result;
       }
-
+      
       public Builder mergeFrom(com.google.protobuf.Message other) {
         if (other instanceof org.apache.flume.channel.file.proto.ProtosFactory.Rollback) {
           return mergeFrom((org.apache.flume.channel.file.proto.ProtosFactory.Rollback)other);
@@ -4171,17 +4228,17 @@ public final class ProtosFactory {
           return this;
         }
       }
-
+      
       public Builder mergeFrom(org.apache.flume.channel.file.proto.ProtosFactory.Rollback other) {
         if (other == org.apache.flume.channel.file.proto.ProtosFactory.Rollback.getDefaultInstance()) return this;
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
-
+      
       public final boolean isInitialized() {
         return true;
       }
-
+      
       public Builder mergeFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@@ -4208,22 +4265,22 @@ public final class ProtosFactory {
           }
         }
       }
-
-
+      
+      
       // @@protoc_insertion_point(builder_scope:Rollback)
     }
-
+    
     static {
       defaultInstance = new Rollback(true);
       defaultInstance.initFields();
     }
-
+    
     // @@protoc_insertion_point(class_scope:Rollback)
   }
-
+  
   public interface CommitOrBuilder
       extends com.google.protobuf.MessageOrBuilder {
-
+    
     // required sfixed32 type = 1;
     boolean hasType();
     int getType();
@@ -4236,26 +4293,26 @@ public final class ProtosFactory {
       super(builder);
     }
     private Commit(boolean noInit) {}
-
+    
     private static final Commit defaultInstance;
     public static Commit getDefaultInstance() {
       return defaultInstance;
     }
-
+    
     public Commit getDefaultInstanceForType() {
       return defaultInstance;
     }
-
+    
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Commit_descriptor;
     }
-
+    
     protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
         internalGetFieldAccessorTable() {
       return org.apache.flume.channel.file.proto.ProtosFactory.internal_static_Commit_fieldAccessorTable;
     }
-
+    
     private int bitField0_;
     // required sfixed32 type = 1;
     public static final int TYPE_FIELD_NUMBER = 1;
@@ -4266,7 +4323,7 @@ public final class ProtosFactory {
     public int getType() {
       return type_;
     }
-
+    
     private void initFields() {
       type_ = 0;
     }
@@ -4274,7 +4331,7 @@ public final class ProtosFactory {
     public final boolean isInitialized() {
       byte isInitialized = memoizedIsInitialized;
       if (isInitialized != -1) return isInitialized == 1;
-
+      
       if (!hasType()) {
         memoizedIsInitialized = 0;
         return false;
@@ -4282,7 +4339,7 @@ public final class ProtosFactory {
       memoizedIsInitialized = 1;
       return true;
     }
-
+    
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
@@ -4291,12 +4348,12 @@ public final class ProtosFactory {
       }
       getUnknownFields().writeTo(output);
     }
-
+    
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = memoizedSerializedSize;
       if (size != -1) return size;
-
+    
       size = 0;
       if (((bitField0_ & 0x00000001) == 0x00000001)) {
         size += com.google.protobuf.CodedOutputStream
@@ -4306,14 +4363,14 @@ public final class ProtosFactory {
       memoizedSerializedSize = size;
       return size;
     }
-
+    
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
-
+    
     public static org.apache.flume.channel.file.proto.ProtosFactory.Commit parseFrom(
         com.google.protobuf.ByteString data)
        

<TRUNCATED>

Mime
View raw message