Skip to content
Snippets Groups Projects
Commit d2e1043d authored by Andrea Burattin's avatar Andrea Burattin
Browse files

Removed tracking for test files

parent 8c353ff5
No related branches found
No related tags found
No related merge requests found
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");
}
}
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");
}
}
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()
);
}
});
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment