From 0caba1539c0e998ee534a365640ce210e667711f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Geoffrey=20=E2=80=9CFrogeye=E2=80=9D=20Preud=27homme?= Date: Sun, 10 Feb 2019 22:18:01 +0100 Subject: [PATCH] Added `-p` option --- README.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 78f85bf..94c0558 100644 --- a/README.md +++ b/README.md @@ -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