Serialized Form

Package com.google.cloud.dataflow.examples

Class com.google.cloud.dataflow.examples.PubsubFileInjector.Bound extends DoFn<String,Void> implements Serializable

serialVersionUID:

0L

Serialized Fields

outputTopic

String outputTopic

timestampLabelKey

String timestampLabelKey

Class com.google.cloud.dataflow.examples.WordCount.CountWords extends PTransform<PCollection<String>,PCollection<KV<String,Long>>> implements Serializable

serialVersionUID:

0L

Class com.google.cloud.dataflow.examples.WordCount.FormatAsTextFn extends DoFn<KV<String,Long>,String> implements Serializable

serialVersionUID:

0L

Package com.google.cloud.dataflow.examples.complete

Class com.google.cloud.dataflow.examples.complete.AutoComplete.ComputeTopCompletions extends PTransform<PCollection<String>,PCollection<KV<String,List<com.google.cloud.dataflow.examples.complete.AutoComplete.CompletionCandidate>>>> implements Serializable

serialVersionUID:

0L

Serialized Fields

candidatesPerPrefix

int candidatesPerPrefix

recursive

boolean recursive

Class com.google.cloud.dataflow.examples.complete.TfIdf.ComputeTfIdf extends PTransform<PCollection<KV<URI,String>>,PCollection<KV<String,KV<URI,Double>>>> implements Serializable

serialVersionUID:

0L

Class com.google.cloud.dataflow.examples.complete.TfIdf.ReadDocuments extends PTransform<PInput,PCollection<KV<URI,String>>> implements Serializable

serialVersionUID:

0L

Serialized Fields

uris

Iterable<T> uris

Class com.google.cloud.dataflow.examples.complete.TfIdf.WriteTfIdf extends PTransform<PCollection<KV<String,KV<URI,Double>>>,PDone> implements Serializable

serialVersionUID:

0L

Serialized Fields

output

String output

Class com.google.cloud.dataflow.examples.complete.TrafficMaxLaneFlow.MaxFlow extends Object implements Serializable

serialVersionUID:

0L

Package com.google.cloud.dataflow.examples.cookbook

Class com.google.cloud.dataflow.examples.cookbook.CombinePerKeyExamples.ConcatWords extends Object implements Serializable

serialVersionUID:

0L