enginev1

package
v0.4.14 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_chalk_engine_v1_bloom_filter_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v1_plan_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v1_plan_server_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v1_query_server_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BloomFilter 

type BloomFilter struct {
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	Namespace   string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// number of items actually inserted into this bloom filter
	NumEntries uint64 `protobuf:"varint,3,opt,name=num_entries,json=numEntries,proto3" json:"num_entries,omitempty"`
	// Expected max number of entries, used to calculate size w.r.t error rate
	NumExpectedEntries uint64 `protobuf:"varint,4,opt,name=num_expected_entries,json=numExpectedEntries,proto3" json:"num_expected_entries,omitempty"`
	NumHashes          uint64 `protobuf:"varint,5,opt,name=num_hashes,json=numHashes,proto3" json:"num_hashes,omitempty"`
	SizeBytes          uint64 `protobuf:"varint,6,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Data               []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BloomFilter) Descriptor deprecated 

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

Deprecated: Use BloomFilter.ProtoReflect.Descriptor instead.

func (*BloomFilter) GetData 

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

func (*BloomFilter) GetEnvironment 

func (x *BloomFilter) GetEnvironment() string

func (*BloomFilter) GetNamespace 

func (x *BloomFilter) GetNamespace() string

func (*BloomFilter) GetNumEntries 

func (x *BloomFilter) GetNumEntries() uint64

func (*BloomFilter) GetNumExpectedEntries 

func (x *BloomFilter) GetNumExpectedEntries() uint64

func (*BloomFilter) GetNumHashes 

func (x *BloomFilter) GetNumHashes() uint64

func (*BloomFilter) GetSizeBytes 

func (x *BloomFilter) GetSizeBytes() uint64

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 ChalkProject 

type ChalkProject struct {
	Fields                 []*Key `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	PromoteTsToFeatureTime bool   `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChalkProject) Descriptor deprecated 

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

Deprecated: Use ChalkProject.ProtoReflect.Descriptor instead.

func (*ChalkProject) GetFields 

func (x *ChalkProject) GetFields() []*Key

func (*ChalkProject) GetPromoteTsToFeatureTime 

func (x *ChalkProject) GetPromoteTsToFeatureTime() bool

func (*ChalkProject) ProtoMessage 

func (*ChalkProject) ProtoMessage()

func (*ChalkProject) ProtoReflect 

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

func (*ChalkProject) Reset 

func (x *ChalkProject) Reset()

func (*ChalkProject) String 

func (x *ChalkProject) String() string

type ColumnKey 

type ColumnKey struct {

	// Types that are assignable to Key:
	//
	//	*ColumnKey_Feature
	//	*ColumnKey_Raw
	Key isColumnKey_Key `protobuf_oneof:"key"`
	// contains filtered or unexported fields
}

func (*ColumnKey) Descriptor deprecated 

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

Deprecated: Use ColumnKey.ProtoReflect.Descriptor instead.

func (*ColumnKey) GetFeature 

func (x *ColumnKey) GetFeature() *FeatureColumnKey

func (*ColumnKey) GetKey 

func (m *ColumnKey) GetKey() isColumnKey_Key

func (*ColumnKey) GetRaw 

func (x *ColumnKey) GetRaw() *RawColumnKey

func (*ColumnKey) ProtoMessage 

func (*ColumnKey) ProtoMessage()

func (*ColumnKey) ProtoReflect 

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

func (*ColumnKey) Reset 

func (x *ColumnKey) Reset()

func (*ColumnKey) String 

func (x *ColumnKey) String() string

type ColumnKey_Feature 

type ColumnKey_Feature struct {
	Feature *FeatureColumnKey `protobuf:"bytes,1,opt,name=feature,proto3,oneof"`
}

type ColumnKey_Raw 

type ColumnKey_Raw struct {
	Raw *RawColumnKey `protobuf:"bytes,2,opt,name=raw,proto3,oneof"`
}

type DataFrame 

type DataFrame struct {
	OptionalColumns []*FeatureColumnKey `protobuf:"bytes,1,rep,name=optional_columns,json=optionalColumns,proto3" json:"optional_columns,omitempty"`
	RequiredColumns []*FeatureColumnKey `protobuf:"bytes,2,rep,name=required_columns,json=requiredColumns,proto3" json:"required_columns,omitempty"`
	Limit           *uint64             `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // optional Filter filter = 4; // TODO, represents filters on dfs/has-manys like (transaction.amount < 10)
	// contains filtered or unexported fields
}

func (*DataFrame) Descriptor deprecated 

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

Deprecated: Use DataFrame.ProtoReflect.Descriptor instead.

func (*DataFrame) GetLimit 

func (x *DataFrame) GetLimit() uint64

func (*DataFrame) GetOptionalColumns 

func (x *DataFrame) GetOptionalColumns() []*FeatureColumnKey

func (*DataFrame) GetRequiredColumns 

func (x *DataFrame) GetRequiredColumns() []*FeatureColumnKey

func (*DataFrame) ProtoMessage 

func (*DataFrame) ProtoMessage()

func (*DataFrame) ProtoReflect 

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

func (*DataFrame) Reset 

func (x *DataFrame) Reset()

func (*DataFrame) String 

func (x *DataFrame) String() string

type DataFrameFeatureKey 

type DataFrameFeatureKey struct {
	RootNamespace string     `protobuf:"bytes,1,opt,name=root_namespace,json=rootNamespace,proto3" json:"root_namespace,omitempty"`
	Df            *DataFrame `protobuf:"bytes,2,opt,name=df,proto3" json:"df,omitempty"`
	// contains filtered or unexported fields
}

func (*DataFrameFeatureKey) Descriptor deprecated 

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

Deprecated: Use DataFrameFeatureKey.ProtoReflect.Descriptor instead.

func (*DataFrameFeatureKey) GetDf 

func (x *DataFrameFeatureKey) GetDf() *DataFrame

func (*DataFrameFeatureKey) GetRootNamespace 

func (x *DataFrameFeatureKey) GetRootNamespace() string

func (*DataFrameFeatureKey) ProtoMessage 

func (*DataFrameFeatureKey) ProtoMessage()

func (*DataFrameFeatureKey) ProtoReflect 

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

func (*DataFrameFeatureKey) Reset 

func (x *DataFrameFeatureKey) Reset()

func (*DataFrameFeatureKey) String 

func (x *DataFrameFeatureKey) String() string

type DefaultInjector 

type DefaultInjector struct {
	DefaultingFeatures []*Key `protobuf:"bytes,1,rep,name=defaulting_features,json=defaultingFeatures,proto3" json:"defaulting_features,omitempty"` // Note: actual default values should be pulled from the graph
	// contains filtered or unexported fields
}

func (*DefaultInjector) Descriptor deprecated 

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

Deprecated: Use DefaultInjector.ProtoReflect.Descriptor instead.

func (*DefaultInjector) GetDefaultingFeatures 

func (x *DefaultInjector) GetDefaultingFeatures() []*Key

func (*DefaultInjector) ProtoMessage 

func (*DefaultInjector) ProtoMessage()

func (*DefaultInjector) ProtoReflect 

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

func (*DefaultInjector) Reset 

func (x *DefaultInjector) Reset()

func (*DefaultInjector) String 

func (x *DefaultInjector) String() string

type ExecuteQueryRequest 

type ExecuteQueryRequest struct {
	OnlineQueryRequest *v1.OnlineQueryRequest `protobuf:"bytes,1,opt,name=online_query_request,json=onlineQueryRequest,proto3" json:"online_query_request,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetOnlineQueryRequest 

func (x *ExecuteQueryRequest) GetOnlineQueryRequest() *v1.OnlineQueryRequest

func (*ExecuteQueryRequest) ProtoMessage 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect 

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

func (*ExecuteQueryRequest) Reset 

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) String 

func (x *ExecuteQueryRequest) String() string

type ExecuteQueryResponse 

type ExecuteQueryResponse struct {
	OnlineQueryResponse *v1.OnlineQueryResponse `protobuf:"bytes,1,opt,name=online_query_response,json=onlineQueryResponse,proto3" json:"online_query_response,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetOnlineQueryResponse 

func (x *ExecuteQueryResponse) GetOnlineQueryResponse() *v1.OnlineQueryResponse

func (*ExecuteQueryResponse) ProtoMessage 

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect 

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

func (*ExecuteQueryResponse) Reset 

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) String 

func (x *ExecuteQueryResponse) String() string

type FeatureColumnKey 

type FeatureColumnKey struct {
	RootFqn string `protobuf:"bytes,1,opt,name=root_fqn,json=rootFqn,proto3" json:"root_fqn,omitempty"`
	// contains filtered or unexported fields
}

Represents a feature in the graph that corresponds to a single column in a table, i.e. not a has-many or a dataframe. Basically a "scalar" but shouldn't be confused w/ ScalarFeatureType

func (*FeatureColumnKey) Descriptor deprecated 

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

Deprecated: Use FeatureColumnKey.ProtoReflect.Descriptor instead.

func (*FeatureColumnKey) GetRootFqn 

func (x *FeatureColumnKey) GetRootFqn() string

func (*FeatureColumnKey) ProtoMessage 

func (*FeatureColumnKey) ProtoMessage()

func (*FeatureColumnKey) ProtoReflect 

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

func (*FeatureColumnKey) Reset 

func (x *FeatureColumnKey) Reset()

func (*FeatureColumnKey) String 

func (x *FeatureColumnKey) String() string

type GetPlanRequest 

type GetPlanRequest struct {
	OnlineQueryRequest *v1.OnlineQueryRequest `protobuf:"bytes,1,opt,name=online_query_request,json=onlineQueryRequest,proto3" json:"online_query_request,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPlanRequest) Descriptor deprecated 

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

Deprecated: Use GetPlanRequest.ProtoReflect.Descriptor instead.

func (*GetPlanRequest) GetOnlineQueryRequest 

func (x *GetPlanRequest) GetOnlineQueryRequest() *v1.OnlineQueryRequest

func (*GetPlanRequest) ProtoMessage 

func (*GetPlanRequest) ProtoMessage()

func (*GetPlanRequest) ProtoReflect 

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

func (*GetPlanRequest) Reset 

func (x *GetPlanRequest) Reset()

func (*GetPlanRequest) String 

func (x *GetPlanRequest) String() string

type GetPlanResponse 

type GetPlanResponse struct {
	Plan *Plan `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPlanResponse) Descriptor deprecated 

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

Deprecated: Use GetPlanResponse.ProtoReflect.Descriptor instead.

func (*GetPlanResponse) GetPlan 

func (x *GetPlanResponse) GetPlan() *Plan

func (*GetPlanResponse) ProtoMessage 

func (*GetPlanResponse) ProtoMessage()

func (*GetPlanResponse) ProtoReflect 

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

func (*GetPlanResponse) Reset 

func (x *GetPlanResponse) Reset()

func (*GetPlanResponse) String 

func (x *GetPlanResponse) String() string

type GivensScan 

type GivensScan struct {

	// / TODO I think there's some discussion as to how exactly Givens will be implemented
	// One option is basically a "project" where it lists expected fields, and caller passes in an actual PlanBatch during execution
	Fields []*Key `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*GivensScan) Descriptor deprecated 

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

Deprecated: Use GivensScan.ProtoReflect.Descriptor instead.

func (*GivensScan) GetFields 

func (x *GivensScan) GetFields() []*Key

func (*GivensScan) ProtoMessage 

func (*GivensScan) ProtoMessage()

func (*GivensScan) ProtoReflect 

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

func (*GivensScan) Reset 

func (x *GivensScan) Reset()

func (*GivensScan) String 

func (x *GivensScan) String() string

type HasManyFeatureKey 

type HasManyFeatureKey struct {
	RootFqn string     `protobuf:"bytes,1,opt,name=root_fqn,json=rootFqn,proto3" json:"root_fqn,omitempty"`
	Df      *DataFrame `protobuf:"bytes,2,opt,name=df,proto3" json:"df,omitempty"`
	// contains filtered or unexported fields
}

func (*HasManyFeatureKey) Descriptor deprecated 

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

Deprecated: Use HasManyFeatureKey.ProtoReflect.Descriptor instead.

func (*HasManyFeatureKey) GetDf 

func (x *HasManyFeatureKey) GetDf() *DataFrame

func (*HasManyFeatureKey) GetRootFqn 

func (x *HasManyFeatureKey) GetRootFqn() string

func (*HasManyFeatureKey) ProtoMessage 

func (*HasManyFeatureKey) ProtoMessage()

func (*HasManyFeatureKey) ProtoReflect 

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

func (*HasManyFeatureKey) Reset 

func (x *HasManyFeatureKey) Reset()

func (*HasManyFeatureKey) String 

func (x *HasManyFeatureKey) String() string

type Key 

type Key struct {

	// Types that are assignable to Impl:
	//
	//	*Key_RawColumn
	//	*Key_Scalar
	//	*Key_HasMany
	//	*Key_Dataframe
	Impl isKey_Impl `protobuf_oneof:"impl"`
	// contains filtered or unexported fields
}

func (*Key) Descriptor deprecated 

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetDataframe 

func (x *Key) GetDataframe() *DataFrameFeatureKey

func (*Key) GetHasMany 

func (x *Key) GetHasMany() *HasManyFeatureKey

func (*Key) GetImpl 

func (m *Key) GetImpl() isKey_Impl

func (*Key) GetRawColumn 

func (x *Key) GetRawColumn() *RawColumnKey

func (*Key) GetScalar 

func (x *Key) GetScalar() *FeatureColumnKey

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 Key_Dataframe 

type Key_Dataframe struct {
	Dataframe *DataFrameFeatureKey `protobuf:"bytes,4,opt,name=dataframe,proto3,oneof"`
}

type Key_HasMany 

type Key_HasMany struct {
	HasMany *HasManyFeatureKey `protobuf:"bytes,3,opt,name=has_many,json=hasMany,proto3,oneof"`
}

type Key_RawColumn 

type Key_RawColumn struct {
	RawColumn *RawColumnKey `protobuf:"bytes,1,opt,name=raw_column,json=rawColumn,proto3,oneof"`
}

type Key_Scalar 

type Key_Scalar struct {
	Scalar *FeatureColumnKey `protobuf:"bytes,2,opt,name=scalar,proto3,oneof"`
}

type Node 

type Node struct {

	// Corresponds to indices in Plan.nodes
	ChildrenIndices []uint32  `protobuf:"varint,1,rep,packed,name=children_indices,json=childrenIndices,proto3" json:"children_indices,omitempty"`
	Impl            *NodeImpl `protobuf:"bytes,2,opt,name=impl,proto3" json:"impl,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetChildrenIndices 

func (x *Node) GetChildrenIndices() []uint32

func (*Node) GetImpl 

func (x *Node) GetImpl() *NodeImpl

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeImpl 

type NodeImpl struct {

	// Types that are assignable to Impl:
	//
	//	*NodeImpl_Unknown
	//	*NodeImpl_GivensScan
	//	*NodeImpl_Project
	//	*NodeImpl_ChalkProject
	//	*NodeImpl_DefaultInjector
	Impl isNodeImpl_Impl `protobuf_oneof:"impl"`
	// contains filtered or unexported fields
}

func (*NodeImpl) Descriptor deprecated 

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

Deprecated: Use NodeImpl.ProtoReflect.Descriptor instead.

func (*NodeImpl) GetChalkProject 

func (x *NodeImpl) GetChalkProject() *ChalkProject

func (*NodeImpl) GetDefaultInjector 

func (x *NodeImpl) GetDefaultInjector() *DefaultInjector

func (*NodeImpl) GetGivensScan 

func (x *NodeImpl) GetGivensScan() *GivensScan

func (*NodeImpl) GetImpl 

func (m *NodeImpl) GetImpl() isNodeImpl_Impl

func (*NodeImpl) GetProject 

func (x *NodeImpl) GetProject() *Project

func (*NodeImpl) GetUnknown 

func (x *NodeImpl) GetUnknown() *UnknownNode

func (*NodeImpl) ProtoMessage 

func (*NodeImpl) ProtoMessage()

func (*NodeImpl) ProtoReflect 

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

func (*NodeImpl) Reset 

func (x *NodeImpl) Reset()

func (*NodeImpl) String 

func (x *NodeImpl) String() string

type NodeImpl_ChalkProject 

type NodeImpl_ChalkProject struct {
	ChalkProject *ChalkProject `protobuf:"bytes,4,opt,name=chalk_project,json=chalkProject,proto3,oneof"`
}

type NodeImpl_DefaultInjector 

type NodeImpl_DefaultInjector struct {
	DefaultInjector *DefaultInjector `protobuf:"bytes,5,opt,name=default_injector,json=defaultInjector,proto3,oneof"`
}

type NodeImpl_GivensScan 

type NodeImpl_GivensScan struct {
	GivensScan *GivensScan `protobuf:"bytes,2,opt,name=givens_scan,json=givensScan,proto3,oneof"`
}

type NodeImpl_Project 

type NodeImpl_Project struct {
	Project *Project `protobuf:"bytes,3,opt,name=project,proto3,oneof"`
}

type NodeImpl_Unknown 

type NodeImpl_Unknown struct {
	Unknown *UnknownNode `protobuf:"bytes,1,opt,name=unknown,proto3,oneof"`
}

type PingRequest 

type PingRequest struct {
	Num int32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetNum 

func (x *PingRequest) GetNum() int32

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	Num int32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetNum 

func (x *PingResponse) GetNum() int32

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type Plan 

type Plan struct {
	Nodes         []*Node        `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	RootNodeIdx   uint32         `protobuf:"varint,2,opt,name=root_node_idx,json=rootNodeIdx,proto3" json:"root_node_idx,omitempty"`
	PyarrowSchema *PyArrowSchema `protobuf:"bytes,3,opt,name=pyarrow_schema,json=pyarrowSchema,proto3" json:"pyarrow_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*Plan) Descriptor deprecated 

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

Deprecated: Use Plan.ProtoReflect.Descriptor instead.

func (*Plan) GetNodes 

func (x *Plan) GetNodes() []*Node

func (*Plan) GetPyarrowSchema 

func (x *Plan) GetPyarrowSchema() *PyArrowSchema

func (*Plan) GetRootNodeIdx 

func (x *Plan) GetRootNodeIdx() uint32

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) ProtoReflect 

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

func (*Plan) Reset 

func (x *Plan) Reset()

func (*Plan) String 

func (x *Plan) String() string

type Project 

type Project struct {
	Fields []*Key `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Project) Descriptor deprecated 

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetFields 

func (x *Project) GetFields() []*Key

func (*Project) ProtoMessage 

func (*Project) ProtoMessage()

func (*Project) ProtoReflect 

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

func (*Project) Reset 

func (x *Project) Reset()

func (*Project) String 

func (x *Project) String() string

type PyArrowSchema 

type PyArrowSchema struct {
	Scalars []*PyArrowSchema_ColumnSchema `protobuf:"bytes,1,rep,name=scalars,proto3" json:"scalars,omitempty"`
	Groups  []*PyArrowSchema_TableSchema  `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*PyArrowSchema) Descriptor deprecated 

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

Deprecated: Use PyArrowSchema.ProtoReflect.Descriptor instead.

func (*PyArrowSchema) GetGroups 

func (x *PyArrowSchema) GetGroups() []*PyArrowSchema_TableSchema

func (*PyArrowSchema) GetScalars 

func (x *PyArrowSchema) GetScalars() []*PyArrowSchema_ColumnSchema

func (*PyArrowSchema) ProtoMessage 

func (*PyArrowSchema) ProtoMessage()

func (*PyArrowSchema) ProtoReflect 

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

func (*PyArrowSchema) Reset 

func (x *PyArrowSchema) Reset()

func (*PyArrowSchema) String 

func (x *PyArrowSchema) String() string

type PyArrowSchema_ColumnSchema 

type PyArrowSchema_ColumnSchema struct {
	Key    *ColumnKey    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Schema *v1.ArrowType `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*PyArrowSchema_ColumnSchema) Descriptor deprecated 

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

Deprecated: Use PyArrowSchema_ColumnSchema.ProtoReflect.Descriptor instead.

func (*PyArrowSchema_ColumnSchema) GetKey 

func (x *PyArrowSchema_ColumnSchema) GetKey() *ColumnKey

func (*PyArrowSchema_ColumnSchema) GetSchema 

func (x *PyArrowSchema_ColumnSchema) GetSchema() *v1.ArrowType

func (*PyArrowSchema_ColumnSchema) ProtoMessage 

func (*PyArrowSchema_ColumnSchema) ProtoMessage()

func (*PyArrowSchema_ColumnSchema) ProtoReflect 

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

func (*PyArrowSchema_ColumnSchema) Reset 

func (x *PyArrowSchema_ColumnSchema) Reset()

func (*PyArrowSchema_ColumnSchema) String 

func (x *PyArrowSchema_ColumnSchema) String() string

type PyArrowSchema_TableSchema 

type PyArrowSchema_TableSchema struct {
	Key    *TableKey                `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Schema map[string]*v1.ArrowType `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PyArrowSchema_TableSchema) Descriptor deprecated 

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

Deprecated: Use PyArrowSchema_TableSchema.ProtoReflect.Descriptor instead.

func (*PyArrowSchema_TableSchema) GetKey 

func (x *PyArrowSchema_TableSchema) GetKey() *TableKey

func (*PyArrowSchema_TableSchema) GetSchema 

func (x *PyArrowSchema_TableSchema) GetSchema() map[string]*v1.ArrowType

func (*PyArrowSchema_TableSchema) ProtoMessage 

func (*PyArrowSchema_TableSchema) ProtoMessage()

func (*PyArrowSchema_TableSchema) ProtoReflect 

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

func (*PyArrowSchema_TableSchema) Reset 

func (x *PyArrowSchema_TableSchema) Reset()

func (*PyArrowSchema_TableSchema) String 

func (x *PyArrowSchema_TableSchema) String() string

type RawColumnKey 

type RawColumnKey struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Arbitrary computed column that does not correspond to a feature (e.g. for computing a sum(...) )

func (*RawColumnKey) Descriptor deprecated 

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

Deprecated: Use RawColumnKey.ProtoReflect.Descriptor instead.

func (*RawColumnKey) GetName 

func (x *RawColumnKey) GetName() string

func (*RawColumnKey) ProtoMessage 

func (*RawColumnKey) ProtoMessage()

func (*RawColumnKey) ProtoReflect 

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

func (*RawColumnKey) Reset 

func (x *RawColumnKey) Reset()

func (*RawColumnKey) String 

func (x *RawColumnKey) String() string

type TableKey 

type TableKey struct {

	// Types that are assignable to Key:
	//
	//	*TableKey_HasMany
	//	*TableKey_DataFrame
	Key isTableKey_Key `protobuf_oneof:"key"`
	// contains filtered or unexported fields
}

func (*TableKey) Descriptor deprecated 

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

Deprecated: Use TableKey.ProtoReflect.Descriptor instead.

func (*TableKey) GetDataFrame 

func (x *TableKey) GetDataFrame() *DataFrameFeatureKey

func (*TableKey) GetHasMany 

func (x *TableKey) GetHasMany() *HasManyFeatureKey

func (*TableKey) GetKey 

func (m *TableKey) GetKey() isTableKey_Key

func (*TableKey) ProtoMessage 

func (*TableKey) ProtoMessage()

func (*TableKey) ProtoReflect 

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

func (*TableKey) Reset 

func (x *TableKey) Reset()

func (*TableKey) String 

func (x *TableKey) String() string

type TableKey_DataFrame 

type TableKey_DataFrame struct {
	DataFrame *DataFrameFeatureKey `protobuf:"bytes,2,opt,name=data_frame,json=dataFrame,proto3,oneof"`
}

type TableKey_HasMany 

type TableKey_HasMany struct {
	HasMany *HasManyFeatureKey `protobuf:"bytes,1,opt,name=has_many,json=hasMany,proto3,oneof"`
}

type UnknownNode 

type UnknownNode struct {
	TypeName string `protobuf:"bytes,1,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UnknownNode) Descriptor deprecated 

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

Deprecated: Use UnknownNode.ProtoReflect.Descriptor instead.

func (*UnknownNode) GetTypeName 

func (x *UnknownNode) GetTypeName() string

func (*UnknownNode) ProtoMessage 

func (*UnknownNode) ProtoMessage()

func (*UnknownNode) ProtoReflect 

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

func (*UnknownNode) Reset 

func (x *UnknownNode) Reset()

func (*UnknownNode) String 

func (x *UnknownNode) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.