From d2e1043d12355b3b2f24a0541dd22f5b466a34ae Mon Sep 17 00:00:00 2001
From: Andrea Burattin <andrea.burattin@gmail.com>
Date: Tue, 15 Mar 2022 22:30:06 +0100
Subject: [PATCH] Removed tracking for test files
---
src/main/java/beamline/tester/Tester.java | 136 ---------------------
src/main/java/beamline/tester/Tester2.java | 35 ------
src/main/java/beamline/tester/Tester3.java | 71 -----------
3 files changed, 242 deletions(-)
delete mode 100644 src/main/java/beamline/tester/Tester.java
delete mode 100644 src/main/java/beamline/tester/Tester2.java
delete mode 100644 src/main/java/beamline/tester/Tester3.java
diff --git a/src/main/java/beamline/tester/Tester.java b/src/main/java/beamline/tester/Tester.java
deleted file mode 100644
index b4289f0..0000000
--- a/src/main/java/beamline/tester/Tester.java
+++ /dev/null
@@ -1,136 +0,0 @@
-package beamline.tester;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-
-import org.deckfour.xes.extension.std.XConceptExtension;
-import org.deckfour.xes.extension.std.XTimeExtension;
-import org.deckfour.xes.in.XParser;
-import org.deckfour.xes.in.XesXmlParser;
-import org.deckfour.xes.model.XEvent;
-import org.deckfour.xes.model.XLog;
-import org.deckfour.xes.model.XTrace;
-
-import beamline.filters.ExcludeActivitiesFilter;
-import beamline.filters.RetainActivitiesFilter;
-import beamline.mappers.DirectlyFollowsRelation;
-import beamline.mappers.InfiniteSizeDirectlyFollowsMapper;
-import beamline.models.algorithms.HookEventProcessing;
-import beamline.models.algorithms.StreamMiningAlgorithm;
-import beamline.models.responses.GraphvizResponse;
-import beamline.sources.MQTTXesSource;
-import beamline.sources.XesLogSource;
-import beamline.sources.XesSource;
-import io.reactivex.rxjava3.annotations.NonNull;
-import io.reactivex.rxjava3.core.Observable;
-import io.reactivex.rxjava3.core.ObservableEmitter;
-import io.reactivex.rxjava3.core.ObservableOnSubscribe;
-import io.reactivex.rxjava3.core.ObservableSource;
-import io.reactivex.rxjava3.functions.Consumer;
-import io.reactivex.rxjava3.functions.Function;
-import io.reactivex.rxjava3.functions.Predicate;
-import jdk.jshell.execution.StreamingExecutionControl;
-
-public class Tester {
-
- public static void main(String[] args) throws Exception {
- System.out.println("start");
-
- XParser p = new XesXmlParser();
- XLog l = p.parse(new File("C:\\Users\\andbur\\Desktop\\input.xes")).get(0);
-// XesSource source = new XesLogSource(l);
- XesSource source = new MQTTXesSource("tcp://broker.hivemq.com:1883", "pmcep", "test");
- source.prepare();
-
-// DiscoveryMiner miner = new DiscoveryMiner();
-// miner.setMinDependency(0.3);
-// miner.setModelRefreshRate(1);
-// miner.setOnAfterEvent(new HookEventProcessing() {
-// @Override
-// public void trigger() {
-// if (miner.getProcessedEvents() % 100 == 0) {
-// try {
-// GraphvizResponse resp = miner.getLatestResponse();
-// resp.generateDot().exportToSvg(new File("C:\\Users\\andbur\\Desktop\\output-" + miner.getProcessedEvents() + ".svg"));
-// } catch (IOException e) { }
-// }
-// }
-// });
-
- Observable<XTrace> obs = source.getObservable();
- obs
-// .filter(new RetainActivitiesFilter("A", "B", "C", "dummy-retain"))
-// .filter(new ExcludeActivitiesFilter("A", "dummy-exclude"))
-// .map(new DirectSuccessionMapper())
-// .combine(new SlidingWindow(1000))
-// .map(new Miner(1, 0.5))
-// .subscribe(miner);
-// .mapOptional(new Function<XTrace, Optional<Pair<String, String>>>() {
-//
-// @Override
-// public @NonNull Optional<Pair<String, String>> apply(@NonNull XTrace t) throws Throwable {
-// // TODO Auto-generated method stub
-// return null;
-// }
-// });
-// .map(new Function<XTrace, DirectlyFollowRelation>() {
-// Map<String, String> map = new HashMap<String, String>();
-//
-// @Override
-// public @NonNull DirectlyFollowRelation apply(@NonNull XTrace t) throws Throwable {
-// String caseId = XConceptExtension.instance().extractName(t);
-// String act = XConceptExtension.instance().extractName(t.get(0));
-// DirectlyFollowRelation toRet = new DirectlyFollowRelation();
-// if (map.containsKey(caseId)) {
-// String prevAct = map.get(caseId);
-// toRet.first = prevAct;
-// toRet.second = act;
-// toRet.caseId = caseId;
-// }
-// map.put(caseId, act);
-//
-// return toRet;
-// }
-// })
-// .filter(new Predicate<DirectlyFollowRelation>() {
-// @Override
-// public boolean test(@NonNull DirectlyFollowRelation t) throws Throwable {
-// return t.first != null && t.second != null;
-// }
-// })
- .flatMap(new InfiniteSizeDirectlyFollowsMapper())
- .subscribe(new Consumer<DirectlyFollowsRelation>() {
-
- @Override
- public void accept(@NonNull DirectlyFollowsRelation t) throws Throwable {
- System.out.println(
- XConceptExtension.instance().extractName(t.getFirst()) + " -> " +
- XConceptExtension.instance().extractName(t.getSecond()) + " for case " + t.getCaseId());
- }
- });
-
-
-
-// .subscribe(new Consumer<XTrace>() {
-// @Override
-// public void accept(@NonNull XTrace t) throws Throwable {
-// System.out.println(
-// XConceptExtension.instance().extractName(t) + " - " +
-// XConceptExtension.instance().extractName(t.get(0)) + " - " +
-// XTimeExtension.instance().extractTimestamp(t.get(0))
-// );
-// }
-// });
-
-// miner.getLatestResponse().generateDot().exportToSvg(new File("C:\\Users\\andbur\\Desktop\\output.svg"));
-
- System.out.println("done");
- }
-
-}
diff --git a/src/main/java/beamline/tester/Tester2.java b/src/main/java/beamline/tester/Tester2.java
deleted file mode 100644
index 9eca93b..0000000
--- a/src/main/java/beamline/tester/Tester2.java
+++ /dev/null
@@ -1,35 +0,0 @@
-package beamline.tester;
-
-import java.io.IOException;
-
-import org.deckfour.xes.extension.std.XConceptExtension;
-import org.deckfour.xes.model.XTrace;
-
-import beamline.sources.CSVLogSource;
-import beamline.sources.XesSource;
-import io.reactivex.rxjava3.annotations.NonNull;
-import io.reactivex.rxjava3.core.Observable;
-import io.reactivex.rxjava3.functions.Consumer;
-
-public class Tester2 {
-
- public static void main(String[] args) throws Exception {
- String f = "C:\\Users\\andbur\\OneDrive - Danmarks Tekniske Universitet\\uni\\publishing\\papers\\conferences\\2022-caise\\material\\data\\synthetic\\event streams\\sudden_time_noise0_500_pm_simple.csv";
- XesSource source = new CSVLogSource(f, 1, 2);
- source.prepare();
-
- Observable<XTrace> obs = source.getObservable();
- obs.subscribe(new Consumer<XTrace>() {
- @Override
- public void accept(@NonNull XTrace t) throws Throwable {
- System.out.println(
- XConceptExtension.instance().extractName(t) + " - " +
- XConceptExtension.instance().extractName(t.get(0)) + " - " +
- t.get(0).getAttributes()
- );
- }
- });
-
- System.out.println("done");
- }
-}
diff --git a/src/main/java/beamline/tester/Tester3.java b/src/main/java/beamline/tester/Tester3.java
deleted file mode 100644
index 168c338..0000000
--- a/src/main/java/beamline/tester/Tester3.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package beamline.tester;
-
-import java.io.IOException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-
-import org.deckfour.xes.extension.std.XConceptExtension;
-import org.deckfour.xes.factory.XFactory;
-import org.deckfour.xes.factory.XFactoryNaiveImpl;
-import org.deckfour.xes.model.XEvent;
-import org.deckfour.xes.model.XTrace;
-
-import beamline.mappers.DirectlyFollowsRelation;
-import io.reactivex.rxjava3.annotations.NonNull;
-import io.reactivex.rxjava3.core.Observable;
-import io.reactivex.rxjava3.core.ObservableSource;
-import io.reactivex.rxjava3.core.Observer;
-import io.reactivex.rxjava3.functions.Consumer;
-import io.reactivex.rxjava3.functions.Function;
-
-public class Tester3 {
-
- public static void main(String[] args) {
-
- String fileName = "C:\\Users\\andbur\\Desktop\\log.txt";
- XFactory factory = new XFactoryNaiveImpl();
-
- Observable<String> stramOfStrings = Observable.defer(() -> new ObservableSource<String>() {
- @Override
- public void subscribe(@NonNull Observer<? super @NonNull String> observer) {
- try {
- Files.lines(Paths.get(fileName)).forEach(observer::onNext);
- observer.onComplete();
- } catch (IOException e) {
- observer.onError(e);
- }
- }
- });
-
-
- Observable<XTrace> streamOfXTraces = stramOfStrings.flatMap(new Function<String, ObservableSource<XTrace>>() {
- @Override
- public @NonNull ObservableSource<XTrace> apply(@NonNull String t) throws Throwable {
- String caseId = t.substring(0, 3);
- String activityName = t.substring(3);
-
- XTrace wrapper = factory.createTrace();
- XEvent event = factory.createEvent();
-
- XConceptExtension.instance().assignName(wrapper, caseId);
- XConceptExtension.instance().assignName(event, activityName);
-
- wrapper.add(event);
-
- return Observable.just(wrapper);
- }
- });
-
-
- streamOfXTraces.subscribe(new Consumer<XTrace>() {
- @Override
- public void accept(@NonNull XTrace t) throws Throwable {
- System.out.println(
- XConceptExtension.instance().extractName(t) + " - " +
- XConceptExtension.instance().extractName(t.get(0)) + " - " +
- t.get(0).getAttributes()
- );
- }
- });
- }
-}
--
GitLab