public static class WindowingWordCount.CountWords extends PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>>
Although this pipeline fragment could be inlined, bundling it as a PTransform allows for easy reuse, modular testing, and an improved monitoring experience.
name| Constructor and Description |
|---|
WindowingWordCount.CountWords() |
| Modifier and Type | Method and Description |
|---|---|
PCollection<java.lang.String> |
apply(PCollection<java.lang.String> lines) |
finishSpecifying, getCoderRegistry, getDefaultName, getDefaultOutputCoder, getDefaultOutputCoder, getInput, getKindString, getName, getOutput, getPipeline, setName, setPipeline, toString, withNamepublic PCollection<java.lang.String> apply(PCollection<java.lang.String> lines)
apply in class PTransform<PCollection<java.lang.String>,PCollection<java.lang.String>>