Documentation
¶
Index ¶
Constants ¶
const ( Bool = "Bool" Int8 = "Int8" Uint8 = "Uint8" Int16 = "Int16" Uint16 = "Uint16" Int32 = "Int32" Uint32 = "Uint32" Float32 = "Float32" SmallEnum = "SmallEnum" BigEnum = "BigEnum" UUID = "UUID" GeoPoint = "GeoPoint" GeoShape = "GeoShape" Int64 = "Int64" )
string representations of data types
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Column ¶
type Column struct {
// Immutable, columns cannot be renamed.
Name string `json:"name"`
// Immutable, columns cannot have their types changed.
Type string `json:"type"`
// Deleted columns are kept as placeholders in Table.Columns.
// read only: true
Deleted bool `json:"deleted,omitempty"`
// We store the default value as string here since it's from user input.
// Nil means the default value is NULL. Actual default value of column data type
// should be stored in memstore.
DefaultValue *string `json:"defaultValue,omitempty"`
// Whether to compare characters case insensitively for enum columns. It only matters
// for ingestion client as it's the place to concert enum strings to enum values.
CaseInsensitive bool `json:"caseInsensitive,omitempty"`
// Whether disable enum cases auto expansion.
DisableAutoExpand bool `json:"disableAutoExpand,omitempty"`
// Mutable column configs.
Config ColumnConfig `json:"config,omitempty"`
}
Column defines the schema of a column from MetaStore. swagger:model column
func (Column) IsEnumColumn ¶
IsEnumColumn checks whether a column is enum column
func (Column) IsOverwriteOnlyDataType ¶
IsOverwriteOnlyDataType checks whether a column is overwrite only
type ColumnConfig ¶
type ColumnConfig struct {
// ColumnEvictionConfig : For column level in-memory eviction, it’s the best
// effort TTL for in-memory data.
// Column level eviction has nothing to do with data availability, but based
// on how much data we pre-loaded, the major impact will be there for query
// performance. Here we bring in two priorities configs: Preloading days and
// Priority.
// - Preloading days is defined at each column level to indicate how many
// recent days data we want to preload to host memory. This is best effort
// operation.
// - Priority is defined at each column level to indicate the priority of
// each column. When data eviction happens, we will rely on column priority
// to decide which column will be evicted first.
// High number implies high priority.
PreloadingDays int `json:"preloadingDays,omitempty"`
Priority int64 `json:"priority,omitempty"`
}
ColumnConfig defines the schema of a column config that can be mutated by UpdateColumn API call. swagger:model columnConfig
type ShardOwnership ¶
ShardOwnership defines an instruction on whether the receiving instance should start to own or disown the specified table shard.
type Table ¶
type Table struct {
// Name of the table, immutable.
Name string `json:"name"`
// Index to Columns also serves as column IDs.
Columns []Column `json:"columns"`
// IDs of primary key columns. This field is immutable.
PrimaryKeyColumns []int `json:"primaryKeyColumns"`
// Whether this is a fact table.
IsFactTable bool `json:"isFactTable"`
// table configurations
Config TableConfig `json:"config"`
// Fact table only.
// IDs of columns to sort based upon.
ArchivingSortColumns []int `json:"archivingSortColumns,omitempty"`
Version int `json:"version"`
}
Table defines the schema and configurations of a table from MetaStore. swagger:model table
type TableConfig ¶
type TableConfig struct {
// Initial setting of number of buckets for primary key
// if equals to 0, default will be used
InitialPrimaryKeyNumBuckets int `json:"initPrimaryKeyNumBuckets,omitempty"`
// Size of each live batch, should be sufficiently large.
BatchSize int `json:"batchSize,omitempty"`
// Specifies how often to create a new redo log file.
RedoLogRotationInterval int `json:"redoLogRotationInterval,omitempty"`
// Specifies the size limit of a single redo log file.
MaxRedoLogFileSize int `json:"maxRedoLogFileSize,omitempty"`
// Number of minutes after event time before a record can be archived.
ArchivingDelayMinutes uint32 `json:"archivingDelayMinutes,omitempty"`
// Specifies how often archiving runs.
ArchivingIntervalMinutes uint32 `json:"archivingIntervalMinutes,omitempty"`
// Specifies how often backfill runs.
BackfillIntervalMinutes uint32 `json:"backfillIntervalMinutes,omitempty"`
// Upper limit of current backfill buffer size + backfilling buffer size.
BackfillMaxBufferSize int64 `json:"backfillMaxBufferSize,omitempty"`
// Backfill buffer size in bytes that will trigger a backfill job.
BackfillThresholdInBytes int64 `json:"backfillThresholdInBytes,omitempty"`
// Size of each live batch used by backfill job.
BackfillStoreBatchSize int `json:"backfillStoreBatchSize,omitempty"`
// Records with timestamp older than now - RecordRetentionInDays will be skipped
// during ingestion and backfill. 0 means unlimited days.
RecordRetentionInDays int `json:"recordRetentionInDays,omitempty"`
// Number of mutations to accumulate before creating a new snapshot.
SnapshotThreshold int `json:"snapshotThreshold,omitempty"`
// Specifies how often snapshot runs.
SnapshotIntervalMinutes int `json:"snapshotIntervalMinutes,omitempty"`
AllowMissingEventTime bool `json:"allowMissingEventTime,omitempty"`
}
TableConfig defines the table configurations that can be changed swagger:model tableConfig