From 3f0aa9b3a0228b68bdf43fb6fa060ad594fc2237 Mon Sep 17 00:00:00 2001
From: Andrea Burattin <andrea.burattin@gmail.com>
Date: Fri, 25 Mar 2022 09:08:27 +0100
Subject: [PATCH] Renamed source for CSV
---
.../{CSVLogSource.java => CSVXesLogSource.java} | 10 +++++-----
src/test/java/beamline/tests/SourcesTest.java | 10 +++++-----
2 files changed, 10 insertions(+), 10 deletions(-)
rename src/main/java/beamline/sources/{CSVLogSource.java => CSVXesLogSource.java} (87%)
diff --git a/src/main/java/beamline/sources/CSVLogSource.java b/src/main/java/beamline/sources/CSVXesLogSource.java
similarity index 87%
rename from src/main/java/beamline/sources/CSVLogSource.java
rename to src/main/java/beamline/sources/CSVXesLogSource.java
index b97d3bb..46eda05 100644
--- a/src/main/java/beamline/sources/CSVLogSource.java
+++ b/src/main/java/beamline/sources/CSVXesLogSource.java
@@ -25,10 +25,10 @@ import beamline.exceptions.SourceException;
*
* @author Andrea Burattin
*/
-public class CSVLogSource extends BeamlineAbstractSource {
+public class CSVXesLogSource extends BeamlineAbstractSource {
private static final long serialVersionUID = 205574514393782145L;
- private CSVLogSource.ParserConfiguration parserConfiguration;
+ private CSVXesLogSource.ParserConfiguration parserConfiguration;
private String filename;
private int caseIdColumn;
private int activityNameColumn;
@@ -44,7 +44,7 @@ public class CSVLogSource extends BeamlineAbstractSource {
* @param parserConfiguration the parser configuration to be used for
* parsing the CSV file
*/
- public CSVLogSource(String filename, int caseIdColumn, int activityNameColumn, CSVLogSource.ParserConfiguration parserConfiguration) {
+ public CSVXesLogSource(String filename, int caseIdColumn, int activityNameColumn, CSVXesLogSource.ParserConfiguration parserConfiguration) {
this.filename = filename;
this.caseIdColumn = caseIdColumn;
this.activityNameColumn = activityNameColumn;
@@ -60,8 +60,8 @@ public class CSVLogSource extends BeamlineAbstractSource {
* @param activityNameColumn the id of the column containing the activity
* name (counting starts from 0)
*/
- public CSVLogSource(String filename, int caseIdColumn, int activityNameColumn) {
- this(filename, caseIdColumn, activityNameColumn, new CSVLogSource.ParserConfiguration());
+ public CSVXesLogSource(String filename, int caseIdColumn, int activityNameColumn) {
+ this(filename, caseIdColumn, activityNameColumn, new CSVXesLogSource.ParserConfiguration());
}
@Override
diff --git a/src/test/java/beamline/tests/SourcesTest.java b/src/test/java/beamline/tests/SourcesTest.java
index 5a7dd07..fd3561b 100644
--- a/src/test/java/beamline/tests/SourcesTest.java
+++ b/src/test/java/beamline/tests/SourcesTest.java
@@ -26,7 +26,7 @@ import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.junit.jupiter.api.Test;
import beamline.events.BEvent;
-import beamline.sources.CSVLogSource;
+import beamline.sources.CSVXesLogSource;
import beamline.sources.MQTTXesSource;
import beamline.sources.XesLogSource;
@@ -36,7 +36,7 @@ public class SourcesTest {
public void test_csv_source_1() throws Exception {
List<String> acts = new LinkedList<>();
List<String> caseIds = new LinkedList<>();
- CSVLogSource source = new CSVLogSource("src/test/resources/sources/source.csv", 0, 1);
+ CSVXesLogSource source = new CSVXesLogSource("src/test/resources/sources/source.csv", 0, 1);
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<BEvent> stream = env.addSource(source);
@@ -56,11 +56,11 @@ public class SourcesTest {
public void test_csv_source_2() throws Exception {
List<String> acts = new LinkedList<>();
List<String> caseIds = new LinkedList<>();
- CSVLogSource source = new CSVLogSource(
+ CSVXesLogSource source = new CSVXesLogSource(
"src/test/resources/sources/source_2.csv",
0,
1,
- new CSVLogSource.ParserConfiguration().withSeparator('|'));
+ new CSVXesLogSource.ParserConfiguration().withSeparator('|'));
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<BEvent> stream = env.addSource(source);
@@ -78,7 +78,7 @@ public class SourcesTest {
@Test
public void test_csv_source_3() {
- CSVLogSource source = new CSVLogSource("DOESNT_EXIST", 0, 1);
+ CSVXesLogSource source = new CSVXesLogSource("DOESNT_EXIST", 0, 1);
assertThrowsExactly(JobExecutionException.class, () -> {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.addSource(source).map(e -> e).print();
--
GitLab