udfspb

package
v0.0.0-...-8540621 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthUdfs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUdfs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUdfs = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var UDFExecType_name = map[int32]string{
	0: "SCALAR_UDF",
	1: "UDA",
}
View Source 
var UDFExecType_value = map[string]int32{
	"SCALAR_UDF": 0,
	"UDA":        1,
}
View Source 
var UDFSourceExecutor_name = map[int32]string{
	0: "UDF_UNSPECIFIED",
	1: "UDF_ALL",
	2: "UDF_PEM",
	3: "UDF_KELVIN",
}
View Source 
var UDFSourceExecutor_value = map[string]int32{
	"UDF_UNSPECIFIED": 0,
	"UDF_ALL":         1,
	"UDF_PEM":         2,
	"UDF_KELVIN":      3,
}
View Source 
var UDTFSourceExecutor_name = map[int32]string{
	0: "UDTF_UNSPECIFIED",
	1: "UDTF_ALL_AGENTS",
	2: "UDTF_ALL_PEM",
	3: "UDTF_ALL_KELVIN",
	4: "UDTF_SUBSET_PEM",
	5: "UDTF_SUBSET_KELVIN",
	6: "UDTF_ONE_KELVIN",
}
View Source 
var UDTFSourceExecutor_value = map[string]int32{
	"UDTF_UNSPECIFIED":   0,
	"UDTF_ALL_AGENTS":    1,
	"UDTF_ALL_PEM":       2,
	"UDTF_ALL_KELVIN":    3,
	"UDTF_SUBSET_PEM":    4,
	"UDTF_SUBSET_KELVIN": 5,
	"UDTF_ONE_KELVIN":    6,
}

Functions

This section is empty.

Types

type Doc 

type Doc struct {
	Name     string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Brief    string        `protobuf:"bytes,2,opt,name=brief,proto3" json:"brief,omitempty"`
	Desc     string        `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Examples []*ExampleDoc `protobuf:"bytes,4,rep,name=examples,proto3" json:"examples,omitempty"`
	// Types that are valid to be assigned to U:
	//	*Doc_ScalarUdfDoc
	//	*Doc_UdaDoc
	U isDoc_U `protobuf_oneof:"u"`
}

func (*Doc) Descriptor 

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

func (*Doc) Equal 

func (this *Doc) Equal(that interface{}) bool

func (*Doc) GetBrief 

func (m *Doc) GetBrief() string

func (*Doc) GetDesc 

func (m *Doc) GetDesc() string

func (*Doc) GetExamples 

func (m *Doc) GetExamples() []*ExampleDoc

func (*Doc) GetName 

func (m *Doc) GetName() string

func (*Doc) GetScalarUdfDoc 

func (m *Doc) GetScalarUdfDoc() *ScalarDoc

func (*Doc) GetU 

func (m *Doc) GetU() isDoc_U

func (*Doc) GetUdaDoc 

func (m *Doc) GetUdaDoc() *UDADoc

func (*Doc) GoString 

func (this *Doc) GoString() string

func (*Doc) Marshal 

func (m *Doc) Marshal() (dAtA []byte, err error)

func (*Doc) MarshalTo 

func (m *Doc) MarshalTo(dAtA []byte) (int, error)

func (*Doc) MarshalToSizedBuffer 

func (m *Doc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Doc) ProtoMessage 

func (*Doc) ProtoMessage()

func (*Doc) Reset 

func (m *Doc) Reset()

func (*Doc) Size 

func (m *Doc) Size() (n int)

func (*Doc) String 

func (this *Doc) String() string

func (*Doc) Unmarshal 

func (m *Doc) Unmarshal(dAtA []byte) error

func (*Doc) XXX_DiscardUnknown 

func (m *Doc) XXX_DiscardUnknown()

func (*Doc) XXX_Marshal 

func (m *Doc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Doc) XXX_Merge 

func (m *Doc) XXX_Merge(src proto.Message)

func (*Doc) XXX_OneofWrappers 

func (*Doc) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Doc) XXX_Size 

func (m *Doc) XXX_Size() int

func (*Doc) XXX_Unmarshal 

func (m *Doc) XXX_Unmarshal(b []byte) error

type Doc_ScalarUdfDoc 

type Doc_ScalarUdfDoc struct {
	ScalarUdfDoc *ScalarDoc `protobuf:"bytes,5,opt,name=scalar_udf_doc,json=scalarUdfDoc,proto3,oneof" json:"scalar_udf_doc,omitempty"`
}

func (*Doc_ScalarUdfDoc) Equal 

func (this *Doc_ScalarUdfDoc) Equal(that interface{}) bool

func (*Doc_ScalarUdfDoc) GoString 

func (this *Doc_ScalarUdfDoc) GoString() string

func (*Doc_ScalarUdfDoc) MarshalTo 

func (m *Doc_ScalarUdfDoc) MarshalTo(dAtA []byte) (int, error)

func (*Doc_ScalarUdfDoc) MarshalToSizedBuffer 

func (m *Doc_ScalarUdfDoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Doc_ScalarUdfDoc) Size 

func (m *Doc_ScalarUdfDoc) Size() (n int)

func (*Doc_ScalarUdfDoc) String 

func (this *Doc_ScalarUdfDoc) String() string

type Doc_UdaDoc 

type Doc_UdaDoc struct {
	UdaDoc *UDADoc `protobuf:"bytes,6,opt,name=uda_doc,json=udaDoc,proto3,oneof" json:"uda_doc,omitempty"`
}

func (*Doc_UdaDoc) Equal 

func (this *Doc_UdaDoc) Equal(that interface{}) bool

func (*Doc_UdaDoc) GoString 

func (this *Doc_UdaDoc) GoString() string

func (*Doc_UdaDoc) MarshalTo 

func (m *Doc_UdaDoc) MarshalTo(dAtA []byte) (int, error)

func (*Doc_UdaDoc) MarshalToSizedBuffer 

func (m *Doc_UdaDoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Doc_UdaDoc) Size 

func (m *Doc_UdaDoc) Size() (n int)

func (*Doc_UdaDoc) String 

func (this *Doc_UdaDoc) String() string

type Docs 

type Docs struct {
	Udf []*Doc `protobuf:"bytes,1,rep,name=udf,proto3" json:"udf,omitempty"`
}

func (*Docs) Descriptor 

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

func (*Docs) Equal 

func (this *Docs) Equal(that interface{}) bool

func (*Docs) GetUdf 

func (m *Docs) GetUdf() []*Doc

func (*Docs) GoString 

func (this *Docs) GoString() string

func (*Docs) Marshal 

func (m *Docs) Marshal() (dAtA []byte, err error)

func (*Docs) MarshalTo 

func (m *Docs) MarshalTo(dAtA []byte) (int, error)

func (*Docs) MarshalToSizedBuffer 

func (m *Docs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Docs) ProtoMessage 

func (*Docs) ProtoMessage()

func (*Docs) Reset 

func (m *Docs) Reset()

func (*Docs) Size 

func (m *Docs) Size() (n int)

func (*Docs) String 

func (this *Docs) String() string

func (*Docs) Unmarshal 

func (m *Docs) Unmarshal(dAtA []byte) error

func (*Docs) XXX_DiscardUnknown 

func (m *Docs) XXX_DiscardUnknown()

func (*Docs) XXX_Marshal 

func (m *Docs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Docs) XXX_Merge 

func (m *Docs) XXX_Merge(src proto.Message)

func (*Docs) XXX_Size 

func (m *Docs) XXX_Size() int

func (*Docs) XXX_Unmarshal 

func (m *Docs) XXX_Unmarshal(b []byte) error

type ExampleDoc 

type ExampleDoc struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ExampleDoc) Descriptor 

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

func (*ExampleDoc) Equal 

func (this *ExampleDoc) Equal(that interface{}) bool

func (*ExampleDoc) GetValue 

func (m *ExampleDoc) GetValue() string

func (*ExampleDoc) GoString 

func (this *ExampleDoc) GoString() string

func (*ExampleDoc) Marshal 

func (m *ExampleDoc) Marshal() (dAtA []byte, err error)

func (*ExampleDoc) MarshalTo 

func (m *ExampleDoc) MarshalTo(dAtA []byte) (int, error)

func (*ExampleDoc) MarshalToSizedBuffer 

func (m *ExampleDoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExampleDoc) ProtoMessage 

func (*ExampleDoc) ProtoMessage()

func (*ExampleDoc) Reset 

func (m *ExampleDoc) Reset()

func (*ExampleDoc) Size 

func (m *ExampleDoc) Size() (n int)

func (*ExampleDoc) String 

func (this *ExampleDoc) String() string

func (*ExampleDoc) Unmarshal 

func (m *ExampleDoc) Unmarshal(dAtA []byte) error

func (*ExampleDoc) XXX_DiscardUnknown 

func (m *ExampleDoc) XXX_DiscardUnknown()

func (*ExampleDoc) XXX_Marshal 

func (m *ExampleDoc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExampleDoc) XXX_Merge 

func (m *ExampleDoc) XXX_Merge(src proto.Message)

func (*ExampleDoc) XXX_Size 

func (m *ExampleDoc) XXX_Size() int

func (*ExampleDoc) XXX_Unmarshal 

func (m *ExampleDoc) XXX_Unmarshal(b []byte) error

type IdentDoc 

type IdentDoc struct {
	Ident string           `protobuf:"bytes,1,opt,name=ident,proto3" json:"ident,omitempty"`
	Desc  string           `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	Type  typespb.DataType `protobuf:"varint,3,opt,name=type,proto3,enum=px.types.DataType" json:"type,omitempty"`
}

func (*IdentDoc) Descriptor 

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

func (*IdentDoc) Equal 

func (this *IdentDoc) Equal(that interface{}) bool

func (*IdentDoc) GetDesc 

func (m *IdentDoc) GetDesc() string

func (*IdentDoc) GetIdent 

func (m *IdentDoc) GetIdent() string

func (*IdentDoc) GetType 

func (m *IdentDoc) GetType() typespb.DataType

func (*IdentDoc) GoString 

func (this *IdentDoc) GoString() string

func (*IdentDoc) Marshal 

func (m *IdentDoc) Marshal() (dAtA []byte, err error)

func (*IdentDoc) MarshalTo 

func (m *IdentDoc) MarshalTo(dAtA []byte) (int, error)

func (*IdentDoc) MarshalToSizedBuffer 

func (m *IdentDoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IdentDoc) ProtoMessage 

func (*IdentDoc) ProtoMessage()

func (*IdentDoc) Reset 

func (m *IdentDoc) Reset()

func (*IdentDoc) Size 

func (m *IdentDoc) Size() (n int)

func (*IdentDoc) String 

func (this *IdentDoc) String() string

func (*IdentDoc) Unmarshal 

func (m *IdentDoc) Unmarshal(dAtA []byte) error

func (*IdentDoc) XXX_DiscardUnknown 

func (m *IdentDoc) XXX_DiscardUnknown()

func (*IdentDoc) XXX_Marshal 

func (m *IdentDoc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IdentDoc) XXX_Merge 

func (m *IdentDoc) XXX_Merge(src proto.Message)

func (*IdentDoc) XXX_Size 

func (m *IdentDoc) XXX_Size() int

func (*IdentDoc) XXX_Unmarshal 

func (m *IdentDoc) XXX_Unmarshal(b []byte) error

type ScalarDoc 

type ScalarDoc struct {
	Args   []*IdentDoc `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	Retval *IdentDoc   `protobuf:"bytes,2,opt,name=retval,proto3" json:"retval,omitempty"`
}

func (*ScalarDoc) Descriptor 

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

func (*ScalarDoc) Equal 

func (this *ScalarDoc) Equal(that interface{}) bool

func (*ScalarDoc) GetArgs 

func (m *ScalarDoc) GetArgs() []*IdentDoc

func (*ScalarDoc) GetRetval 

func (m *ScalarDoc) GetRetval() *IdentDoc

func (*ScalarDoc) GoString 

func (this *ScalarDoc) GoString() string

func (*ScalarDoc) Marshal 

func (m *ScalarDoc) Marshal() (dAtA []byte, err error)

func (*ScalarDoc) MarshalTo 

func (m *ScalarDoc) MarshalTo(dAtA []byte) (int, error)

func (*ScalarDoc) MarshalToSizedBuffer 

func (m *ScalarDoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarDoc) ProtoMessage 

func (*ScalarDoc) ProtoMessage()

func (*ScalarDoc) Reset 

func (m *ScalarDoc) Reset()

func (*ScalarDoc) Size 

func (m *ScalarDoc) Size() (n int)

func (*ScalarDoc) String 

func (this *ScalarDoc) String() string

func (*ScalarDoc) Unmarshal 

func (m *ScalarDoc) Unmarshal(dAtA []byte) error

func (*ScalarDoc) XXX_DiscardUnknown 

func (m *ScalarDoc) XXX_DiscardUnknown()

func (*ScalarDoc) XXX_Marshal 

func (m *ScalarDoc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScalarDoc) XXX_Merge 

func (m *ScalarDoc) XXX_Merge(src proto.Message)

func (*ScalarDoc) XXX_Size 

func (m *ScalarDoc) XXX_Size() int

func (*ScalarDoc) XXX_Unmarshal 

func (m *ScalarDoc) XXX_Unmarshal(b []byte) error

type ScalarUDFSpec 

type ScalarUDFSpec struct {
	Name         string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InitArgTypes []typespb.DataType `` /* 130-byte string literal not displayed */
	ExecArgTypes []typespb.DataType `` /* 130-byte string literal not displayed */
	ReturnType   typespb.DataType   `protobuf:"varint,4,opt,name=return_type,json=returnType,proto3,enum=px.types.DataType" json:"return_type,omitempty"`
	Executor     UDFSourceExecutor  `protobuf:"varint,5,opt,name=executor,proto3,enum=px.carnot.udfspb.UDFSourceExecutor" json:"executor,omitempty"`
}

func (*ScalarUDFSpec) Descriptor 

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

func (*ScalarUDFSpec) Equal 

func (this *ScalarUDFSpec) Equal(that interface{}) bool

func (*ScalarUDFSpec) GetExecArgTypes 

func (m *ScalarUDFSpec) GetExecArgTypes() []typespb.DataType

func (*ScalarUDFSpec) GetExecutor 

func (m *ScalarUDFSpec) GetExecutor() UDFSourceExecutor

func (*ScalarUDFSpec) GetInitArgTypes 

func (m *ScalarUDFSpec) GetInitArgTypes() []typespb.DataType

func (*ScalarUDFSpec) GetName 

func (m *ScalarUDFSpec) GetName() string

func (*ScalarUDFSpec) GetReturnType 

func (m *ScalarUDFSpec) GetReturnType() typespb.DataType

func (*ScalarUDFSpec) GoString 

func (this *ScalarUDFSpec) GoString() string

func (*ScalarUDFSpec) Marshal 

func (m *ScalarUDFSpec) Marshal() (dAtA []byte, err error)

func (*ScalarUDFSpec) MarshalTo 

func (m *ScalarUDFSpec) MarshalTo(dAtA []byte) (int, error)

func (*ScalarUDFSpec) MarshalToSizedBuffer 

func (m *ScalarUDFSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarUDFSpec) ProtoMessage 

func (*ScalarUDFSpec) ProtoMessage()

func (*ScalarUDFSpec) Reset 

func (m *ScalarUDFSpec) Reset()

func (*ScalarUDFSpec) Size 

func (m *ScalarUDFSpec) Size() (n int)

func (*ScalarUDFSpec) String 

func (this *ScalarUDFSpec) String() string

func (*ScalarUDFSpec) Unmarshal 

func (m *ScalarUDFSpec) Unmarshal(dAtA []byte) error

func (*ScalarUDFSpec) XXX_DiscardUnknown 

func (m *ScalarUDFSpec) XXX_DiscardUnknown()

func (*ScalarUDFSpec) XXX_Marshal 

func (m *ScalarUDFSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScalarUDFSpec) XXX_Merge 

func (m *ScalarUDFSpec) XXX_Merge(src proto.Message)

func (*ScalarUDFSpec) XXX_Size 

func (m *ScalarUDFSpec) XXX_Size() int

func (*ScalarUDFSpec) XXX_Unmarshal 

func (m *ScalarUDFSpec) XXX_Unmarshal(b []byte) error

type SemanticInferenceRule 

type SemanticInferenceRule struct {
	Name           string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UdfExecType    UDFExecType            `` /* 131-byte string literal not displayed */
	InitArgTypes   []typespb.SemanticType `` /* 134-byte string literal not displayed */
	UpdateArgTypes []typespb.SemanticType `` /* 140-byte string literal not displayed */
	ExecArgTypes   []typespb.SemanticType `` /* 134-byte string literal not displayed */
	OutputType     typespb.SemanticType   `protobuf:"varint,6,opt,name=output_type,json=outputType,proto3,enum=px.types.SemanticType" json:"output_type,omitempty"`
}

func (*SemanticInferenceRule) Descriptor 

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

func (*SemanticInferenceRule) Equal 

func (this *SemanticInferenceRule) Equal(that interface{}) bool

func (*SemanticInferenceRule) GetExecArgTypes 

func (m *SemanticInferenceRule) GetExecArgTypes() []typespb.SemanticType

func (*SemanticInferenceRule) GetInitArgTypes 

func (m *SemanticInferenceRule) GetInitArgTypes() []typespb.SemanticType

func (*SemanticInferenceRule) GetName 

func (m *SemanticInferenceRule) GetName() string

func (*SemanticInferenceRule) GetOutputType 

func (m *SemanticInferenceRule) GetOutputType() typespb.SemanticType

func (*SemanticInferenceRule) GetUdfExecType 

func (m *SemanticInferenceRule) GetUdfExecType() UDFExecType

func (*SemanticInferenceRule) GetUpdateArgTypes 

func (m *SemanticInferenceRule) GetUpdateArgTypes() []typespb.SemanticType

func (*SemanticInferenceRule) GoString 

func (this *SemanticInferenceRule) GoString() string

func (*SemanticInferenceRule) Marshal 

func (m *SemanticInferenceRule) Marshal() (dAtA []byte, err error)

func (*SemanticInferenceRule) MarshalTo 

func (m *SemanticInferenceRule) MarshalTo(dAtA []byte) (int, error)

func (*SemanticInferenceRule) MarshalToSizedBuffer 

func (m *SemanticInferenceRule) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SemanticInferenceRule) ProtoMessage 

func (*SemanticInferenceRule) ProtoMessage()

func (*SemanticInferenceRule) Reset 

func (m *SemanticInferenceRule) Reset()

func (*SemanticInferenceRule) Size 

func (m *SemanticInferenceRule) Size() (n int)

func (*SemanticInferenceRule) String 

func (this *SemanticInferenceRule) String() string

func (*SemanticInferenceRule) Unmarshal 

func (m *SemanticInferenceRule) Unmarshal(dAtA []byte) error

func (*SemanticInferenceRule) XXX_DiscardUnknown 

func (m *SemanticInferenceRule) XXX_DiscardUnknown()

func (*SemanticInferenceRule) XXX_Marshal 

func (m *SemanticInferenceRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SemanticInferenceRule) XXX_Merge 

func (m *SemanticInferenceRule) XXX_Merge(src proto.Message)

func (*SemanticInferenceRule) XXX_Size 

func (m *SemanticInferenceRule) XXX_Size() int

func (*SemanticInferenceRule) XXX_Unmarshal 

func (m *SemanticInferenceRule) XXX_Unmarshal(b []byte) error

type UDADoc 

type UDADoc struct {
	UpdateArgs []*IdentDoc `protobuf:"bytes,1,rep,name=update_args,json=updateArgs,proto3" json:"update_args,omitempty"`
	Result     *IdentDoc   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
}

func (*UDADoc) Descriptor 

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

func (*UDADoc) Equal 

func (this *UDADoc) Equal(that interface{}) bool

func (*UDADoc) GetResult 

func (m *UDADoc) GetResult() *IdentDoc

func (*UDADoc) GetUpdateArgs 

func (m *UDADoc) GetUpdateArgs() []*IdentDoc

func (*UDADoc) GoString 

func (this *UDADoc) GoString() string

func (*UDADoc) Marshal 

func (m *UDADoc) Marshal() (dAtA []byte, err error)

func (*UDADoc) MarshalTo 

func (m *UDADoc) MarshalTo(dAtA []byte) (int, error)

func (*UDADoc) MarshalToSizedBuffer 

func (m *UDADoc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UDADoc) ProtoMessage 

func (*UDADoc) ProtoMessage()

func (*UDADoc) Reset 

func (m *UDADoc) Reset()

func (*UDADoc) Size 

func (m *UDADoc) Size() (n int)

func (*UDADoc) String 

func (this *UDADoc) String() string

func (*UDADoc) Unmarshal 

func (m *UDADoc) Unmarshal(dAtA []byte) error

func (*UDADoc) XXX_DiscardUnknown 

func (m *UDADoc) XXX_DiscardUnknown()

func (*UDADoc) XXX_Marshal 

func (m *UDADoc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDADoc) XXX_Merge 

func (m *UDADoc) XXX_Merge(src proto.Message)

func (*UDADoc) XXX_Size 

func (m *UDADoc) XXX_Size() int

func (*UDADoc) XXX_Unmarshal 

func (m *UDADoc) XXX_Unmarshal(b []byte) error

type UDASpec 

type UDASpec struct {
	Name            string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InitArgTypes    []typespb.DataType `` /* 130-byte string literal not displayed */
	UpdateArgTypes  []typespb.DataType `` /* 136-byte string literal not displayed */
	FinalizeType    typespb.DataType   `protobuf:"varint,4,opt,name=finalize_type,json=finalizeType,proto3,enum=px.types.DataType" json:"finalize_type,omitempty"`
	SupportsPartial bool               `protobuf:"varint,5,opt,name=supports_partial,json=supportsPartial,proto3" json:"supports_partial,omitempty"`
}

func (*UDASpec) Descriptor 

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

func (*UDASpec) Equal 

func (this *UDASpec) Equal(that interface{}) bool

func (*UDASpec) GetFinalizeType 

func (m *UDASpec) GetFinalizeType() typespb.DataType

func (*UDASpec) GetInitArgTypes 

func (m *UDASpec) GetInitArgTypes() []typespb.DataType

func (*UDASpec) GetName 

func (m *UDASpec) GetName() string

func (*UDASpec) GetSupportsPartial 

func (m *UDASpec) GetSupportsPartial() bool

func (*UDASpec) GetUpdateArgTypes 

func (m *UDASpec) GetUpdateArgTypes() []typespb.DataType

func (*UDASpec) GoString 

func (this *UDASpec) GoString() string

func (*UDASpec) Marshal 

func (m *UDASpec) Marshal() (dAtA []byte, err error)

func (*UDASpec) MarshalTo 

func (m *UDASpec) MarshalTo(dAtA []byte) (int, error)

func (*UDASpec) MarshalToSizedBuffer 

func (m *UDASpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UDASpec) ProtoMessage 

func (*UDASpec) ProtoMessage()

func (*UDASpec) Reset 

func (m *UDASpec) Reset()

func (*UDASpec) Size 

func (m *UDASpec) Size() (n int)

func (*UDASpec) String 

func (this *UDASpec) String() string

func (*UDASpec) Unmarshal 

func (m *UDASpec) Unmarshal(dAtA []byte) error

func (*UDASpec) XXX_DiscardUnknown 

func (m *UDASpec) XXX_DiscardUnknown()

func (*UDASpec) XXX_Marshal 

func (m *UDASpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDASpec) XXX_Merge 

func (m *UDASpec) XXX_Merge(src proto.Message)

func (*UDASpec) XXX_Size 

func (m *UDASpec) XXX_Size() int

func (*UDASpec) XXX_Unmarshal 

func (m *UDASpec) XXX_Unmarshal(b []byte) error

type UDFExecType 

type UDFExecType int32
const (
	SCALAR_UDF UDFExecType = 0
	UDA        UDFExecType = 1
)

func (UDFExecType) EnumDescriptor 

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

func (UDFExecType) String 

func (x UDFExecType) String() string

type UDFInfo 

type UDFInfo struct {
	Udas              []*UDASpec               `protobuf:"bytes,1,rep,name=udas,proto3" json:"udas,omitempty"`
	ScalarUdfs        []*ScalarUDFSpec         `protobuf:"bytes,2,rep,name=scalar_udfs,json=scalarUdfs,proto3" json:"scalar_udfs,omitempty"`
	Udtfs             []*UDTFSourceSpec        `protobuf:"bytes,3,rep,name=udtfs,proto3" json:"udtfs,omitempty"`
	SemanticTypeRules []*SemanticInferenceRule `protobuf:"bytes,4,rep,name=semantic_type_rules,json=semanticTypeRules,proto3" json:"semantic_type_rules,omitempty"`
}

func (*UDFInfo) Descriptor 

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

func (*UDFInfo) Equal 

func (this *UDFInfo) Equal(that interface{}) bool

func (*UDFInfo) GetScalarUdfs 

func (m *UDFInfo) GetScalarUdfs() []*ScalarUDFSpec

func (*UDFInfo) GetSemanticTypeRules 

func (m *UDFInfo) GetSemanticTypeRules() []*SemanticInferenceRule

func (*UDFInfo) GetUdas 

func (m *UDFInfo) GetUdas() []*UDASpec

func (*UDFInfo) GetUdtfs 

func (m *UDFInfo) GetUdtfs() []*UDTFSourceSpec

func (*UDFInfo) GoString 

func (this *UDFInfo) GoString() string

func (*UDFInfo) Marshal 

func (m *UDFInfo) Marshal() (dAtA []byte, err error)

func (*UDFInfo) MarshalTo 

func (m *UDFInfo) MarshalTo(dAtA []byte) (int, error)

func (*UDFInfo) MarshalToSizedBuffer 

func (m *UDFInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UDFInfo) ProtoMessage 

func (*UDFInfo) ProtoMessage()

func (*UDFInfo) Reset 

func (m *UDFInfo) Reset()

func (*UDFInfo) Size 

func (m *UDFInfo) Size() (n int)

func (*UDFInfo) String 

func (this *UDFInfo) String() string

func (*UDFInfo) Unmarshal 

func (m *UDFInfo) Unmarshal(dAtA []byte) error

func (*UDFInfo) XXX_DiscardUnknown 

func (m *UDFInfo) XXX_DiscardUnknown()

func (*UDFInfo) XXX_Marshal 

func (m *UDFInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDFInfo) XXX_Merge 

func (m *UDFInfo) XXX_Merge(src proto.Message)

func (*UDFInfo) XXX_Size 

func (m *UDFInfo) XXX_Size() int

func (*UDFInfo) XXX_Unmarshal 

func (m *UDFInfo) XXX_Unmarshal(b []byte) error

type UDFSourceExecutor 

type UDFSourceExecutor int32
const (
	UDF_UNSPECIFIED UDFSourceExecutor = 0
	UDF_ALL         UDFSourceExecutor = 1
	UDF_PEM         UDFSourceExecutor = 2
	UDF_KELVIN      UDFSourceExecutor = 3
)

func (UDFSourceExecutor) EnumDescriptor 

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

func (UDFSourceExecutor) String 

func (x UDFSourceExecutor) String() string

type UDTFSourceExecutor 

type UDTFSourceExecutor int32
const (
	UDTF_UNSPECIFIED   UDTFSourceExecutor = 0
	UDTF_ALL_AGENTS    UDTFSourceExecutor = 1
	UDTF_ALL_PEM       UDTFSourceExecutor = 2
	UDTF_ALL_KELVIN    UDTFSourceExecutor = 3
	UDTF_SUBSET_PEM    UDTFSourceExecutor = 4
	UDTF_SUBSET_KELVIN UDTFSourceExecutor = 5
	UDTF_ONE_KELVIN    UDTFSourceExecutor = 6
)

func (UDTFSourceExecutor) EnumDescriptor 

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

func (UDTFSourceExecutor) String 

func (x UDTFSourceExecutor) String() string

type UDTFSourceSpec 

type UDTFSourceSpec struct {
	Name     string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args     []*UDTFSourceSpec_Arg `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Executor UDTFSourceExecutor    `protobuf:"varint,3,opt,name=executor,proto3,enum=px.carnot.udfspb.UDTFSourceExecutor" json:"executor,omitempty"`
	Relation *schemapb.Relation    `protobuf:"bytes,4,opt,name=relation,proto3" json:"relation,omitempty"`
}

func (*UDTFSourceSpec) Descriptor 

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

func (*UDTFSourceSpec) Equal 

func (this *UDTFSourceSpec) Equal(that interface{}) bool

func (*UDTFSourceSpec) GetArgs 

func (m *UDTFSourceSpec) GetArgs() []*UDTFSourceSpec_Arg

func (*UDTFSourceSpec) GetExecutor 

func (m *UDTFSourceSpec) GetExecutor() UDTFSourceExecutor

func (*UDTFSourceSpec) GetName 

func (m *UDTFSourceSpec) GetName() string

func (*UDTFSourceSpec) GetRelation 

func (m *UDTFSourceSpec) GetRelation() *schemapb.Relation

func (*UDTFSourceSpec) GoString 

func (this *UDTFSourceSpec) GoString() string

func (*UDTFSourceSpec) Marshal 

func (m *UDTFSourceSpec) Marshal() (dAtA []byte, err error)

func (*UDTFSourceSpec) MarshalTo 

func (m *UDTFSourceSpec) MarshalTo(dAtA []byte) (int, error)

func (*UDTFSourceSpec) MarshalToSizedBuffer 

func (m *UDTFSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UDTFSourceSpec) ProtoMessage 

func (*UDTFSourceSpec) ProtoMessage()

func (*UDTFSourceSpec) Reset 

func (m *UDTFSourceSpec) Reset()

func (*UDTFSourceSpec) Size 

func (m *UDTFSourceSpec) Size() (n int)

func (*UDTFSourceSpec) String 

func (this *UDTFSourceSpec) String() string

func (*UDTFSourceSpec) Unmarshal 

func (m *UDTFSourceSpec) Unmarshal(dAtA []byte) error

func (*UDTFSourceSpec) XXX_DiscardUnknown 

func (m *UDTFSourceSpec) XXX_DiscardUnknown()

func (*UDTFSourceSpec) XXX_Marshal 

func (m *UDTFSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDTFSourceSpec) XXX_Merge 

func (m *UDTFSourceSpec) XXX_Merge(src proto.Message)

func (*UDTFSourceSpec) XXX_Size 

func (m *UDTFSourceSpec) XXX_Size() int

func (*UDTFSourceSpec) XXX_Unmarshal 

func (m *UDTFSourceSpec) XXX_Unmarshal(b []byte) error

type UDTFSourceSpec_Arg 

type UDTFSourceSpec_Arg struct {
	Name         string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ArgType      typespb.DataType     `protobuf:"varint,2,opt,name=arg_type,json=argType,proto3,enum=px.types.DataType" json:"arg_type,omitempty"`
	SemanticType typespb.SemanticType `protobuf:"varint,3,opt,name=semantic_type,json=semanticType,proto3,enum=px.types.SemanticType" json:"semantic_type,omitempty"`
	DefaultValue *planpb.ScalarValue  `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
}

func (*UDTFSourceSpec_Arg) Descriptor 

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

func (*UDTFSourceSpec_Arg) Equal 

func (this *UDTFSourceSpec_Arg) Equal(that interface{}) bool

func (*UDTFSourceSpec_Arg) GetArgType 

func (m *UDTFSourceSpec_Arg) GetArgType() typespb.DataType

func (*UDTFSourceSpec_Arg) GetDefaultValue 

func (m *UDTFSourceSpec_Arg) GetDefaultValue() *planpb.ScalarValue

func (*UDTFSourceSpec_Arg) GetName 

func (m *UDTFSourceSpec_Arg) GetName() string

func (*UDTFSourceSpec_Arg) GetSemanticType 

func (m *UDTFSourceSpec_Arg) GetSemanticType() typespb.SemanticType

func (*UDTFSourceSpec_Arg) GoString 

func (this *UDTFSourceSpec_Arg) GoString() string

func (*UDTFSourceSpec_Arg) Marshal 

func (m *UDTFSourceSpec_Arg) Marshal() (dAtA []byte, err error)

func (*UDTFSourceSpec_Arg) MarshalTo 

func (m *UDTFSourceSpec_Arg) MarshalTo(dAtA []byte) (int, error)

func (*UDTFSourceSpec_Arg) MarshalToSizedBuffer 

func (m *UDTFSourceSpec_Arg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UDTFSourceSpec_Arg) ProtoMessage 

func (*UDTFSourceSpec_Arg) ProtoMessage()

func (*UDTFSourceSpec_Arg) Reset 

func (m *UDTFSourceSpec_Arg) Reset()

func (*UDTFSourceSpec_Arg) Size 

func (m *UDTFSourceSpec_Arg) Size() (n int)

func (*UDTFSourceSpec_Arg) String 

func (this *UDTFSourceSpec_Arg) String() string

func (*UDTFSourceSpec_Arg) Unmarshal 

func (m *UDTFSourceSpec_Arg) Unmarshal(dAtA []byte) error

func (*UDTFSourceSpec_Arg) XXX_DiscardUnknown 

func (m *UDTFSourceSpec_Arg) XXX_DiscardUnknown()

func (*UDTFSourceSpec_Arg) XXX_Marshal 

func (m *UDTFSourceSpec_Arg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDTFSourceSpec_Arg) XXX_Merge 

func (m *UDTFSourceSpec_Arg) XXX_Merge(src proto.Message)

func (*UDTFSourceSpec_Arg) XXX_Size 

func (m *UDTFSourceSpec_Arg) XXX_Size() int

func (*UDTFSourceSpec_Arg) XXX_Unmarshal 

func (m *UDTFSourceSpec_Arg) XXX_Unmarshal(b []byte) error

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.