ColumnDataFile.java
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: column_data_file.proto
package org.apache.doris.proto;
public final class ColumnDataFile {
private ColumnDataFile() {}
public static void registerAllExtensions(
com.google.protobuf.ExtensionRegistryLite registry) {
}
public static void registerAllExtensions(
com.google.protobuf.ExtensionRegistry registry) {
registerAllExtensions(
(com.google.protobuf.ExtensionRegistryLite) registry);
}
public interface StreamInfoMessageOrBuilder extends
// @@protoc_insertion_point(interface_extends:doris.StreamInfoMessage)
com.google.protobuf.MessageOrBuilder {
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return Whether the kind field is set.
*/
boolean hasKind();
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return The kind.
*/
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind getKind();
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return Whether the columnUniqueId field is set.
*/
boolean hasColumnUniqueId();
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return The columnUniqueId.
*/
int getColumnUniqueId();
/**
* <code>required uint64 length = 3;</code>
* @return Whether the length field is set.
*/
boolean hasLength();
/**
* <code>required uint64 length = 3;</code>
* @return The length.
*/
long getLength();
}
/**
* Protobuf type {@code doris.StreamInfoMessage}
*/
public static final class StreamInfoMessage extends
com.google.protobuf.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:doris.StreamInfoMessage)
StreamInfoMessageOrBuilder {
private static final long serialVersionUID = 0L;
// Use StreamInfoMessage.newBuilder() to construct.
private StreamInfoMessage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private StreamInfoMessage() {
kind_ = 0;
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
return new StreamInfoMessage();
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_StreamInfoMessage_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_StreamInfoMessage_fieldAccessorTable
.ensureFieldAccessorsInitialized(
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.class, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder.class);
}
/**
* Protobuf enum {@code doris.StreamInfoMessage.Kind}
*/
public enum Kind
implements com.google.protobuf.ProtocolMessageEnum {
/**
* <code>ROW_INDEX = 0;</code>
*/
ROW_INDEX(0),
/**
* <code>PRESENT = 1;</code>
*/
PRESENT(1),
/**
* <code>DATA = 2;</code>
*/
DATA(2),
/**
* <code>LENGTH = 3;</code>
*/
LENGTH(3),
/**
* <code>DICTIONARY_DATA = 4;</code>
*/
DICTIONARY_DATA(4),
/**
* <code>SECONDARY = 5;</code>
*/
SECONDARY(5),
/**
* <code>ROW_INDEX_STATISTIC = 6;</code>
*/
ROW_INDEX_STATISTIC(6),
/**
* <code>BLOOM_FILTER = 7;</code>
*/
BLOOM_FILTER(7),
;
/**
* <code>ROW_INDEX = 0;</code>
*/
public static final int ROW_INDEX_VALUE = 0;
/**
* <code>PRESENT = 1;</code>
*/
public static final int PRESENT_VALUE = 1;
/**
* <code>DATA = 2;</code>
*/
public static final int DATA_VALUE = 2;
/**
* <code>LENGTH = 3;</code>
*/
public static final int LENGTH_VALUE = 3;
/**
* <code>DICTIONARY_DATA = 4;</code>
*/
public static final int DICTIONARY_DATA_VALUE = 4;
/**
* <code>SECONDARY = 5;</code>
*/
public static final int SECONDARY_VALUE = 5;
/**
* <code>ROW_INDEX_STATISTIC = 6;</code>
*/
public static final int ROW_INDEX_STATISTIC_VALUE = 6;
/**
* <code>BLOOM_FILTER = 7;</code>
*/
public static final int BLOOM_FILTER_VALUE = 7;
public final int getNumber() {
return value;
}
/**
* @param value The numeric wire value of the corresponding enum entry.
* @return The enum associated with the given numeric wire value.
* @deprecated Use {@link #forNumber(int)} instead.
*/
@java.lang.Deprecated
public static Kind valueOf(int value) {
return forNumber(value);
}
/**
* @param value The numeric wire value of the corresponding enum entry.
* @return The enum associated with the given numeric wire value.
*/
public static Kind forNumber(int value) {
switch (value) {
case 0: return ROW_INDEX;
case 1: return PRESENT;
case 2: return DATA;
case 3: return LENGTH;
case 4: return DICTIONARY_DATA;
case 5: return SECONDARY;
case 6: return ROW_INDEX_STATISTIC;
case 7: return BLOOM_FILTER;
default: return null;
}
}
public static com.google.protobuf.Internal.EnumLiteMap<Kind>
internalGetValueMap() {
return internalValueMap;
}
private static final com.google.protobuf.Internal.EnumLiteMap<
Kind> internalValueMap =
new com.google.protobuf.Internal.EnumLiteMap<Kind>() {
public Kind findValueByNumber(int number) {
return Kind.forNumber(number);
}
};
public final com.google.protobuf.Descriptors.EnumValueDescriptor
getValueDescriptor() {
return getDescriptor().getValues().get(ordinal());
}
public final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptorForType() {
return getDescriptor();
}
public static final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.getDescriptor().getEnumTypes().get(0);
}
private static final Kind[] VALUES = values();
public static Kind valueOf(
com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
if (desc.getType() != getDescriptor()) {
throw new java.lang.IllegalArgumentException(
"EnumValueDescriptor is not for this type.");
}
return VALUES[desc.getIndex()];
}
private final int value;
private Kind(int value) {
this.value = value;
}
// @@protoc_insertion_point(enum_scope:doris.StreamInfoMessage.Kind)
}
private int bitField0_;
public static final int KIND_FIELD_NUMBER = 1;
private int kind_ = 0;
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return Whether the kind field is set.
*/
@java.lang.Override public boolean hasKind() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return The kind.
*/
@java.lang.Override public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind getKind() {
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind result = org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind.forNumber(kind_);
return result == null ? org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind.ROW_INDEX : result;
}
public static final int COLUMN_UNIQUE_ID_FIELD_NUMBER = 2;
private int columnUniqueId_ = 0;
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return Whether the columnUniqueId field is set.
*/
@java.lang.Override
public boolean hasColumnUniqueId() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return The columnUniqueId.
*/
@java.lang.Override
public int getColumnUniqueId() {
return columnUniqueId_;
}
public static final int LENGTH_FIELD_NUMBER = 3;
private long length_ = 0L;
/**
* <code>required uint64 length = 3;</code>
* @return Whether the length field is set.
*/
@java.lang.Override
public boolean hasLength() {
return ((bitField0_ & 0x00000004) != 0);
}
/**
* <code>required uint64 length = 3;</code>
* @return The length.
*/
@java.lang.Override
public long getLength() {
return length_;
}
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
if (isInitialized == 1) return true;
if (isInitialized == 0) return false;
if (!hasKind()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasColumnUniqueId()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasLength()) {
memoizedIsInitialized = 0;
return false;
}
memoizedIsInitialized = 1;
return true;
}
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
if (((bitField0_ & 0x00000001) != 0)) {
output.writeEnum(1, kind_);
}
if (((bitField0_ & 0x00000002) != 0)) {
output.writeUInt32(2, columnUniqueId_);
}
if (((bitField0_ & 0x00000004) != 0)) {
output.writeUInt64(3, length_);
}
getUnknownFields().writeTo(output);
}
@java.lang.Override
public int getSerializedSize() {
int size = memoizedSize;
if (size != -1) return size;
size = 0;
if (((bitField0_ & 0x00000001) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(1, kind_);
}
if (((bitField0_ & 0x00000002) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(2, columnUniqueId_);
}
if (((bitField0_ & 0x00000004) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt64Size(3, length_);
}
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
@java.lang.Override
public boolean equals(final java.lang.Object obj) {
if (obj == this) {
return true;
}
if (!(obj instanceof org.apache.doris.proto.ColumnDataFile.StreamInfoMessage)) {
return super.equals(obj);
}
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage other = (org.apache.doris.proto.ColumnDataFile.StreamInfoMessage) obj;
if (hasKind() != other.hasKind()) return false;
if (hasKind()) {
if (kind_ != other.kind_) return false;
}
if (hasColumnUniqueId() != other.hasColumnUniqueId()) return false;
if (hasColumnUniqueId()) {
if (getColumnUniqueId()
!= other.getColumnUniqueId()) return false;
}
if (hasLength() != other.hasLength()) return false;
if (hasLength()) {
if (getLength()
!= other.getLength()) return false;
}
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
return true;
}
@java.lang.Override
public int hashCode() {
if (memoizedHashCode != 0) {
return memoizedHashCode;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
if (hasKind()) {
hash = (37 * hash) + KIND_FIELD_NUMBER;
hash = (53 * hash) + kind_;
}
if (hasColumnUniqueId()) {
hash = (37 * hash) + COLUMN_UNIQUE_ID_FIELD_NUMBER;
hash = (53 * hash) + getColumnUniqueId();
}
if (hasLength()) {
hash = (37 * hash) + LENGTH_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
getLength());
}
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
@java.lang.Override
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(org.apache.doris.proto.ColumnDataFile.StreamInfoMessage prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
public Builder toBuilder() {
return this == DEFAULT_INSTANCE
? new Builder() : new Builder().mergeFrom(this);
}
@java.lang.Override
protected Builder newBuilderForType(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
Builder builder = new Builder(parent);
return builder;
}
/**
* Protobuf type {@code doris.StreamInfoMessage}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:doris.StreamInfoMessage)
org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_StreamInfoMessage_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_StreamInfoMessage_fieldAccessorTable
.ensureFieldAccessorsInitialized(
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.class, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder.class);
}
// Construct using org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.newBuilder()
private Builder() {
}
private Builder(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
}
@java.lang.Override
public Builder clear() {
super.clear();
bitField0_ = 0;
kind_ = 0;
columnUniqueId_ = 0;
length_ = 0L;
return this;
}
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_StreamInfoMessage_descriptor;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage getDefaultInstanceForType() {
return org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.getDefaultInstance();
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage build() {
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage buildPartial() {
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage result = new org.apache.doris.proto.ColumnDataFile.StreamInfoMessage(this);
if (bitField0_ != 0) { buildPartial0(result); }
onBuilt();
return result;
}
private void buildPartial0(org.apache.doris.proto.ColumnDataFile.StreamInfoMessage result) {
int from_bitField0_ = bitField0_;
int to_bitField0_ = 0;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.kind_ = kind_;
to_bitField0_ |= 0x00000001;
}
if (((from_bitField0_ & 0x00000002) != 0)) {
result.columnUniqueId_ = columnUniqueId_;
to_bitField0_ |= 0x00000002;
}
if (((from_bitField0_ & 0x00000004) != 0)) {
result.length_ = length_;
to_bitField0_ |= 0x00000004;
}
result.bitField0_ |= to_bitField0_;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(
com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(
com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(
com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
}
@java.lang.Override
public Builder setRepeatedField(
com.google.protobuf.Descriptors.FieldDescriptor field,
int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
}
@java.lang.Override
public Builder addRepeatedField(
com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.apache.doris.proto.ColumnDataFile.StreamInfoMessage) {
return mergeFrom((org.apache.doris.proto.ColumnDataFile.StreamInfoMessage)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(org.apache.doris.proto.ColumnDataFile.StreamInfoMessage other) {
if (other == org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.getDefaultInstance()) return this;
if (other.hasKind()) {
setKind(other.getKind());
}
if (other.hasColumnUniqueId()) {
setColumnUniqueId(other.getColumnUniqueId());
}
if (other.hasLength()) {
setLength(other.getLength());
}
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
@java.lang.Override
public final boolean isInitialized() {
if (!hasKind()) {
return false;
}
if (!hasColumnUniqueId()) {
return false;
}
if (!hasLength()) {
return false;
}
return true;
}
@java.lang.Override
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch (tag) {
case 0:
done = true;
break;
case 8: {
int tmpRaw = input.readEnum();
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind tmpValue =
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind.forNumber(tmpRaw);
if (tmpValue == null) {
mergeUnknownVarintField(1, tmpRaw);
} else {
kind_ = tmpRaw;
bitField0_ |= 0x00000001;
}
break;
} // case 8
case 16: {
columnUniqueId_ = input.readUInt32();
bitField0_ |= 0x00000002;
break;
} // case 16
case 24: {
length_ = input.readUInt64();
bitField0_ |= 0x00000004;
break;
} // case 24
default: {
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
done = true; // was an endgroup tag
}
break;
} // default:
} // switch (tag)
} // while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.unwrapIOException();
} finally {
onChanged();
} // finally
return this;
}
private int bitField0_;
private int kind_ = 0;
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return Whether the kind field is set.
*/
@java.lang.Override public boolean hasKind() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return The kind.
*/
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind getKind() {
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind result = org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind.forNumber(kind_);
return result == null ? org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind.ROW_INDEX : result;
}
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @param value The kind to set.
* @return This builder for chaining.
*/
public Builder setKind(org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Kind value) {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000001;
kind_ = value.getNumber();
onChanged();
return this;
}
/**
* <code>required .doris.StreamInfoMessage.Kind kind = 1;</code>
* @return This builder for chaining.
*/
public Builder clearKind() {
bitField0_ = (bitField0_ & ~0x00000001);
kind_ = 0;
onChanged();
return this;
}
private int columnUniqueId_ ;
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return Whether the columnUniqueId field is set.
*/
@java.lang.Override
public boolean hasColumnUniqueId() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return The columnUniqueId.
*/
@java.lang.Override
public int getColumnUniqueId() {
return columnUniqueId_;
}
/**
* <code>required uint32 column_unique_id = 2;</code>
* @param value The columnUniqueId to set.
* @return This builder for chaining.
*/
public Builder setColumnUniqueId(int value) {
columnUniqueId_ = value;
bitField0_ |= 0x00000002;
onChanged();
return this;
}
/**
* <code>required uint32 column_unique_id = 2;</code>
* @return This builder for chaining.
*/
public Builder clearColumnUniqueId() {
bitField0_ = (bitField0_ & ~0x00000002);
columnUniqueId_ = 0;
onChanged();
return this;
}
private long length_ ;
/**
* <code>required uint64 length = 3;</code>
* @return Whether the length field is set.
*/
@java.lang.Override
public boolean hasLength() {
return ((bitField0_ & 0x00000004) != 0);
}
/**
* <code>required uint64 length = 3;</code>
* @return The length.
*/
@java.lang.Override
public long getLength() {
return length_;
}
/**
* <code>required uint64 length = 3;</code>
* @param value The length to set.
* @return This builder for chaining.
*/
public Builder setLength(long value) {
length_ = value;
bitField0_ |= 0x00000004;
onChanged();
return this;
}
/**
* <code>required uint64 length = 3;</code>
* @return This builder for chaining.
*/
public Builder clearLength() {
bitField0_ = (bitField0_ & ~0x00000004);
length_ = 0L;
onChanged();
return this;
}
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
}
@java.lang.Override
public final Builder mergeUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.mergeUnknownFields(unknownFields);
}
// @@protoc_insertion_point(builder_scope:doris.StreamInfoMessage)
}
// @@protoc_insertion_point(class_scope:doris.StreamInfoMessage)
private static final org.apache.doris.proto.ColumnDataFile.StreamInfoMessage DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new org.apache.doris.proto.ColumnDataFile.StreamInfoMessage();
}
public static org.apache.doris.proto.ColumnDataFile.StreamInfoMessage getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@java.lang.Deprecated public static final com.google.protobuf.Parser<StreamInfoMessage>
PARSER = new com.google.protobuf.AbstractParser<StreamInfoMessage>() {
@java.lang.Override
public StreamInfoMessage parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e)
.setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
public static com.google.protobuf.Parser<StreamInfoMessage> parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser<StreamInfoMessage> getParserForType() {
return PARSER;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}
public interface ColumnEncodingMessageOrBuilder extends
// @@protoc_insertion_point(interface_extends:doris.ColumnEncodingMessage)
com.google.protobuf.MessageOrBuilder {
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return Whether the kind field is set.
*/
boolean hasKind();
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return The kind.
*/
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind getKind();
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return Whether the dictionarySize field is set.
*/
boolean hasDictionarySize();
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return The dictionarySize.
*/
int getDictionarySize();
}
/**
* Protobuf type {@code doris.ColumnEncodingMessage}
*/
public static final class ColumnEncodingMessage extends
com.google.protobuf.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:doris.ColumnEncodingMessage)
ColumnEncodingMessageOrBuilder {
private static final long serialVersionUID = 0L;
// Use ColumnEncodingMessage.newBuilder() to construct.
private ColumnEncodingMessage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private ColumnEncodingMessage() {
kind_ = 0;
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
return new ColumnEncodingMessage();
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnEncodingMessage_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnEncodingMessage_fieldAccessorTable
.ensureFieldAccessorsInitialized(
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.class, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder.class);
}
/**
* Protobuf enum {@code doris.ColumnEncodingMessage.Kind}
*/
public enum Kind
implements com.google.protobuf.ProtocolMessageEnum {
/**
* <code>DIRECT = 0;</code>
*/
DIRECT(0),
/**
* <code>DICTIONARY = 1;</code>
*/
DICTIONARY(1),
;
/**
* <code>DIRECT = 0;</code>
*/
public static final int DIRECT_VALUE = 0;
/**
* <code>DICTIONARY = 1;</code>
*/
public static final int DICTIONARY_VALUE = 1;
public final int getNumber() {
return value;
}
/**
* @param value The numeric wire value of the corresponding enum entry.
* @return The enum associated with the given numeric wire value.
* @deprecated Use {@link #forNumber(int)} instead.
*/
@java.lang.Deprecated
public static Kind valueOf(int value) {
return forNumber(value);
}
/**
* @param value The numeric wire value of the corresponding enum entry.
* @return The enum associated with the given numeric wire value.
*/
public static Kind forNumber(int value) {
switch (value) {
case 0: return DIRECT;
case 1: return DICTIONARY;
default: return null;
}
}
public static com.google.protobuf.Internal.EnumLiteMap<Kind>
internalGetValueMap() {
return internalValueMap;
}
private static final com.google.protobuf.Internal.EnumLiteMap<
Kind> internalValueMap =
new com.google.protobuf.Internal.EnumLiteMap<Kind>() {
public Kind findValueByNumber(int number) {
return Kind.forNumber(number);
}
};
public final com.google.protobuf.Descriptors.EnumValueDescriptor
getValueDescriptor() {
return getDescriptor().getValues().get(ordinal());
}
public final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptorForType() {
return getDescriptor();
}
public static final com.google.protobuf.Descriptors.EnumDescriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.getDescriptor().getEnumTypes().get(0);
}
private static final Kind[] VALUES = values();
public static Kind valueOf(
com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
if (desc.getType() != getDescriptor()) {
throw new java.lang.IllegalArgumentException(
"EnumValueDescriptor is not for this type.");
}
return VALUES[desc.getIndex()];
}
private final int value;
private Kind(int value) {
this.value = value;
}
// @@protoc_insertion_point(enum_scope:doris.ColumnEncodingMessage.Kind)
}
private int bitField0_;
public static final int KIND_FIELD_NUMBER = 1;
private int kind_ = 0;
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return Whether the kind field is set.
*/
@java.lang.Override public boolean hasKind() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return The kind.
*/
@java.lang.Override public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind getKind() {
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind result = org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind.forNumber(kind_);
return result == null ? org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind.DIRECT : result;
}
public static final int DICTIONARY_SIZE_FIELD_NUMBER = 2;
private int dictionarySize_ = 0;
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return Whether the dictionarySize field is set.
*/
@java.lang.Override
public boolean hasDictionarySize() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return The dictionarySize.
*/
@java.lang.Override
public int getDictionarySize() {
return dictionarySize_;
}
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
if (isInitialized == 1) return true;
if (isInitialized == 0) return false;
memoizedIsInitialized = 1;
return true;
}
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
if (((bitField0_ & 0x00000001) != 0)) {
output.writeEnum(1, kind_);
}
if (((bitField0_ & 0x00000002) != 0)) {
output.writeUInt32(2, dictionarySize_);
}
getUnknownFields().writeTo(output);
}
@java.lang.Override
public int getSerializedSize() {
int size = memoizedSize;
if (size != -1) return size;
size = 0;
if (((bitField0_ & 0x00000001) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(1, kind_);
}
if (((bitField0_ & 0x00000002) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(2, dictionarySize_);
}
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
@java.lang.Override
public boolean equals(final java.lang.Object obj) {
if (obj == this) {
return true;
}
if (!(obj instanceof org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage)) {
return super.equals(obj);
}
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage other = (org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage) obj;
if (hasKind() != other.hasKind()) return false;
if (hasKind()) {
if (kind_ != other.kind_) return false;
}
if (hasDictionarySize() != other.hasDictionarySize()) return false;
if (hasDictionarySize()) {
if (getDictionarySize()
!= other.getDictionarySize()) return false;
}
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
return true;
}
@java.lang.Override
public int hashCode() {
if (memoizedHashCode != 0) {
return memoizedHashCode;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
if (hasKind()) {
hash = (37 * hash) + KIND_FIELD_NUMBER;
hash = (53 * hash) + kind_;
}
if (hasDictionarySize()) {
hash = (37 * hash) + DICTIONARY_SIZE_FIELD_NUMBER;
hash = (53 * hash) + getDictionarySize();
}
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
@java.lang.Override
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
public Builder toBuilder() {
return this == DEFAULT_INSTANCE
? new Builder() : new Builder().mergeFrom(this);
}
@java.lang.Override
protected Builder newBuilderForType(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
Builder builder = new Builder(parent);
return builder;
}
/**
* Protobuf type {@code doris.ColumnEncodingMessage}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:doris.ColumnEncodingMessage)
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnEncodingMessage_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnEncodingMessage_fieldAccessorTable
.ensureFieldAccessorsInitialized(
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.class, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder.class);
}
// Construct using org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.newBuilder()
private Builder() {
}
private Builder(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
}
@java.lang.Override
public Builder clear() {
super.clear();
bitField0_ = 0;
kind_ = 0;
dictionarySize_ = 0;
return this;
}
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnEncodingMessage_descriptor;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage getDefaultInstanceForType() {
return org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.getDefaultInstance();
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage build() {
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage buildPartial() {
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage result = new org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage(this);
if (bitField0_ != 0) { buildPartial0(result); }
onBuilt();
return result;
}
private void buildPartial0(org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage result) {
int from_bitField0_ = bitField0_;
int to_bitField0_ = 0;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.kind_ = kind_;
to_bitField0_ |= 0x00000001;
}
if (((from_bitField0_ & 0x00000002) != 0)) {
result.dictionarySize_ = dictionarySize_;
to_bitField0_ |= 0x00000002;
}
result.bitField0_ |= to_bitField0_;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(
com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(
com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(
com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
}
@java.lang.Override
public Builder setRepeatedField(
com.google.protobuf.Descriptors.FieldDescriptor field,
int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
}
@java.lang.Override
public Builder addRepeatedField(
com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage) {
return mergeFrom((org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage other) {
if (other == org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.getDefaultInstance()) return this;
if (other.hasKind()) {
setKind(other.getKind());
}
if (other.hasDictionarySize()) {
setDictionarySize(other.getDictionarySize());
}
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
@java.lang.Override
public final boolean isInitialized() {
return true;
}
@java.lang.Override
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch (tag) {
case 0:
done = true;
break;
case 8: {
int tmpRaw = input.readEnum();
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind tmpValue =
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind.forNumber(tmpRaw);
if (tmpValue == null) {
mergeUnknownVarintField(1, tmpRaw);
} else {
kind_ = tmpRaw;
bitField0_ |= 0x00000001;
}
break;
} // case 8
case 16: {
dictionarySize_ = input.readUInt32();
bitField0_ |= 0x00000002;
break;
} // case 16
default: {
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
done = true; // was an endgroup tag
}
break;
} // default:
} // switch (tag)
} // while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.unwrapIOException();
} finally {
onChanged();
} // finally
return this;
}
private int bitField0_;
private int kind_ = 0;
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return Whether the kind field is set.
*/
@java.lang.Override public boolean hasKind() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return The kind.
*/
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind getKind() {
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind result = org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind.forNumber(kind_);
return result == null ? org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind.DIRECT : result;
}
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @param value The kind to set.
* @return This builder for chaining.
*/
public Builder setKind(org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Kind value) {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000001;
kind_ = value.getNumber();
onChanged();
return this;
}
/**
* <code>optional .doris.ColumnEncodingMessage.Kind kind = 1;</code>
* @return This builder for chaining.
*/
public Builder clearKind() {
bitField0_ = (bitField0_ & ~0x00000001);
kind_ = 0;
onChanged();
return this;
}
private int dictionarySize_ ;
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return Whether the dictionarySize field is set.
*/
@java.lang.Override
public boolean hasDictionarySize() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return The dictionarySize.
*/
@java.lang.Override
public int getDictionarySize() {
return dictionarySize_;
}
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @param value The dictionarySize to set.
* @return This builder for chaining.
*/
public Builder setDictionarySize(int value) {
dictionarySize_ = value;
bitField0_ |= 0x00000002;
onChanged();
return this;
}
/**
* <code>optional uint32 dictionary_size = 2;</code>
* @return This builder for chaining.
*/
public Builder clearDictionarySize() {
bitField0_ = (bitField0_ & ~0x00000002);
dictionarySize_ = 0;
onChanged();
return this;
}
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
}
@java.lang.Override
public final Builder mergeUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.mergeUnknownFields(unknownFields);
}
// @@protoc_insertion_point(builder_scope:doris.ColumnEncodingMessage)
}
// @@protoc_insertion_point(class_scope:doris.ColumnEncodingMessage)
private static final org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage();
}
public static org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@java.lang.Deprecated public static final com.google.protobuf.Parser<ColumnEncodingMessage>
PARSER = new com.google.protobuf.AbstractParser<ColumnEncodingMessage>() {
@java.lang.Override
public ColumnEncodingMessage parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e)
.setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
public static com.google.protobuf.Parser<ColumnEncodingMessage> parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser<ColumnEncodingMessage> getParserForType() {
return PARSER;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}
public interface ColumnDataHeaderMessageOrBuilder extends
// @@protoc_insertion_point(interface_extends:doris.ColumnDataHeaderMessage)
com.google.protobuf.MessageOrBuilder {
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return Whether the magicString field is set.
*/
boolean hasMagicString();
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return The magicString.
*/
java.lang.String getMagicString();
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return The bytes for magicString.
*/
com.google.protobuf.ByteString
getMagicStringBytes();
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return Whether the version field is set.
*/
boolean hasVersion();
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return The version.
*/
int getVersion();
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return Whether the numberOfRows field is set.
*/
boolean hasNumberOfRows();
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return The numberOfRows.
*/
long getNumberOfRows();
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
java.util.List<org.apache.doris.proto.OlapCommon.ColumnMessage>
getColumnList();
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
org.apache.doris.proto.OlapCommon.ColumnMessage getColumn(int index);
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
int getColumnCount();
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
java.util.List<? extends org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder>
getColumnOrBuilderList();
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder getColumnOrBuilder(
int index);
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return Whether the indexLength field is set.
*/
boolean hasIndexLength();
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return The indexLength.
*/
long getIndexLength();
/**
* <code>required uint64 data_length = 8;</code>
* @return Whether the dataLength field is set.
*/
boolean hasDataLength();
/**
* <code>required uint64 data_length = 8;</code>
* @return The dataLength.
*/
long getDataLength();
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return Whether the compressKind field is set.
*/
boolean hasCompressKind();
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return The compressKind.
*/
org.apache.doris.proto.OlapCommon.CompressKind getCompressKind();
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
java.util.List<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage>
getStreamInfoList();
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage getStreamInfo(int index);
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
int getStreamInfoCount();
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
java.util.List<? extends org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder>
getStreamInfoOrBuilderList();
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder getStreamInfoOrBuilder(
int index);
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
java.util.List<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage>
getColumnEncodingList();
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage getColumnEncoding(int index);
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
int getColumnEncodingCount();
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
java.util.List<? extends org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder>
getColumnEncodingOrBuilderList();
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder getColumnEncodingOrBuilder(
int index);
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return Whether the streamBufferSize field is set.
*/
boolean hasStreamBufferSize();
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return The streamBufferSize.
*/
int getStreamBufferSize();
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return Whether the numRowsPerBlock field is set.
*/
boolean hasNumRowsPerBlock();
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return The numRowsPerBlock.
*/
int getNumRowsPerBlock();
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return Whether the bfHashFunctionNum field is set.
*/
boolean hasBfHashFunctionNum();
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return The bfHashFunctionNum.
*/
int getBfHashFunctionNum();
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return Whether the bfBitNum field is set.
*/
boolean hasBfBitNum();
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return The bfBitNum.
*/
int getBfBitNum();
}
/**
* Protobuf type {@code doris.ColumnDataHeaderMessage}
*/
public static final class ColumnDataHeaderMessage extends
com.google.protobuf.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:doris.ColumnDataHeaderMessage)
ColumnDataHeaderMessageOrBuilder {
private static final long serialVersionUID = 0L;
// Use ColumnDataHeaderMessage.newBuilder() to construct.
private ColumnDataHeaderMessage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private ColumnDataHeaderMessage() {
magicString_ = "COLUMN DATA";
version_ = 1;
column_ = java.util.Collections.emptyList();
compressKind_ = 1;
streamInfo_ = java.util.Collections.emptyList();
columnEncoding_ = java.util.Collections.emptyList();
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
return new ColumnDataHeaderMessage();
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnDataHeaderMessage_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnDataHeaderMessage_fieldAccessorTable
.ensureFieldAccessorsInitialized(
org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.class, org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.Builder.class);
}
private int bitField0_;
public static final int MAGIC_STRING_FIELD_NUMBER = 1;
@SuppressWarnings("serial")
private volatile java.lang.Object magicString_ = "COLUMN DATA";
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return Whether the magicString field is set.
*/
@java.lang.Override
public boolean hasMagicString() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return The magicString.
*/
@java.lang.Override
public java.lang.String getMagicString() {
java.lang.Object ref = magicString_;
if (ref instanceof java.lang.String) {
return (java.lang.String) ref;
} else {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
if (bs.isValidUtf8()) {
magicString_ = s;
}
return s;
}
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return The bytes for magicString.
*/
@java.lang.Override
public com.google.protobuf.ByteString
getMagicStringBytes() {
java.lang.Object ref = magicString_;
if (ref instanceof java.lang.String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
magicString_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
public static final int VERSION_FIELD_NUMBER = 2;
private int version_ = 1;
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return Whether the version field is set.
*/
@java.lang.Override
public boolean hasVersion() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return The version.
*/
@java.lang.Override
public int getVersion() {
return version_;
}
public static final int NUMBER_OF_ROWS_FIELD_NUMBER = 4;
private long numberOfRows_ = 0L;
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return Whether the numberOfRows field is set.
*/
@java.lang.Override
public boolean hasNumberOfRows() {
return ((bitField0_ & 0x00000004) != 0);
}
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return The numberOfRows.
*/
@java.lang.Override
public long getNumberOfRows() {
return numberOfRows_;
}
public static final int COLUMN_FIELD_NUMBER = 5;
@SuppressWarnings("serial")
private java.util.List<org.apache.doris.proto.OlapCommon.ColumnMessage> column_;
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
@java.lang.Override
public java.util.List<org.apache.doris.proto.OlapCommon.ColumnMessage> getColumnList() {
return column_;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
@java.lang.Override
public java.util.List<? extends org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder>
getColumnOrBuilderList() {
return column_;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
@java.lang.Override
public int getColumnCount() {
return column_.size();
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
@java.lang.Override
public org.apache.doris.proto.OlapCommon.ColumnMessage getColumn(int index) {
return column_.get(index);
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
@java.lang.Override
public org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder getColumnOrBuilder(
int index) {
return column_.get(index);
}
public static final int INDEX_LENGTH_FIELD_NUMBER = 7;
private long indexLength_ = 0L;
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return Whether the indexLength field is set.
*/
@java.lang.Override
public boolean hasIndexLength() {
return ((bitField0_ & 0x00000008) != 0);
}
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return The indexLength.
*/
@java.lang.Override
public long getIndexLength() {
return indexLength_;
}
public static final int DATA_LENGTH_FIELD_NUMBER = 8;
private long dataLength_ = 0L;
/**
* <code>required uint64 data_length = 8;</code>
* @return Whether the dataLength field is set.
*/
@java.lang.Override
public boolean hasDataLength() {
return ((bitField0_ & 0x00000010) != 0);
}
/**
* <code>required uint64 data_length = 8;</code>
* @return The dataLength.
*/
@java.lang.Override
public long getDataLength() {
return dataLength_;
}
public static final int COMPRESS_KIND_FIELD_NUMBER = 9;
private int compressKind_ = 1;
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return Whether the compressKind field is set.
*/
@java.lang.Override public boolean hasCompressKind() {
return ((bitField0_ & 0x00000020) != 0);
}
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return The compressKind.
*/
@java.lang.Override public org.apache.doris.proto.OlapCommon.CompressKind getCompressKind() {
org.apache.doris.proto.OlapCommon.CompressKind result = org.apache.doris.proto.OlapCommon.CompressKind.forNumber(compressKind_);
return result == null ? org.apache.doris.proto.OlapCommon.CompressKind.COMPRESS_LZO : result;
}
public static final int STREAM_INFO_FIELD_NUMBER = 10;
@SuppressWarnings("serial")
private java.util.List<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage> streamInfo_;
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
@java.lang.Override
public java.util.List<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage> getStreamInfoList() {
return streamInfo_;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
@java.lang.Override
public java.util.List<? extends org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder>
getStreamInfoOrBuilderList() {
return streamInfo_;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
@java.lang.Override
public int getStreamInfoCount() {
return streamInfo_.size();
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage getStreamInfo(int index) {
return streamInfo_.get(index);
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder getStreamInfoOrBuilder(
int index) {
return streamInfo_.get(index);
}
public static final int COLUMN_ENCODING_FIELD_NUMBER = 11;
@SuppressWarnings("serial")
private java.util.List<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage> columnEncoding_;
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
@java.lang.Override
public java.util.List<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage> getColumnEncodingList() {
return columnEncoding_;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
@java.lang.Override
public java.util.List<? extends org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder>
getColumnEncodingOrBuilderList() {
return columnEncoding_;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
@java.lang.Override
public int getColumnEncodingCount() {
return columnEncoding_.size();
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage getColumnEncoding(int index) {
return columnEncoding_.get(index);
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder getColumnEncodingOrBuilder(
int index) {
return columnEncoding_.get(index);
}
public static final int STREAM_BUFFER_SIZE_FIELD_NUMBER = 12;
private int streamBufferSize_ = 0;
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return Whether the streamBufferSize field is set.
*/
@java.lang.Override
public boolean hasStreamBufferSize() {
return ((bitField0_ & 0x00000040) != 0);
}
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return The streamBufferSize.
*/
@java.lang.Override
public int getStreamBufferSize() {
return streamBufferSize_;
}
public static final int NUM_ROWS_PER_BLOCK_FIELD_NUMBER = 13;
private int numRowsPerBlock_ = 0;
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return Whether the numRowsPerBlock field is set.
*/
@java.lang.Override
public boolean hasNumRowsPerBlock() {
return ((bitField0_ & 0x00000080) != 0);
}
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return The numRowsPerBlock.
*/
@java.lang.Override
public int getNumRowsPerBlock() {
return numRowsPerBlock_;
}
public static final int BF_HASH_FUNCTION_NUM_FIELD_NUMBER = 14;
private int bfHashFunctionNum_ = 0;
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return Whether the bfHashFunctionNum field is set.
*/
@java.lang.Override
public boolean hasBfHashFunctionNum() {
return ((bitField0_ & 0x00000100) != 0);
}
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return The bfHashFunctionNum.
*/
@java.lang.Override
public int getBfHashFunctionNum() {
return bfHashFunctionNum_;
}
public static final int BF_BIT_NUM_FIELD_NUMBER = 15;
private int bfBitNum_ = 0;
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return Whether the bfBitNum field is set.
*/
@java.lang.Override
public boolean hasBfBitNum() {
return ((bitField0_ & 0x00000200) != 0);
}
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return The bfBitNum.
*/
@java.lang.Override
public int getBfBitNum() {
return bfBitNum_;
}
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
if (isInitialized == 1) return true;
if (isInitialized == 0) return false;
if (!hasMagicString()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasVersion()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasNumberOfRows()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasIndexLength()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasDataLength()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasCompressKind()) {
memoizedIsInitialized = 0;
return false;
}
if (!hasStreamBufferSize()) {
memoizedIsInitialized = 0;
return false;
}
for (int i = 0; i < getColumnCount(); i++) {
if (!getColumn(i).isInitialized()) {
memoizedIsInitialized = 0;
return false;
}
}
for (int i = 0; i < getStreamInfoCount(); i++) {
if (!getStreamInfo(i).isInitialized()) {
memoizedIsInitialized = 0;
return false;
}
}
memoizedIsInitialized = 1;
return true;
}
@java.lang.Override
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
if (((bitField0_ & 0x00000001) != 0)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 1, magicString_);
}
if (((bitField0_ & 0x00000002) != 0)) {
output.writeUInt32(2, version_);
}
if (((bitField0_ & 0x00000004) != 0)) {
output.writeUInt64(4, numberOfRows_);
}
for (int i = 0; i < column_.size(); i++) {
output.writeMessage(5, column_.get(i));
}
if (((bitField0_ & 0x00000008) != 0)) {
output.writeUInt64(7, indexLength_);
}
if (((bitField0_ & 0x00000010) != 0)) {
output.writeUInt64(8, dataLength_);
}
if (((bitField0_ & 0x00000020) != 0)) {
output.writeEnum(9, compressKind_);
}
for (int i = 0; i < streamInfo_.size(); i++) {
output.writeMessage(10, streamInfo_.get(i));
}
for (int i = 0; i < columnEncoding_.size(); i++) {
output.writeMessage(11, columnEncoding_.get(i));
}
if (((bitField0_ & 0x00000040) != 0)) {
output.writeUInt32(12, streamBufferSize_);
}
if (((bitField0_ & 0x00000080) != 0)) {
output.writeUInt32(13, numRowsPerBlock_);
}
if (((bitField0_ & 0x00000100) != 0)) {
output.writeUInt32(14, bfHashFunctionNum_);
}
if (((bitField0_ & 0x00000200) != 0)) {
output.writeUInt32(15, bfBitNum_);
}
getUnknownFields().writeTo(output);
}
@java.lang.Override
public int getSerializedSize() {
int size = memoizedSize;
if (size != -1) return size;
size = 0;
if (((bitField0_ & 0x00000001) != 0)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, magicString_);
}
if (((bitField0_ & 0x00000002) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(2, version_);
}
if (((bitField0_ & 0x00000004) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt64Size(4, numberOfRows_);
}
for (int i = 0; i < column_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(5, column_.get(i));
}
if (((bitField0_ & 0x00000008) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt64Size(7, indexLength_);
}
if (((bitField0_ & 0x00000010) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt64Size(8, dataLength_);
}
if (((bitField0_ & 0x00000020) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(9, compressKind_);
}
for (int i = 0; i < streamInfo_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(10, streamInfo_.get(i));
}
for (int i = 0; i < columnEncoding_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(11, columnEncoding_.get(i));
}
if (((bitField0_ & 0x00000040) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(12, streamBufferSize_);
}
if (((bitField0_ & 0x00000080) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(13, numRowsPerBlock_);
}
if (((bitField0_ & 0x00000100) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(14, bfHashFunctionNum_);
}
if (((bitField0_ & 0x00000200) != 0)) {
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(15, bfBitNum_);
}
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
}
@java.lang.Override
public boolean equals(final java.lang.Object obj) {
if (obj == this) {
return true;
}
if (!(obj instanceof org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage)) {
return super.equals(obj);
}
org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage other = (org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage) obj;
if (hasMagicString() != other.hasMagicString()) return false;
if (hasMagicString()) {
if (!getMagicString()
.equals(other.getMagicString())) return false;
}
if (hasVersion() != other.hasVersion()) return false;
if (hasVersion()) {
if (getVersion()
!= other.getVersion()) return false;
}
if (hasNumberOfRows() != other.hasNumberOfRows()) return false;
if (hasNumberOfRows()) {
if (getNumberOfRows()
!= other.getNumberOfRows()) return false;
}
if (!getColumnList()
.equals(other.getColumnList())) return false;
if (hasIndexLength() != other.hasIndexLength()) return false;
if (hasIndexLength()) {
if (getIndexLength()
!= other.getIndexLength()) return false;
}
if (hasDataLength() != other.hasDataLength()) return false;
if (hasDataLength()) {
if (getDataLength()
!= other.getDataLength()) return false;
}
if (hasCompressKind() != other.hasCompressKind()) return false;
if (hasCompressKind()) {
if (compressKind_ != other.compressKind_) return false;
}
if (!getStreamInfoList()
.equals(other.getStreamInfoList())) return false;
if (!getColumnEncodingList()
.equals(other.getColumnEncodingList())) return false;
if (hasStreamBufferSize() != other.hasStreamBufferSize()) return false;
if (hasStreamBufferSize()) {
if (getStreamBufferSize()
!= other.getStreamBufferSize()) return false;
}
if (hasNumRowsPerBlock() != other.hasNumRowsPerBlock()) return false;
if (hasNumRowsPerBlock()) {
if (getNumRowsPerBlock()
!= other.getNumRowsPerBlock()) return false;
}
if (hasBfHashFunctionNum() != other.hasBfHashFunctionNum()) return false;
if (hasBfHashFunctionNum()) {
if (getBfHashFunctionNum()
!= other.getBfHashFunctionNum()) return false;
}
if (hasBfBitNum() != other.hasBfBitNum()) return false;
if (hasBfBitNum()) {
if (getBfBitNum()
!= other.getBfBitNum()) return false;
}
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
return true;
}
@java.lang.Override
public int hashCode() {
if (memoizedHashCode != 0) {
return memoizedHashCode;
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
if (hasMagicString()) {
hash = (37 * hash) + MAGIC_STRING_FIELD_NUMBER;
hash = (53 * hash) + getMagicString().hashCode();
}
if (hasVersion()) {
hash = (37 * hash) + VERSION_FIELD_NUMBER;
hash = (53 * hash) + getVersion();
}
if (hasNumberOfRows()) {
hash = (37 * hash) + NUMBER_OF_ROWS_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
getNumberOfRows());
}
if (getColumnCount() > 0) {
hash = (37 * hash) + COLUMN_FIELD_NUMBER;
hash = (53 * hash) + getColumnList().hashCode();
}
if (hasIndexLength()) {
hash = (37 * hash) + INDEX_LENGTH_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
getIndexLength());
}
if (hasDataLength()) {
hash = (37 * hash) + DATA_LENGTH_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
getDataLength());
}
if (hasCompressKind()) {
hash = (37 * hash) + COMPRESS_KIND_FIELD_NUMBER;
hash = (53 * hash) + compressKind_;
}
if (getStreamInfoCount() > 0) {
hash = (37 * hash) + STREAM_INFO_FIELD_NUMBER;
hash = (53 * hash) + getStreamInfoList().hashCode();
}
if (getColumnEncodingCount() > 0) {
hash = (37 * hash) + COLUMN_ENCODING_FIELD_NUMBER;
hash = (53 * hash) + getColumnEncodingList().hashCode();
}
if (hasStreamBufferSize()) {
hash = (37 * hash) + STREAM_BUFFER_SIZE_FIELD_NUMBER;
hash = (53 * hash) + getStreamBufferSize();
}
if (hasNumRowsPerBlock()) {
hash = (37 * hash) + NUM_ROWS_PER_BLOCK_FIELD_NUMBER;
hash = (53 * hash) + getNumRowsPerBlock();
}
if (hasBfHashFunctionNum()) {
hash = (37 * hash) + BF_HASH_FUNCTION_NUM_FIELD_NUMBER;
hash = (53 * hash) + getBfHashFunctionNum();
}
if (hasBfBitNum()) {
hash = (37 * hash) + BF_BIT_NUM_FIELD_NUMBER;
hash = (53 * hash) + getBfBitNum();
}
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input, extensionRegistry);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input, extensionRegistry);
}
@java.lang.Override
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder() {
return DEFAULT_INSTANCE.toBuilder();
}
public static Builder newBuilder(org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage prototype) {
return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
}
@java.lang.Override
public Builder toBuilder() {
return this == DEFAULT_INSTANCE
? new Builder() : new Builder().mergeFrom(this);
}
@java.lang.Override
protected Builder newBuilderForType(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
Builder builder = new Builder(parent);
return builder;
}
/**
* Protobuf type {@code doris.ColumnDataHeaderMessage}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:doris.ColumnDataHeaderMessage)
org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessageOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnDataHeaderMessage_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnDataHeaderMessage_fieldAccessorTable
.ensureFieldAccessorsInitialized(
org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.class, org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.Builder.class);
}
// Construct using org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.newBuilder()
private Builder() {
}
private Builder(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
}
@java.lang.Override
public Builder clear() {
super.clear();
bitField0_ = 0;
magicString_ = "COLUMN DATA";
version_ = 1;
numberOfRows_ = 0L;
if (columnBuilder_ == null) {
column_ = java.util.Collections.emptyList();
} else {
column_ = null;
columnBuilder_.clear();
}
bitField0_ = (bitField0_ & ~0x00000008);
indexLength_ = 0L;
dataLength_ = 0L;
compressKind_ = 1;
if (streamInfoBuilder_ == null) {
streamInfo_ = java.util.Collections.emptyList();
} else {
streamInfo_ = null;
streamInfoBuilder_.clear();
}
bitField0_ = (bitField0_ & ~0x00000080);
if (columnEncodingBuilder_ == null) {
columnEncoding_ = java.util.Collections.emptyList();
} else {
columnEncoding_ = null;
columnEncodingBuilder_.clear();
}
bitField0_ = (bitField0_ & ~0x00000100);
streamBufferSize_ = 0;
numRowsPerBlock_ = 0;
bfHashFunctionNum_ = 0;
bfBitNum_ = 0;
return this;
}
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return org.apache.doris.proto.ColumnDataFile.internal_static_doris_ColumnDataHeaderMessage_descriptor;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage getDefaultInstanceForType() {
return org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.getDefaultInstance();
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage build() {
org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage buildPartial() {
org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage result = new org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage(this);
buildPartialRepeatedFields(result);
if (bitField0_ != 0) { buildPartial0(result); }
onBuilt();
return result;
}
private void buildPartialRepeatedFields(org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage result) {
if (columnBuilder_ == null) {
if (((bitField0_ & 0x00000008) != 0)) {
column_ = java.util.Collections.unmodifiableList(column_);
bitField0_ = (bitField0_ & ~0x00000008);
}
result.column_ = column_;
} else {
result.column_ = columnBuilder_.build();
}
if (streamInfoBuilder_ == null) {
if (((bitField0_ & 0x00000080) != 0)) {
streamInfo_ = java.util.Collections.unmodifiableList(streamInfo_);
bitField0_ = (bitField0_ & ~0x00000080);
}
result.streamInfo_ = streamInfo_;
} else {
result.streamInfo_ = streamInfoBuilder_.build();
}
if (columnEncodingBuilder_ == null) {
if (((bitField0_ & 0x00000100) != 0)) {
columnEncoding_ = java.util.Collections.unmodifiableList(columnEncoding_);
bitField0_ = (bitField0_ & ~0x00000100);
}
result.columnEncoding_ = columnEncoding_;
} else {
result.columnEncoding_ = columnEncodingBuilder_.build();
}
}
private void buildPartial0(org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage result) {
int from_bitField0_ = bitField0_;
int to_bitField0_ = 0;
if (((from_bitField0_ & 0x00000001) != 0)) {
result.magicString_ = magicString_;
to_bitField0_ |= 0x00000001;
}
if (((from_bitField0_ & 0x00000002) != 0)) {
result.version_ = version_;
to_bitField0_ |= 0x00000002;
}
if (((from_bitField0_ & 0x00000004) != 0)) {
result.numberOfRows_ = numberOfRows_;
to_bitField0_ |= 0x00000004;
}
if (((from_bitField0_ & 0x00000010) != 0)) {
result.indexLength_ = indexLength_;
to_bitField0_ |= 0x00000008;
}
if (((from_bitField0_ & 0x00000020) != 0)) {
result.dataLength_ = dataLength_;
to_bitField0_ |= 0x00000010;
}
if (((from_bitField0_ & 0x00000040) != 0)) {
result.compressKind_ = compressKind_;
to_bitField0_ |= 0x00000020;
}
if (((from_bitField0_ & 0x00000200) != 0)) {
result.streamBufferSize_ = streamBufferSize_;
to_bitField0_ |= 0x00000040;
}
if (((from_bitField0_ & 0x00000400) != 0)) {
result.numRowsPerBlock_ = numRowsPerBlock_;
to_bitField0_ |= 0x00000080;
}
if (((from_bitField0_ & 0x00000800) != 0)) {
result.bfHashFunctionNum_ = bfHashFunctionNum_;
to_bitField0_ |= 0x00000100;
}
if (((from_bitField0_ & 0x00001000) != 0)) {
result.bfBitNum_ = bfBitNum_;
to_bitField0_ |= 0x00000200;
}
result.bitField0_ |= to_bitField0_;
}
@java.lang.Override
public Builder clone() {
return super.clone();
}
@java.lang.Override
public Builder setField(
com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) {
return super.setField(field, value);
}
@java.lang.Override
public Builder clearField(
com.google.protobuf.Descriptors.FieldDescriptor field) {
return super.clearField(field);
}
@java.lang.Override
public Builder clearOneof(
com.google.protobuf.Descriptors.OneofDescriptor oneof) {
return super.clearOneof(oneof);
}
@java.lang.Override
public Builder setRepeatedField(
com.google.protobuf.Descriptors.FieldDescriptor field,
int index, java.lang.Object value) {
return super.setRepeatedField(field, index, value);
}
@java.lang.Override
public Builder addRepeatedField(
com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) {
return super.addRepeatedField(field, value);
}
@java.lang.Override
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage) {
return mergeFrom((org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage other) {
if (other == org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage.getDefaultInstance()) return this;
if (other.hasMagicString()) {
magicString_ = other.magicString_;
bitField0_ |= 0x00000001;
onChanged();
}
if (other.hasVersion()) {
setVersion(other.getVersion());
}
if (other.hasNumberOfRows()) {
setNumberOfRows(other.getNumberOfRows());
}
if (columnBuilder_ == null) {
if (!other.column_.isEmpty()) {
if (column_.isEmpty()) {
column_ = other.column_;
bitField0_ = (bitField0_ & ~0x00000008);
} else {
ensureColumnIsMutable();
column_.addAll(other.column_);
}
onChanged();
}
} else {
if (!other.column_.isEmpty()) {
if (columnBuilder_.isEmpty()) {
columnBuilder_.dispose();
columnBuilder_ = null;
column_ = other.column_;
bitField0_ = (bitField0_ & ~0x00000008);
columnBuilder_ =
com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
getColumnFieldBuilder() : null;
} else {
columnBuilder_.addAllMessages(other.column_);
}
}
}
if (other.hasIndexLength()) {
setIndexLength(other.getIndexLength());
}
if (other.hasDataLength()) {
setDataLength(other.getDataLength());
}
if (other.hasCompressKind()) {
setCompressKind(other.getCompressKind());
}
if (streamInfoBuilder_ == null) {
if (!other.streamInfo_.isEmpty()) {
if (streamInfo_.isEmpty()) {
streamInfo_ = other.streamInfo_;
bitField0_ = (bitField0_ & ~0x00000080);
} else {
ensureStreamInfoIsMutable();
streamInfo_.addAll(other.streamInfo_);
}
onChanged();
}
} else {
if (!other.streamInfo_.isEmpty()) {
if (streamInfoBuilder_.isEmpty()) {
streamInfoBuilder_.dispose();
streamInfoBuilder_ = null;
streamInfo_ = other.streamInfo_;
bitField0_ = (bitField0_ & ~0x00000080);
streamInfoBuilder_ =
com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
getStreamInfoFieldBuilder() : null;
} else {
streamInfoBuilder_.addAllMessages(other.streamInfo_);
}
}
}
if (columnEncodingBuilder_ == null) {
if (!other.columnEncoding_.isEmpty()) {
if (columnEncoding_.isEmpty()) {
columnEncoding_ = other.columnEncoding_;
bitField0_ = (bitField0_ & ~0x00000100);
} else {
ensureColumnEncodingIsMutable();
columnEncoding_.addAll(other.columnEncoding_);
}
onChanged();
}
} else {
if (!other.columnEncoding_.isEmpty()) {
if (columnEncodingBuilder_.isEmpty()) {
columnEncodingBuilder_.dispose();
columnEncodingBuilder_ = null;
columnEncoding_ = other.columnEncoding_;
bitField0_ = (bitField0_ & ~0x00000100);
columnEncodingBuilder_ =
com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
getColumnEncodingFieldBuilder() : null;
} else {
columnEncodingBuilder_.addAllMessages(other.columnEncoding_);
}
}
}
if (other.hasStreamBufferSize()) {
setStreamBufferSize(other.getStreamBufferSize());
}
if (other.hasNumRowsPerBlock()) {
setNumRowsPerBlock(other.getNumRowsPerBlock());
}
if (other.hasBfHashFunctionNum()) {
setBfHashFunctionNum(other.getBfHashFunctionNum());
}
if (other.hasBfBitNum()) {
setBfBitNum(other.getBfBitNum());
}
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
}
@java.lang.Override
public final boolean isInitialized() {
if (!hasMagicString()) {
return false;
}
if (!hasVersion()) {
return false;
}
if (!hasNumberOfRows()) {
return false;
}
if (!hasIndexLength()) {
return false;
}
if (!hasDataLength()) {
return false;
}
if (!hasCompressKind()) {
return false;
}
if (!hasStreamBufferSize()) {
return false;
}
for (int i = 0; i < getColumnCount(); i++) {
if (!getColumn(i).isInitialized()) {
return false;
}
}
for (int i = 0; i < getStreamInfoCount(); i++) {
if (!getStreamInfo(i).isInitialized()) {
return false;
}
}
return true;
}
@java.lang.Override
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
try {
boolean done = false;
while (!done) {
int tag = input.readTag();
switch (tag) {
case 0:
done = true;
break;
case 10: {
magicString_ = input.readBytes();
bitField0_ |= 0x00000001;
break;
} // case 10
case 16: {
version_ = input.readUInt32();
bitField0_ |= 0x00000002;
break;
} // case 16
case 32: {
numberOfRows_ = input.readUInt64();
bitField0_ |= 0x00000004;
break;
} // case 32
case 42: {
org.apache.doris.proto.OlapCommon.ColumnMessage m =
input.readMessage(
org.apache.doris.proto.OlapCommon.ColumnMessage.PARSER,
extensionRegistry);
if (columnBuilder_ == null) {
ensureColumnIsMutable();
column_.add(m);
} else {
columnBuilder_.addMessage(m);
}
break;
} // case 42
case 56: {
indexLength_ = input.readUInt64();
bitField0_ |= 0x00000010;
break;
} // case 56
case 64: {
dataLength_ = input.readUInt64();
bitField0_ |= 0x00000020;
break;
} // case 64
case 72: {
int tmpRaw = input.readEnum();
org.apache.doris.proto.OlapCommon.CompressKind tmpValue =
org.apache.doris.proto.OlapCommon.CompressKind.forNumber(tmpRaw);
if (tmpValue == null) {
mergeUnknownVarintField(9, tmpRaw);
} else {
compressKind_ = tmpRaw;
bitField0_ |= 0x00000040;
}
break;
} // case 72
case 82: {
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage m =
input.readMessage(
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.PARSER,
extensionRegistry);
if (streamInfoBuilder_ == null) {
ensureStreamInfoIsMutable();
streamInfo_.add(m);
} else {
streamInfoBuilder_.addMessage(m);
}
break;
} // case 82
case 90: {
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage m =
input.readMessage(
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.PARSER,
extensionRegistry);
if (columnEncodingBuilder_ == null) {
ensureColumnEncodingIsMutable();
columnEncoding_.add(m);
} else {
columnEncodingBuilder_.addMessage(m);
}
break;
} // case 90
case 96: {
streamBufferSize_ = input.readUInt32();
bitField0_ |= 0x00000200;
break;
} // case 96
case 104: {
numRowsPerBlock_ = input.readUInt32();
bitField0_ |= 0x00000400;
break;
} // case 104
case 112: {
bfHashFunctionNum_ = input.readUInt32();
bitField0_ |= 0x00000800;
break;
} // case 112
case 120: {
bfBitNum_ = input.readUInt32();
bitField0_ |= 0x00001000;
break;
} // case 120
default: {
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
done = true; // was an endgroup tag
}
break;
} // default:
} // switch (tag)
} // while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.unwrapIOException();
} finally {
onChanged();
} // finally
return this;
}
private int bitField0_;
private java.lang.Object magicString_ = "COLUMN DATA";
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return Whether the magicString field is set.
*/
public boolean hasMagicString() {
return ((bitField0_ & 0x00000001) != 0);
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return The magicString.
*/
public java.lang.String getMagicString() {
java.lang.Object ref = magicString_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
if (bs.isValidUtf8()) {
magicString_ = s;
}
return s;
} else {
return (java.lang.String) ref;
}
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return The bytes for magicString.
*/
public com.google.protobuf.ByteString
getMagicStringBytes() {
java.lang.Object ref = magicString_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
magicString_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @param value The magicString to set.
* @return This builder for chaining.
*/
public Builder setMagicString(
java.lang.String value) {
if (value == null) { throw new NullPointerException(); }
magicString_ = value;
bitField0_ |= 0x00000001;
onChanged();
return this;
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @return This builder for chaining.
*/
public Builder clearMagicString() {
magicString_ = getDefaultInstance().getMagicString();
bitField0_ = (bitField0_ & ~0x00000001);
onChanged();
return this;
}
/**
* <code>required string magic_string = 1 [default = "COLUMN DATA"];</code>
* @param value The bytes for magicString to set.
* @return This builder for chaining.
*/
public Builder setMagicStringBytes(
com.google.protobuf.ByteString value) {
if (value == null) { throw new NullPointerException(); }
magicString_ = value;
bitField0_ |= 0x00000001;
onChanged();
return this;
}
private int version_ = 1;
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return Whether the version field is set.
*/
@java.lang.Override
public boolean hasVersion() {
return ((bitField0_ & 0x00000002) != 0);
}
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return The version.
*/
@java.lang.Override
public int getVersion() {
return version_;
}
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @param value The version to set.
* @return This builder for chaining.
*/
public Builder setVersion(int value) {
version_ = value;
bitField0_ |= 0x00000002;
onChanged();
return this;
}
/**
* <code>required uint32 version = 2 [default = 1];</code>
* @return This builder for chaining.
*/
public Builder clearVersion() {
bitField0_ = (bitField0_ & ~0x00000002);
version_ = 1;
onChanged();
return this;
}
private long numberOfRows_ ;
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return Whether the numberOfRows field is set.
*/
@java.lang.Override
public boolean hasNumberOfRows() {
return ((bitField0_ & 0x00000004) != 0);
}
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return The numberOfRows.
*/
@java.lang.Override
public long getNumberOfRows() {
return numberOfRows_;
}
/**
* <code>required uint64 number_of_rows = 4;</code>
* @param value The numberOfRows to set.
* @return This builder for chaining.
*/
public Builder setNumberOfRows(long value) {
numberOfRows_ = value;
bitField0_ |= 0x00000004;
onChanged();
return this;
}
/**
* <code>required uint64 number_of_rows = 4;</code>
* @return This builder for chaining.
*/
public Builder clearNumberOfRows() {
bitField0_ = (bitField0_ & ~0x00000004);
numberOfRows_ = 0L;
onChanged();
return this;
}
private java.util.List<org.apache.doris.proto.OlapCommon.ColumnMessage> column_ =
java.util.Collections.emptyList();
private void ensureColumnIsMutable() {
if (!((bitField0_ & 0x00000008) != 0)) {
column_ = new java.util.ArrayList<org.apache.doris.proto.OlapCommon.ColumnMessage>(column_);
bitField0_ |= 0x00000008;
}
}
private com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.OlapCommon.ColumnMessage, org.apache.doris.proto.OlapCommon.ColumnMessage.Builder, org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder> columnBuilder_;
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public java.util.List<org.apache.doris.proto.OlapCommon.ColumnMessage> getColumnList() {
if (columnBuilder_ == null) {
return java.util.Collections.unmodifiableList(column_);
} else {
return columnBuilder_.getMessageList();
}
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public int getColumnCount() {
if (columnBuilder_ == null) {
return column_.size();
} else {
return columnBuilder_.getCount();
}
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public org.apache.doris.proto.OlapCommon.ColumnMessage getColumn(int index) {
if (columnBuilder_ == null) {
return column_.get(index);
} else {
return columnBuilder_.getMessage(index);
}
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder setColumn(
int index, org.apache.doris.proto.OlapCommon.ColumnMessage value) {
if (columnBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureColumnIsMutable();
column_.set(index, value);
onChanged();
} else {
columnBuilder_.setMessage(index, value);
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder setColumn(
int index, org.apache.doris.proto.OlapCommon.ColumnMessage.Builder builderForValue) {
if (columnBuilder_ == null) {
ensureColumnIsMutable();
column_.set(index, builderForValue.build());
onChanged();
} else {
columnBuilder_.setMessage(index, builderForValue.build());
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder addColumn(org.apache.doris.proto.OlapCommon.ColumnMessage value) {
if (columnBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureColumnIsMutable();
column_.add(value);
onChanged();
} else {
columnBuilder_.addMessage(value);
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder addColumn(
int index, org.apache.doris.proto.OlapCommon.ColumnMessage value) {
if (columnBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureColumnIsMutable();
column_.add(index, value);
onChanged();
} else {
columnBuilder_.addMessage(index, value);
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder addColumn(
org.apache.doris.proto.OlapCommon.ColumnMessage.Builder builderForValue) {
if (columnBuilder_ == null) {
ensureColumnIsMutable();
column_.add(builderForValue.build());
onChanged();
} else {
columnBuilder_.addMessage(builderForValue.build());
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder addColumn(
int index, org.apache.doris.proto.OlapCommon.ColumnMessage.Builder builderForValue) {
if (columnBuilder_ == null) {
ensureColumnIsMutable();
column_.add(index, builderForValue.build());
onChanged();
} else {
columnBuilder_.addMessage(index, builderForValue.build());
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder addAllColumn(
java.lang.Iterable<? extends org.apache.doris.proto.OlapCommon.ColumnMessage> values) {
if (columnBuilder_ == null) {
ensureColumnIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(
values, column_);
onChanged();
} else {
columnBuilder_.addAllMessages(values);
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder clearColumn() {
if (columnBuilder_ == null) {
column_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00000008);
onChanged();
} else {
columnBuilder_.clear();
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public Builder removeColumn(int index) {
if (columnBuilder_ == null) {
ensureColumnIsMutable();
column_.remove(index);
onChanged();
} else {
columnBuilder_.remove(index);
}
return this;
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public org.apache.doris.proto.OlapCommon.ColumnMessage.Builder getColumnBuilder(
int index) {
return getColumnFieldBuilder().getBuilder(index);
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder getColumnOrBuilder(
int index) {
if (columnBuilder_ == null) {
return column_.get(index); } else {
return columnBuilder_.getMessageOrBuilder(index);
}
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public java.util.List<? extends org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder>
getColumnOrBuilderList() {
if (columnBuilder_ != null) {
return columnBuilder_.getMessageOrBuilderList();
} else {
return java.util.Collections.unmodifiableList(column_);
}
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public org.apache.doris.proto.OlapCommon.ColumnMessage.Builder addColumnBuilder() {
return getColumnFieldBuilder().addBuilder(
org.apache.doris.proto.OlapCommon.ColumnMessage.getDefaultInstance());
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public org.apache.doris.proto.OlapCommon.ColumnMessage.Builder addColumnBuilder(
int index) {
return getColumnFieldBuilder().addBuilder(
index, org.apache.doris.proto.OlapCommon.ColumnMessage.getDefaultInstance());
}
/**
* <pre>
* column schema
* </pre>
*
* <code>repeated .doris.ColumnMessage column = 5;</code>
*/
public java.util.List<org.apache.doris.proto.OlapCommon.ColumnMessage.Builder>
getColumnBuilderList() {
return getColumnFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.OlapCommon.ColumnMessage, org.apache.doris.proto.OlapCommon.ColumnMessage.Builder, org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder>
getColumnFieldBuilder() {
if (columnBuilder_ == null) {
columnBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.OlapCommon.ColumnMessage, org.apache.doris.proto.OlapCommon.ColumnMessage.Builder, org.apache.doris.proto.OlapCommon.ColumnMessageOrBuilder>(
column_,
((bitField0_ & 0x00000008) != 0),
getParentForChildren(),
isClean());
column_ = null;
}
return columnBuilder_;
}
private long indexLength_ ;
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return Whether the indexLength field is set.
*/
@java.lang.Override
public boolean hasIndexLength() {
return ((bitField0_ & 0x00000010) != 0);
}
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return The indexLength.
*/
@java.lang.Override
public long getIndexLength() {
return indexLength_;
}
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @param value The indexLength to set.
* @return This builder for chaining.
*/
public Builder setIndexLength(long value) {
indexLength_ = value;
bitField0_ |= 0x00000010;
onChanged();
return this;
}
/**
* <pre>
* statistics for each column
* </pre>
*
* <code>required uint64 index_length = 7;</code>
* @return This builder for chaining.
*/
public Builder clearIndexLength() {
bitField0_ = (bitField0_ & ~0x00000010);
indexLength_ = 0L;
onChanged();
return this;
}
private long dataLength_ ;
/**
* <code>required uint64 data_length = 8;</code>
* @return Whether the dataLength field is set.
*/
@java.lang.Override
public boolean hasDataLength() {
return ((bitField0_ & 0x00000020) != 0);
}
/**
* <code>required uint64 data_length = 8;</code>
* @return The dataLength.
*/
@java.lang.Override
public long getDataLength() {
return dataLength_;
}
/**
* <code>required uint64 data_length = 8;</code>
* @param value The dataLength to set.
* @return This builder for chaining.
*/
public Builder setDataLength(long value) {
dataLength_ = value;
bitField0_ |= 0x00000020;
onChanged();
return this;
}
/**
* <code>required uint64 data_length = 8;</code>
* @return This builder for chaining.
*/
public Builder clearDataLength() {
bitField0_ = (bitField0_ & ~0x00000020);
dataLength_ = 0L;
onChanged();
return this;
}
private int compressKind_ = 1;
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return Whether the compressKind field is set.
*/
@java.lang.Override public boolean hasCompressKind() {
return ((bitField0_ & 0x00000040) != 0);
}
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return The compressKind.
*/
@java.lang.Override
public org.apache.doris.proto.OlapCommon.CompressKind getCompressKind() {
org.apache.doris.proto.OlapCommon.CompressKind result = org.apache.doris.proto.OlapCommon.CompressKind.forNumber(compressKind_);
return result == null ? org.apache.doris.proto.OlapCommon.CompressKind.COMPRESS_LZO : result;
}
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @param value The compressKind to set.
* @return This builder for chaining.
*/
public Builder setCompressKind(org.apache.doris.proto.OlapCommon.CompressKind value) {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000040;
compressKind_ = value.getNumber();
onChanged();
return this;
}
/**
* <code>required .doris.CompressKind compress_kind = 9 [default = COMPRESS_LZO];</code>
* @return This builder for chaining.
*/
public Builder clearCompressKind() {
bitField0_ = (bitField0_ & ~0x00000040);
compressKind_ = 1;
onChanged();
return this;
}
private java.util.List<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage> streamInfo_ =
java.util.Collections.emptyList();
private void ensureStreamInfoIsMutable() {
if (!((bitField0_ & 0x00000080) != 0)) {
streamInfo_ = new java.util.ArrayList<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage>(streamInfo_);
bitField0_ |= 0x00000080;
}
}
private com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder, org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder> streamInfoBuilder_;
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public java.util.List<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage> getStreamInfoList() {
if (streamInfoBuilder_ == null) {
return java.util.Collections.unmodifiableList(streamInfo_);
} else {
return streamInfoBuilder_.getMessageList();
}
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public int getStreamInfoCount() {
if (streamInfoBuilder_ == null) {
return streamInfo_.size();
} else {
return streamInfoBuilder_.getCount();
}
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage getStreamInfo(int index) {
if (streamInfoBuilder_ == null) {
return streamInfo_.get(index);
} else {
return streamInfoBuilder_.getMessage(index);
}
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder setStreamInfo(
int index, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage value) {
if (streamInfoBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureStreamInfoIsMutable();
streamInfo_.set(index, value);
onChanged();
} else {
streamInfoBuilder_.setMessage(index, value);
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder setStreamInfo(
int index, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder builderForValue) {
if (streamInfoBuilder_ == null) {
ensureStreamInfoIsMutable();
streamInfo_.set(index, builderForValue.build());
onChanged();
} else {
streamInfoBuilder_.setMessage(index, builderForValue.build());
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder addStreamInfo(org.apache.doris.proto.ColumnDataFile.StreamInfoMessage value) {
if (streamInfoBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureStreamInfoIsMutable();
streamInfo_.add(value);
onChanged();
} else {
streamInfoBuilder_.addMessage(value);
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder addStreamInfo(
int index, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage value) {
if (streamInfoBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureStreamInfoIsMutable();
streamInfo_.add(index, value);
onChanged();
} else {
streamInfoBuilder_.addMessage(index, value);
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder addStreamInfo(
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder builderForValue) {
if (streamInfoBuilder_ == null) {
ensureStreamInfoIsMutable();
streamInfo_.add(builderForValue.build());
onChanged();
} else {
streamInfoBuilder_.addMessage(builderForValue.build());
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder addStreamInfo(
int index, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder builderForValue) {
if (streamInfoBuilder_ == null) {
ensureStreamInfoIsMutable();
streamInfo_.add(index, builderForValue.build());
onChanged();
} else {
streamInfoBuilder_.addMessage(index, builderForValue.build());
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder addAllStreamInfo(
java.lang.Iterable<? extends org.apache.doris.proto.ColumnDataFile.StreamInfoMessage> values) {
if (streamInfoBuilder_ == null) {
ensureStreamInfoIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(
values, streamInfo_);
onChanged();
} else {
streamInfoBuilder_.addAllMessages(values);
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder clearStreamInfo() {
if (streamInfoBuilder_ == null) {
streamInfo_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00000080);
onChanged();
} else {
streamInfoBuilder_.clear();
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public Builder removeStreamInfo(int index) {
if (streamInfoBuilder_ == null) {
ensureStreamInfoIsMutable();
streamInfo_.remove(index);
onChanged();
} else {
streamInfoBuilder_.remove(index);
}
return this;
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder getStreamInfoBuilder(
int index) {
return getStreamInfoFieldBuilder().getBuilder(index);
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder getStreamInfoOrBuilder(
int index) {
if (streamInfoBuilder_ == null) {
return streamInfo_.get(index); } else {
return streamInfoBuilder_.getMessageOrBuilder(index);
}
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public java.util.List<? extends org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder>
getStreamInfoOrBuilderList() {
if (streamInfoBuilder_ != null) {
return streamInfoBuilder_.getMessageOrBuilderList();
} else {
return java.util.Collections.unmodifiableList(streamInfo_);
}
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder addStreamInfoBuilder() {
return getStreamInfoFieldBuilder().addBuilder(
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.getDefaultInstance());
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder addStreamInfoBuilder(
int index) {
return getStreamInfoFieldBuilder().addBuilder(
index, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.getDefaultInstance());
}
/**
* <code>repeated .doris.StreamInfoMessage stream_info = 10;</code>
*/
public java.util.List<org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder>
getStreamInfoBuilderList() {
return getStreamInfoFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder, org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder>
getStreamInfoFieldBuilder() {
if (streamInfoBuilder_ == null) {
streamInfoBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.ColumnDataFile.StreamInfoMessage, org.apache.doris.proto.ColumnDataFile.StreamInfoMessage.Builder, org.apache.doris.proto.ColumnDataFile.StreamInfoMessageOrBuilder>(
streamInfo_,
((bitField0_ & 0x00000080) != 0),
getParentForChildren(),
isClean());
streamInfo_ = null;
}
return streamInfoBuilder_;
}
private java.util.List<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage> columnEncoding_ =
java.util.Collections.emptyList();
private void ensureColumnEncodingIsMutable() {
if (!((bitField0_ & 0x00000100) != 0)) {
columnEncoding_ = new java.util.ArrayList<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage>(columnEncoding_);
bitField0_ |= 0x00000100;
}
}
private com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder> columnEncodingBuilder_;
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public java.util.List<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage> getColumnEncodingList() {
if (columnEncodingBuilder_ == null) {
return java.util.Collections.unmodifiableList(columnEncoding_);
} else {
return columnEncodingBuilder_.getMessageList();
}
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public int getColumnEncodingCount() {
if (columnEncodingBuilder_ == null) {
return columnEncoding_.size();
} else {
return columnEncodingBuilder_.getCount();
}
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage getColumnEncoding(int index) {
if (columnEncodingBuilder_ == null) {
return columnEncoding_.get(index);
} else {
return columnEncodingBuilder_.getMessage(index);
}
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder setColumnEncoding(
int index, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage value) {
if (columnEncodingBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureColumnEncodingIsMutable();
columnEncoding_.set(index, value);
onChanged();
} else {
columnEncodingBuilder_.setMessage(index, value);
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder setColumnEncoding(
int index, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder builderForValue) {
if (columnEncodingBuilder_ == null) {
ensureColumnEncodingIsMutable();
columnEncoding_.set(index, builderForValue.build());
onChanged();
} else {
columnEncodingBuilder_.setMessage(index, builderForValue.build());
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder addColumnEncoding(org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage value) {
if (columnEncodingBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureColumnEncodingIsMutable();
columnEncoding_.add(value);
onChanged();
} else {
columnEncodingBuilder_.addMessage(value);
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder addColumnEncoding(
int index, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage value) {
if (columnEncodingBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureColumnEncodingIsMutable();
columnEncoding_.add(index, value);
onChanged();
} else {
columnEncodingBuilder_.addMessage(index, value);
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder addColumnEncoding(
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder builderForValue) {
if (columnEncodingBuilder_ == null) {
ensureColumnEncodingIsMutable();
columnEncoding_.add(builderForValue.build());
onChanged();
} else {
columnEncodingBuilder_.addMessage(builderForValue.build());
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder addColumnEncoding(
int index, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder builderForValue) {
if (columnEncodingBuilder_ == null) {
ensureColumnEncodingIsMutable();
columnEncoding_.add(index, builderForValue.build());
onChanged();
} else {
columnEncodingBuilder_.addMessage(index, builderForValue.build());
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder addAllColumnEncoding(
java.lang.Iterable<? extends org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage> values) {
if (columnEncodingBuilder_ == null) {
ensureColumnEncodingIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(
values, columnEncoding_);
onChanged();
} else {
columnEncodingBuilder_.addAllMessages(values);
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder clearColumnEncoding() {
if (columnEncodingBuilder_ == null) {
columnEncoding_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00000100);
onChanged();
} else {
columnEncodingBuilder_.clear();
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public Builder removeColumnEncoding(int index) {
if (columnEncodingBuilder_ == null) {
ensureColumnEncodingIsMutable();
columnEncoding_.remove(index);
onChanged();
} else {
columnEncodingBuilder_.remove(index);
}
return this;
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder getColumnEncodingBuilder(
int index) {
return getColumnEncodingFieldBuilder().getBuilder(index);
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder getColumnEncodingOrBuilder(
int index) {
if (columnEncodingBuilder_ == null) {
return columnEncoding_.get(index); } else {
return columnEncodingBuilder_.getMessageOrBuilder(index);
}
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public java.util.List<? extends org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder>
getColumnEncodingOrBuilderList() {
if (columnEncodingBuilder_ != null) {
return columnEncodingBuilder_.getMessageOrBuilderList();
} else {
return java.util.Collections.unmodifiableList(columnEncoding_);
}
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder addColumnEncodingBuilder() {
return getColumnEncodingFieldBuilder().addBuilder(
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.getDefaultInstance());
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder addColumnEncodingBuilder(
int index) {
return getColumnEncodingFieldBuilder().addBuilder(
index, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.getDefaultInstance());
}
/**
* <code>repeated .doris.ColumnEncodingMessage column_encoding = 11;</code>
*/
public java.util.List<org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder>
getColumnEncodingBuilderList() {
return getColumnEncodingFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder>
getColumnEncodingFieldBuilder() {
if (columnEncodingBuilder_ == null) {
columnEncodingBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessage.Builder, org.apache.doris.proto.ColumnDataFile.ColumnEncodingMessageOrBuilder>(
columnEncoding_,
((bitField0_ & 0x00000100) != 0),
getParentForChildren(),
isClean());
columnEncoding_ = null;
}
return columnEncodingBuilder_;
}
private int streamBufferSize_ ;
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return Whether the streamBufferSize field is set.
*/
@java.lang.Override
public boolean hasStreamBufferSize() {
return ((bitField0_ & 0x00000200) != 0);
}
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return The streamBufferSize.
*/
@java.lang.Override
public int getStreamBufferSize() {
return streamBufferSize_;
}
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @param value The streamBufferSize to set.
* @return This builder for chaining.
*/
public Builder setStreamBufferSize(int value) {
streamBufferSize_ = value;
bitField0_ |= 0x00000200;
onChanged();
return this;
}
/**
* <code>required uint32 stream_buffer_size = 12;</code>
* @return This builder for chaining.
*/
public Builder clearStreamBufferSize() {
bitField0_ = (bitField0_ & ~0x00000200);
streamBufferSize_ = 0;
onChanged();
return this;
}
private int numRowsPerBlock_ ;
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return Whether the numRowsPerBlock field is set.
*/
@java.lang.Override
public boolean hasNumRowsPerBlock() {
return ((bitField0_ & 0x00000400) != 0);
}
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return The numRowsPerBlock.
*/
@java.lang.Override
public int getNumRowsPerBlock() {
return numRowsPerBlock_;
}
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @param value The numRowsPerBlock to set.
* @return This builder for chaining.
*/
public Builder setNumRowsPerBlock(int value) {
numRowsPerBlock_ = value;
bitField0_ |= 0x00000400;
onChanged();
return this;
}
/**
* <code>optional uint32 num_rows_per_block = 13 [default = 0];</code>
* @return This builder for chaining.
*/
public Builder clearNumRowsPerBlock() {
bitField0_ = (bitField0_ & ~0x00000400);
numRowsPerBlock_ = 0;
onChanged();
return this;
}
private int bfHashFunctionNum_ ;
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return Whether the bfHashFunctionNum field is set.
*/
@java.lang.Override
public boolean hasBfHashFunctionNum() {
return ((bitField0_ & 0x00000800) != 0);
}
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return The bfHashFunctionNum.
*/
@java.lang.Override
public int getBfHashFunctionNum() {
return bfHashFunctionNum_;
}
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @param value The bfHashFunctionNum to set.
* @return This builder for chaining.
*/
public Builder setBfHashFunctionNum(int value) {
bfHashFunctionNum_ = value;
bitField0_ |= 0x00000800;
onChanged();
return this;
}
/**
* <pre>
* bloom filter params
* </pre>
*
* <code>optional uint32 bf_hash_function_num = 14;</code>
* @return This builder for chaining.
*/
public Builder clearBfHashFunctionNum() {
bitField0_ = (bitField0_ & ~0x00000800);
bfHashFunctionNum_ = 0;
onChanged();
return this;
}
private int bfBitNum_ ;
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return Whether the bfBitNum field is set.
*/
@java.lang.Override
public boolean hasBfBitNum() {
return ((bitField0_ & 0x00001000) != 0);
}
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return The bfBitNum.
*/
@java.lang.Override
public int getBfBitNum() {
return bfBitNum_;
}
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @param value The bfBitNum to set.
* @return This builder for chaining.
*/
public Builder setBfBitNum(int value) {
bfBitNum_ = value;
bitField0_ |= 0x00001000;
onChanged();
return this;
}
/**
* <code>optional uint32 bf_bit_num = 15;</code>
* @return This builder for chaining.
*/
public Builder clearBfBitNum() {
bitField0_ = (bitField0_ & ~0x00001000);
bfBitNum_ = 0;
onChanged();
return this;
}
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
}
@java.lang.Override
public final Builder mergeUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.mergeUnknownFields(unknownFields);
}
// @@protoc_insertion_point(builder_scope:doris.ColumnDataHeaderMessage)
}
// @@protoc_insertion_point(class_scope:doris.ColumnDataHeaderMessage)
private static final org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage();
}
public static org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage getDefaultInstance() {
return DEFAULT_INSTANCE;
}
@java.lang.Deprecated public static final com.google.protobuf.Parser<ColumnDataHeaderMessage>
PARSER = new com.google.protobuf.AbstractParser<ColumnDataHeaderMessage>() {
@java.lang.Override
public ColumnDataHeaderMessage parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e)
.setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
public static com.google.protobuf.Parser<ColumnDataHeaderMessage> parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser<ColumnDataHeaderMessage> getParserForType() {
return PARSER;
}
@java.lang.Override
public org.apache.doris.proto.ColumnDataFile.ColumnDataHeaderMessage getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}
private static final com.google.protobuf.Descriptors.Descriptor
internal_static_doris_StreamInfoMessage_descriptor;
private static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_doris_StreamInfoMessage_fieldAccessorTable;
private static final com.google.protobuf.Descriptors.Descriptor
internal_static_doris_ColumnEncodingMessage_descriptor;
private static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_doris_ColumnEncodingMessage_fieldAccessorTable;
private static final com.google.protobuf.Descriptors.Descriptor
internal_static_doris_ColumnDataHeaderMessage_descriptor;
private static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_doris_ColumnDataHeaderMessage_fieldAccessorTable;
public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() {
return descriptor;
}
private static com.google.protobuf.Descriptors.FileDescriptor
descriptor;
static {
java.lang.String[] descriptorData = {
"\n\026column_data_file.proto\022\005doris\032\021olap_co" +
"mmon.proto\"\364\001\n\021StreamInfoMessage\022+\n\004kind" +
"\030\001 \002(\0162\035.doris.StreamInfoMessage.Kind\022\030\n" +
"\020column_unique_id\030\002 \002(\r\022\016\n\006length\030\003 \002(\004\"" +
"\207\001\n\004Kind\022\r\n\tROW_INDEX\020\000\022\013\n\007PRESENT\020\001\022\010\n\004" +
"DATA\020\002\022\n\n\006LENGTH\020\003\022\023\n\017DICTIONARY_DATA\020\004\022" +
"\r\n\tSECONDARY\020\005\022\027\n\023ROW_INDEX_STATISTIC\020\006\022" +
"\020\n\014BLOOM_FILTER\020\007\"\205\001\n\025ColumnEncodingMess" +
"age\022/\n\004kind\030\001 \001(\0162!.doris.ColumnEncoding" +
"Message.Kind\022\027\n\017dictionary_size\030\002 \001(\r\"\"\n" +
"\004Kind\022\n\n\006DIRECT\020\000\022\016\n\nDICTIONARY\020\001\"\306\003\n\027Co" +
"lumnDataHeaderMessage\022!\n\014magic_string\030\001 " +
"\002(\t:\013COLUMN DATA\022\022\n\007version\030\002 \002(\r:\0011\022\026\n\016" +
"number_of_rows\030\004 \002(\004\022$\n\006column\030\005 \003(\0132\024.d" +
"oris.ColumnMessage\022\024\n\014index_length\030\007 \002(\004" +
"\022\023\n\013data_length\030\010 \002(\004\0228\n\rcompress_kind\030\t" +
" \002(\0162\023.doris.CompressKind:\014COMPRESS_LZO\022" +
"-\n\013stream_info\030\n \003(\0132\030.doris.StreamInfoM" +
"essage\0225\n\017column_encoding\030\013 \003(\0132\034.doris." +
"ColumnEncodingMessage\022\032\n\022stream_buffer_s" +
"ize\030\014 \002(\r\022\035\n\022num_rows_per_block\030\r \001(\r:\0010" +
"\022\034\n\024bf_hash_function_num\030\016 \001(\r\022\022\n\nbf_bit" +
"_num\030\017 \001(\rB\030\n\026org.apache.doris.proto"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
new com.google.protobuf.Descriptors.FileDescriptor[] {
org.apache.doris.proto.OlapCommon.getDescriptor(),
});
internal_static_doris_StreamInfoMessage_descriptor =
getDescriptor().getMessageTypes().get(0);
internal_static_doris_StreamInfoMessage_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_doris_StreamInfoMessage_descriptor,
new java.lang.String[] { "Kind", "ColumnUniqueId", "Length", });
internal_static_doris_ColumnEncodingMessage_descriptor =
getDescriptor().getMessageTypes().get(1);
internal_static_doris_ColumnEncodingMessage_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_doris_ColumnEncodingMessage_descriptor,
new java.lang.String[] { "Kind", "DictionarySize", });
internal_static_doris_ColumnDataHeaderMessage_descriptor =
getDescriptor().getMessageTypes().get(2);
internal_static_doris_ColumnDataHeaderMessage_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_doris_ColumnDataHeaderMessage_descriptor,
new java.lang.String[] { "MagicString", "Version", "NumberOfRows", "Column", "IndexLength", "DataLength", "CompressKind", "StreamInfo", "ColumnEncoding", "StreamBufferSize", "NumRowsPerBlock", "BfHashFunctionNum", "BfBitNum", });
org.apache.doris.proto.OlapCommon.getDescriptor();
}
// @@protoc_insertion_point(outer_class_scope)
}