Skip to content
Snippets Groups Projects
Commit c28f9a1d authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Merge branch 'master' of git.se.informatik.uni-kiel.de:she/theodolite into...

Merge branch 'master' of git.se.informatik.uni-kiel.de:she/theodolite into feature/281-Add-Beam-Kubernetes-Benchmark-Definitions
parents 591ddf1c c4283e7b
No related branches found
No related tags found
1 merge request!218Add Beam Kubernetes Benchmark Definitions
Pipeline #6127 passed
Showing
with 895 additions and 69 deletions
......@@ -18,7 +18,7 @@ public class LogKeyValue extends DoFn<KV<String, String>, KV<String, String>> {
*/
@ProcessElement
public void processElement(@Element final KV<String, String> kv,
final OutputReceiver<KV<String, String>> out) {
final OutputReceiver<KV<String, String>> out) {
if (LOGGER.isInfoEnabled()) {
LOGGER.info("Key: {}, Value: {}", kv.getKey(), kv.getValue());
}
......
......@@ -15,7 +15,7 @@ public final class Uc2BeamFlink extends AbstractBeamService {
/**
* Private constructor setting specific options for this use case.
*/
private Uc2BeamFlink(final String[] args) { //NOPMD
private Uc2BeamFlink(final String[] args) { // NOPMD
super(args);
this.options.setRunner(FlinkRunner.class);
}
......
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment