public static class AutoComplete.ComputeTopCompletions extends PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.util.List<com.google.cloud.dataflow.examples.AutoComplete.CompletionCandidate>>>>
name| Modifier | Constructor and Description |
|---|---|
protected |
AutoComplete.ComputeTopCompletions(int candidatesPerPrefix,
boolean recursive) |
| Modifier and Type | Method and Description |
|---|---|
PCollection<KV<java.lang.String,java.util.List<com.google.cloud.dataflow.examples.AutoComplete.CompletionCandidate>>> |
apply(PCollection<java.lang.String> input) |
static AutoComplete.ComputeTopCompletions |
top(int candidatesPerPrefix,
boolean recursive) |
finishSpecifying, getCoderRegistry, getDefaultName, getDefaultOutputCoder, getDefaultOutputCoder, getInput, getKindString, getName, getOutput, getPipeline, setName, setPipeline, toString, withNameprotected AutoComplete.ComputeTopCompletions(int candidatesPerPrefix,
boolean recursive)
public static AutoComplete.ComputeTopCompletions top(int candidatesPerPrefix, boolean recursive)
public PCollection<KV<java.lang.String,java.util.List<com.google.cloud.dataflow.examples.AutoComplete.CompletionCandidate>>> apply(PCollection<java.lang.String> input)
apply in class PTransform<PCollection<java.lang.String>,PCollection<KV<java.lang.String,java.util.List<com.google.cloud.dataflow.examples.AutoComplete.CompletionCandidate>>>>