@@ -4,6 +4,7 @@ isort:skip_file
44"""
55import builtins
66import collections .abc
7+ import feast .core .DataSource_pb2
78import feast .core .Feature_pb2
89import google .protobuf .descriptor
910import google .protobuf .internal .containers
@@ -43,6 +44,11 @@ class FeatureViewProjection(google.protobuf.message.Message):
4344 FEATURE_VIEW_NAME_ALIAS_FIELD_NUMBER : builtins .int
4445 FEATURE_COLUMNS_FIELD_NUMBER : builtins .int
4546 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
4652 feature_view_name : builtins .str
4753 """The feature view name"""
4854 feature_view_name_alias : builtins .str
@@ -53,14 +59,29 @@ class FeatureViewProjection(google.protobuf.message.Message):
5359 @property
5460 def join_key_map (self ) -> google .protobuf .internal .containers .ScalarMap [builtins .str , builtins .str ]:
5561 """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."""
5671 def __init__ (
5772 self ,
5873 * ,
5974 feature_view_name : builtins .str = ...,
6075 feature_view_name_alias : builtins .str = ...,
6176 feature_columns : collections .abc .Iterable [feast .core .Feature_pb2 .FeatureSpecV2 ] | None = ...,
6277 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 = ...,
6383 ) -> 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 : ...
6586
6687global___FeatureViewProjection = FeatureViewProjection
0 commit comments