com.google.cloud.dataflow.sdk.transforms

Interfaces

• Aggregator
• Combine.AccumulatingCombineFn.Accumulator
• DoFn.KeyedState
• DoFn.RequiresKeyedState
• DoFn.RequiresWindowAccess
• Partition.PartitionFn
• SerializableComparator
• SerializableFunction

Classes

• ApproximateQuantiles
• ApproximateQuantiles.ApproximateQuantilesCombineFn
• ApproximateUnique
• ApproximateUnique.ApproximateUniqueCombineFn
• ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique
• Combine
• Combine.AccumulatingCombineFn
• Combine.BinaryCombineDoubleFn
• Combine.BinaryCombineFn
• Combine.BinaryCombineIntegerFn
• Combine.BinaryCombineLongFn
• Combine.CombineFn
• Combine.Globally
• Combine.GloballyAsSingletonView
• Combine.GroupedValues
• Combine.KeyedCombineFn
• Combine.PerKey
• Combine.PerKeyWithHotKeys
• Combine.SimpleCombineFn
• Count
• Count.Globally
• Count.PerElement
• Create
• DoFn
• DoFnTester
• Filter
• First
• Flatten
• Flatten.FlattenIterables
• Flatten.FlattenPCollectionList
• GroupByKey
• GroupByKey.GroupAlsoByWindow
• GroupByKey.GroupByKeyOnly
• GroupByKey.ReifyTimestampsAndWindows
• GroupByKey.SortValuesByTimestamp
• Keys
• KvSwap
• Max
• Max.MaxDoubleFn
• Max.MaxFn
• Max.MaxIntegerFn
• Max.MaxLongFn
• Mean
• Mean.MeanFn
• Min
• Min.MinDoubleFn
• Min.MinFn
• Min.MinIntegerFn
• Min.MinLongFn
• ParDo
• ParDo.Bound
• ParDo.BoundMulti
• ParDo.Unbound
• ParDo.UnboundMulti
• Partition
• PTransform
• RateLimiting
• RateLimiting.RateLimitingDoFn
• RateLimiting.RateLimitingTransform
• RemoveDuplicates
• Sample
• Sample.FixedSizedSampleFn
• Sum
• Sum.SumDoubleFn
• Sum.SumIntegerFn
• Sum.SumLongFn
• Top
• Top.Largest
• Top.Smallest
• Top.TopCombineFn
• Values
• View
• View.AsIterable
• View.AsMultimap
• View.AsSingleton
• View.AsSingletonMap
• View.CreatePCollectionView
• WithKeys