geoffrey/s9-mtds-prj-flink
geoffrey/s9-mtds-prj-flink
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Added -p option

Browse source
This commit is contained in:
Geoffrey Frogeye 2019-02-10 22:18:01 +01:00
parent 24e85deb17
commit 0caba1539c
Signed by: geoffrey
GPG key ID: D8A7ECA00A8CD3DD
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
README.md
View file

@ -1,6 +1,6 @@
# K-Means clustering algorithm using Apache Flink
Project for the Middleware Technologies for Distributed Systems.
Project for the course: Middleware Technologies for Distributed Systems.
## Note
@ -37,10 +37,10 @@ Input data is a point per line, in the folowing format: `xCoords,yCoords`.
Output data is a point per line, in the folowing format: `xCoords,yCoords,clusterIndex`.
```shell
flink run target/project-*.jar --input $INPUT --output $OUTPUT [--k $K] [--maxIterations $ITERATIONS]
flink run -p $NBWORKERS target/project-*.jar --input $INPUT --output $OUTPUT [--k $K] [--maxIterations $ITERATIONS]
```
(example: `flink run target/project-1.0.jar --input $PWD/input.csv --output $PWD/output.csv --k 5`)
(example: `flink run -p 4 target/project-1.0.jar --input $PWD/input.csv --output $PWD/output.csv --k 5`)
## Show results