Skip to content

Commit

Permalink
update EbeanLocalDao constuctors with urnClass & minor update
Browse files Browse the repository at this point in the history
  • Loading branch information
JiaoMaWHU committed Dec 5, 2023
1 parent 80da721 commit 51453ac
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -223,14 +223,15 @@ public BaseLocalDAO(@Nonnull Class<ASPECT_UNION> aspectUnionClass, @Nonnull Base
* @param producer {@link BaseMetadataEventProducer} for the metadata event producer
* @param storageConfig {@link LocalDAOStorageConfig} containing storage config of full list of supported aspects
*/
public BaseLocalDAO(@Nonnull BaseMetadataEventProducer producer, @Nonnull LocalDAOStorageConfig storageConfig) {
public BaseLocalDAO(@Nonnull BaseMetadataEventProducer producer, @Nonnull LocalDAOStorageConfig storageConfig,
@Nonnull Class<URN> urnClass) {
super(storageConfig.getAspectStorageConfigMap().keySet());
_producer = producer;
_storageConfig = storageConfig;
_aspectUnionClass = producer.getAspectUnionClass();
_trackingManager = null;
_trackingProducer = null;
_urnClass = null;
_urnClass = urnClass;
}

/**
Expand All @@ -242,14 +243,14 @@ public BaseLocalDAO(@Nonnull BaseMetadataEventProducer producer, @Nonnull LocalD
*
*/
public BaseLocalDAO(@Nonnull BaseTrackingMetadataEventProducer trackingProducer, @Nonnull LocalDAOStorageConfig storageConfig,
@Nonnull BaseTrackingManager trackingManager) {
@Nonnull BaseTrackingManager trackingManager, @Nonnull Class<URN> urnClass) {
super(storageConfig.getAspectStorageConfigMap().keySet());
_producer = null;
_storageConfig = storageConfig;
_aspectUnionClass = trackingProducer.getAspectUnionClass();
_trackingManager = trackingManager;
_trackingProducer = trackingProducer;
_urnClass = null;
_urnClass = urnClass;
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -432,7 +432,7 @@ private EbeanLocalDAO(@Nonnull Class<ASPECT_UNION> aspectUnionClass,
EbeanLocalDAO(@Nonnull BaseMetadataEventProducer producer, @Nonnull EbeanServer server,
@Nonnull LocalDAOStorageConfig storageConfig, @Nonnull Class<URN> urnClass,
@Nonnull UrnPathExtractor<URN> urnPathExtractor) {
super(producer, storageConfig);
super(producer, storageConfig, urnClass);
_server = server;
_urnClass = urnClass;
_urnPathExtractor = urnPathExtractor;
Expand All @@ -441,7 +441,7 @@ private EbeanLocalDAO(@Nonnull Class<ASPECT_UNION> aspectUnionClass,
private EbeanLocalDAO(@Nonnull BaseTrackingMetadataEventProducer producer, @Nonnull EbeanServer server,
@Nonnull LocalDAOStorageConfig storageConfig, @Nonnull Class<URN> urnClass,
@Nonnull UrnPathExtractor<URN> urnPathExtractor, @Nonnull BaseTrackingManager trackingManager) {
super(producer, storageConfig, trackingManager);
super(producer, storageConfig, trackingManager, urnClass);
_server = server;
_urnClass = urnClass;
_urnPathExtractor = urnPathExtractor;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ public abstract class BaseEntityAgnosticResource {
*
* @param backfillRequests an array of {@link BackfillItem} to be backfilled. Empty aspect list means backfill all aspects.
* @param ingestionMode {@link IngestionMode} to indicate the processing strategy. Live mode together with no-change
* should represent no-op, empty map will be returned. Backfill is to redo
* should represent no-op, empty array will be returned. Backfill is to redo
* any metadata update that is missed or skipped in the past.
* Bootstrap indicates building the metadata from scratch.
* @return an array of {@link BackfillItem} that is backfilled, failed urns and aspects will be filtered out
Expand Down

0 comments on commit 51453ac

Please sign in to comment.