proto

package
v0.0.0-...-1e7f4ca Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 19, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EncryptionAlgorithm_name = map[int32]string{
		0: "UNKNOWN_ENCRYPTION",
		1: "AES_CTR_128",
		2: "AES_CTR_256",
	}
	EncryptionAlgorithm_value = map[string]int32{
		"UNKNOWN_ENCRYPTION": 0,
		"AES_CTR_128":        1,
		"AES_CTR_256":        2,
	}
)

Enum value maps for EncryptionAlgorithm.

View Source 
var (
	KeyProviderKind_name = map[int32]string{
		0: "UNKNOWN",
		1: "HADOOP",
		2: "AWS",
		3: "GCP",
		4: "AZURE",
	}
	KeyProviderKind_value = map[string]int32{
		"UNKNOWN": 0,
		"HADOOP":  1,
		"AWS":     2,
		"GCP":     3,
		"AZURE":   4,
	}
)

Enum value maps for KeyProviderKind.

View Source 
var (
	CompressionKind_name = map[int32]string{
		0: "NONE",
		1: "ZLIB",
		2: "SNAPPY",
		3: "LZO",
		4: "LZ4",
		5: "ZSTD",
	}
	CompressionKind_value = map[string]int32{
		"NONE":   0,
		"ZLIB":   1,
		"SNAPPY": 2,
		"LZO":    3,
		"LZ4":    4,
		"ZSTD":   5,
	}
)

Enum value maps for CompressionKind.

View Source 
var (
	Stream_Kind_name = map[int32]string{
		0:   "PRESENT",
		1:   "DATA",
		2:   "LENGTH",
		3:   "DICTIONARY_DATA",
		4:   "DICTIONARY_COUNT",
		5:   "SECONDARY",
		6:   "ROW_INDEX",
		7:   "BLOOM_FILTER",
		8:   "BLOOM_FILTER_UTF8",
		9:   "ENCRYPTED_INDEX",
		10:  "ENCRYPTED_DATA",
		100: "STRIPE_STATISTICS",
		101: "FILE_STATISTICS",
	}
	Stream_Kind_value = map[string]int32{
		"PRESENT":           0,
		"DATA":              1,
		"LENGTH":            2,
		"DICTIONARY_DATA":   3,
		"DICTIONARY_COUNT":  4,
		"SECONDARY":         5,
		"ROW_INDEX":         6,
		"BLOOM_FILTER":      7,
		"BLOOM_FILTER_UTF8": 8,
		"ENCRYPTED_INDEX":   9,
		"ENCRYPTED_DATA":    10,
		"STRIPE_STATISTICS": 100,
		"FILE_STATISTICS":   101,
	}
)

Enum value maps for Stream_Kind.

View Source 
var (
	ColumnEncoding_Kind_name = map[int32]string{
		0: "DIRECT",
		1: "DICTIONARY",
		2: "DIRECT_V2",
		3: "DICTIONARY_V2",
	}
	ColumnEncoding_Kind_value = map[string]int32{
		"DIRECT":        0,
		"DICTIONARY":    1,
		"DIRECT_V2":     2,
		"DICTIONARY_V2": 3,
	}
)

Enum value maps for ColumnEncoding_Kind.

View Source 
var (
	Type_Kind_name = map[int32]string{
		0:  "BOOLEAN",
		1:  "BYTE",
		2:  "SHORT",
		3:  "INT",
		4:  "LONG",
		5:  "FLOAT",
		6:  "DOUBLE",
		7:  "STRING",
		8:  "BINARY",
		9:  "TIMESTAMP",
		10: "LIST",
		11: "MAP",
		12: "STRUCT",
		13: "UNION",
		14: "DECIMAL",
		15: "DATE",
		16: "VARCHAR",
		17: "CHAR",
		18: "TIMESTAMP_INSTANT",
	}
	Type_Kind_value = map[string]int32{
		"BOOLEAN":           0,
		"BYTE":              1,
		"SHORT":             2,
		"INT":               3,
		"LONG":              4,
		"FLOAT":             5,
		"DOUBLE":            6,
		"STRING":            7,
		"BINARY":            8,
		"TIMESTAMP":         9,
		"LIST":              10,
		"MAP":               11,
		"STRUCT":            12,
		"UNION":             13,
		"DECIMAL":           14,
		"DATE":              15,
		"VARCHAR":           16,
		"CHAR":              17,
		"TIMESTAMP_INSTANT": 18,
	}
)

Enum value maps for Type_Kind.

View Source 
var (
	Space_Kind_name = map[int32]string{
		0: "EP",
		1: "NEP",
	}
	Space_Kind_value = map[string]int32{
		"EP":  0,
		"NEP": 1,
	}
)

Enum value maps for Space_Kind.

View Source 
var File_moth_proto_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BinaryStatistics 

type BinaryStatistics struct {

	// sum will store the total binary blob length in a stripe
	Sum *int64 `protobuf:"zigzag64,1,opt,name=sum" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryStatistics) Descriptor deprecated 

func (*BinaryStatistics) Descriptor() ([]byte, []int)

Deprecated: Use BinaryStatistics.ProtoReflect.Descriptor instead.

func (*BinaryStatistics) GetSum 

func (x *BinaryStatistics) GetSum() int64

func (*BinaryStatistics) ProtoMessage 

func (*BinaryStatistics) ProtoMessage()

func (*BinaryStatistics) ProtoReflect 

func (x *BinaryStatistics) ProtoReflect() protoreflect.Message

func (*BinaryStatistics) Reset 

func (x *BinaryStatistics) Reset()

func (*BinaryStatistics) String 

func (x *BinaryStatistics) String() string

type BloomFilter 

type BloomFilter struct {
	NumHashFunctions *uint32  `protobuf:"varint,1,opt,name=numHashFunctions" json:"numHashFunctions,omitempty"`
	Bitset           []uint64 `protobuf:"fixed64,2,rep,name=bitset" json:"bitset,omitempty"`
	Utf8Bitset       []byte   `protobuf:"bytes,3,opt,name=utf8bitset" json:"utf8bitset,omitempty"`
	// contains filtered or unexported fields
}

func (*BloomFilter) Descriptor deprecated 

func (*BloomFilter) Descriptor() ([]byte, []int)

Deprecated: Use BloomFilter.ProtoReflect.Descriptor instead.

func (*BloomFilter) GetBitset 

func (x *BloomFilter) GetBitset() []uint64

func (*BloomFilter) GetNumHashFunctions 

func (x *BloomFilter) GetNumHashFunctions() uint32

func (*BloomFilter) GetUtf8Bitset 

func (x *BloomFilter) GetUtf8Bitset() []byte

func (*BloomFilter) ProtoMessage 

func (*BloomFilter) ProtoMessage()

func (*BloomFilter) ProtoReflect 

func (x *BloomFilter) ProtoReflect() protoreflect.Message

func (*BloomFilter) Reset 

func (x *BloomFilter) Reset()

func (*BloomFilter) String 

func (x *BloomFilter) String() string

type BloomFilterIndex 

type BloomFilterIndex struct {
	BloomFilter []*BloomFilter `protobuf:"bytes,1,rep,name=bloomFilter" json:"bloomFilter,omitempty"`
	// contains filtered or unexported fields
}

func (*BloomFilterIndex) Descriptor deprecated 

func (*BloomFilterIndex) Descriptor() ([]byte, []int)

Deprecated: Use BloomFilterIndex.ProtoReflect.Descriptor instead.

func (*BloomFilterIndex) GetBloomFilter 

func (x *BloomFilterIndex) GetBloomFilter() []*BloomFilter

func (*BloomFilterIndex) ProtoMessage 

func (*BloomFilterIndex) ProtoMessage()

func (*BloomFilterIndex) ProtoReflect 

func (x *BloomFilterIndex) ProtoReflect() protoreflect.Message

func (*BloomFilterIndex) Reset 

func (x *BloomFilterIndex) Reset()

func (*BloomFilterIndex) String 

func (x *BloomFilterIndex) String() string

type BucketStatistics 

type BucketStatistics struct {
	Count []uint64 `protobuf:"varint,1,rep,packed,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketStatistics) Descriptor deprecated 

func (*BucketStatistics) Descriptor() ([]byte, []int)

Deprecated: Use BucketStatistics.ProtoReflect.Descriptor instead.

func (*BucketStatistics) GetCount 

func (x *BucketStatistics) GetCount() []uint64

func (*BucketStatistics) ProtoMessage 

func (*BucketStatistics) ProtoMessage()

func (*BucketStatistics) ProtoReflect 

func (x *BucketStatistics) ProtoReflect() protoreflect.Message

func (*BucketStatistics) Reset 

func (x *BucketStatistics) Reset()

func (*BucketStatistics) String 

func (x *BucketStatistics) String() string

type CollectionStatistics 

type CollectionStatistics struct {
	MinChildren   *uint64 `protobuf:"varint,1,opt,name=minChildren" json:"minChildren,omitempty"`
	MaxChildren   *uint64 `protobuf:"varint,2,opt,name=maxChildren" json:"maxChildren,omitempty"`
	TotalChildren *uint64 `protobuf:"varint,3,opt,name=totalChildren" json:"totalChildren,omitempty"`
	// contains filtered or unexported fields
}

Statistics for list and map

func (*CollectionStatistics) Descriptor deprecated 

func (*CollectionStatistics) Descriptor() ([]byte, []int)

Deprecated: Use CollectionStatistics.ProtoReflect.Descriptor instead.

func (*CollectionStatistics) GetMaxChildren 

func (x *CollectionStatistics) GetMaxChildren() uint64

func (*CollectionStatistics) GetMinChildren 

func (x *CollectionStatistics) GetMinChildren() uint64

func (*CollectionStatistics) GetTotalChildren 

func (x *CollectionStatistics) GetTotalChildren() uint64

func (*CollectionStatistics) ProtoMessage 

func (*CollectionStatistics) ProtoMessage()

func (*CollectionStatistics) ProtoReflect 

func (x *CollectionStatistics) ProtoReflect() protoreflect.Message

func (*CollectionStatistics) Reset 

func (x *CollectionStatistics) Reset()

func (*CollectionStatistics) String 

func (x *CollectionStatistics) String() string

type ColumnEncoding 

type ColumnEncoding struct {
	Kind           *ColumnEncoding_Kind `protobuf:"varint,1,opt,name=kind,enum=moth.proto.ColumnEncoding_Kind" json:"kind,omitempty"`
	DictionarySize *uint32              `protobuf:"varint,2,opt,name=dictionarySize" json:"dictionarySize,omitempty"`
	// The encoding of the bloom filters for this column:
	//   0 or missing = none or original
	//   1            = MOTH-135 (utc for timestamps)
	BloomEncoding *uint32 `protobuf:"varint,3,opt,name=bloomEncoding" json:"bloomEncoding,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnEncoding) Descriptor deprecated 

func (*ColumnEncoding) Descriptor() ([]byte, []int)

Deprecated: Use ColumnEncoding.ProtoReflect.Descriptor instead.

func (*ColumnEncoding) GetBloomEncoding 

func (x *ColumnEncoding) GetBloomEncoding() uint32

func (*ColumnEncoding) GetDictionarySize 

func (x *ColumnEncoding) GetDictionarySize() uint32

func (*ColumnEncoding) GetKind 

func (x *ColumnEncoding) GetKind() ColumnEncoding_Kind

func (*ColumnEncoding) ProtoMessage 

func (*ColumnEncoding) ProtoMessage()

func (*ColumnEncoding) ProtoReflect 

func (x *ColumnEncoding) ProtoReflect() protoreflect.Message

func (*ColumnEncoding) Reset 

func (x *ColumnEncoding) Reset()

func (*ColumnEncoding) String 

func (x *ColumnEncoding) String() string

type ColumnEncoding_Kind 

type ColumnEncoding_Kind int32
const (
	ColumnEncoding_DIRECT        ColumnEncoding_Kind = 0
	ColumnEncoding_DICTIONARY    ColumnEncoding_Kind = 1
	ColumnEncoding_DIRECT_V2     ColumnEncoding_Kind = 2
	ColumnEncoding_DICTIONARY_V2 ColumnEncoding_Kind = 3
)

func (ColumnEncoding_Kind) Descriptor 

func (ColumnEncoding_Kind) Descriptor() protoreflect.EnumDescriptor

func (ColumnEncoding_Kind) Enum 

func (x ColumnEncoding_Kind) Enum() *ColumnEncoding_Kind

func (ColumnEncoding_Kind) EnumDescriptor deprecated 

func (ColumnEncoding_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnEncoding_Kind.Descriptor instead.

func (ColumnEncoding_Kind) Number 

func (x ColumnEncoding_Kind) Number() protoreflect.EnumNumber

func (ColumnEncoding_Kind) String 

func (x ColumnEncoding_Kind) String() string

func (ColumnEncoding_Kind) Type 

func (ColumnEncoding_Kind) Type() protoreflect.EnumType

func (*ColumnEncoding_Kind) UnmarshalJSON deprecated 

func (x *ColumnEncoding_Kind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ColumnStatistics 

type ColumnStatistics struct {
	NumberOfValues       *uint64               `protobuf:"varint,1,opt,name=numberOfValues" json:"numberOfValues,omitempty"`
	IntStatistics        *IntegerStatistics    `protobuf:"bytes,2,opt,name=intStatistics" json:"intStatistics,omitempty"`
	DoubleStatistics     *DoubleStatistics     `protobuf:"bytes,3,opt,name=doubleStatistics" json:"doubleStatistics,omitempty"`
	StringStatistics     *StringStatistics     `protobuf:"bytes,4,opt,name=stringStatistics" json:"stringStatistics,omitempty"`
	BucketStatistics     *BucketStatistics     `protobuf:"bytes,5,opt,name=bucketStatistics" json:"bucketStatistics,omitempty"`
	DecimalStatistics    *DecimalStatistics    `protobuf:"bytes,6,opt,name=decimalStatistics" json:"decimalStatistics,omitempty"`
	DateStatistics       *DateStatistics       `protobuf:"bytes,7,opt,name=dateStatistics" json:"dateStatistics,omitempty"`
	BinaryStatistics     *BinaryStatistics     `protobuf:"bytes,8,opt,name=binaryStatistics" json:"binaryStatistics,omitempty"`
	TimestampStatistics  *TimestampStatistics  `protobuf:"bytes,9,opt,name=timestampStatistics" json:"timestampStatistics,omitempty"`
	HasNull              *bool                 `protobuf:"varint,10,opt,name=hasNull" json:"hasNull,omitempty"`
	BytesOnDisk          *uint64               `protobuf:"varint,11,opt,name=bytesOnDisk" json:"bytesOnDisk,omitempty"`
	CollectionStatistics *CollectionStatistics `protobuf:"bytes,12,opt,name=collectionStatistics" json:"collectionStatistics,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnStatistics) Descriptor deprecated 

func (*ColumnStatistics) Descriptor() ([]byte, []int)

Deprecated: Use ColumnStatistics.ProtoReflect.Descriptor instead.

func (*ColumnStatistics) GetBinaryStatistics 

func (x *ColumnStatistics) GetBinaryStatistics() *BinaryStatistics

func (*ColumnStatistics) GetBucketStatistics 

func (x *ColumnStatistics) GetBucketStatistics() *BucketStatistics

func (*ColumnStatistics) GetBytesOnDisk 

func (x *ColumnStatistics) GetBytesOnDisk() uint64

func (*ColumnStatistics) GetCollectionStatistics 

func (x *ColumnStatistics) GetCollectionStatistics() *CollectionStatistics

func (*ColumnStatistics) GetDateStatistics 

func (x *ColumnStatistics) GetDateStatistics() *DateStatistics

func (*ColumnStatistics) GetDecimalStatistics 

func (x *ColumnStatistics) GetDecimalStatistics() *DecimalStatistics

func (*ColumnStatistics) GetDoubleStatistics 

func (x *ColumnStatistics) GetDoubleStatistics() *DoubleStatistics

func (*ColumnStatistics) GetHasNull 

func (x *ColumnStatistics) GetHasNull() bool

func (*ColumnStatistics) GetIntStatistics 

func (x *ColumnStatistics) GetIntStatistics() *IntegerStatistics

func (*ColumnStatistics) GetNumberOfValues 

func (x *ColumnStatistics) GetNumberOfValues() uint64

func (*ColumnStatistics) GetStringStatistics 

func (x *ColumnStatistics) GetStringStatistics() *StringStatistics

func (*ColumnStatistics) GetTimestampStatistics 

func (x *ColumnStatistics) GetTimestampStatistics() *TimestampStatistics

func (*ColumnStatistics) ProtoMessage 

func (*ColumnStatistics) ProtoMessage()

func (*ColumnStatistics) ProtoReflect 

func (x *ColumnStatistics) ProtoReflect() protoreflect.Message

func (*ColumnStatistics) Reset 

func (x *ColumnStatistics) Reset()

func (*ColumnStatistics) String 

func (x *ColumnStatistics) String() string

type ColumnarStripeStatistics 

type ColumnarStripeStatistics struct {

	// one value for each stripe in the file
	ColStats []*ColumnStatistics `protobuf:"bytes,1,rep,name=colStats" json:"colStats,omitempty"`
	// contains filtered or unexported fields
}

In MOTH v2 (and for encrypted columns in v1), each column has their column statistics written separately.

func (*ColumnarStripeStatistics) Descriptor deprecated 

func (*ColumnarStripeStatistics) Descriptor() ([]byte, []int)

Deprecated: Use ColumnarStripeStatistics.ProtoReflect.Descriptor instead.

func (*ColumnarStripeStatistics) GetColStats 

func (x *ColumnarStripeStatistics) GetColStats() []*ColumnStatistics

func (*ColumnarStripeStatistics) ProtoMessage 

func (*ColumnarStripeStatistics) ProtoMessage()

func (*ColumnarStripeStatistics) ProtoReflect 

func (x *ColumnarStripeStatistics) ProtoReflect() protoreflect.Message

func (*ColumnarStripeStatistics) Reset 

func (x *ColumnarStripeStatistics) Reset()

func (*ColumnarStripeStatistics) String 

func (x *ColumnarStripeStatistics) String() string

type CompressionKind 

type CompressionKind int32
const (
	CompressionKind_NONE   CompressionKind = 0
	CompressionKind_ZLIB   CompressionKind = 1
	CompressionKind_SNAPPY CompressionKind = 2
	CompressionKind_LZO    CompressionKind = 3
	CompressionKind_LZ4    CompressionKind = 4
	CompressionKind_ZSTD   CompressionKind = 5
)

func (CompressionKind) Descriptor 

func (CompressionKind) Descriptor() protoreflect.EnumDescriptor

func (CompressionKind) Enum 

func (x CompressionKind) Enum() *CompressionKind

func (CompressionKind) EnumDescriptor deprecated 

func (CompressionKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use CompressionKind.Descriptor instead.

func (CompressionKind) Number 

func (x CompressionKind) Number() protoreflect.EnumNumber

func (CompressionKind) String 

func (x CompressionKind) String() string

func (CompressionKind) Type 

func (CompressionKind) Type() protoreflect.EnumType

func (*CompressionKind) UnmarshalJSON deprecated 

func (x *CompressionKind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type DataMask 

type DataMask struct {

	// the kind of masking, which may include third party masks
	Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// parameters for the mask
	MaskParameters []string `protobuf:"bytes,2,rep,name=maskParameters" json:"maskParameters,omitempty"`
	// the unencrypted column roots this mask was applied to
	Columns []uint32 `protobuf:"varint,3,rep,packed,name=columns" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

How was the data masked? This isn't necessary for reading the file, but is documentation about how the file was written.

func (*DataMask) Descriptor deprecated 

func (*DataMask) Descriptor() ([]byte, []int)

Deprecated: Use DataMask.ProtoReflect.Descriptor instead.

func (*DataMask) GetColumns 

func (x *DataMask) GetColumns() []uint32

func (*DataMask) GetMaskParameters 

func (x *DataMask) GetMaskParameters() []string

func (*DataMask) GetName 

func (x *DataMask) GetName() string

func (*DataMask) ProtoMessage 

func (*DataMask) ProtoMessage()

func (*DataMask) ProtoReflect 

func (x *DataMask) ProtoReflect() protoreflect.Message

func (*DataMask) Reset 

func (x *DataMask) Reset()

func (*DataMask) String 

func (x *DataMask) String() string

type DateStatistics 

type DateStatistics struct {

	// min,max values saved as days since epoch
	Minimum *int32 `protobuf:"zigzag32,1,opt,name=minimum" json:"minimum,omitempty"`
	Maximum *int32 `protobuf:"zigzag32,2,opt,name=maximum" json:"maximum,omitempty"`
	// contains filtered or unexported fields
}

func (*DateStatistics) Descriptor deprecated 

func (*DateStatistics) Descriptor() ([]byte, []int)

Deprecated: Use DateStatistics.ProtoReflect.Descriptor instead.

func (*DateStatistics) GetMaximum 

func (x *DateStatistics) GetMaximum() int32

func (*DateStatistics) GetMinimum 

func (x *DateStatistics) GetMinimum() int32

func (*DateStatistics) ProtoMessage 

func (*DateStatistics) ProtoMessage()

func (*DateStatistics) ProtoReflect 

func (x *DateStatistics) ProtoReflect() protoreflect.Message

func (*DateStatistics) Reset 

func (x *DateStatistics) Reset()

func (*DateStatistics) String 

func (x *DateStatistics) String() string

type DecimalStatistics 

type DecimalStatistics struct {
	Minimum *string `protobuf:"bytes,1,opt,name=minimum" json:"minimum,omitempty"`
	Maximum *string `protobuf:"bytes,2,opt,name=maximum" json:"maximum,omitempty"`
	Sum     *string `protobuf:"bytes,3,opt,name=sum" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*DecimalStatistics) Descriptor deprecated 

func (*DecimalStatistics) Descriptor() ([]byte, []int)

Deprecated: Use DecimalStatistics.ProtoReflect.Descriptor instead.

func (*DecimalStatistics) GetMaximum 

func (x *DecimalStatistics) GetMaximum() string

func (*DecimalStatistics) GetMinimum 

func (x *DecimalStatistics) GetMinimum() string

func (*DecimalStatistics) GetSum 

func (x *DecimalStatistics) GetSum() string

func (*DecimalStatistics) ProtoMessage 

func (*DecimalStatistics) ProtoMessage()

func (*DecimalStatistics) ProtoReflect 

func (x *DecimalStatistics) ProtoReflect() protoreflect.Message

func (*DecimalStatistics) Reset 

func (x *DecimalStatistics) Reset()

func (*DecimalStatistics) String 

func (x *DecimalStatistics) String() string

type DeleteKey 

type DeleteKey struct {

	// 存储key
	Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	// 时间戳记录当前key的版本号
	Ts *uint64 `protobuf:"varint,2,req,name=ts" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKey) Descriptor deprecated 

func (*DeleteKey) Descriptor() ([]byte, []int)

Deprecated: Use DeleteKey.ProtoReflect.Descriptor instead.

func (*DeleteKey) GetKey 

func (x *DeleteKey) GetKey() []byte

func (*DeleteKey) GetTs 

func (x *DeleteKey) GetTs() uint64

func (*DeleteKey) ProtoMessage 

func (*DeleteKey) ProtoMessage()

func (*DeleteKey) ProtoReflect 

func (x *DeleteKey) ProtoReflect() protoreflect.Message

func (*DeleteKey) Reset 

func (x *DeleteKey) Reset()

func (*DeleteKey) String 

func (x *DeleteKey) String() string

type DoubleStatistics 

type DoubleStatistics struct {
	Minimum *float64 `protobuf:"fixed64,1,opt,name=minimum" json:"minimum,omitempty"`
	Maximum *float64 `protobuf:"fixed64,2,opt,name=maximum" json:"maximum,omitempty"`
	Sum     *float64 `protobuf:"fixed64,3,opt,name=sum" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*DoubleStatistics) Descriptor deprecated 

func (*DoubleStatistics) Descriptor() ([]byte, []int)

Deprecated: Use DoubleStatistics.ProtoReflect.Descriptor instead.

func (*DoubleStatistics) GetMaximum 

func (x *DoubleStatistics) GetMaximum() float64

func (*DoubleStatistics) GetMinimum 

func (x *DoubleStatistics) GetMinimum() float64

func (*DoubleStatistics) GetSum 

func (x *DoubleStatistics) GetSum() float64

func (*DoubleStatistics) ProtoMessage 

func (*DoubleStatistics) ProtoMessage()

func (*DoubleStatistics) ProtoReflect 

func (x *DoubleStatistics) ProtoReflect() protoreflect.Message

func (*DoubleStatistics) Reset 

func (x *DoubleStatistics) Reset()

func (*DoubleStatistics) String 

func (x *DoubleStatistics) String() string

type Encryption 

type Encryption struct {

	// all of the masks used in this file
	Mask []*DataMask `protobuf:"bytes,1,rep,name=mask" json:"mask,omitempty"`
	// all of the keys used in this file
	Key []*EncryptionKey `protobuf:"bytes,2,rep,name=key" json:"key,omitempty"`
	// The encrypted variants.
	// Readers should prefer the first variant that the user has access to
	// the corresponding key. If they don't have access to any of the keys,
	// they should get the unencrypted masked data.
	Variants []*EncryptionVariant `protobuf:"bytes,3,rep,name=variants" json:"variants,omitempty"`
	// How are the local keys encrypted?
	KeyProvider *KeyProviderKind `protobuf:"varint,4,opt,name=keyProvider,enum=moth.proto.KeyProviderKind" json:"keyProvider,omitempty"`
	// contains filtered or unexported fields
}

func (*Encryption) Descriptor deprecated 

func (*Encryption) Descriptor() ([]byte, []int)

Deprecated: Use Encryption.ProtoReflect.Descriptor instead.

func (*Encryption) GetKey 

func (x *Encryption) GetKey() []*EncryptionKey

func (*Encryption) GetKeyProvider 

func (x *Encryption) GetKeyProvider() KeyProviderKind

func (*Encryption) GetMask 

func (x *Encryption) GetMask() []*DataMask

func (*Encryption) GetVariants 

func (x *Encryption) GetVariants() []*EncryptionVariant

func (*Encryption) ProtoMessage 

func (*Encryption) ProtoMessage()

func (*Encryption) ProtoReflect 

func (x *Encryption) ProtoReflect() protoreflect.Message

func (*Encryption) Reset 

func (x *Encryption) Reset()

func (*Encryption) String 

func (x *Encryption) String() string

type EncryptionAlgorithm 

type EncryptionAlgorithm int32
const (
	EncryptionAlgorithm_UNKNOWN_ENCRYPTION EncryptionAlgorithm = 0 // used for detecting future algorithms
	EncryptionAlgorithm_AES_CTR_128        EncryptionAlgorithm = 1
	EncryptionAlgorithm_AES_CTR_256        EncryptionAlgorithm = 2
)

func (EncryptionAlgorithm) Descriptor 

func (EncryptionAlgorithm) Descriptor() protoreflect.EnumDescriptor

func (EncryptionAlgorithm) Enum 

func (x EncryptionAlgorithm) Enum() *EncryptionAlgorithm

func (EncryptionAlgorithm) EnumDescriptor deprecated 

func (EncryptionAlgorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use EncryptionAlgorithm.Descriptor instead.

func (EncryptionAlgorithm) Number 

func (x EncryptionAlgorithm) Number() protoreflect.EnumNumber

func (EncryptionAlgorithm) String 

func (x EncryptionAlgorithm) String() string

func (EncryptionAlgorithm) Type 

func (EncryptionAlgorithm) Type() protoreflect.EnumType

func (*EncryptionAlgorithm) UnmarshalJSON deprecated 

func (x *EncryptionAlgorithm) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type EncryptionKey 

type EncryptionKey struct {
	KeyName    *string              `protobuf:"bytes,1,opt,name=keyName" json:"keyName,omitempty"`
	KeyVersion *uint32              `protobuf:"varint,2,opt,name=keyVersion" json:"keyVersion,omitempty"`
	Algorithm  *EncryptionAlgorithm `protobuf:"varint,3,opt,name=algorithm,enum=moth.proto.EncryptionAlgorithm" json:"algorithm,omitempty"`
	// contains filtered or unexported fields
}

Information about the encryption keys.

func (*EncryptionKey) Descriptor deprecated 

func (*EncryptionKey) Descriptor() ([]byte, []int)

Deprecated: Use EncryptionKey.ProtoReflect.Descriptor instead.

func (*EncryptionKey) GetAlgorithm 

func (x *EncryptionKey) GetAlgorithm() EncryptionAlgorithm

func (*EncryptionKey) GetKeyName 

func (x *EncryptionKey) GetKeyName() string

func (*EncryptionKey) GetKeyVersion 

func (x *EncryptionKey) GetKeyVersion() uint32

func (*EncryptionKey) ProtoMessage 

func (*EncryptionKey) ProtoMessage()

func (*EncryptionKey) ProtoReflect 

func (x *EncryptionKey) ProtoReflect() protoreflect.Message

func (*EncryptionKey) Reset 

func (x *EncryptionKey) Reset()

func (*EncryptionKey) String 

func (x *EncryptionKey) String() string

type EncryptionVariant 

type EncryptionVariant struct {

	// the column id of the root
	Root *uint32 `protobuf:"varint,1,opt,name=root" json:"root,omitempty"`
	// The master key that was used to encrypt the local key, referenced as
	// an index into the Encryption.key list.
	Key *uint32 `protobuf:"varint,2,opt,name=key" json:"key,omitempty"`
	// the encrypted key for the file footer
	EncryptedKey []byte `protobuf:"bytes,3,opt,name=encryptedKey" json:"encryptedKey,omitempty"`
	// the stripe statistics for this variant
	StripeStatistics []*Stream `protobuf:"bytes,4,rep,name=stripeStatistics" json:"stripeStatistics,omitempty"`
	// encrypted file statistics as a FileStatistics
	FileStatistics []byte `protobuf:"bytes,5,opt,name=fileStatistics" json:"fileStatistics,omitempty"`
	// contains filtered or unexported fields
}

The description of an encryption variant. Each variant is a single subtype that is encrypted with a single key.

func (*EncryptionVariant) Descriptor deprecated 

func (*EncryptionVariant) Descriptor() ([]byte, []int)

Deprecated: Use EncryptionVariant.ProtoReflect.Descriptor instead.

func (*EncryptionVariant) GetEncryptedKey 

func (x *EncryptionVariant) GetEncryptedKey() []byte

func (*EncryptionVariant) GetFileStatistics 

func (x *EncryptionVariant) GetFileStatistics() []byte

func (*EncryptionVariant) GetKey 

func (x *EncryptionVariant) GetKey() uint32

func (*EncryptionVariant) GetRoot 

func (x *EncryptionVariant) GetRoot() uint32

func (*EncryptionVariant) GetStripeStatistics 

func (x *EncryptionVariant) GetStripeStatistics() []*Stream

func (*EncryptionVariant) ProtoMessage 

func (*EncryptionVariant) ProtoMessage()

func (*EncryptionVariant) ProtoReflect 

func (x *EncryptionVariant) ProtoReflect() protoreflect.Message

func (*EncryptionVariant) Reset 

func (x *EncryptionVariant) Reset()

func (*EncryptionVariant) String 

func (x *EncryptionVariant) String() string

type FileStatistics 

type FileStatistics struct {
	Column []*ColumnStatistics `protobuf:"bytes,1,rep,name=column" json:"column,omitempty"`
	// contains filtered or unexported fields
}

func (*FileStatistics) Descriptor deprecated 

func (*FileStatistics) Descriptor() ([]byte, []int)

Deprecated: Use FileStatistics.ProtoReflect.Descriptor instead.

func (*FileStatistics) GetColumn 

func (x *FileStatistics) GetColumn() []*ColumnStatistics

func (*FileStatistics) ProtoMessage 

func (*FileStatistics) ProtoMessage()

func (*FileStatistics) ProtoReflect 

func (x *FileStatistics) ProtoReflect() protoreflect.Message

func (*FileStatistics) Reset 

func (x *FileStatistics) Reset()

func (*FileStatistics) String 

func (x *FileStatistics) String() string

type FileTail 

type FileTail struct {
	Postscript       *PostScript `protobuf:"bytes,1,opt,name=postscript" json:"postscript,omitempty"`
	Footer           *Footer     `protobuf:"bytes,2,opt,name=footer" json:"footer,omitempty"`
	FileLength       *uint64     `protobuf:"varint,3,opt,name=fileLength" json:"fileLength,omitempty"`
	PostscriptLength *uint64     `protobuf:"varint,4,opt,name=postscriptLength" json:"postscriptLength,omitempty"`
	// contains filtered or unexported fields
}

The contents of the file tail that must be serialized. This gets serialized as part of OrcSplit, also used by footer cache.

func (*FileTail) Descriptor deprecated 

func (*FileTail) Descriptor() ([]byte, []int)

Deprecated: Use FileTail.ProtoReflect.Descriptor instead.

func (*FileTail) GetFileLength 

func (x *FileTail) GetFileLength() uint64

func (*FileTail) GetFooter 

func (x *FileTail) GetFooter() *Footer

func (*FileTail) GetPostscript 

func (x *FileTail) GetPostscript() *PostScript

func (*FileTail) GetPostscriptLength 

func (x *FileTail) GetPostscriptLength() uint64

func (*FileTail) ProtoMessage 

func (*FileTail) ProtoMessage()

func (*FileTail) ProtoReflect 

func (x *FileTail) ProtoReflect() protoreflect.Message

func (*FileTail) Reset 

func (x *FileTail) Reset()

func (*FileTail) String 

func (x *FileTail) String() string
type Footer struct {
	HeaderLength   *uint64              `protobuf:"varint,1,opt,name=headerLength" json:"headerLength,omitempty"`
	ContentLength  *uint64              `protobuf:"varint,2,opt,name=contentLength" json:"contentLength,omitempty"`
	Stripes        []*StripeInformation `protobuf:"bytes,3,rep,name=stripes" json:"stripes,omitempty"`
	Types          []*Type              `protobuf:"bytes,4,rep,name=types" json:"types,omitempty"`
	Metadata       []*UserMetadataItem  `protobuf:"bytes,5,rep,name=metadata" json:"metadata,omitempty"`
	NumberOfRows   *uint64              `protobuf:"varint,6,opt,name=numberOfRows" json:"numberOfRows,omitempty"`
	Statistics     []*ColumnStatistics  `protobuf:"bytes,7,rep,name=statistics" json:"statistics,omitempty"`
	RowIndexStride *uint32              `protobuf:"varint,8,opt,name=rowIndexStride" json:"rowIndexStride,omitempty"`
	// Each implementation that writes MOTH files should register for a code
	// 0 = MOTH Java
	// 1 = MOTH C++
	// 2 = Presto
	// 3 = Scritchley Go from https://github.com/scritchley/orc
	Writer *uint32 `protobuf:"varint,9,opt,name=writer" json:"writer,omitempty"`
	// information about the encryption in this file
	Encryption *Encryption `protobuf:"bytes,10,opt,name=encryption" json:"encryption,omitempty"`
	// the number of bytes in the encrypted stripe statistics
	StripeStatisticsLength *uint64 `protobuf:"varint,11,opt,name=stripeStatisticsLength" json:"stripeStatisticsLength,omitempty"`
	// contains filtered or unexported fields
}

func (*Footer) Descriptor deprecated 

func (*Footer) Descriptor() ([]byte, []int)

Deprecated: Use Footer.ProtoReflect.Descriptor instead.

func (*Footer) GetContentLength 

func (x *Footer) GetContentLength() uint64

func (*Footer) GetEncryption 

func (x *Footer) GetEncryption() *Encryption

func (*Footer) GetHeaderLength 

func (x *Footer) GetHeaderLength() uint64

func (*Footer) GetMetadata 

func (x *Footer) GetMetadata() []*UserMetadataItem

func (*Footer) GetNumberOfRows 

func (x *Footer) GetNumberOfRows() uint64

func (*Footer) GetRowIndexStride 

func (x *Footer) GetRowIndexStride() uint32

func (*Footer) GetStatistics 

func (x *Footer) GetStatistics() []*ColumnStatistics

func (*Footer) GetStripeStatisticsLength 

func (x *Footer) GetStripeStatisticsLength() uint64

func (*Footer) GetStripes 

func (x *Footer) GetStripes() []*StripeInformation

func (*Footer) GetTypes 

func (x *Footer) GetTypes() []*Type

func (*Footer) GetWriter 

func (x *Footer) GetWriter() uint32

func (*Footer) ProtoMessage 

func (*Footer) ProtoMessage()

func (*Footer) ProtoReflect 

func (x *Footer) ProtoReflect() protoreflect.Message

func (*Footer) Reset 

func (x *Footer) Reset()

func (*Footer) String 

func (x *Footer) String() string

type IntegerStatistics 

type IntegerStatistics struct {
	Minimum *int64 `protobuf:"zigzag64,1,opt,name=minimum" json:"minimum,omitempty"`
	Maximum *int64 `protobuf:"zigzag64,2,opt,name=maximum" json:"maximum,omitempty"`
	Sum     *int64 `protobuf:"zigzag64,3,opt,name=sum" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*IntegerStatistics) Descriptor deprecated 

func (*IntegerStatistics) Descriptor() ([]byte, []int)

Deprecated: Use IntegerStatistics.ProtoReflect.Descriptor instead.

func (*IntegerStatistics) GetMaximum 

func (x *IntegerStatistics) GetMaximum() int64

func (*IntegerStatistics) GetMinimum 

func (x *IntegerStatistics) GetMinimum() int64

func (*IntegerStatistics) GetSum 

func (x *IntegerStatistics) GetSum() int64

func (*IntegerStatistics) ProtoMessage 

func (*IntegerStatistics) ProtoMessage()

func (*IntegerStatistics) ProtoReflect 

func (x *IntegerStatistics) ProtoReflect() protoreflect.Message

func (*IntegerStatistics) Reset 

func (x *IntegerStatistics) Reset()

func (*IntegerStatistics) String 

func (x *IntegerStatistics) String() string

type Key 

type Key struct {

	// 存储key
	Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	// 存储当前key所在 Stripe的顺序量，根据此顺序快速定位每个字段位置
	// 该值是自增的
	Position *uint32 `protobuf:"varint,2,req,name=position" json:"position,omitempty"`
	// 时间戳记录当前key的版本号
	Ts *uint64 `protobuf:"varint,3,req,name=ts" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*Key) Descriptor deprecated 

func (*Key) Descriptor() ([]byte, []int)

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetKey 

func (x *Key) GetKey() []byte

func (*Key) GetPosition 

func (x *Key) GetPosition() uint32

func (*Key) GetTs 

func (x *Key) GetTs() uint64

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) ProtoReflect 

func (x *Key) ProtoReflect() protoreflect.Message

func (*Key) Reset 

func (x *Key) Reset()

func (*Key) String 

func (x *Key) String() string

type KeyProviderKind 

type KeyProviderKind int32

Which KeyProvider encrypted the local keys. 

const (
	KeyProviderKind_UNKNOWN KeyProviderKind = 0
	KeyProviderKind_HADOOP  KeyProviderKind = 1
	KeyProviderKind_AWS     KeyProviderKind = 2
	KeyProviderKind_GCP     KeyProviderKind = 3
	KeyProviderKind_AZURE   KeyProviderKind = 4
)

func (KeyProviderKind) Descriptor 

func (KeyProviderKind) Descriptor() protoreflect.EnumDescriptor

func (KeyProviderKind) Enum 

func (x KeyProviderKind) Enum() *KeyProviderKind

func (KeyProviderKind) EnumDescriptor deprecated 

func (KeyProviderKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use KeyProviderKind.Descriptor instead.

func (KeyProviderKind) Number 

func (x KeyProviderKind) Number() protoreflect.EnumNumber

func (KeyProviderKind) String 

func (x KeyProviderKind) String() string

func (KeyProviderKind) Type 

func (KeyProviderKind) Type() protoreflect.EnumType

func (*KeyProviderKind) UnmarshalJSON deprecated 

func (x *KeyProviderKind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Metadata 

type Metadata struct {
	StripeStats []*StripeStatistics `protobuf:"bytes,1,rep,name=stripeStats" json:"stripeStats,omitempty"`
	// contains filtered or unexported fields
}

This message type is only used in MOTH v0 and v1.

func (*Metadata) Descriptor deprecated 

func (*Metadata) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetStripeStats 

func (x *Metadata) GetStripeStats() []*StripeStatistics

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type PostScript 

type PostScript struct {
	FooterLength         *uint64          `protobuf:"varint,1,opt,name=footerLength" json:"footerLength,omitempty"`
	Compression          *CompressionKind `protobuf:"varint,2,opt,name=compression,enum=moth.proto.CompressionKind" json:"compression,omitempty"`
	CompressionBlockSize *uint64          `protobuf:"varint,3,opt,name=compressionBlockSize" json:"compressionBlockSize,omitempty"`
	// the version of the file format
	//   [0, 11] = Hive 0.11
	//   [0, 12] = Hive 0.12
	Version        []uint32 `protobuf:"varint,4,rep,packed,name=version" json:"version,omitempty"`
	MetadataLength *uint64  `protobuf:"varint,5,opt,name=metadataLength" json:"metadataLength,omitempty"`
	// The version of the writer that wrote the file. This number is
	// updated when we make fixes or large changes to the writer so that
	// readers can detect whether a given bug is present in the data.
	//
	// Only the Java MOTH writer may use values under 6 (or missing) so that
	// readers that predate MOTH-202 treat the new writers correctly. Each
	// writer should assign their own sequence of versions starting from 6.
	//
	// Version of the MOTH Java writer:
	//   0 = original
	//   1 = HIVE-8732 fixed (fixed stripe/file maximum statistics &
	//                        string statistics use utf8 for min/max)
	//   2 = HIVE-4243 fixed (use real column names from Hive tables)
	//   3 = HIVE-12055 added (vectorized writer implementation)
	//   4 = HIVE-13083 fixed (decimals write present stream correctly)
	//   5 = MOTH-101 fixed (bloom filters use utf8 consistently)
	//   6 = MOTH-135 fixed (timestamp statistics use utc)
	//   7 = MOTH-517 fixed (decimal64 min/max incorrect)
	//   8 = MOTH-203 added (trim very long string statistics)
	//   9 = MOTH-14 added (column encryption)
	//
	// Version of the MOTH C++ writer:
	//   6 = original
	//
	// Version of the Presto writer:
	//   6 = original
	//
	// Version of the Scritchley Go writer:
	//   6 = original
	//
	WriterVersion *uint32 `protobuf:"varint,6,opt,name=writerVersion" json:"writerVersion,omitempty"`
	// Leave this last in the record
	Magic *string `protobuf:"bytes,8000,opt,name=magic" json:"magic,omitempty"`
	// contains filtered or unexported fields
}

Serialized length must be less that 255 bytes

func (*PostScript) Descriptor deprecated 

func (*PostScript) Descriptor() ([]byte, []int)

Deprecated: Use PostScript.ProtoReflect.Descriptor instead.

func (*PostScript) GetCompression 

func (x *PostScript) GetCompression() CompressionKind

func (*PostScript) GetCompressionBlockSize 

func (x *PostScript) GetCompressionBlockSize() uint64

func (*PostScript) GetFooterLength 

func (x *PostScript) GetFooterLength() uint64

func (*PostScript) GetMagic 

func (x *PostScript) GetMagic() string

func (*PostScript) GetMetadataLength 

func (x *PostScript) GetMetadataLength() uint64

func (*PostScript) GetVersion 

func (x *PostScript) GetVersion() []uint32

func (*PostScript) GetWriterVersion 

func (x *PostScript) GetWriterVersion() uint32

func (*PostScript) ProtoMessage 

func (*PostScript) ProtoMessage()

func (*PostScript) ProtoReflect 

func (x *PostScript) ProtoReflect() protoreflect.Message

func (*PostScript) Reset 

func (x *PostScript) Reset()

func (*PostScript) String 

func (x *PostScript) String() string

type RowIndex 

type RowIndex struct {
	Entry []*RowIndexEntry `protobuf:"bytes,1,rep,name=entry" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*RowIndex) Descriptor deprecated 

func (*RowIndex) Descriptor() ([]byte, []int)

Deprecated: Use RowIndex.ProtoReflect.Descriptor instead.

func (*RowIndex) GetEntry 

func (x *RowIndex) GetEntry() []*RowIndexEntry

func (*RowIndex) ProtoMessage 

func (*RowIndex) ProtoMessage()

func (*RowIndex) ProtoReflect 

func (x *RowIndex) ProtoReflect() protoreflect.Message

func (*RowIndex) Reset 

func (x *RowIndex) Reset()

func (*RowIndex) String 

func (x *RowIndex) String() string

type RowIndexEntry 

type RowIndexEntry struct {
	Positions  []uint64          `protobuf:"varint,1,rep,packed,name=positions" json:"positions,omitempty"`
	Statistics *ColumnStatistics `protobuf:"bytes,2,opt,name=statistics" json:"statistics,omitempty"`
	// contains filtered or unexported fields
}

func (*RowIndexEntry) Descriptor deprecated 

func (*RowIndexEntry) Descriptor() ([]byte, []int)

Deprecated: Use RowIndexEntry.ProtoReflect.Descriptor instead.

func (*RowIndexEntry) GetPositions 

func (x *RowIndexEntry) GetPositions() []uint64

func (*RowIndexEntry) GetStatistics 

func (x *RowIndexEntry) GetStatistics() *ColumnStatistics

func (*RowIndexEntry) ProtoMessage 

func (*RowIndexEntry) ProtoMessage()

func (*RowIndexEntry) ProtoReflect 

func (x *RowIndexEntry) ProtoReflect() protoreflect.Message

func (*RowIndexEntry) Reset 

func (x *RowIndexEntry) Reset()

func (*RowIndexEntry) String 

func (x *RowIndexEntry) String() string

type Space 

type Space struct {

	// 空间ID
	Id *uint64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	// 空间类型
	Kind *Space_Kind `protobuf:"varint,2,req,name=kind,enum=moth.proto.Space_Kind" json:"kind,omitempty"`
	// 元数存储类型
	Types []Type_Kind `protobuf:"varint,3,rep,name=types,enum=moth.proto.Type_Kind" json:"types,omitempty"`
	// contains filtered or unexported fields
}

空间元数据库

func (*Space) Descriptor deprecated 

func (*Space) Descriptor() ([]byte, []int)

Deprecated: Use Space.ProtoReflect.Descriptor instead.

func (*Space) GetId 

func (x *Space) GetId() uint64

func (*Space) GetKind 

func (x *Space) GetKind() Space_Kind

func (*Space) GetTypes 

func (x *Space) GetTypes() []Type_Kind

func (*Space) ProtoMessage 

func (*Space) ProtoMessage()

func (*Space) ProtoReflect 

func (x *Space) ProtoReflect() protoreflect.Message

func (*Space) Reset 

func (x *Space) Reset()

func (*Space) String 

func (x *Space) String() string

type Space_Kind 

type Space_Kind int32
const (
	Space_EP  Space_Kind = 0 // Exclusivespace 独占空间
	Space_NEP Space_Kind = 1 // Non-exclusivespace 非独占空间
)

func (Space_Kind) Descriptor 

func (Space_Kind) Descriptor() protoreflect.EnumDescriptor

func (Space_Kind) Enum 

func (x Space_Kind) Enum() *Space_Kind

func (Space_Kind) EnumDescriptor deprecated 

func (Space_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use Space_Kind.Descriptor instead.

func (Space_Kind) Number 

func (x Space_Kind) Number() protoreflect.EnumNumber

func (Space_Kind) String 

func (x Space_Kind) String() string

func (Space_Kind) Type 

func (Space_Kind) Type() protoreflect.EnumType

func (*Space_Kind) UnmarshalJSON deprecated 

func (x *Space_Kind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Stream 

type Stream struct {
	Kind   *Stream_Kind `protobuf:"varint,1,opt,name=kind,enum=moth.proto.Stream_Kind" json:"kind,omitempty"`
	Column *uint32      `protobuf:"varint,2,opt,name=column" json:"column,omitempty"`
	Length *uint64      `protobuf:"varint,3,opt,name=length" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated 

func (*Stream) Descriptor() ([]byte, []int)

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetColumn 

func (x *Stream) GetColumn() uint32

func (*Stream) GetKind 

func (x *Stream) GetKind() Stream_Kind

func (*Stream) GetLength 

func (x *Stream) GetLength() uint64

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

func (x *Stream) ProtoReflect() protoreflect.Message

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type Stream_Kind 

type Stream_Kind int32

if you add new index stream kinds, you need to make sure to update StreamName to ensure it is added to the stripe in the right area 

const (
	Stream_PRESENT           Stream_Kind = 0
	Stream_DATA              Stream_Kind = 1
	Stream_LENGTH            Stream_Kind = 2
	Stream_DICTIONARY_DATA   Stream_Kind = 3
	Stream_DICTIONARY_COUNT  Stream_Kind = 4
	Stream_SECONDARY         Stream_Kind = 5
	Stream_ROW_INDEX         Stream_Kind = 6
	Stream_BLOOM_FILTER      Stream_Kind = 7
	Stream_BLOOM_FILTER_UTF8 Stream_Kind = 8
	// Virtual stream kinds to allocate space for encrypted index and data.
	Stream_ENCRYPTED_INDEX Stream_Kind = 9
	Stream_ENCRYPTED_DATA  Stream_Kind = 10
	// stripe statistics streams
	Stream_STRIPE_STATISTICS Stream_Kind = 100
	// A virtual stream kind that is used for setting the encryption IV.
	Stream_FILE_STATISTICS Stream_Kind = 101
)

func (Stream_Kind) Descriptor 

func (Stream_Kind) Descriptor() protoreflect.EnumDescriptor

func (Stream_Kind) Enum 

func (x Stream_Kind) Enum() *Stream_Kind

func (Stream_Kind) EnumDescriptor deprecated 

func (Stream_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use Stream_Kind.Descriptor instead.

func (Stream_Kind) Number 

func (x Stream_Kind) Number() protoreflect.EnumNumber

func (Stream_Kind) String 

func (x Stream_Kind) String() string

func (Stream_Kind) Type 

func (Stream_Kind) Type() protoreflect.EnumType

func (*Stream_Kind) UnmarshalJSON deprecated 

func (x *Stream_Kind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type StringPair 

type StringPair struct {
	Key   *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringPair) Descriptor deprecated 

func (*StringPair) Descriptor() ([]byte, []int)

Deprecated: Use StringPair.ProtoReflect.Descriptor instead.

func (*StringPair) GetKey 

func (x *StringPair) GetKey() string

func (*StringPair) GetValue 

func (x *StringPair) GetValue() string

func (*StringPair) ProtoMessage 

func (*StringPair) ProtoMessage()

func (*StringPair) ProtoReflect 

func (x *StringPair) ProtoReflect() protoreflect.Message

func (*StringPair) Reset 

func (x *StringPair) Reset()

func (*StringPair) String 

func (x *StringPair) String() string

type StringStatistics 

type StringStatistics struct {
	Minimum *string `protobuf:"bytes,1,opt,name=minimum" json:"minimum,omitempty"`
	Maximum *string `protobuf:"bytes,2,opt,name=maximum" json:"maximum,omitempty"`
	// sum will store the total length of all strings in a stripe
	Sum *int64 `protobuf:"zigzag64,3,opt,name=sum" json:"sum,omitempty"`
	// If the minimum or maximum value was longer than 1024 bytes, store a lower or upper
	// bound instead of the minimum or maximum values above.
	LowerBound *string `protobuf:"bytes,4,opt,name=lowerBound" json:"lowerBound,omitempty"`
	UpperBound *string `protobuf:"bytes,5,opt,name=upperBound" json:"upperBound,omitempty"`
	// contains filtered or unexported fields
}

func (*StringStatistics) Descriptor deprecated 

func (*StringStatistics) Descriptor() ([]byte, []int)

Deprecated: Use StringStatistics.ProtoReflect.Descriptor instead.

func (*StringStatistics) GetLowerBound 

func (x *StringStatistics) GetLowerBound() string

func (*StringStatistics) GetMaximum 

func (x *StringStatistics) GetMaximum() string

func (*StringStatistics) GetMinimum 

func (x *StringStatistics) GetMinimum() string

func (*StringStatistics) GetSum 

func (x *StringStatistics) GetSum() int64

func (*StringStatistics) GetUpperBound 

func (x *StringStatistics) GetUpperBound() string

func (*StringStatistics) ProtoMessage 

func (*StringStatistics) ProtoMessage()

func (*StringStatistics) ProtoReflect 

func (x *StringStatistics) ProtoReflect() protoreflect.Message

func (*StringStatistics) Reset 

func (x *StringStatistics) Reset()

func (*StringStatistics) String 

func (x *StringStatistics) String() string

type StripeEncryptionVariant 

type StripeEncryptionVariant struct {
	Streams  []*Stream         `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
	Encoding []*ColumnEncoding `protobuf:"bytes,2,rep,name=encoding" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

func (*StripeEncryptionVariant) Descriptor deprecated 

func (*StripeEncryptionVariant) Descriptor() ([]byte, []int)

Deprecated: Use StripeEncryptionVariant.ProtoReflect.Descriptor instead.

func (*StripeEncryptionVariant) GetEncoding 

func (x *StripeEncryptionVariant) GetEncoding() []*ColumnEncoding

func (*StripeEncryptionVariant) GetStreams 

func (x *StripeEncryptionVariant) GetStreams() []*Stream

func (*StripeEncryptionVariant) ProtoMessage 

func (*StripeEncryptionVariant) ProtoMessage()

func (*StripeEncryptionVariant) ProtoReflect 

func (x *StripeEncryptionVariant) ProtoReflect() protoreflect.Message

func (*StripeEncryptionVariant) Reset 

func (x *StripeEncryptionVariant) Reset()

func (*StripeEncryptionVariant) String 

func (x *StripeEncryptionVariant) String() string

type StripeFooter 

type StripeFooter struct {
	Streams        []*Stream         `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
	Columns        []*ColumnEncoding `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	WriterTimezone *string           `protobuf:"bytes,3,opt,name=writerTimezone" json:"writerTimezone,omitempty"`
	// one for each column encryption variant
	Encryption []*StripeEncryptionVariant `protobuf:"bytes,4,rep,name=encryption" json:"encryption,omitempty"`
	// contains filtered or unexported fields
}

func (*StripeFooter) Descriptor deprecated 

func (*StripeFooter) Descriptor() ([]byte, []int)

Deprecated: Use StripeFooter.ProtoReflect.Descriptor instead.

func (*StripeFooter) GetColumns 

func (x *StripeFooter) GetColumns() []*ColumnEncoding

func (*StripeFooter) GetEncryption 

func (x *StripeFooter) GetEncryption() []*StripeEncryptionVariant

func (*StripeFooter) GetStreams 

func (x *StripeFooter) GetStreams() []*Stream

func (*StripeFooter) GetWriterTimezone 

func (x *StripeFooter) GetWriterTimezone() string

func (*StripeFooter) ProtoMessage 

func (*StripeFooter) ProtoMessage()

func (*StripeFooter) ProtoReflect 

func (x *StripeFooter) ProtoReflect() protoreflect.Message

func (*StripeFooter) Reset 

func (x *StripeFooter) Reset()

func (*StripeFooter) String 

func (x *StripeFooter) String() string

type StripeInformation 

type StripeInformation struct {

	// the global file offset of the start of the stripe
	Offset *uint64 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
	// the number of bytes of index
	IndexLength *uint64 `protobuf:"varint,2,opt,name=indexLength" json:"indexLength,omitempty"`
	// the number of bytes of data
	DataLength *uint64 `protobuf:"varint,3,opt,name=dataLength" json:"dataLength,omitempty"`
	// the number of bytes in the stripe footer
	FooterLength *uint64 `protobuf:"varint,4,opt,name=footerLength" json:"footerLength,omitempty"`
	// the number of rows in this stripe
	NumberOfRows *uint64 `protobuf:"varint,5,opt,name=numberOfRows" json:"numberOfRows,omitempty"`
	// If this is present, the reader should use this value for the encryption
	// stripe id for setting the encryption IV. Otherwise, the reader should
	// use one larger than the previous stripe's encryptStripeId.
	// For unmerged MOTH files, the first stripe will use 1 and the rest of the
	// stripes won't have it set. For merged files, the stripe information
	// will be copied from their original files and thus the first stripe of
	// each of the input files will reset it to 1.
	// Note that 1 was choosen, because protobuf v3 doesn't serialize
	// primitive types that are the default (eg. 0).
	EncryptStripeId *uint64 `protobuf:"varint,6,opt,name=encryptStripeId" json:"encryptStripeId,omitempty"`
	// For each encryption variant, the new encrypted local key to use
	// until we find a replacement.
	EncryptedLocalKeys [][]byte `protobuf:"bytes,7,rep,name=encryptedLocalKeys" json:"encryptedLocalKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*StripeInformation) Descriptor deprecated 

func (*StripeInformation) Descriptor() ([]byte, []int)

Deprecated: Use StripeInformation.ProtoReflect.Descriptor instead.

func (*StripeInformation) GetDataLength 

func (x *StripeInformation) GetDataLength() uint64

func (*StripeInformation) GetEncryptStripeId 

func (x *StripeInformation) GetEncryptStripeId() uint64

func (*StripeInformation) GetEncryptedLocalKeys 

func (x *StripeInformation) GetEncryptedLocalKeys() [][]byte

func (*StripeInformation) GetFooterLength 

func (x *StripeInformation) GetFooterLength() uint64

func (*StripeInformation) GetIndexLength 

func (x *StripeInformation) GetIndexLength() uint64

func (*StripeInformation) GetNumberOfRows 

func (x *StripeInformation) GetNumberOfRows() uint64

func (*StripeInformation) GetOffset 

func (x *StripeInformation) GetOffset() uint64

func (*StripeInformation) ProtoMessage 

func (*StripeInformation) ProtoMessage()

func (*StripeInformation) ProtoReflect 

func (x *StripeInformation) ProtoReflect() protoreflect.Message

func (*StripeInformation) Reset 

func (x *StripeInformation) Reset()

func (*StripeInformation) String 

func (x *StripeInformation) String() string

type StripeStatistics 

type StripeStatistics struct {
	ColStats []*ColumnStatistics `protobuf:"bytes,1,rep,name=colStats" json:"colStats,omitempty"`
	// contains filtered or unexported fields
}

StripeStatistics (1 per a stripe), which each contain the ColumnStatistics for each column. This message type is only used in MOTH v0 and v1.

func (*StripeStatistics) Descriptor deprecated 

func (*StripeStatistics) Descriptor() ([]byte, []int)

Deprecated: Use StripeStatistics.ProtoReflect.Descriptor instead.

func (*StripeStatistics) GetColStats 

func (x *StripeStatistics) GetColStats() []*ColumnStatistics

func (*StripeStatistics) ProtoMessage 

func (*StripeStatistics) ProtoMessage()

func (*StripeStatistics) ProtoReflect 

func (x *StripeStatistics) ProtoReflect() protoreflect.Message

func (*StripeStatistics) Reset 

func (x *StripeStatistics) Reset()

func (*StripeStatistics) String 

func (x *StripeStatistics) String() string

type TimestampStatistics 

type TimestampStatistics struct {

	// min,max values saved as milliseconds since epoch
	Minimum    *int64 `protobuf:"zigzag64,1,opt,name=minimum" json:"minimum,omitempty"`
	Maximum    *int64 `protobuf:"zigzag64,2,opt,name=maximum" json:"maximum,omitempty"`
	MinimumUtc *int64 `protobuf:"zigzag64,3,opt,name=minimumUtc" json:"minimumUtc,omitempty"`
	MaximumUtc *int64 `protobuf:"zigzag64,4,opt,name=maximumUtc" json:"maximumUtc,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampStatistics) Descriptor deprecated 

func (*TimestampStatistics) Descriptor() ([]byte, []int)

Deprecated: Use TimestampStatistics.ProtoReflect.Descriptor instead.

func (*TimestampStatistics) GetMaximum 

func (x *TimestampStatistics) GetMaximum() int64

func (*TimestampStatistics) GetMaximumUtc 

func (x *TimestampStatistics) GetMaximumUtc() int64

func (*TimestampStatistics) GetMinimum 

func (x *TimestampStatistics) GetMinimum() int64

func (*TimestampStatistics) GetMinimumUtc 

func (x *TimestampStatistics) GetMinimumUtc() int64

func (*TimestampStatistics) ProtoMessage 

func (*TimestampStatistics) ProtoMessage()

func (*TimestampStatistics) ProtoReflect 

func (x *TimestampStatistics) ProtoReflect() protoreflect.Message

func (*TimestampStatistics) Reset 

func (x *TimestampStatistics) Reset()

func (*TimestampStatistics) String 

func (x *TimestampStatistics) String() string

type Type 

type Type struct {
	Kind          *Type_Kind    `protobuf:"varint,1,opt,name=kind,enum=moth.proto.Type_Kind" json:"kind,omitempty"`
	Subtypes      []uint32      `protobuf:"varint,2,rep,packed,name=subtypes" json:"subtypes,omitempty"`
	FieldNames    []string      `protobuf:"bytes,3,rep,name=fieldNames" json:"fieldNames,omitempty"`
	MaximumLength *uint32       `protobuf:"varint,4,opt,name=maximumLength" json:"maximumLength,omitempty"`
	Precision     *uint32       `protobuf:"varint,5,opt,name=precision" json:"precision,omitempty"`
	Scale         *uint32       `protobuf:"varint,6,opt,name=scale" json:"scale,omitempty"`
	Attributes    []*StringPair `protobuf:"bytes,7,rep,name=attributes" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*Type) Descriptor deprecated 

func (*Type) Descriptor() ([]byte, []int)

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetAttributes 

func (x *Type) GetAttributes() []*StringPair

func (*Type) GetFieldNames 

func (x *Type) GetFieldNames() []string

func (*Type) GetKind 

func (x *Type) GetKind() Type_Kind

func (*Type) GetMaximumLength 

func (x *Type) GetMaximumLength() uint32

func (*Type) GetPrecision 

func (x *Type) GetPrecision() uint32

func (*Type) GetScale 

func (x *Type) GetScale() uint32

func (*Type) GetSubtypes 

func (x *Type) GetSubtypes() []uint32

func (*Type) ProtoMessage 

func (*Type) ProtoMessage()

func (*Type) ProtoReflect 

func (x *Type) ProtoReflect() protoreflect.Message

func (*Type) Reset 

func (x *Type) Reset()

func (*Type) String 

func (x *Type) String() string

type Type_Kind 

type Type_Kind int32
const (
	Type_BOOLEAN           Type_Kind = 0
	Type_BYTE              Type_Kind = 1
	Type_SHORT             Type_Kind = 2
	Type_INT               Type_Kind = 3
	Type_LONG              Type_Kind = 4
	Type_FLOAT             Type_Kind = 5
	Type_DOUBLE            Type_Kind = 6
	Type_STRING            Type_Kind = 7
	Type_BINARY            Type_Kind = 8
	Type_TIMESTAMP         Type_Kind = 9
	Type_LIST              Type_Kind = 10
	Type_MAP               Type_Kind = 11
	Type_STRUCT            Type_Kind = 12
	Type_UNION             Type_Kind = 13
	Type_DECIMAL           Type_Kind = 14
	Type_DATE              Type_Kind = 15
	Type_VARCHAR           Type_Kind = 16
	Type_CHAR              Type_Kind = 17
	Type_TIMESTAMP_INSTANT Type_Kind = 18
)

func (Type_Kind) Descriptor 

func (Type_Kind) Descriptor() protoreflect.EnumDescriptor

func (Type_Kind) Enum 

func (x Type_Kind) Enum() *Type_Kind

func (Type_Kind) EnumDescriptor deprecated 

func (Type_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use Type_Kind.Descriptor instead.

func (Type_Kind) Number 

func (x Type_Kind) Number() protoreflect.EnumNumber

func (Type_Kind) String 

func (x Type_Kind) String() string

func (Type_Kind) Type 

func (Type_Kind) Type() protoreflect.EnumType

func (*Type_Kind) UnmarshalJSON deprecated 

func (x *Type_Kind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type UserMetadataItem 

type UserMetadataItem struct {
	Name  *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Value []byte  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UserMetadataItem) Descriptor deprecated 

func (*UserMetadataItem) Descriptor() ([]byte, []int)

Deprecated: Use UserMetadataItem.ProtoReflect.Descriptor instead.

func (*UserMetadataItem) GetName 

func (x *UserMetadataItem) GetName() string

func (*UserMetadataItem) GetValue 

func (x *UserMetadataItem) GetValue() []byte

func (*UserMetadataItem) ProtoMessage 

func (*UserMetadataItem) ProtoMessage()

func (*UserMetadataItem) ProtoReflect 

func (x *UserMetadataItem) ProtoReflect() protoreflect.Message

func (*UserMetadataItem) Reset 

func (x *UserMetadataItem) Reset()

func (*UserMetadataItem) String 

func (x *UserMetadataItem) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.