public static PCollection buildPipeline()

in src/main/java/com/example/App.java [34:42]

• 9 lines of code
• 1 McCabe index (conditional complexity)

	public static PCollection<String> buildPipeline(Pipeline pipeline, String inputText) {
		return pipeline
				.apply("Create elements", Create.of(Arrays.asList("Hello", "World!", inputText)))
				.apply("Print elements",
						MapElements.into(TypeDescriptors.strings()).via(x -> {
							System.out.println(x);
							return x;
						}));
	}