@@ -4,6 +4,7 @@ isort:skip_file
4
4
"""
5
5
import builtins
6
6
import collections .abc
7
+ import feast .core .DataSource_pb2
7
8
import feast .core .Feature_pb2
8
9
import google .protobuf .descriptor
9
10
import google .protobuf .internal .containers
@@ -43,6 +44,11 @@ class FeatureViewProjection(google.protobuf.message.Message):
43
44
FEATURE_VIEW_NAME_ALIAS_FIELD_NUMBER : builtins .int
44
45
FEATURE_COLUMNS_FIELD_NUMBER : builtins .int
45
46
JOIN_KEY_MAP_FIELD_NUMBER : builtins .int
47
+ TIMESTAMP_FIELD_FIELD_NUMBER : builtins .int
48
+ DATE_PARTITION_COLUMN_FIELD_NUMBER : builtins .int
49
+ CREATED_TIMESTAMP_COLUMN_FIELD_NUMBER : builtins .int
50
+ BATCH_SOURCE_FIELD_NUMBER : builtins .int
51
+ STREAM_SOURCE_FIELD_NUMBER : builtins .int
46
52
feature_view_name : builtins .str
47
53
"""The feature view name"""
48
54
feature_view_name_alias : builtins .str
@@ -53,14 +59,29 @@ class FeatureViewProjection(google.protobuf.message.Message):
53
59
@property
54
60
def join_key_map (self ) -> google .protobuf .internal .containers .ScalarMap [builtins .str , builtins .str ]:
55
61
"""Map for entity join_key overrides of feature data entity join_key to entity data join_key"""
62
+ timestamp_field : builtins .str
63
+ date_partition_column : builtins .str
64
+ created_timestamp_column : builtins .str
65
+ @property
66
+ def batch_source (self ) -> feast .core .DataSource_pb2 .DataSource :
67
+ """Batch/Offline DataSource where this view can retrieve offline feature data."""
68
+ @property
69
+ def stream_source (self ) -> feast .core .DataSource_pb2 .DataSource :
70
+ """Streaming DataSource from where this view can consume "online" feature data."""
56
71
def __init__ (
57
72
self ,
58
73
* ,
59
74
feature_view_name : builtins .str = ...,
60
75
feature_view_name_alias : builtins .str = ...,
61
76
feature_columns : collections .abc .Iterable [feast .core .Feature_pb2 .FeatureSpecV2 ] | None = ...,
62
77
join_key_map : collections .abc .Mapping [builtins .str , builtins .str ] | None = ...,
78
+ timestamp_field : builtins .str = ...,
79
+ date_partition_column : builtins .str = ...,
80
+ created_timestamp_column : builtins .str = ...,
81
+ batch_source : feast .core .DataSource_pb2 .DataSource | None = ...,
82
+ stream_source : feast .core .DataSource_pb2 .DataSource | None = ...,
63
83
) -> None : ...
64
- def ClearField (self , field_name : typing_extensions .Literal ["feature_columns" , b"feature_columns" , "feature_view_name" , b"feature_view_name" , "feature_view_name_alias" , b"feature_view_name_alias" , "join_key_map" , b"join_key_map" ]) -> None : ...
84
+ def HasField (self , field_name : typing_extensions .Literal ["batch_source" , b"batch_source" , "stream_source" , b"stream_source" ]) -> builtins .bool : ...
85
+ def ClearField (self , field_name : typing_extensions .Literal ["batch_source" , b"batch_source" , "created_timestamp_column" , b"created_timestamp_column" , "date_partition_column" , b"date_partition_column" , "feature_columns" , b"feature_columns" , "feature_view_name" , b"feature_view_name" , "feature_view_name_alias" , b"feature_view_name_alias" , "join_key_map" , b"join_key_map" , "stream_source" , b"stream_source" , "timestamp_field" , b"timestamp_field" ]) -> None : ...
65
86
66
87
global___FeatureViewProjection = FeatureViewProjection
0 commit comments