Author: Can Wang
- System A
cd src/main/java/Lab1/SystemA
javac *.java
java Plumber
The output file is located at
src/main/java/Lab1/SystemA/OutputA.csv
- System B
cd src/main/java/Lab1/SystemB
javac *.java
java Plumber
The output file is located at
src/main/java/Lab1/SystemB/WildPoints.csv
andsrc/main/java/Lab1/SystemB/OutputB.csv
.
- To use different input test cases, you need to change the variable named
fileName
atSourceFilter.java
. The default file used is.../Lab1/DataSets/FlightData.dat
. - For the implementation in System B, I changed the id of "incorrect" altitude from
2
to6
. Since6
is an unused value of each id, so when theSinkFilter
reaches a data with an id of6
afterward, the program will know the data was changed previously and should append a*
at the end of the data when writing this record to the CSV file on local disk. - In my implementation, if the altitude was changed, then the previous altitude for the next altitude to compare with will be its updated value, instead of the original one.
- The output csv files from the case I was provided with are also available at
src/main/java/Lab1/MyCaseOutput
. The original non-truncate intermediate files are at.../MyCaseOutput/RawResultsWithoutTruncating
.
Thank you for reviewing, for any issues, feel free to contact me here. :)