Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Add Field class
Signed-off-by: Felix Wang <wangfelix98@gmail.com>
  • Loading branch information
felixwang9817 committed Apr 6, 2022
commit 0104782bfbdd60f5cb0e78d4e08020168633ee62
70 changes: 70 additions & 0 deletions sdk/python/feast/field.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,70 @@
# Copyright 2022 The Feast Authors
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

from feast.protos.feast.core.Feature_pb2 import FeatureSpecV2 as FieldProto
from feast.types import FeastType, from_value_type


class Field:
"""
A Field represents a set of values with the same structure.

Attributes:
name: The name of the field.
dtype: The type of the field, such as string or float.
"""

name: str
dtype: FeastType

def __init__(
self, *, name: str, dtype: FeastType,
Comment thread
felixwang9817 marked this conversation as resolved.
Outdated
):
"""
Creates a Field object.

Args:
name: The name of the field.
dtype: The type of the field, such as string or float.
"""
self.name = name
self.dtype = dtype

def __eq__(self, other):
if self.name != other.name or self.dtype != other.dtype:
return False
return True
Comment thread
kevjumba marked this conversation as resolved.
Outdated

def __lt__(self, other):
return self.name < other.name

def __repr__(self):
return f"{self.name}-{self.dtype}"

def __str__(self):
return f"Field(name={self.name}, dtype={self.dtype})"

def to_proto(self) -> FieldProto:
"""Converts a Field object to its protobuf representation."""
return FieldProto(name=self.name, value_type=self.dtype.to_value_type())

@classmethod
def from_proto(cls, field_proto: FieldProto):
"""
Creates a Field object from a protobuf representation.

Args:
field_proto: FieldProto protobuf object
"""
return cls(name=field_proto.name, dtype=from_value_type(field_proto.value_type))
29 changes: 23 additions & 6 deletions sdk/python/feast/types.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,9 @@ def to_value_type(self) -> ValueTypeProto.Enum:
value_type_name = PRIMITIVE_FEAST_TYPES_TO_VALUE_TYPES[self.name]
return ValueTypeProto.Enum.Value(value_type_name)

def __str__(self):
return PRIMITIVE_FEAST_TYPES_TO_STRING[self.name]


Invalid = PrimitiveFeastType.INVALID
Bytes = PrimitiveFeastType.BYTES
Expand All @@ -99,6 +102,18 @@ def to_value_type(self) -> ValueTypeProto.Enum:
UnixTimestamp,
]

PRIMITIVE_FEAST_TYPES_TO_STRING = {
"INVALID": "Invalid",
"STRING": "String",
"BYTES": "Bytes",
"BOOL": "Bool",
"INT32": "Int32",
"INT64": "Int64",
"FLOAT32": "Float32",
"FLOAT64": "Float64",
"UNIX_TIMESTAMP": "UnixTimestamp",
}


class Array(ComplexFeastType):
"""
Expand All @@ -124,10 +139,14 @@ def to_value_type(self) -> int:
value_type_list_name = value_type_name + "_LIST"
return ValueTypeProto.Enum.Value(value_type_list_name)

def __str__(self):
return f"Array({self.base_type})"


FeastType = Union[ComplexFeastType, PrimitiveFeastType]


VALUE_TYPES_TO_FEAST_TYPES: Dict[
"ValueTypeProto.Enum", Union[ComplexFeastType, PrimitiveFeastType]
] = {
VALUE_TYPES_TO_FEAST_TYPES: Dict["ValueTypeProto.Enum", FeastType] = {
ValueTypeProto.Enum.INVALID: Invalid,
ValueTypeProto.Enum.BYTES: Bytes,
ValueTypeProto.Enum.STRING: String,
Expand All @@ -148,9 +167,7 @@ def to_value_type(self) -> int:
}


def from_value_type(
value_type: ValueTypeProto.Enum,
) -> Union[ComplexFeastType, PrimitiveFeastType]:
def from_value_type(value_type: ValueTypeProto.Enum,) -> FeastType:
"""
Converts a ValueTypeProto.Enum to a Feast type.

Expand Down