File tree Expand file tree Collapse file tree
ingestion/src/test/java/feast/ingestion Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -215,16 +215,16 @@ public void testImportFileJson() throws IOException {
215215 job .expand ();
216216
217217 PCollection <FeatureRowExtended > writtenToServing =
218- PCollectionList .of (ServingStoreService .get (MockServingStore .class ).getWrite ().getInputs ())
218+ PCollectionList .of (FeatureServingFactoryService .get (MockServingFactory .class ).getWrite ().getInputs ())
219219 .apply ("flatten serving input" , Flatten .pCollections ());
220220
221221 PCollection <FeatureRowExtended > writtenToWarehouse =
222222 PCollectionList .of (
223- WarehouseStoreService .get (MockWarehouseStore .class ).getWrite ().getInputs ())
223+ FeatureWarehouseFactoryService .get (MockWarehouseFactory .class ).getWrite ().getInputs ())
224224 .apply ("flatten warehouse input" , Flatten .pCollections ());
225225
226226 PCollection <FeatureRowExtended > writtenToErrors =
227- PCollectionList .of (ErrorsStoreService .get (MockErrorsStore .class ).getWrite ().getInputs ())
227+ PCollectionList .of (FeatureErrorsFactoryService .get (MockFeatureErrorsFactory .class ).getWrite ().getInputs ())
228228 .apply ("flatten errors input" , Flatten .pCollections ());
229229
230230 List <FeatureRow > expectedRows =
You can’t perform that action at this time.
0 commit comments