distributed

Sep 8, 2026

Changes in this version

+ type HiddenJoinColumn struct

+ Name string

+ Ordinal int

+ Probe bool

+ type LateralEmptyDefault struct

+ Column string

+ ExprSQL string

type OpSpec

+ DropMarker bool

+ EmptyDefaults []LateralEmptyDefault

+ HiddenColumns []HiddenJoinColumn

+ PadMarker string

type Task

+ HiddenJoinColumns []HiddenJoinColumn

+ LateralDropMarker bool

+ LateralEmptyDefaults []LateralEmptyDefault

+ LateralPadMarker string

Sep 5, 2026

Changes in this version

type ProjectSpec

+ SourceIdx *int

Sep 4, 2026

Changes in this version

type SortKeySpec

+ SlotPos int

Sep 4, 2026

Changes in this version

type ColumnSpec

+ ElementType *ColumnSpec

+ Fields []ColumnSpec

Sep 3, 2026

Changes in this version

type ResultNotification

+ SQLState string

Sep 3, 2026

Changes in this version

+ type GroupKeyResolveSpec struct

+ Computed bool

+ Expr string

type OpSpec

+ GroupByResolve []GroupKeyResolveSpec

Sep 2, 2026

Changes in this version

type AggSpec

+ Distinct bool

Aug 30, 2026

Changes in this version

type AggSpec

+ InputPrecision int

+ InputScale int

+ OutputPrecision int

+ OutputScale int

+ type DecimalMeta struct

+ Precision int

+ Scale int

type FusedJoinSpec

+ JoinKeyTypes []int

type OpSpec

+ GroupByDecimal map[string]DecimalMeta

+ KeyTypes []int

+ ScanSchemaFilter bool

+ ShuffleKeyTypes []int

type ProjectSpec

+ Precision int

+ Scale int

type Task

+ JoinKeyTypes []int

+ ShuffleKeyTypes []int

Aug 28, 2026

Changes in this version

type OpSpec

+ Coercions []ColumnSpec

+ NullAwareAnti bool

+ WindowKeyExprs []ProjectSpec

type OpType

+ const OpDecimalCoerce

type Task

+ NullAwareAnti bool

Aug 25, 2026

Changes in this version

+ type DeleteSpec struct

+ File string

+ Runs []byte

type OpSpec

+ HasLimitCount bool

+ LimitCount int

+ LimitOffset int

type OpType

+ const OpLimit

type ResultNotification

+ Panicked bool

+ PlanRefused bool

type Task

+ DeleteMarkers []DeleteSpec

Aug 24, 2026

Changes in this version

type ColumnSpec

+ Dimension int

+ Precision int

+ Scale int

type OpSpec

+ BuildColumnTypes []ColumnSpec

+ ColumnTypes []ColumnSpec

+ HasSortLimit bool

type Task

+ ColumnTypes []ColumnSpec

Aug 23, 2026

Changes in this version

+ const BaseTablePeerKeyPrefix

+ const KVCatalogLocks

+ const KVUserFunctions

+ const StreamDLQ

+ const StreamPriTasks

+ const StreamResults

+ const StreamTasks

+ const SubjectCancel

+ const SubjectCatalogLock

+ const SubjectComplete

+ const SubjectDLQ

+ const SubjectDLQAll

+ const SubjectEagerManifest

+ const SubjectHeartbeat

+ const SubjectPriTasksAll

+ const SubjectPriTasksDeep

+ const SubjectPriTasksLeaf

+ const SubjectProfileCollect

+ const SubjectProfileStart

+ const SubjectQueryActive

+ const SubjectResults

+ const SubjectResultsAll

+ const SubjectTaskProgress

+ const SubjectTaskProgressAll

+ const SubjectTasksAggregate

+ const SubjectTasksAll

+ const SubjectTasksJoin

+ const SubjectTasksScan

+ const SubjectTasksShuffle

+ const SubjectTasksSort

+ const SubjectTasksWindow

+ const SubjectUploadComplete

+ const SubjectUploadRelease

+ func AffinityOwner(file string, workers []string) string

+ func AffinityRank(file string, workers []string) []string

+ func BaseTablePeerKey(bucket, key string) string

+ func BuildNATSClientTLS(certFile, keyFile, caFile string) (*tls.Config, error)

+ func CancelSubject(queryID string) string

+ func CancelSubjectAll() string

+ func ClusterPriTaskSubject(clusterID, class, taskType, queryID, stageID string) string

+ func ClusterPriTasksFilter(clusterID, class string) string

+ func ClusterTaskSubject(clusterID, taskType, queryID, stageID string) string

+ func ClusterTasksFilter(clusterID string) string

+ func CompleteSubject(queryID string) string

+ func CompleteSubjectAll() string

+ func Connect(url string, tlsCfg *tls.Config) (*nats.Conn, error)

+ func ConnectInProcess(server *natsserver.Server) (*nats.Conn, error)

+ func ContextWithTrace(ctx context.Context, tc TraceContext) context.Context

+ func CutBaseTablePeerKey(peerKey string) (bucket, key string, ok bool)

+ func DLQSubject(queryID, taskID string) string

+ func DirDiskUsage(dir string) int64

+ func EagerManifestSubject(rootQueryID, stageID string) string

+ func EncodeDynamicFilterArtifact(w io.Writer, a *DynamicFilterArtifact) error

+ func Marshal(v any) ([]byte, error)

+ func NewJetStream(nc *nats.Conn) (jetstream.JetStream, error)

+ func NullsLastPtr(v bool) *bool

+ func NumGoroutines() int

+ func PriTaskClass(deep bool) string

+ func PriTaskSubject(class, taskType, queryID, stageID string) string

+ func ProcessRSS() int64

+ func QueryResultSubject(queryID string) string

+ func ResultSubject(queryID, stageID, taskID string) string

+ func ScratchQueryID(key string) string

+ func SetupStreams(ctx context.Context, js jetstream.JetStream) error

+ func TaskProgressSubject(queryID, taskID string) string

+ func TaskRootQueryID(t *Task) string

+ func TaskSubject(taskType string, queryID string, stageID string) string

+ func Unmarshal(data []byte, v any) error

+ func WindowTypePtr(v int) *int

+ type AggSpec struct

+ Func string

+ InputCol string

+ InputCol2 string

+ InputExpr string

+ InputType *int

+ OutputCol string

+ OutputType *int

+ Percentile float64

+ Separator string

+ type ColumnSpec struct

+ Name string

+ Type int

+ type ComputedColSpec struct

+ Expr string

+ Name string

+ type DLQEntry struct

+ EntryID string

+ Error string

+ QueryID string

+ Reason string

+ StageID string

+ TaskData []byte

+ TaskID string

+ TaskType TaskType

+ Timestamp time.Time

+ WorkerID string

+ type DynamicFilterArtifact struct

+ Bloom []uint64

+ BloomMask uint64

+ FilterID string

+ HasRange bool

+ KeyType string

+ Max int64

+ Min int64

+ RowCount int64

+ func DecodeDynamicFilterArtifact(r io.Reader) (*DynamicFilterArtifact, error)

+ type DynamicFilterConsume struct

+ FilterID string

+ KeyType string

+ SourceStageID string

+ TargetColumn string

+ type DynamicFilterEmit struct

+ AtOutput bool

+ BloomBits int

+ FilterID string

+ GuardConsumes []string

+ KeyColumn string

+ KeyType string

+ PartialPrefix string

+ StagePartials int

+ type DynamicFilterPartialRef struct

+ Bucket string

+ FilterID string

+ Key string

+ type DynamicFilterSpec struct

+ Bloom []uint64

+ BloomBucket string

+ BloomKey string

+ BloomMask uint64

+ BloomWords int

+ Deferred bool

+ FilterID string

+ HasRange bool

+ KeyType string

+ Max int64

+ Min int64

+ PartialPrefix string

+ TargetColumn string

+ type EagerInput struct

+ PartitionEnd int

+ PartitionStart int

+ ProducerTaskIDs []string

+ Replay []ProducerTaskManifest

+ RootQueryID string

+ StageID string

+ type EmbeddedNATS struct

+ func NewEmbeddedNATS(cfg NATSConfig, logger *slog.Logger) (*EmbeddedNATS, error)

+ func (e *EmbeddedNATS) ClientURL() string

+ func (e *EmbeddedNATS) Server() *natsserver.Server

+ func (e *EmbeddedNATS) Shutdown()

+ type FusedJoinSpec struct

+ BuildColOrigins map[string]string

+ BuildFiles []string

+ BuildSchema []ColumnSpec

+ BuildTableAlias string

+ FilterExprs []string

+ JoinFilter string

+ JoinLeftKeys []string

+ JoinRightKeys []string

+ JoinType string

+ type GatherBatchMsg struct

+ Err string

+ Payload []byte

+ RowCount int32

+ Terminal bool

+ WorkerID string

+ type NATSConfig struct

+ ClusterID string

+ Host string

+ LeafRemotes []string

+ MaxPayload int32

+ Port int

+ StoreDir string

+ TLSCA string

+ TLSCert string

+ TLSKey string

+ func DefaultNATSConfig() NATSConfig

+ type NATSUDFStore struct

+ func NewNATSUDFStore(ctx context.Context, js jetstream.JetStream, store *expr.UDFStore, ...) (*NATSUDFStore, error)

+ func (n *NATSUDFStore) Create(ctx context.Context, def expr.UDFDef, isAdmin bool) error

+ func (n *NATSUDFStore) Delete(ctx context.Context, name, caller string, isAdmin bool) error

+ func (n *NATSUDFStore) List() []expr.UDFDef

+ func (n *NATSUDFStore) LoadAll(ctx context.Context) error

+ func (n *NATSUDFStore) Watch(ctx context.Context) (context.CancelFunc, error)

+ type OpSpec struct

+ Aggregates []AggSpec

+ BuildAlias string

+ BuildBucket string

+ BuildColOrigins map[string]string

+ BuildFiles []string

+ BuildFilterExprs []string

+ BuildProject bool

+ BuildRowHint int64

+ BuildSchema []ColumnSpec

+ Columns []string

+ DynamicFilterEmits []DynamicFilterEmit

+ DynamicFilters []DynamicFilterSpec

+ EmitEmptyIdentity bool

+ FoldAvg bool

+ GroupByAll bool

+ GroupByCols []string

+ GroupByTypes map[string]int

+ InputAlias string

+ InputBucket string

+ InputFiles []string

+ InputRowBound int64

+ JoinFilter string

+ JoinType string

+ LateMaterialize bool

+ LeftKeys []string

+ MergeMode bool

+ NumPartitions int

+ OutputColumns []string

+ Predicates []string

+ ProbeSchema []ColumnSpec

+ Projections []ProjectSpec

+ QualifyAllBuildCols bool

+ ReplySubject string

+ RightKeys []string

+ ScanShardCount int

+ ScanShardIndex int

+ SemiAntiKeyOnly bool

+ SetOp string

+ SetOpAll bool

+ SetOpLeftCol string

+ SetOpRightCol string

+ ShuffleKeys []string

+ SortKeySpecs []SortKeySpec

+ SortLimit int

+ Type OpType

+ WindowCols []WindowColSpec

+ type OpType string

+ const OpBroadcastProbe

+ const OpColumnPrune

+ const OpExchangeSender

+ const OpFilter

+ const OpGatherSink

+ const OpHashAggregate

+ const OpHashJoinProbe

+ const OpProject

+ const OpScan

+ const OpSetOpEmit

+ const OpShuffleSource

+ const OpSort

+ const OpSortMergeJoin

+ const OpUnpartitionedSink

+ const OpWindow

+ type OperatorPeak struct

+ Closed int

+ Current int64

+ Name string

+ Owned int64

+ Peak int64

+ Retained int64

+ State string

+ type PreComputedAggregate struct

+ AggSpecs []AggSpec

+ CacheFiles []string

+ GroupByCols []string

+ InputTable string

+ type ProducerTaskManifest struct

+ Attempt int

+ Files []string

+ Final bool

+ PeerAddr string

+ StageID string

+ TaskID string

+ WorkerID string

+ type ProjectSpec struct

+ Expr string

+ Name string

+ Type int

+ type QueryManifest struct

+ QueryID string

+ ResultFiles []string

+ TotalBytes int64

+ TotalRows int64

+ type ResultNotification struct

+ Duration time.Duration

+ DynamicFilterPartials []DynamicFilterPartialRef

+ Error string

+ InlineData []byte

+ MissingInputKey string

+ NumRows int64

+ PartitionBytes []int64

+ PartitionRows []int64

+ QueryID string

+ ResultFiles []string

+ ResultPath string

+ SizeBytes int64

+ SpanID string

+ StageID string

+ Success bool

+ TaskID string

+ TaskStats *TaskStats

+ Timestamp time.Time

+ TraceID string

+ UploadPendingKeys []string

+ WorkerID string

+ type SortKeySpec struct

+ Column string

+ Desc bool

+ NullsLast *bool

+ func (s SortKeySpec) PlaceNullsLast() bool

+ type Task struct

+ AffinityWorkerID string

+ Aggregates []AggSpec

+ AsyncUpload bool

+ Attempt int

+ BuildColOrigins map[string]string

+ BuildFiles []string

+ BuildFilterExprs []string

+ BuildRowHint int64

+ BuildTableAlias string

+ ClusterID string

+ Columns []string

+ ComputedCols []ComputedColSpec

+ CreatedAt time.Time

+ DataBucket string

+ DegradedMemory bool

+ DropCols []string

+ DynamicFilters []DynamicFilterSpec

+ EagerInputs map[string]EagerInput

+ EstimatedBytes int64

+ FetchToken string

+ Files []string

+ FilterExprs []string

+ FusedJoins []FusedJoinSpec

+ GatherLimit int

+ GatherOrdering []SortKeySpec

+ GroupByCols []string

+ ID string

+ IdentityName string

+ IdentityRole string

+ InputFiles []string

+ InputLocations map[string]string

+ Inputs map[string][]string

+ JoinBuildSchema []ColumnSpec

+ JoinFilter string

+ JoinLeftKeys []string

+ JoinProbeSchema []ColumnSpec

+ JoinRightKeys []string

+ JoinType string

+ Limit int

+ MergePartials bool

+ MergePreSorted bool

+ NumPartitions int

+ Operators []OpSpec

+ Output string

+ PartialAggKeys []string

+ PartialAggSpecs []AggSpec

+ PartialAggregate bool

+ PartitionFilter map[string]string

+ PartitionID int

+ PolicyDecisionJSON json.RawMessage

+ PostFilterExprs []string

+ PreComputedAggregates []PreComputedAggregate

+ PreScannedInputs map[string][]string

+ Priority bool

+ PriorityDeep bool

+ QualifyAllBuildCols bool

+ QueryID string

+ ReplySubject string

+ ResultBucket string

+ ResultPrefix string

+ RowLimit int

+ SQLText string

+ ScanAggGroupBy []string

+ ScanAggSpecs []AggSpec

+ ScanFileFilter map[string][]string

+ ScanShardCount int

+ ScanShardIndex int

+ SemiAntiKeyOnly bool

+ ShuffleKeys []string

+ SortKeys []SortKeySpec

+ SpanID string

+ StageID string

+ StageType string

+ TableName string

+ TraceFlags byte

+ TraceID string

+ Type TaskType

+ UploadPolicy UploadPolicy

+ type TaskProgress struct

+ BytesProcessed int64

+ QueryID string

+ RowsProcessed int64

+ StageID string

+ TaskID string

+ Timestamp time.Time

+ WorkerID string

+ type TaskStats struct

+ DriftMB int64

+ MemBudget int64

+ MemUsed int64

+ MmapRSSMB int64

+ OperatorPeaks []OperatorPeak

+ PeakHeapMB int64

+ RSS int64

+ SpillBytes int64

+ SpillFiles int

+ TrackerPeak int64

+ type TaskType string

+ const TaskTypeGather

+ const TaskTypePipeline

+ const TaskTypeShuffle

+ const TaskTypeStage

+ type TraceContext struct

+ SpanID string

+ TraceFlags byte

+ TraceID string

+ func NewTraceContext() TraceContext

+ func TraceFromContext(ctx context.Context) TraceContext

+ func (tc TraceContext) NewSpanID() TraceContext

+ type UDFEntry struct

+ Body string

+ Locked bool

+ Name string

+ Owner string

+ Params []string

+ type UploadComplete struct

+ Failed bool

+ Keys []string

+ RootQueryID string

+ TaskID string

+ WorkerID string

+ type UploadPolicy string

+ const UploadEager

+ const UploadLazy

+ const UploadOff

+ type WindowBoundSpec struct

+ Offset int

+ Type string

+ type WindowColSpec struct

+ Frame *WindowFrameSpec

+ Func string

+ InputCol string

+ LagLeadDefault any

+ LagLeadOffset int

+ NthValueN int

+ NtileBuckets int

+ OrderBy []SortKeySpec

+ OutputCol string

+ OutputType *int

+ PartitionBy []string

+ type WindowFrameSpec struct

+ End WindowBoundSpec

+ Mode string

+ Start WindowBoundSpec

+ type WorkerHeartbeat struct

+ ActiveTaskIDs []string

+ ActiveTasks int

+ ClusterID string

+ Draining bool

+ Mallocs uint64

+ MaxConcurrent int

+ MemoryTotal int64

+ MemoryUsed int64

+ NumGoroutines int

+ PeerAddr string

+ PoolBudget int64

+ PoolUsed int64

+ RSS int64

+ SpillDiskUsed int64

+ Timestamp time.Time

+ WorkerID string