Skip to content

fix: Timestamp update #2486

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
feast-ci-bot merged 13 commits into from
Apr 6, 2022
Merged

fix: Timestamp update #2486

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
3c2f776
Timestamps
kevjumba Apr 1, 2022
bba6b02
Fix
kevjumba Apr 4, 2022
22fa4ce
Update md files
kevjumba Apr 4, 2022
a7e85ca
Update more
kevjumba Apr 4, 2022
cde6af0
Update batch source creators
kevjumba Apr 4, 2022
245dc19
Fix
kevjumba Apr 4, 2022
dab8982
Fix data source
kevjumba Apr 4, 2022
ac6689b
Fix
kevjumba Apr 4, 2022
db6cbb1
fix
kevjumba Apr 5, 2022
c871a59
Fix
kevjumba Apr 5, 2022
1f16637
Fix
kevjumba Apr 5, 2022
d98720c
Temp fix
kevjumba Apr 5, 2022
ad141af
Fixed
kevjumba Apr 5, 2022
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
Prev Previous commit
Next Next commit
fix 
Signed-off-by: Kevin Zhang <kzhang@tecton.ai>
  • Loading branch information
@kevjumba
kevjumba committed Apr 5, 2022
commit db6cbb1bc626a4e69cbfe0611c9ccf0a5b47db00
10 changes: 5 additions & 5 deletions java/serving/src/test/java/feast/serving/util/DataGenerator.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ public static FeatureTableSpec createFeatureTableSpec(
.setMaxAge(Duration.newBuilder().setSeconds(3600).build())
.setBatchSource(
DataSource.newBuilder()
.setEventTimestampColumn("ts")
.setTimestampField("ts")
.setType(DataSource.SourceType.BATCH_FILE)
.setFileOptions(
FileOptions.newBuilder()
Expand Down Expand Up @@ -204,7 +204,7 @@ public static DataSource createFileDataSourceSpec(
.setType(DataSource.SourceType.BATCH_FILE)
.setFileOptions(
FileOptions.newBuilder().setFileFormat(createParquetFormat()).setUri(fileURL).build())
.setEventTimestampColumn(timestampColumn)
.setTimestampField(timestampColumn)
.setDatePartitionColumn(datePartitionColumn)
.build();
}
Expand All @@ -215,7 +215,7 @@ public static DataSource createBigQueryDataSourceSpec(
.setType(DataSource.SourceType.BATCH_BIGQUERY)
.setBigqueryOptions(
DataSource.BigQueryOptions.newBuilder().setTableRef(bigQueryTableRef).build())
.setEventTimestampColumn(timestampColumn)
.setTimestampField(timestampColumn)
.setDatePartitionColumn(datePartitionColumn)
.build();
}
Expand All @@ -230,7 +230,7 @@ public static DataSource createKafkaDataSourceSpec(
.setBootstrapServers(servers)
.setMessageFormat(createProtoFormat("class.path"))
.build())
.setEventTimestampColumn(timestampColumn)
.setTimestampField(timestampColumn)
.build();
}

Expand Down Expand Up @@ -292,7 +292,7 @@ public static DataSource createKinesisDataSourceSpec(
.setStreamName("stream")
.setRecordFormat(createProtoFormat(classPath))
.build())
.setEventTimestampColumn(timestampColumn)
.setTimestampField(timestampColumn)
.build();
}

Expand Down