diff --git a/entity-registry/build.gradle b/entity-registry/build.gradle index 78590ee816..986ffc7b42 100644 --- a/entity-registry/build.gradle +++ b/entity-registry/build.gradle @@ -15,6 +15,8 @@ dependencies { compile externalDependency.mavenArtifact testCompile externalDependency.testng + testCompile externalDependency.mockito + testCompile externalDependency.mockitoInline testCompile project(':test-models') } diff --git a/metadata-io/src/main/java/com/linkedin/metadata/graph/LineageRegistry.java b/entity-registry/src/main/java/com/linkedin/metadata/models/registry/LineageRegistry.java similarity index 97% rename from metadata-io/src/main/java/com/linkedin/metadata/graph/LineageRegistry.java rename to entity-registry/src/main/java/com/linkedin/metadata/models/registry/LineageRegistry.java index 16066e2480..922ce6a819 100644 --- a/metadata-io/src/main/java/com/linkedin/metadata/graph/LineageRegistry.java +++ b/entity-registry/src/main/java/com/linkedin/metadata/models/registry/LineageRegistry.java @@ -1,7 +1,7 @@ -package com.linkedin.metadata.graph; +package com.linkedin.metadata.models.registry; +import com.linkedin.metadata.graph.LineageDirection; import com.linkedin.metadata.models.annotation.RelationshipAnnotation; -import com.linkedin.metadata.models.registry.EntityRegistry; import com.linkedin.metadata.query.filter.RelationshipDirection; import java.util.ArrayList; import java.util.Collection; @@ -91,7 +91,7 @@ public class LineageRegistry { if (spec == null) { return Collections.emptyList(); } - + if (direction == LineageDirection.UPSTREAM) { return spec.getUpstreamEdges(); } diff --git a/metadata-io/src/test/java/com/linkedin/metadata/graph/LineageRegistryTest.java b/entity-registry/src/test/java/com/linkedin/metadata/models/registry/LineageRegistryTest.java similarity index 97% rename from metadata-io/src/test/java/com/linkedin/metadata/graph/LineageRegistryTest.java rename to entity-registry/src/test/java/com/linkedin/metadata/models/registry/LineageRegistryTest.java index db3ca3be53..15f3df0fcd 100644 --- a/metadata-io/src/test/java/com/linkedin/metadata/graph/LineageRegistryTest.java +++ b/entity-registry/src/test/java/com/linkedin/metadata/models/registry/LineageRegistryTest.java @@ -1,10 +1,9 @@ -package com.linkedin.metadata.graph; +package com.linkedin.metadata.models.registry; import com.google.common.collect.ImmutableList; import com.linkedin.metadata.models.EntitySpec; import com.linkedin.metadata.models.RelationshipFieldSpec; import com.linkedin.metadata.models.annotation.RelationshipAnnotation; -import com.linkedin.metadata.models.registry.EntityRegistry; import com.linkedin.metadata.query.filter.RelationshipDirection; import java.util.Collections; import java.util.HashMap; diff --git a/metadata-io/src/main/java/com/linkedin/metadata/graph/GraphService.java b/metadata-io/src/main/java/com/linkedin/metadata/graph/GraphService.java index 124033e602..b010995e0c 100644 --- a/metadata-io/src/main/java/com/linkedin/metadata/graph/GraphService.java +++ b/metadata-io/src/main/java/com/linkedin/metadata/graph/GraphService.java @@ -1,6 +1,7 @@ package com.linkedin.metadata.graph; import com.linkedin.common.urn.Urn; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.query.filter.Filter; import com.linkedin.metadata.query.filter.RelationshipDirection; import com.linkedin.metadata.query.filter.RelationshipFilter; diff --git a/metadata-io/src/main/java/com/linkedin/metadata/graph/dgraph/DgraphGraphService.java b/metadata-io/src/main/java/com/linkedin/metadata/graph/dgraph/DgraphGraphService.java index 7ee29d2f72..22b70156c5 100644 --- a/metadata-io/src/main/java/com/linkedin/metadata/graph/dgraph/DgraphGraphService.java +++ b/metadata-io/src/main/java/com/linkedin/metadata/graph/dgraph/DgraphGraphService.java @@ -6,7 +6,7 @@ import com.google.protobuf.ByteString; import com.linkedin.common.urn.Urn; import com.linkedin.metadata.graph.Edge; import com.linkedin.metadata.graph.GraphService; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.RelatedEntitiesResult; import com.linkedin.metadata.graph.RelatedEntity; import com.linkedin.metadata.query.filter.Criterion; diff --git a/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ESGraphQueryDAO.java b/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ESGraphQueryDAO.java index cc2ab4fc8d..bcba903ce1 100644 --- a/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ESGraphQueryDAO.java +++ b/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ESGraphQueryDAO.java @@ -7,8 +7,8 @@ import com.google.common.collect.Lists; import com.linkedin.common.urn.Urn; import com.linkedin.common.urn.UrnUtils; import com.linkedin.metadata.graph.LineageDirection; -import com.linkedin.metadata.graph.LineageRegistry; -import com.linkedin.metadata.graph.LineageRegistry.EdgeInfo; +import com.linkedin.metadata.models.registry.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry.EdgeInfo; import com.linkedin.metadata.graph.LineageRelationship; import com.linkedin.metadata.query.filter.Condition; import com.linkedin.metadata.query.filter.ConjunctiveCriterion; diff --git a/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphService.java b/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphService.java index bec46a9f66..2441ff83d8 100644 --- a/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphService.java +++ b/metadata-io/src/main/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphService.java @@ -8,7 +8,7 @@ import com.linkedin.metadata.graph.Edge; import com.linkedin.metadata.graph.EntityLineageResult; import com.linkedin.metadata.graph.GraphService; import com.linkedin.metadata.graph.LineageDirection; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.LineageRelationshipArray; import com.linkedin.metadata.graph.RelatedEntitiesResult; import com.linkedin.metadata.graph.RelatedEntity; diff --git a/metadata-io/src/main/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphService.java b/metadata-io/src/main/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphService.java index 4993495079..3476ddfa99 100644 --- a/metadata-io/src/main/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphService.java +++ b/metadata-io/src/main/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphService.java @@ -7,7 +7,7 @@ import com.google.common.collect.ImmutableMap; import com.linkedin.common.urn.Urn; import com.linkedin.metadata.graph.Edge; import com.linkedin.metadata.graph.GraphService; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.RelatedEntitiesResult; import com.linkedin.metadata.graph.RelatedEntity; import com.linkedin.metadata.query.filter.Condition; diff --git a/metadata-io/src/test/java/com/linkedin/metadata/graph/dgraph/DgraphGraphServiceTest.java b/metadata-io/src/test/java/com/linkedin/metadata/graph/dgraph/DgraphGraphServiceTest.java index 70f1123ce7..3626fa2df2 100644 --- a/metadata-io/src/test/java/com/linkedin/metadata/graph/dgraph/DgraphGraphServiceTest.java +++ b/metadata-io/src/test/java/com/linkedin/metadata/graph/dgraph/DgraphGraphServiceTest.java @@ -2,7 +2,7 @@ package com.linkedin.metadata.graph.dgraph; import com.linkedin.metadata.graph.GraphService; import com.linkedin.metadata.graph.GraphServiceTestBase; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.RelatedEntity; import com.linkedin.metadata.models.registry.SnapshotEntityRegistry; import com.linkedin.metadata.query.filter.RelationshipDirection; diff --git a/metadata-io/src/test/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphServiceTest.java b/metadata-io/src/test/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphServiceTest.java index 3f0f9a4f51..8f016c38a3 100644 --- a/metadata-io/src/test/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphServiceTest.java +++ b/metadata-io/src/test/java/com/linkedin/metadata/graph/elastic/ElasticSearchGraphServiceTest.java @@ -7,7 +7,7 @@ import com.linkedin.metadata.graph.EntityLineageResult; import com.linkedin.metadata.graph.GraphService; import com.linkedin.metadata.graph.GraphServiceTestBase; import com.linkedin.metadata.graph.LineageDirection; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.LineageRelationship; import com.linkedin.metadata.graph.RelatedEntitiesResult; import com.linkedin.metadata.graph.RelatedEntity; diff --git a/metadata-io/src/test/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphServiceTest.java b/metadata-io/src/test/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphServiceTest.java index 1c7065e6b1..458cb52599 100644 --- a/metadata-io/src/test/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphServiceTest.java +++ b/metadata-io/src/test/java/com/linkedin/metadata/graph/neo4j/Neo4jGraphServiceTest.java @@ -2,7 +2,7 @@ package com.linkedin.metadata.graph.neo4j; import com.linkedin.metadata.graph.GraphService; import com.linkedin.metadata.graph.GraphServiceTestBase; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.RelatedEntitiesResult; import com.linkedin.metadata.graph.RelatedEntity; import com.linkedin.metadata.models.registry.SnapshotEntityRegistry; diff --git a/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/ElasticSearchGraphServiceFactory.java b/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/ElasticSearchGraphServiceFactory.java index 463fccd3bb..12ede1ef94 100644 --- a/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/ElasticSearchGraphServiceFactory.java +++ b/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/ElasticSearchGraphServiceFactory.java @@ -3,7 +3,7 @@ package com.linkedin.gms.factory.common; import com.linkedin.gms.factory.entityregistry.EntityRegistryFactory; import com.linkedin.gms.factory.search.BaseElasticSearchComponentsFactory; import com.linkedin.gms.factory.spring.YamlPropertySourceFactory; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.elastic.ESGraphQueryDAO; import com.linkedin.metadata.graph.elastic.ESGraphWriteDAO; import com.linkedin.metadata.graph.elastic.ElasticSearchGraphService; diff --git a/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/Neo4jGraphServiceFactory.java b/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/Neo4jGraphServiceFactory.java index 86705c9b71..e62dfd50f8 100644 --- a/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/Neo4jGraphServiceFactory.java +++ b/metadata-service/factories/src/main/java/com/linkedin/gms/factory/common/Neo4jGraphServiceFactory.java @@ -1,7 +1,7 @@ package com.linkedin.gms.factory.common; import com.linkedin.gms.factory.entityregistry.EntityRegistryFactory; -import com.linkedin.metadata.graph.LineageRegistry; +import com.linkedin.metadata.models.registry.LineageRegistry; import com.linkedin.metadata.graph.neo4j.Neo4jGraphService; import com.linkedin.metadata.models.registry.EntityRegistry; import javax.annotation.Nonnull; diff --git a/metadata-service/restli-servlet-impl/build.gradle b/metadata-service/restli-servlet-impl/build.gradle index b790ae5c83..eafe43f74e 100644 --- a/metadata-service/restli-servlet-impl/build.gradle +++ b/metadata-service/restli-servlet-impl/build.gradle @@ -46,7 +46,6 @@ dependencies { annotationProcessor externalDependency.lombok testCompile project(':test-models') - testCompile externalDependency.parseqTest testCompile externalDependency.mockito testCompile externalDependency.testng