-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
15 changed files
with
193 additions
and
30 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
18 changes: 18 additions & 0 deletions
18
client/src/test/java/eu/europeana/processing/config/JarIdsProperties.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,18 @@ | ||
| package eu.europeana.processing.config; | ||
|
|
||
| import lombok.Getter; | ||
| import lombok.Setter; | ||
| import org.springframework.boot.context.properties.ConfigurationProperties; | ||
|
|
||
| @Setter | ||
| @Getter | ||
| @ConfigurationProperties(prefix = "flink.jar.id") | ||
| public class JarIdsProperties { | ||
| private String oai; | ||
| private String validation; | ||
| private String transformation; | ||
| private String normalization; | ||
| private String enrichment; | ||
| private String media; | ||
| private String indexing; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
21 changes: 21 additions & 0 deletions
21
client/src/test/java/eu/europeana/processing/config/db/entity/ExecutionRecord.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| package eu.europeana.processing.config.db.entity; | ||
|
|
||
| import jakarta.persistence.Column; | ||
| import jakarta.persistence.Entity; | ||
| import jakarta.persistence.Index; | ||
| import jakarta.persistence.Table; | ||
| import lombok.Getter; | ||
| import lombok.Setter; | ||
|
|
||
| @Getter | ||
| @Setter | ||
| @Entity | ||
| @Table(schema = "batch-framework", indexes = {@Index(name = "execution_record_dataset_id_execution_id_idx", columnList = "datasetId, executionId")}) | ||
| public class ExecutionRecord extends ExecutionRecordIdentifier{ | ||
|
|
||
| @Column(length = 50) | ||
| private String executionName; | ||
| @Column(columnDefinition = "TEXT") | ||
| private String recordData; | ||
| } | ||
|
|
16 changes: 16 additions & 0 deletions
16
client/src/test/java/eu/europeana/processing/config/db/entity/ExecutionRecordDTO.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,16 @@ | ||
| package eu.europeana.processing.config.db.entity; | ||
|
|
||
| import lombok.Getter; | ||
| import lombok.Setter; | ||
|
|
||
| @Getter | ||
| @Setter | ||
| public class ExecutionRecordDTO { | ||
|
|
||
| private String datasetId; | ||
| private String executionId; | ||
| private String recordId; | ||
| private String executionName; | ||
| private String recordData; | ||
| private String exception; | ||
| } |
20 changes: 20 additions & 0 deletions
20
...t/src/test/java/eu/europeana/processing/config/db/entity/ExecutionRecordExceptionLog.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| package eu.europeana.processing.config.db.entity; | ||
|
|
||
| import jakarta.persistence.Column; | ||
| import jakarta.persistence.Entity; | ||
| import jakarta.persistence.Index; | ||
| import jakarta.persistence.Table; | ||
| import lombok.Getter; | ||
| import lombok.Setter; | ||
|
|
||
| @Getter | ||
| @Setter | ||
| @Entity | ||
| @Table(schema = "batch-framework", indexes = {@Index(name = "execution_record_exception_log_dataset_id_execution_id_idx", columnList = "datasetId, executionId")}) | ||
| public class ExecutionRecordExceptionLog extends ExecutionRecordIdentifier{ | ||
|
|
||
| @Column(length = 50) | ||
| private String executionName; | ||
| @Column(columnDefinition = "TEXT") | ||
| private String exception; | ||
| } |
15 changes: 15 additions & 0 deletions
15
...test/java/eu/europeana/processing/config/db/entity/ExecutionRecordExternalIdentifier.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,15 @@ | ||
| package eu.europeana.processing.config.db.entity; | ||
|
|
||
| import jakarta.persistence.Entity; | ||
| import jakarta.persistence.Table; | ||
| import lombok.Getter; | ||
| import lombok.Setter; | ||
|
|
||
| @Getter | ||
| @Setter | ||
| @Entity | ||
| @Table(schema = "batch-framework") | ||
| public class ExecutionRecordExternalIdentifier extends ExecutionRecordIdentifier{ | ||
|
|
||
| private boolean isDeleted; | ||
| } |
28 changes: 28 additions & 0 deletions
28
client/src/test/java/eu/europeana/processing/config/db/entity/ExecutionRecordIdentifier.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,28 @@ | ||
| package eu.europeana.processing.config.db.entity; | ||
|
|
||
| import jakarta.persistence.Column; | ||
| import jakarta.persistence.Entity; | ||
| import jakarta.persistence.Id; | ||
| import jakarta.persistence.IdClass; | ||
| import jakarta.persistence.Inheritance; | ||
| import jakarta.persistence.InheritanceType; | ||
| import lombok.Getter; | ||
| import lombok.Setter; | ||
|
|
||
| @Getter | ||
| @Setter | ||
| @Entity | ||
| @IdClass(ExecutionRecordIdentifier.class) | ||
| @Inheritance(strategy = InheritanceType.TABLE_PER_CLASS) | ||
| public class ExecutionRecordIdentifier { | ||
| @Id | ||
| @Column(length = 20) | ||
| private String datasetId; | ||
| @Id | ||
| @Column(length = 50) | ||
| private String executionId; | ||
| @Id | ||
| @Column(length = 300) | ||
| private String recordId; | ||
|
|
||
| } |
11 changes: 11 additions & 0 deletions
11
...eu/europeana/processing/config/db/repositories/ExecutionRecordExceptionLogRepository.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,11 @@ | ||
| package eu.europeana.processing.config.db.repositories; | ||
|
|
||
| import eu.europeana.processing.config.db.entity.ExecutionRecordExceptionLog; | ||
| import eu.europeana.processing.config.db.entity.ExecutionRecordIdentifier; | ||
| import org.springframework.data.jpa.repository.JpaRepository; | ||
| import org.springframework.stereotype.Repository; | ||
|
|
||
| @Repository | ||
| public interface ExecutionRecordExceptionLogRepository<T extends ExecutionRecordIdentifier> extends JpaRepository<ExecutionRecordExceptionLog, T> { | ||
| long countByDatasetIdAndExecutionId(String datasetId, String executionId); | ||
| } |
14 changes: 14 additions & 0 deletions
14
...opeana/processing/config/db/repositories/ExecutionRecordExternalIdentifierRepository.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| package eu.europeana.processing.config.db.repositories; | ||
|
|
||
| import eu.europeana.processing.config.db.entity.ExecutionRecordExternalIdentifier; | ||
| import eu.europeana.processing.config.db.entity.ExecutionRecordIdentifier; | ||
| import org.springframework.data.domain.Page; | ||
| import org.springframework.data.domain.Pageable; | ||
| import org.springframework.data.jpa.repository.JpaRepository; | ||
|
|
||
| public interface ExecutionRecordExternalIdentifierRepository<T extends ExecutionRecordIdentifier> extends JpaRepository<ExecutionRecordExternalIdentifier, T> { | ||
|
|
||
| Page<ExecutionRecordExternalIdentifier> findAllByExecutionId(String executionId, Pageable pageable); | ||
| long countByDatasetIdAndExecutionId(String datasetId, String executionId); | ||
|
|
||
| } |
14 changes: 14 additions & 0 deletions
14
...c/test/java/eu/europeana/processing/config/db/repositories/ExecutionRecordRepository.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| package eu.europeana.processing.config.db.repositories; | ||
|
|
||
| import eu.europeana.processing.config.db.entity.ExecutionRecord; | ||
| import eu.europeana.processing.config.db.entity.ExecutionRecordIdentifier; | ||
| import org.springframework.data.domain.Page; | ||
| import org.springframework.data.domain.Pageable; | ||
| import org.springframework.data.jpa.repository.JpaRepository; | ||
| import org.springframework.stereotype.Repository; | ||
|
|
||
| @Repository | ||
| public interface ExecutionRecordRepository<T extends ExecutionRecordIdentifier> extends JpaRepository<ExecutionRecord, T> { | ||
| Page<ExecutionRecord> findByDatasetIdAndExecutionId(String datasetId, String executionId, Pageable pageable); | ||
| long countByDatasetIdAndExecutionId(String datasetId, String executionId); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters