Skip to content

Commit e083458

Browse files
authored
fix: Fix Java Master (#2499)
* Fix Signed-off-by: Kevin Zhang <[email protected]> * Fix? Signed-off-by: Kevin Zhang <[email protected]> * Update sources Signed-off-by: Kevin Zhang <[email protected]> * Fix Signed-off-by: Kevin Zhang <[email protected]>
1 parent 6abae16 commit e083458

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

examples/java-demo/feature_repo/driver_repo.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ def transformed_conv_rate(inputs: pd.DataFrame) -> pd.DataFrame:
5555
# Define request feature view
5656
driver_age_request_fv = RequestFeatureView(
5757
name="driver_age",
58-
request_source=RequestSource(
58+
request_data_source=RequestSource(
5959
name="driver_age", schema={"driver_age": ValueType.INT64,}
6060
),
6161
)

java/serving/src/test/resources/docker-compose/feast10/definitions.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,14 +7,15 @@
77
from feast.feature_view import FeatureView
88
from feast.entity import Entity
99
from feast.feature_service import FeatureService
10-
from feast.on_demand_feature_view import RequestDataSource, on_demand_feature_view
10+
from feast.data_source import RequestSource
11+
from feast.on_demand_feature_view import on_demand_feature_view
1112
from feast import FileSource
1213

1314

1415
file_path = "driver_stats.parquet"
1516
driver_hourly_stats = FileSource(
1617
path=file_path,
17-
event_timestamp_column="event_timestamp",
18+
timestamp_field="event_timestamp",
1819
created_timestamp_column="created",
1920
)
2021

@@ -40,7 +41,7 @@
4041
)
4142

4243

43-
input_request = RequestDataSource(
44+
input_request = RequestSource(
4445
name="vals_to_add",
4546
schema={
4647
"val_to_add": ValueType.INT64,
@@ -68,7 +69,7 @@ def transformed_conv_rate(features_df: pd.DataFrame) -> pd.DataFrame:
6869

6970
generated_data_source = FileSource(
7071
path="benchmark_data.parquet",
71-
event_timestamp_column="event_timestamp",
72+
timestamp_field="event_timestamp",
7273
)
7374

7475
entity = Entity(

0 commit comments

Comments
 (0)