Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ValueType_Enum_name = map[int32]string{
		0:  "INVALID",
		1:  "BYTES",
		2:  "STRING",
		3:  "INT32",
		4:  "INT64",
		5:  "DOUBLE",
		6:  "FLOAT",
		7:  "BOOL",
		11: "BYTES_LIST",
		12: "STRING_LIST",
		13: "INT32_LIST",
		14: "INT64_LIST",
		15: "DOUBLE_LIST",
		16: "FLOAT_LIST",
		17: "BOOL_LIST",
	}
	ValueType_Enum_value = map[string]int32{
		"INVALID":     0,
		"BYTES":       1,
		"STRING":      2,
		"INT32":       3,
		"INT64":       4,
		"DOUBLE":      5,
		"FLOAT":       6,
		"BOOL":        7,
		"BYTES_LIST":  11,
		"STRING_LIST": 12,
		"INT32_LIST":  13,
		"INT64_LIST":  14,
		"DOUBLE_LIST": 15,
		"FLOAT_LIST":  16,
		"BOOL_LIST":   17,
	}
)

    Enum value maps for ValueType_Enum.

    View Source
    var File_feast_types_FeatureRowExtended_proto protoreflect.FileDescriptor
    View Source
    var File_feast_types_FeatureRow_proto protoreflect.FileDescriptor
    View Source
    var File_feast_types_Field_proto protoreflect.FileDescriptor
    View Source
    var File_feast_types_Value_proto protoreflect.FileDescriptor

    Functions

    This section is empty.

    Types

    type Attempt

    type Attempt struct {
    	Attempts int32  `protobuf:"varint,1,opt,name=attempts,proto3" json:"attempts,omitempty"`
    	Error    *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    	// contains filtered or unexported fields
    }

    func (*Attempt) Descriptor

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

      Deprecated: Use Attempt.ProtoReflect.Descriptor instead.

      func (*Attempt) GetAttempts

      func (x *Attempt) GetAttempts() int32

      func (*Attempt) GetError

      func (x *Attempt) GetError() *Error

      func (*Attempt) ProtoMessage

      func (*Attempt) ProtoMessage()

      func (*Attempt) ProtoReflect

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

      func (*Attempt) Reset

      func (x *Attempt) Reset()

      func (*Attempt) String

      func (x *Attempt) String() string

      type BoolList

      type BoolList struct {
      	Val []bool `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
      	// contains filtered or unexported fields
      }

      func (*BoolList) Descriptor

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

        Deprecated: Use BoolList.ProtoReflect.Descriptor instead.

        func (*BoolList) GetVal

        func (x *BoolList) GetVal() []bool

        func (*BoolList) ProtoMessage

        func (*BoolList) ProtoMessage()

        func (*BoolList) ProtoReflect

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

        func (*BoolList) Reset

        func (x *BoolList) Reset()

        func (*BoolList) String

        func (x *BoolList) String() string

        type BytesList

        type BytesList struct {
        	Val [][]byte `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
        	// contains filtered or unexported fields
        }

        func (*BytesList) Descriptor

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

          Deprecated: Use BytesList.ProtoReflect.Descriptor instead.

          func (*BytesList) GetVal

          func (x *BytesList) GetVal() [][]byte

          func (*BytesList) ProtoMessage

          func (*BytesList) ProtoMessage()

          func (*BytesList) ProtoReflect

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

          func (*BytesList) Reset

          func (x *BytesList) Reset()

          func (*BytesList) String

          func (x *BytesList) String() string

          type DoubleList

          type DoubleList struct {
          	Val []float64 `protobuf:"fixed64,1,rep,packed,name=val,proto3" json:"val,omitempty"`
          	// contains filtered or unexported fields
          }

          func (*DoubleList) Descriptor

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

            Deprecated: Use DoubleList.ProtoReflect.Descriptor instead.

            func (*DoubleList) GetVal

            func (x *DoubleList) GetVal() []float64

            func (*DoubleList) ProtoMessage

            func (*DoubleList) ProtoMessage()

            func (*DoubleList) ProtoReflect

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

            func (*DoubleList) Reset

            func (x *DoubleList) Reset()

            func (*DoubleList) String

            func (x *DoubleList) String() string

            type Error

            type Error struct {
            	Cause      string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`         // exception class name
            	Transform  string `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"` // name of transform where the error occurred
            	Message    string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
            	StackTrace string `protobuf:"bytes,4,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
            	// contains filtered or unexported fields
            }

            func (*Error) Descriptor

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

              Deprecated: Use Error.ProtoReflect.Descriptor instead.

              func (*Error) GetCause

              func (x *Error) GetCause() string

              func (*Error) GetMessage

              func (x *Error) GetMessage() string

              func (*Error) GetStackTrace

              func (x *Error) GetStackTrace() string

              func (*Error) GetTransform

              func (x *Error) GetTransform() string

              func (*Error) ProtoMessage

              func (*Error) ProtoMessage()

              func (*Error) ProtoReflect

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

              func (*Error) Reset

              func (x *Error) Reset()

              func (*Error) String

              func (x *Error) String() string

              type FeatureRow

              type FeatureRow struct {
              
              	// Fields in the feature row.
              	Fields []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
              	// Timestamp of the feature row. While the actual definition of this timestamp may vary
              	// depending on the upstream feature creation pipelines, this is the timestamp that Feast
              	// will use to perform joins, determine latest values, and coalesce rows.
              	EventTimestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
              	// Complete reference to the featureSet this featureRow belongs to, in the form of
              	// <project>/<feature-set-name>. This value will be used by the feast ingestion job to filter
              	// rows, and write the values to the correct tables.
              	FeatureSet string `protobuf:"bytes,6,opt,name=feature_set,json=featureSet,proto3" json:"feature_set,omitempty"`
              	// Identifier tying this feature row to a specific ingestion job.
              	IngestionId string `protobuf:"bytes,7,opt,name=ingestion_id,json=ingestionId,proto3" json:"ingestion_id,omitempty"`
              	// contains filtered or unexported fields
              }

              func (*FeatureRow) Descriptor

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

                Deprecated: Use FeatureRow.ProtoReflect.Descriptor instead.

                func (*FeatureRow) GetEventTimestamp

                func (x *FeatureRow) GetEventTimestamp() *timestamp.Timestamp

                func (*FeatureRow) GetFeatureSet

                func (x *FeatureRow) GetFeatureSet() string

                func (*FeatureRow) GetFields

                func (x *FeatureRow) GetFields() []*Field

                func (*FeatureRow) GetIngestionId

                func (x *FeatureRow) GetIngestionId() string

                func (*FeatureRow) ProtoMessage

                func (*FeatureRow) ProtoMessage()

                func (*FeatureRow) ProtoReflect

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

                func (*FeatureRow) Reset

                func (x *FeatureRow) Reset()

                func (*FeatureRow) String

                func (x *FeatureRow) String() string

                type FeatureRowExtended

                type FeatureRowExtended struct {
                	Row         *FeatureRow          `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"`
                	LastAttempt *Attempt             `protobuf:"bytes,2,opt,name=last_attempt,json=lastAttempt,proto3" json:"last_attempt,omitempty"`
                	FirstSeen   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=first_seen,json=firstSeen,proto3" json:"first_seen,omitempty"`
                	// contains filtered or unexported fields
                }

                func (*FeatureRowExtended) Descriptor

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

                  Deprecated: Use FeatureRowExtended.ProtoReflect.Descriptor instead.

                  func (*FeatureRowExtended) GetFirstSeen

                  func (x *FeatureRowExtended) GetFirstSeen() *timestamp.Timestamp

                  func (*FeatureRowExtended) GetLastAttempt

                  func (x *FeatureRowExtended) GetLastAttempt() *Attempt

                  func (*FeatureRowExtended) GetRow

                  func (x *FeatureRowExtended) GetRow() *FeatureRow

                  func (*FeatureRowExtended) ProtoMessage

                  func (*FeatureRowExtended) ProtoMessage()

                  func (*FeatureRowExtended) ProtoReflect

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

                  func (*FeatureRowExtended) Reset

                  func (x *FeatureRowExtended) Reset()

                  func (*FeatureRowExtended) String

                  func (x *FeatureRowExtended) String() string

                  type Field

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

                  func (*Field) Descriptor

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

                    Deprecated: Use Field.ProtoReflect.Descriptor instead.

                    func (*Field) GetName

                    func (x *Field) GetName() string

                    func (*Field) GetValue

                    func (x *Field) GetValue() *Value

                    func (*Field) ProtoMessage

                    func (*Field) ProtoMessage()

                    func (*Field) ProtoReflect

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

                    func (*Field) Reset

                    func (x *Field) Reset()

                    func (*Field) String

                    func (x *Field) String() string

                    type FloatList

                    type FloatList struct {
                    	Val []float32 `protobuf:"fixed32,1,rep,packed,name=val,proto3" json:"val,omitempty"`
                    	// contains filtered or unexported fields
                    }

                    func (*FloatList) Descriptor

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

                      Deprecated: Use FloatList.ProtoReflect.Descriptor instead.

                      func (*FloatList) GetVal

                      func (x *FloatList) GetVal() []float32

                      func (*FloatList) ProtoMessage

                      func (*FloatList) ProtoMessage()

                      func (*FloatList) ProtoReflect

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

                      func (*FloatList) Reset

                      func (x *FloatList) Reset()

                      func (*FloatList) String

                      func (x *FloatList) String() string

                      type Int32List

                      type Int32List struct {
                      	Val []int32 `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
                      	// contains filtered or unexported fields
                      }

                      func (*Int32List) Descriptor

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

                        Deprecated: Use Int32List.ProtoReflect.Descriptor instead.

                        func (*Int32List) GetVal

                        func (x *Int32List) GetVal() []int32

                        func (*Int32List) ProtoMessage

                        func (*Int32List) ProtoMessage()

                        func (*Int32List) ProtoReflect

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

                        func (*Int32List) Reset

                        func (x *Int32List) Reset()

                        func (*Int32List) String

                        func (x *Int32List) String() string

                        type Int64List

                        type Int64List struct {
                        	Val []int64 `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
                        	// contains filtered or unexported fields
                        }

                        func (*Int64List) Descriptor

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

                          Deprecated: Use Int64List.ProtoReflect.Descriptor instead.

                          func (*Int64List) GetVal

                          func (x *Int64List) GetVal() []int64

                          func (*Int64List) ProtoMessage

                          func (*Int64List) ProtoMessage()

                          func (*Int64List) ProtoReflect

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

                          func (*Int64List) Reset

                          func (x *Int64List) Reset()

                          func (*Int64List) String

                          func (x *Int64List) String() string

                          type StringList

                          type StringList struct {
                          	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
                          	// contains filtered or unexported fields
                          }

                          func (*StringList) Descriptor

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

                            Deprecated: Use StringList.ProtoReflect.Descriptor instead.

                            func (*StringList) GetVal

                            func (x *StringList) GetVal() []string

                            func (*StringList) ProtoMessage

                            func (*StringList) ProtoMessage()

                            func (*StringList) ProtoReflect

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

                            func (*StringList) Reset

                            func (x *StringList) Reset()

                            func (*StringList) String

                            func (x *StringList) String() string

                            type Value

                            type Value struct {
                            
                            	// ValueType is referenced by the metadata types, FeatureInfo and EntityInfo.
                            	// The enum values do not have to match the oneof val field ids, but they should.
                            	//
                            	// Types that are assignable to Val:
                            	//	*Value_BytesVal
                            	//	*Value_StringVal
                            	//	*Value_Int32Val
                            	//	*Value_Int64Val
                            	//	*Value_DoubleVal
                            	//	*Value_FloatVal
                            	//	*Value_BoolVal
                            	//	*Value_BytesListVal
                            	//	*Value_StringListVal
                            	//	*Value_Int32ListVal
                            	//	*Value_Int64ListVal
                            	//	*Value_DoubleListVal
                            	//	*Value_FloatListVal
                            	//	*Value_BoolListVal
                            	Val isValue_Val `protobuf_oneof:"val"`
                            	// contains filtered or unexported fields
                            }

                            func (*Value) Descriptor

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

                              Deprecated: Use Value.ProtoReflect.Descriptor instead.

                              func (*Value) GetBoolListVal

                              func (x *Value) GetBoolListVal() *BoolList

                              func (*Value) GetBoolVal

                              func (x *Value) GetBoolVal() bool

                              func (*Value) GetBytesListVal

                              func (x *Value) GetBytesListVal() *BytesList

                              func (*Value) GetBytesVal

                              func (x *Value) GetBytesVal() []byte

                              func (*Value) GetDoubleListVal

                              func (x *Value) GetDoubleListVal() *DoubleList

                              func (*Value) GetDoubleVal

                              func (x *Value) GetDoubleVal() float64

                              func (*Value) GetFloatListVal

                              func (x *Value) GetFloatListVal() *FloatList

                              func (*Value) GetFloatVal

                              func (x *Value) GetFloatVal() float32

                              func (*Value) GetInt32ListVal

                              func (x *Value) GetInt32ListVal() *Int32List

                              func (*Value) GetInt32Val

                              func (x *Value) GetInt32Val() int32

                              func (*Value) GetInt64ListVal

                              func (x *Value) GetInt64ListVal() *Int64List

                              func (*Value) GetInt64Val

                              func (x *Value) GetInt64Val() int64

                              func (*Value) GetStringListVal

                              func (x *Value) GetStringListVal() *StringList

                              func (*Value) GetStringVal

                              func (x *Value) GetStringVal() string

                              func (*Value) GetVal

                              func (m *Value) GetVal() isValue_Val

                              func (*Value) ProtoMessage

                              func (*Value) ProtoMessage()

                              func (*Value) ProtoReflect

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

                              func (*Value) Reset

                              func (x *Value) Reset()

                              func (*Value) String

                              func (x *Value) String() string

                              type ValueType

                              type ValueType struct {
                              	// contains filtered or unexported fields
                              }

                              func (*ValueType) Descriptor

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

                                Deprecated: Use ValueType.ProtoReflect.Descriptor instead.

                                func (*ValueType) ProtoMessage

                                func (*ValueType) ProtoMessage()

                                func (*ValueType) ProtoReflect

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

                                func (*ValueType) Reset

                                func (x *ValueType) Reset()

                                func (*ValueType) String

                                func (x *ValueType) String() string

                                type ValueType_Enum

                                type ValueType_Enum int32
                                const (
                                	ValueType_INVALID     ValueType_Enum = 0
                                	ValueType_BYTES       ValueType_Enum = 1
                                	ValueType_STRING      ValueType_Enum = 2
                                	ValueType_INT32       ValueType_Enum = 3
                                	ValueType_INT64       ValueType_Enum = 4
                                	ValueType_DOUBLE      ValueType_Enum = 5
                                	ValueType_FLOAT       ValueType_Enum = 6
                                	ValueType_BOOL        ValueType_Enum = 7
                                	ValueType_BYTES_LIST  ValueType_Enum = 11
                                	ValueType_STRING_LIST ValueType_Enum = 12
                                	ValueType_INT32_LIST  ValueType_Enum = 13
                                	ValueType_INT64_LIST  ValueType_Enum = 14
                                	ValueType_DOUBLE_LIST ValueType_Enum = 15
                                	ValueType_FLOAT_LIST  ValueType_Enum = 16
                                	ValueType_BOOL_LIST   ValueType_Enum = 17
                                )

                                func (ValueType_Enum) Descriptor

                                func (ValueType_Enum) Enum

                                func (x ValueType_Enum) Enum() *ValueType_Enum

                                func (ValueType_Enum) EnumDescriptor

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

                                  Deprecated: Use ValueType_Enum.Descriptor instead.

                                  func (ValueType_Enum) Number

                                  func (ValueType_Enum) String

                                  func (x ValueType_Enum) String() string

                                  func (ValueType_Enum) Type

                                  type Value_BoolListVal

                                  type Value_BoolListVal struct {
                                  	BoolListVal *BoolList `protobuf:"bytes,17,opt,name=bool_list_val,json=boolListVal,proto3,oneof"`
                                  }

                                  type Value_BoolVal

                                  type Value_BoolVal struct {
                                  	BoolVal bool `protobuf:"varint,7,opt,name=bool_val,json=boolVal,proto3,oneof"`
                                  }

                                  type Value_BytesListVal

                                  type Value_BytesListVal struct {
                                  	BytesListVal *BytesList `protobuf:"bytes,11,opt,name=bytes_list_val,json=bytesListVal,proto3,oneof"`
                                  }

                                  type Value_BytesVal

                                  type Value_BytesVal struct {
                                  	BytesVal []byte `protobuf:"bytes,1,opt,name=bytes_val,json=bytesVal,proto3,oneof"`
                                  }

                                  type Value_DoubleListVal

                                  type Value_DoubleListVal struct {
                                  	DoubleListVal *DoubleList `protobuf:"bytes,15,opt,name=double_list_val,json=doubleListVal,proto3,oneof"`
                                  }

                                  type Value_DoubleVal

                                  type Value_DoubleVal struct {
                                  	DoubleVal float64 `protobuf:"fixed64,5,opt,name=double_val,json=doubleVal,proto3,oneof"`
                                  }

                                  type Value_FloatListVal

                                  type Value_FloatListVal struct {
                                  	FloatListVal *FloatList `protobuf:"bytes,16,opt,name=float_list_val,json=floatListVal,proto3,oneof"`
                                  }

                                  type Value_FloatVal

                                  type Value_FloatVal struct {
                                  	FloatVal float32 `protobuf:"fixed32,6,opt,name=float_val,json=floatVal,proto3,oneof"`
                                  }

                                  type Value_Int32ListVal

                                  type Value_Int32ListVal struct {
                                  	Int32ListVal *Int32List `protobuf:"bytes,13,opt,name=int32_list_val,json=int32ListVal,proto3,oneof"`
                                  }

                                  type Value_Int32Val

                                  type Value_Int32Val struct {
                                  	Int32Val int32 `protobuf:"varint,3,opt,name=int32_val,json=int32Val,proto3,oneof"`
                                  }

                                  type Value_Int64ListVal

                                  type Value_Int64ListVal struct {
                                  	Int64ListVal *Int64List `protobuf:"bytes,14,opt,name=int64_list_val,json=int64ListVal,proto3,oneof"`
                                  }

                                  type Value_Int64Val

                                  type Value_Int64Val struct {
                                  	Int64Val int64 `protobuf:"varint,4,opt,name=int64_val,json=int64Val,proto3,oneof"`
                                  }

                                  type Value_StringListVal

                                  type Value_StringListVal struct {
                                  	StringListVal *StringList `protobuf:"bytes,12,opt,name=string_list_val,json=stringListVal,proto3,oneof"`
                                  }

                                  type Value_StringVal

                                  type Value_StringVal struct {
                                  	StringVal string `protobuf:"bytes,2,opt,name=string_val,json=stringVal,proto3,oneof"`
                                  }