atlas-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Madhan Neethiraj <mad...@apache.org>
Subject Review Request 63658: ATLAS-2251: Remove/replace use of TypeSystem with AtlasTypeRegistry
Date Wed, 08 Nov 2017 09:37:19 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/63658/
-----------------------------------------------------------

Review request for atlas.


Bugs: ATLAS-2251
    https://issues.apache.org/jira/browse/ATLAS-2251


Repository: atlas


Description
-------

Here is summary of the changes in this patch:
 - removed TypeSystem implementation from Atlas
 - references to TypeSystem have either been removed or replaced to use AtlasTypeRegistry
 - notification module has been refactored to move notification message classes to intg module
 - updated serialize/deserialize of notifications to use Jackson library instead of GSON.
Wire format of the message remain same as the one from GSON generated JSON
 - V1 data classes used in REST API & notifications have been over to model package in
intg module, along with other classes used in V2 REST APIs
 - updated all Hook implementations, UTs and ITs for the changes in classes used in notifications
 - removed all Scala sources from Atlas

Verified that functions correctly with this patch, except for the TODO items listed below:
 - DSL implementation in Scala, which used TypeSystem, has been removed. This needs to be
replaced with equivalent implementation to use AtlasTypeRegistry
 - Few REST APIs that use V1 classes (like MetadataRepository) have been stubbed out - DataSetLineageResource,
LineageResource, MetadataDiscoveryResource. These need to be updated to use V2 implementations


Diffs
-----

  addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/bridge/FalconBridge.java ff745596

  addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java 188b7543

  addons/falcon-bridge/src/test/java/org/apache/atlas/falcon/hook/FalconHookIT.java 72129217

  addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java 8c7481af

  addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/model/HBaseOperationContext.java
ce0f2129 
  addons/hbase-bridge/src/test/java/org/apache/atlas/hbase/HBaseAtlasHookIT.java 032cb518

  addons/hive-bridge/src/main/java/org/apache/atlas/hive/bridge/ColumnLineageUtils.java 663fcdcd

  addons/hive-bridge/src/main/java/org/apache/atlas/hive/bridge/HiveMetaStoreBridge.java d2d2fb54

  addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java 0e8284d2 
  addons/hive-bridge/src/test/java/org/apache/atlas/hive/HiveITBase.java 0d163ee9 
  addons/hive-bridge/src/test/java/org/apache/atlas/hive/bridge/HiveMetaStoreBridgeTest.java
0256cf37 
  addons/hive-bridge/src/test/java/org/apache/atlas/hive/bridge/HiveMetastoreBridgeIT.java
d09db1b4 
  addons/hive-bridge/src/test/java/org/apache/atlas/hive/hook/HiveHookIT.java f7404ae1 
  addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java 50e20fa0 
  addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java c3df8fcd

  addons/storm-bridge/src/test/java/org/apache/atlas/storm/hook/StormAtlasHookIT.java e0800b80

  client/client-v1/src/main/java/org/apache/atlas/AtlasClient.java 8bbc89b6 
  client/client-v1/src/main/java/org/apache/atlas/EntityAuditEvent.java 904674d9 
  client/client-v1/src/main/java/org/apache/atlas/SerDe.java cdc35094 
  client/client-v1/src/test/java/org/apache/atlas/AtlasClientTest.java c387be14 
  common/src/main/java/org/apache/atlas/AtlasConfiguration.java  
  common/src/main/java/org/apache/atlas/repository/Constants.java 5475514c 
  graphdb/api/src/main/java/org/apache/atlas/repository/graphdb/AtlasGraph.java dded76f8 
  graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraph.java
bc63a697 
  graphdb/titan0/src/main/java/org/apache/atlas/repository/graphdb/titan0/Titan0Graph.java
2408287b 
  graphdb/titan1/src/main/java/org/apache/atlas/repository/graphdb/titan1/Titan1Graph.java
ffb6b37f 
  intg/src/main/java/org/apache/atlas/model/notification/EntityNotification.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/model/notification/HookNotification.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/type/AtlasType.java dc0d300c 
  intg/src/main/java/org/apache/atlas/type/AtlasTypeRegistry.java bd4b0e90 
  intg/src/main/java/org/apache/atlas/type/AtlasTypeUtil.java 5f3cefdd 
  intg/src/main/java/org/apache/atlas/v1/model/instance/AtlasSystemAttributes.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/instance/Id.java PRE-CREATION 
  intg/src/main/java/org/apache/atlas/v1/model/instance/Referenceable.java PRE-CREATION 
  intg/src/main/java/org/apache/atlas/v1/model/instance/Struct.java PRE-CREATION 
  intg/src/main/java/org/apache/atlas/v1/model/notification/EntityNotificationV1.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/notification/HookNotificationV1.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/AttributeDefinition.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/ClassTypeDefinition.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/EnumTypeDefinition.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/HierarchicalTypeDefinition.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/Multiplicity.java PRE-CREATION 
  intg/src/main/java/org/apache/atlas/v1/model/typedef/StructTypeDefinition.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/TraitTypeDefinition.java PRE-CREATION

  intg/src/main/java/org/apache/atlas/v1/model/typedef/TypesDef.java PRE-CREATION 
  intg/src/main/java/org/apache/atlas/v1/typesystem/types/utils/TypesUtil.java PRE-CREATION

  notification/src/main/java/org/apache/atlas/hook/AtlasHook.java 38f32082 
  notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java e3bb71ca 
  notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java 6bb8d73a 
  notification/src/main/java/org/apache/atlas/notification/AbstractMessageDeserializer.java
37a57d17 
  notification/src/main/java/org/apache/atlas/notification/AbstractNotification.java 4f56bd8d

  notification/src/main/java/org/apache/atlas/notification/AbstractNotificationConsumer.java
8cf1e8e5 
  notification/src/main/java/org/apache/atlas/notification/AtlasNotificationBaseMessage.java
3b377de6 
  notification/src/main/java/org/apache/atlas/notification/AtlasNotificationMessage.java 63d93c97

  notification/src/main/java/org/apache/atlas/notification/AtlasNotificationMessageDeserializer.java
2a175baf 
  notification/src/main/java/org/apache/atlas/notification/AtlasNotificationStringMessage.java
41485a05 
  notification/src/main/java/org/apache/atlas/notification/MessageVersion.java 7f966388 
  notification/src/main/java/org/apache/atlas/notification/NotificationInterface.java 8809225d

  notification/src/main/java/org/apache/atlas/notification/SplitMessageAggregator.java 148b57fe

  notification/src/main/java/org/apache/atlas/notification/entity/EntityMessageDeserializer.java
a6f7e646 
  notification/src/main/java/org/apache/atlas/notification/entity/EntityNotification.java
379e8155 
  notification/src/main/java/org/apache/atlas/notification/entity/EntityNotificationImpl.java
6a9b362d 
  notification/src/main/java/org/apache/atlas/notification/hook/HookMessageDeserializer.java
8337de04 
  notification/src/main/java/org/apache/atlas/notification/hook/HookNotification.java a25aa521

  notification/src/test/java/org/apache/atlas/hook/AtlasHookTest.java d59cb1cf 
  notification/src/test/java/org/apache/atlas/kafka/KafkaConsumerTest.java 08a20bd4 
  notification/src/test/java/org/apache/atlas/kafka/KafkaNotificationTest.java a1e13b91 
  notification/src/test/java/org/apache/atlas/notification/AbstractNotificationConsumerTest.java
f313ddc4 
  notification/src/test/java/org/apache/atlas/notification/AbstractNotificationTest.java 655252cb

  notification/src/test/java/org/apache/atlas/notification/AtlasNotificationMessageTest.java
27b5034e 
  notification/src/test/java/org/apache/atlas/notification/MessageVersionTest.java d1af4b0b

  notification/src/test/java/org/apache/atlas/notification/SplitMessageAggregatorTest.java
0807221b 
  notification/src/test/java/org/apache/atlas/notification/entity/EntityMessageDeserializerTest.java
7b513dae 
  notification/src/test/java/org/apache/atlas/notification/entity/EntityNotificationDeserializerTest.java
PRE-CREATION 
  notification/src/test/java/org/apache/atlas/notification/entity/EntityNotificationImplTest.java
c3a2db8f 
  notification/src/test/java/org/apache/atlas/notification/entity/EntityNotificationTest.java
PRE-CREATION 
  notification/src/test/java/org/apache/atlas/notification/hook/HookMessageDeserializerTest.java
49b877bc 
  notification/src/test/java/org/apache/atlas/notification/hook/HookNotificationTest.java
dd3257e0 
  repository/src/main/java/org/apache/atlas/discovery/DataSetLineageService.java af7f1b4d

  repository/src/main/java/org/apache/atlas/discovery/DiscoveryService.java e86047eb 
  repository/src/main/java/org/apache/atlas/discovery/EntityDiscoveryService.java 7f24d5ae

  repository/src/main/java/org/apache/atlas/discovery/SearchIndexer.java 8e67e326 
  repository/src/main/java/org/apache/atlas/discovery/graph/DefaultGraphPersistenceStrategy.java
9b0aa4c0 
  repository/src/main/java/org/apache/atlas/discovery/graph/GraphBackedDiscoveryService.java
aed8659c 
  repository/src/main/java/org/apache/atlas/gremlin/Gremlin2ExpressionFactory.java 27de0edd

  repository/src/main/java/org/apache/atlas/gremlin/Gremlin3ExpressionFactory.java b9366956

  repository/src/main/java/org/apache/atlas/gremlin/GremlinExpressionFactory.java d603150f

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/AliasFinder.java 3e6c39ab 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/CallHierarchyVisitor.java 60893537

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/ExpandAndsOptimization.java
d8ecd076 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/ExpandOrsOptimization.java a48a007f

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/ExpressionFinder.java 27210498

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/FunctionGenerator.java 1a93d0fc

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/GremlinOptimization.java bfa45af8

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/GremlinQueryOptimizer.java a0c08fdc

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/HasForbiddenType.java 3fb9faa7

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/IsOr.java ab740873 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/IsOrParent.java 72085d03 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/OptimizationContext.java 86c8b987

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/OrderFinder.java 792fc52e 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/PathExpressionFinder.java 0e9070df

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/RangeFinder.java fa8ca858 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/RepeatExpressionFinder.java
8344f365 
  repository/src/main/java/org/apache/atlas/gremlin/optimizer/SplitPointFinder.java f0295e7d

  repository/src/main/java/org/apache/atlas/gremlin/optimizer/UpdatedExpressions.java 06351ea4

  repository/src/main/java/org/apache/atlas/query/Expressions.java PRE-CREATION 
  repository/src/main/java/org/apache/atlas/query/QueryParser.java PRE-CREATION 
  repository/src/main/java/org/apache/atlas/repository/DiscoverInstances.java 6261499e 
  repository/src/main/java/org/apache/atlas/repository/IRepository.java 1637e117 
  repository/src/main/java/org/apache/atlas/repository/MetadataRepository.java b72ee7dc 
  repository/src/main/java/org/apache/atlas/repository/RepositoryConfiguration.java 261a6d03

  repository/src/main/java/org/apache/atlas/repository/audit/EntityAuditListener.java 2a1881b0

  repository/src/main/java/org/apache/atlas/repository/audit/InMemoryEntityAuditRepository.java
22d2a810 
  repository/src/main/java/org/apache/atlas/repository/audit/NoopEntityAuditRepository.java
c3826019 
  repository/src/main/java/org/apache/atlas/repository/converters/AtlasClassificationFormatConverter.java
cd4f165e 
  repository/src/main/java/org/apache/atlas/repository/converters/AtlasEntityFormatConverter.java
1ce6168b 
  repository/src/main/java/org/apache/atlas/repository/converters/AtlasEnumFormatConverter.java
734bd0ca 
  repository/src/main/java/org/apache/atlas/repository/converters/AtlasInstanceConverter.java
9bde5db6 
  repository/src/main/java/org/apache/atlas/repository/converters/AtlasObjectIdConverter.java
f946b9ca 
  repository/src/main/java/org/apache/atlas/repository/converters/AtlasStructFormatConverter.java
6b6ee015 
  repository/src/main/java/org/apache/atlas/repository/converters/TypeConverterUtil.java 7902100e

  repository/src/main/java/org/apache/atlas/repository/graph/DeleteHandler.java f0fef1f0 
  repository/src/main/java/org/apache/atlas/repository/graph/EntityProcessor.java 892b36d9

  repository/src/main/java/org/apache/atlas/repository/graph/FullTextMapper.java 2e8ae0c6

  repository/src/main/java/org/apache/atlas/repository/graph/FullTextMapperV2.java 76acf8ce

  repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepository.java
74886b56 
  repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java
6eee24b1 
  repository/src/main/java/org/apache/atlas/repository/graph/GraphHelper.java ffe859b3 
  repository/src/main/java/org/apache/atlas/repository/graph/GraphSchemaInitializer.java e8776806

  repository/src/main/java/org/apache/atlas/repository/graph/GraphToTypedInstanceMapper.java
d7a8fa91 
  repository/src/main/java/org/apache/atlas/repository/graph/HardDeleteHandler.java e00ef96d

  repository/src/main/java/org/apache/atlas/repository/graph/SoftDeleteHandler.java b37fe758

  repository/src/main/java/org/apache/atlas/repository/graph/TypedInstanceToGraphMapper.java
1fb4ee99 
  repository/src/main/java/org/apache/atlas/repository/graph/VertexLookupContext.java dd90be6f

  repository/src/main/java/org/apache/atlas/repository/memory/AttributeStores.java 1fb9d693

  repository/src/main/java/org/apache/atlas/repository/memory/ClassStore.java a74c79e4 
  repository/src/main/java/org/apache/atlas/repository/memory/HierarchicalTypeStore.java 429730c9

  repository/src/main/java/org/apache/atlas/repository/memory/IAttributeStore.java b8cbe050

  repository/src/main/java/org/apache/atlas/repository/memory/MemRepository.java aef06a4d

  repository/src/main/java/org/apache/atlas/repository/memory/ReplaceIdWithInstance.java 6741eb8d

  repository/src/main/java/org/apache/atlas/repository/memory/StructStore.java 69a18a5b 
  repository/src/main/java/org/apache/atlas/repository/memory/TraitStore.java 0cbb32d8 
  repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityChangeNotifier.java
7b349c46 
  repository/src/main/java/org/apache/atlas/repository/store/graph/v1/AtlasStructDefStoreV1.java
86f1b884 
  repository/src/main/java/org/apache/atlas/repository/typestore/GraphBackedTypeStore.java
2dd339c2 
  repository/src/main/java/org/apache/atlas/repository/typestore/ITypeStore.java 84779f40

  repository/src/main/java/org/apache/atlas/repository/typestore/StorageException.java c4f64f82

  repository/src/main/java/org/apache/atlas/repository/typestore/StoreBackedTypeCache.java
f472fa61 
  repository/src/main/java/org/apache/atlas/repository/typestore/TypePersistenceVisitor.java
bfb1bfc7 
  repository/src/main/java/org/apache/atlas/repository/typestore/TypeVertexFinder.java 8b381524

  repository/src/main/java/org/apache/atlas/repository/typestore/TypeVertexInfo.java 32a9a196

  repository/src/main/java/org/apache/atlas/repository/typestore/TypeVisitor.java a6e353c1

  repository/src/main/java/org/apache/atlas/services/DefaultMetadataService.java 9eb695c0

  repository/src/main/java/org/apache/atlas/util/AtlasGremlin2QueryProvider.java 65b99cd0

  repository/src/main/java/org/apache/atlas/util/AtlasRepositoryConfiguration.java 09f366e2

  repository/src/main/java/org/apache/atlas/util/AttributeValueMap.java 6e226049 
  repository/src/main/java/org/apache/atlas/util/CompiledQueryCacheKey.java 56a5a2a5 
  repository/src/main/java/org/apache/atlas/util/IndexedInstance.java 60ec8cc2 
  repository/src/main/java/org/apache/atlas/util/NoopGremlinQuery.java 280570e5 
  repository/src/main/java/org/apache/atlas/util/TypeDefSorter.java 733aefde 
  repository/src/main/scala/org/apache/atlas/query/ClosureQuery.scala 1190114c 
  repository/src/main/scala/org/apache/atlas/query/Expressions.scala bf9efd2e 
  repository/src/main/scala/org/apache/atlas/query/GraphPersistenceStrategies.scala c2b3436a

  repository/src/main/scala/org/apache/atlas/query/GremlinEvaluator.scala 5f8ef8ae 
  repository/src/main/scala/org/apache/atlas/query/GremlinQuery.scala 37015d8e 
  repository/src/main/scala/org/apache/atlas/query/QueryParser.scala 4bc6e742 
  repository/src/main/scala/org/apache/atlas/query/QueryProcessor.scala e1e8408b 
  repository/src/main/scala/org/apache/atlas/query/Resolver.scala 1b42f3ee 
  repository/src/main/scala/org/apache/atlas/query/TypeUtils.scala 8d2c7aea 
  repository/src/test/java/org/apache/atlas/BaseRepositoryTest.java 7c6b60b7 
  repository/src/test/java/org/apache/atlas/RepositoryServiceLoadingTest.java 506d11c8 
  repository/src/test/java/org/apache/atlas/TestModules.java 144f6182 
  repository/src/test/java/org/apache/atlas/TestUtils.java 56bfb824 
  repository/src/test/java/org/apache/atlas/discovery/DataSetLineageServiceTest.java 3db58fe3

  repository/src/test/java/org/apache/atlas/discovery/EntityDiscoveryServiceTest.java ced0aa04

  repository/src/test/java/org/apache/atlas/discovery/GraphBackedDiscoveryServiceTest.java
bd730e43 
  repository/src/test/java/org/apache/atlas/lineage/EntityLineageServiceTest.java 202f20c0

  repository/src/test/java/org/apache/atlas/query/QueryProcessorTest.java 57bc74fb 
  repository/src/test/java/org/apache/atlas/repository/BaseTest.java 7e1df676 
  repository/src/test/java/org/apache/atlas/repository/audit/AuditRepositoryTestBase.java
551e6abb 
  repository/src/test/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepositoryHATest.java
f66ac746 
  repository/src/test/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepositoryTest.java
a9dfee33 
  repository/src/test/java/org/apache/atlas/repository/audit/HBaseTestUtils.java 984acfec

  repository/src/test/java/org/apache/atlas/repository/audit/InMemoryAuditRepositoryTest.java
3bdfcf96 
  repository/src/test/java/org/apache/atlas/repository/graph/AbstractGremlinQueryOptimizerTest.java
88de2c49 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryDeleteTestBase.java
0834601f 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedMetadataRepositoryTest.java
952a6448 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedRepositoryHardDeleteTest.java
9c0ef430 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedRepositorySoftDeleteTest.java
8c86235e 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexerMockTest.java
a98ef381 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexerTest.java
feffabf6 
  repository/src/test/java/org/apache/atlas/repository/graph/GraphHelperMockTest.java a0894cd8

  repository/src/test/java/org/apache/atlas/repository/graph/GraphHelperTest.java e64c2c80

  repository/src/test/java/org/apache/atlas/repository/graph/GraphRepoMapperScaleTest.java
1f077ba0 
  repository/src/test/java/org/apache/atlas/repository/graph/Gremlin2QueryOptimizerTest.java
8f638a08 
  repository/src/test/java/org/apache/atlas/repository/graph/Gremlin3QueryOptimizerTest.java
47dff147 
  repository/src/test/java/org/apache/atlas/repository/graph/ReverseReferenceUpdateHardDeleteTest.java
a3207fb8 
  repository/src/test/java/org/apache/atlas/repository/graph/ReverseReferenceUpdateSoftDeleteTest.java
ce43bdca 
  repository/src/test/java/org/apache/atlas/repository/graph/ReverseReferenceUpdateTestBase.java
8518f931 
  repository/src/test/java/org/apache/atlas/repository/graph/TestIntSequence.java b8eefca1

  repository/src/test/java/org/apache/atlas/repository/impexp/AtlasImportRequestTest.java
b70b181c 
  repository/src/test/java/org/apache/atlas/repository/impexp/ExportServiceTest.java 7901ef68

  repository/src/test/java/org/apache/atlas/repository/impexp/ImportServiceTest.java b24774d6

  repository/src/test/java/org/apache/atlas/repository/impexp/ImportServiceTestUtils.java
72895125 
  repository/src/test/java/org/apache/atlas/repository/impexp/ImportTransformerJSONTest.java
7044e713 
  repository/src/test/java/org/apache/atlas/repository/impexp/ImportTransformerTest.java 7ce34c8d

  repository/src/test/java/org/apache/atlas/repository/impexp/ImportTransformsTest.java ccedeb14

  repository/src/test/java/org/apache/atlas/repository/impexp/TypeAttributeDifferenceTest.java
87cb1d42 
  repository/src/test/java/org/apache/atlas/repository/impexp/UniqueListTest.java 93aa518c

  repository/src/test/java/org/apache/atlas/repository/impexp/ZipFileResourceTestUtils.java
5ab8c01b 
  repository/src/test/java/org/apache/atlas/repository/impexp/ZipSinkTest.java e8bbeb59 
  repository/src/test/java/org/apache/atlas/repository/impexp/ZipSourceTest.java 1c1c68f3

  repository/src/test/java/org/apache/atlas/repository/store/graph/AtlasTypeDefGraphStoreTest.java
9088470e 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasDeleteHandlerV1Test.java
718538a0 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityDefStoreV1Test.java
95b57618 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1BulkImportPercentTest.java
73dfe37c 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasEntityStoreV1Test.java
ef8bd2f2 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasRelationshipDefStoreV1Test.java
59bedd12 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasRelationshipStoreHardDeleteV1Test.java
109118ea 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasRelationshipStoreSoftDeleteV1Test.java
4faf5ad3 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/AtlasRelationshipStoreV1Test.java
8c58a928 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/HardDeleteHandlerV1Test.java
407ebffb 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/InverseReferenceUpdateHardDeleteV1Test.java
d54adeb0 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/InverseReferenceUpdateSoftDeleteV1Test.java
884ab546 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/InverseReferenceUpdateV1Test.java
6475639f 
  repository/src/test/java/org/apache/atlas/repository/store/graph/v1/SoftDeleteHandlerV1Test.java
3f1ed031 
  repository/src/test/java/org/apache/atlas/repository/typestore/GraphBackedTypeStoreTest.java
6e3dabb2 
  repository/src/test/java/org/apache/atlas/repository/typestore/StoreBackedTypeCacheTest.java
2ea63ff0 
  repository/src/test/java/org/apache/atlas/repository/userprofile/UserProfileServiceTest.java
0532f161 
  repository/src/test/java/org/apache/atlas/service/DefaultMetadataServiceTest.java e885b8c9

  repository/src/test/java/org/apache/atlas/service/StoreBackedTypeCacheMetadataServiceTest.java
5c37b9e2 
  repository/src/test/java/org/apache/atlas/services/MetricsServiceTest.java 5165bcb9 
  repository/src/test/java/org/apache/atlas/util/CompiledQueryCacheKeyTest.java 725aa43a 
  repository/src/test/java/org/apache/atlas/utils/HiveModel.java 4fc04737 
  repository/src/test/java/org/apache/atlas/utils/ObjectUpdateSynchronizerTest.java 03ebae44

  repository/src/test/scala/org/apache/atlas/query/ExpressionTest.scala 918f3275 
  repository/src/test/scala/org/apache/atlas/query/GremlinTest.scala a948d16d 
  repository/src/test/scala/org/apache/atlas/query/GremlinTest2.scala 880a0c61 
  repository/src/test/scala/org/apache/atlas/query/HiveTitanSample.scala fa0d3419 
  repository/src/test/scala/org/apache/atlas/query/LexerTest.scala 10237a9e 
  repository/src/test/scala/org/apache/atlas/query/LineageQueryTest.scala b01cbf89 
  repository/src/test/scala/org/apache/atlas/query/ParserTest.scala de5d8792 
  repository/src/test/scala/org/apache/atlas/query/QueryTestsUtils.scala f26f98e8 
  server-api/src/main/java/org/apache/atlas/RequestContext.java 3e729b52 
  server-api/src/main/java/org/apache/atlas/RequestContextV1.java 08aa9606 
  server-api/src/main/java/org/apache/atlas/discovery/LineageService.java 5aab3550 
  server-api/src/main/java/org/apache/atlas/listener/EntityChangeListener.java e05a7755 
  server-api/src/main/java/org/apache/atlas/listener/TypesChangeListener.java 5ff6d4aa 
  server-api/src/main/java/org/apache/atlas/services/MetadataService.java d2aa457b 
  server-api/src/main/java/org/apache/atlas/typesystem/exception/EntityExistsException.java
b16cfa99 
  server-api/src/main/java/org/apache/atlas/typesystem/exception/NullRequiredAttributeException.java
db4b054c 
  typesystem/src/main/java/org/apache/atlas/typesystem/IInstance.java adb28d48 
  typesystem/src/main/java/org/apache/atlas/typesystem/IReferenceableInstance.java 04af67cc

  typesystem/src/main/java/org/apache/atlas/typesystem/IStruct.java e0f85761 
  typesystem/src/main/java/org/apache/atlas/typesystem/ITypedInstance.java c3bb9afc 
  typesystem/src/main/java/org/apache/atlas/typesystem/ITypedReferenceableInstance.java 6dae95c5

  typesystem/src/main/java/org/apache/atlas/typesystem/ITypedStruct.java ced255c2 
  typesystem/src/main/java/org/apache/atlas/typesystem/Referenceable.java 8cad2f8c 
  typesystem/src/main/java/org/apache/atlas/typesystem/Struct.java f8d2e42f 
  typesystem/src/main/java/org/apache/atlas/typesystem/persistence/AtlasSystemAttributes.java
3c08a026 
  typesystem/src/main/java/org/apache/atlas/typesystem/persistence/DownCastStructInstance.java
e4ebb178 
  typesystem/src/main/java/org/apache/atlas/typesystem/persistence/Id.java ba05a45f 
  typesystem/src/main/java/org/apache/atlas/typesystem/persistence/MapIds.java e62f29da 
  typesystem/src/main/java/org/apache/atlas/typesystem/persistence/ReferenceableInstance.java
be2634d6 
  typesystem/src/main/java/org/apache/atlas/typesystem/persistence/StructInstance.java 766d2d0c

  typesystem/src/main/java/org/apache/atlas/typesystem/types/AbstractDataType.java 874138b6

  typesystem/src/main/java/org/apache/atlas/typesystem/types/AttributeDefinition.java 5561f0b2

  typesystem/src/main/java/org/apache/atlas/typesystem/types/AttributeInfo.java c24a55f1 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/ClassType.java 2f2b0906 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/DataTypes.java f9f4abe6 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/DownCastFieldMapping.java 85e288ed

  typesystem/src/main/java/org/apache/atlas/typesystem/types/EnumType.java 82e22cee 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/EnumTypeDefinition.java 40cb132c

  typesystem/src/main/java/org/apache/atlas/typesystem/types/EnumValue.java d75259bb 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/FieldMapping.java a2b3db29 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/HierarchicalType.java ac7f442e

  typesystem/src/main/java/org/apache/atlas/typesystem/types/HierarchicalTypeDefinition.java
ab63fea3 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/HierarchicalTypeDependencySorter.java
aaec05c8 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/IConstructableType.java d54da0af

  typesystem/src/main/java/org/apache/atlas/typesystem/types/IDataType.java a7a21238 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/Multiplicity.java c213d75d 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/ObjectGraphTraversal.java 9a1847c6

  typesystem/src/main/java/org/apache/atlas/typesystem/types/ObjectGraphWalker.java 036d18dc

  typesystem/src/main/java/org/apache/atlas/typesystem/types/StructType.java 57f25177 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/StructTypeDefinition.java 4f8695be

  typesystem/src/main/java/org/apache/atlas/typesystem/types/TraitType.java bbb845aa 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/TypeSystem.java 262f784f 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/TypeUpdateException.java 33d1cb5f

  typesystem/src/main/java/org/apache/atlas/typesystem/types/TypeUtils.java 6a14dc41 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/TypedStructHandler.java 9afa8730

  typesystem/src/main/java/org/apache/atlas/typesystem/types/ValueConversionException.java
f7561356 
  typesystem/src/main/java/org/apache/atlas/typesystem/types/cache/DefaultTypeCache.java 0d864742

  typesystem/src/main/java/org/apache/atlas/typesystem/types/cache/TypeCache.java c8f65bec

  typesystem/src/main/java/org/apache/atlas/typesystem/types/utils/TypesUtil.java 39244dc7

  typesystem/src/main/scala/org/apache/atlas/typesystem/TypesDef.scala b51048df 
  typesystem/src/main/scala/org/apache/atlas/typesystem/builders/InstanceBuilder.scala 9e22f674

  typesystem/src/main/scala/org/apache/atlas/typesystem/builders/TypesBuilder.scala 5ea345fe

  typesystem/src/main/scala/org/apache/atlas/typesystem/json/InstanceSerialization.scala d4bed75e

  typesystem/src/main/scala/org/apache/atlas/typesystem/json/Serialization.scala ca4dd7fe

  typesystem/src/main/scala/org/apache/atlas/typesystem/json/TypesSerialization.scala 4478a44b

  typesystem/src/test/java/org/apache/atlas/ApplicationPropertiesTest.java 25a19cf1 
  typesystem/src/test/java/org/apache/atlas/typesystem/json/SerializationJavaTest.java 5ee019cb

  typesystem/src/test/java/org/apache/atlas/typesystem/types/BaseTest.java 95c99e4f 
  typesystem/src/test/java/org/apache/atlas/typesystem/types/ClassTest.java daecdd78 
  typesystem/src/test/java/org/apache/atlas/typesystem/types/EnumTest.java 23071922 
  typesystem/src/test/java/org/apache/atlas/typesystem/types/FieldMappingTest.java 0259ade9

  typesystem/src/test/java/org/apache/atlas/typesystem/types/HierarchicalTypeDependencySorterTest.java
19bdccfc 
  typesystem/src/test/java/org/apache/atlas/typesystem/types/HierarchicalTypeTest.java 9f63f523

  typesystem/src/test/java/org/apache/atlas/typesystem/types/StructTest.java 3a1675e1 
  typesystem/src/test/java/org/apache/atlas/typesystem/types/TraitTest.java 7c392138 
  typesystem/src/test/java/org/apache/atlas/typesystem/types/TypeInheritanceTest.java c13ef3a1

  typesystem/src/test/java/org/apache/atlas/typesystem/types/TypeSystemTest.java 0ef5d10d

  typesystem/src/test/java/org/apache/atlas/typesystem/types/TypeUpdateBaseTest.java 4a6ed2d0

  typesystem/src/test/java/org/apache/atlas/typesystem/types/ValidationTest.java 1a86cf32

  typesystem/src/test/java/org/apache/atlas/typesystem/types/cache/DefaultTypeCacheTest.java
5c397dd8 
  typesystem/src/test/scala/org/apache/atlas/typesystem/builders/BuilderTest.scala 9d1d00f1

  typesystem/src/test/scala/org/apache/atlas/typesystem/builders/InstanceBuilderTest.scala
0331c9cb 
  typesystem/src/test/scala/org/apache/atlas/typesystem/builders/MultiplicityTest.scala 91e72c7d

  typesystem/src/test/scala/org/apache/atlas/typesystem/builders/TypesBuilderTest.scala d01adb4e

  typesystem/src/test/scala/org/apache/atlas/typesystem/json/InstanceSerializationTest.scala
9e656a5d 
  typesystem/src/test/scala/org/apache/atlas/typesystem/json/SerializationTest.scala 931773dd

  typesystem/src/test/scala/org/apache/atlas/typesystem/json/TypesSerializationTest.scala
cfd4bdb2 
  webapp/src/main/java/org/apache/atlas/examples/QuickStart.java 91ba1113 
  webapp/src/main/java/org/apache/atlas/notification/NotificationEntityChangeListener.java
53acf563 
  webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java 4646bff9

  webapp/src/main/java/org/apache/atlas/web/filters/AtlasAuthenticationFilter.java e8020dbb

  webapp/src/main/java/org/apache/atlas/web/filters/AuditFilter.java 191388a9 
  webapp/src/main/java/org/apache/atlas/web/resources/DataSetLineageResource.java 435659e9

  webapp/src/main/java/org/apache/atlas/web/resources/EntityResource.java 8b565071 
  webapp/src/main/java/org/apache/atlas/web/resources/LineageResource.java cba8ccfe 
  webapp/src/main/java/org/apache/atlas/web/resources/MetadataDiscoveryResource.java d7c66d33

  webapp/src/main/java/org/apache/atlas/web/resources/TypesResource.java a9c55090 
  webapp/src/main/java/org/apache/atlas/web/util/LineageUtils.java ad2a697a 
  webapp/src/test/java/org/apache/atlas/examples/QuickStartIT.java 592c2a62 
  webapp/src/test/java/org/apache/atlas/notification/EntityNotificationIT.java 7e943300 
  webapp/src/test/java/org/apache/atlas/notification/NotificationEntityChangeListenerTest.java
a9889155 
  webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerIT.java d41db3ee

  webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java
eb37fa82 
  webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java e2d1022e

  webapp/src/test/java/org/apache/atlas/util/RestUtilsTest.java 87259df2 
  webapp/src/test/java/org/apache/atlas/web/adapters/TestEntitiesREST.java e7538817 
  webapp/src/test/java/org/apache/atlas/web/adapters/TestEntityREST.java b90ea645 
  webapp/src/test/java/org/apache/atlas/web/filters/AtlasAuthenticationKerberosFilterTest.java
5628b177 
  webapp/src/test/java/org/apache/atlas/web/integration/BaseResourceIT.java 512750fc 
  webapp/src/test/java/org/apache/atlas/web/integration/DataSetLineageJerseyResourceIT.java
9a0d0dcf 
  webapp/src/test/java/org/apache/atlas/web/integration/EntityDiscoveryJerseyResourceIT.java
157bf979 
  webapp/src/test/java/org/apache/atlas/web/integration/EntityJerseyResourceIT.java cf44d4af

  webapp/src/test/java/org/apache/atlas/web/integration/EntityLineageJerseyResourceIT.java
38113908 
  webapp/src/test/java/org/apache/atlas/web/integration/EntityV2JerseyResourceIT.java d61a9afc

  webapp/src/test/java/org/apache/atlas/web/integration/MetadataDiscoveryJerseyResourceIT.java
a13f0696 
  webapp/src/test/java/org/apache/atlas/web/integration/TypedefsJerseyResourceIT.java c46689c0

  webapp/src/test/java/org/apache/atlas/web/integration/TypesJerseyResourceIT.java 351e5ae7



Diff: https://reviews.apache.org/r/63658/diff/1/


Testing
-------

- verified that hook notifications from earlier version of hooks are sucessfully processed
by Atlas server
- verified that entitiy notificaitons generated by the server are successfully processed by
earlier version of Ranger
- succesfullt imported types, classifications and entities
- verified that basic-search works


Thanks,

Madhan Neethiraj


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message