-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/73423/
-----------------------------------------------------------
Review request for atlas, Ashutosh Mestry, Jayendra Parab, madhan, Nixon
Rodrigues, Sarath Subramanian, and Sidharth Mishra.
Bugs: ATLAS-4338
https://issues.apache.org/jira/browse/ATLAS-4338
Repository: atlas
Description
-------
Currently Migration import feature (MigrationImport.java) does not support
enabling notifiers (audits writer, notification to Atlas entities topic).
With this improvement, Atlas now will enable notifiers for Migration import,
based on a flag.
Approach:
* New option in AtlasImportRequest - sendNotifications (default : false)
* MigrationImport will use the flag to select appropriate implementation of
IAtlasEntityChangeNotifier to create EntityCreationManager.
* EntityCreationManager will then notify listeners.
Diffs
-----
intg/src/main/java/org/apache/atlas/model/impexp/AtlasImportRequest.java
2c1870444
repository/src/main/java/org/apache/atlas/repository/impexp/ImportService.java
1d29bf833
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityChangeNotifier.java
99be169f2
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/BulkImporterImpl.java
8e17fd410
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/bulkimport/MigrationImport.java
d6f23d6e2
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/bulkimport/pc/EntityConsumer.java
b73988fd7
repository/src/main/java/org/apache/atlas/repository/store/graph/v2/bulkimport/pc/EntityCreationManager.java
734add6d7
Diff: https://reviews.apache.org/r/73423/diff/1/
Testing
-------
* Tested Manually
* Attached sample zip, sample request
{
"options": {
"migration": "true",
"size": "100",
"sendNotifications": "true",
"batchSize": 500,
"numWorkers": 40
}
}
* took ~270 secs to import 12987 entities with notifiers enabled.
* PC build :
File Attachments
----------------
largedb.zip
https://reviews.apache.org/media/uploaded/files/2021/06/15/c84f450b-c2b3-4cac-8b4a-76942a2c14e3__largedb.zip
Thanks,
Nikhil Bonte