yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-02 19:48:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: DELETE endpoint for profiler data (#12912)

Browse Source
This commit is contained in:
Teddy 2023-08-18 20:48:04 +02:00 committed by GitHub
parent a45c644bc4
commit edea862082
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TableRepository.java
View File

@ -402,16 +402,21 @@ public class TableRepository extends EntityRepository<Table> {
public void deleteTableProfile(String fqn, String entityType, Long timestamp) { public void deleteTableProfile(String fqn, String entityType, Long timestamp) {
// Validate the request content // Validate the request content
String extension; String extension;
Class classMapper;
if (entityType.equalsIgnoreCase(Entity.TABLE)) { if (entityType.equalsIgnoreCase(Entity.TABLE)) {
extension = TABLE_PROFILE_EXTENSION; extension = TABLE_PROFILE_EXTENSION;
classMapper = TableProfile.class;
} else if (entityType.equalsIgnoreCase("column")) { } else if (entityType.equalsIgnoreCase("column")) {
extension = TABLE_COLUMN_PROFILE_EXTENSION; extension = TABLE_COLUMN_PROFILE_EXTENSION;
classMapper = ColumnProfile.class;
} else if (entityType.equalsIgnoreCase("system")) {
extension = SYSTEM_PROFILE_EXTENSION;
classMapper = SystemProfile.class;
} else { } else {
throw new IllegalArgumentException("entityType must be table or column"); throw new IllegalArgumentException("entityType must be table, column or system");
} }
TableProfile storedTableProfile = Object storedTableProfile = JsonUtils.readValue(getExtensionAtTimestamp(fqn, extension, timestamp), classMapper);
JsonUtils.readValue(getExtensionAtTimestamp(fqn, extension, timestamp), TableProfile.class);
if (storedTableProfile == null) { if (storedTableProfile == null) {
throw new EntityNotFoundException(String.format("Failed to find table profile for %s at %s", fqn, timestamp)); throw new EntityNotFoundException(String.format("Failed to find table profile for %s at %s", fqn, timestamp));
} }