Added a feature to query stored PM data 04/9104/1
authorPatrikBuhr <patrik.buhr@est.tech>
Fri, 23 Sep 2022 13:06:40 +0000 (15:06 +0200)
committerPatrikBuhr <patrik.buhr@est.tech>
Fri, 23 Sep 2022 13:09:01 +0000 (15:09 +0200)
commit0553c9422aa7b69145b7e6d23f39a9052f2b1da7
tree028e60fc48252ef9b83d1f7b7e1fcf568baac6b6
parent46142fc8863cf20b5e68e30cca55da0e0d68f9c2
Added a feature to query stored PM data

Change-Id: I6ac0f2e6a4a6db0cea8ffd36583c330a1dc0babb
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-773
14 files changed:
config/application.yaml
src/main/java/org/oran/dmaapadapter/configuration/ApplicationConfig.java
src/main/java/org/oran/dmaapadapter/filter/PmReportFilter.java
src/main/java/org/oran/dmaapadapter/repository/Job.java
src/main/java/org/oran/dmaapadapter/tasks/DataStore.java [new file with mode: 0644]
src/main/java/org/oran/dmaapadapter/tasks/FileStore.java [new file with mode: 0644]
src/main/java/org/oran/dmaapadapter/tasks/HttpJobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/JobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicListener.java
src/main/java/org/oran/dmaapadapter/tasks/S3ObjectStore.java [new file with mode: 0644]
src/main/java/org/oran/dmaapadapter/tasks/TopicListeners.java
src/main/resources/typeSchemaPmData.json
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java