com.google.cloud.dataflow.sdk.transforms
Interfaces
- Aggregator
- Combine.AccumulatingCombineFn.Accumulator
- CombineFnBase.GlobalCombineFn
- CombineFnBase.PerKeyCombineFn
- CombineWithContext.RequiresContextInternal
- DoFn.RequiresWindowAccess
- DoFnWithContext.ExtraContextFactory
- Partition.PartitionFn
- SerializableComparator
- SerializableFunction
Classes
- AggregatorRetriever
- AppliedPTransform
- 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.Holder
- Combine.IterableCombineFn
- Combine.KeyedCombineFn
- Combine.PerKey
- Combine.PerKeyWithHotKeyFanout
- Combine.SimpleCombineFn
- CombineFnBase
- CombineFns
- CombineFns.CoCombineResult
- CombineFns.ComposeCombineFnBuilder
- CombineFns.ComposedCombineFn
- CombineFns.ComposedCombineFnWithContext
- CombineFns.ComposedKeyedCombineFn
- CombineFns.ComposedKeyedCombineFnWithContext
- CombineFns.ComposeKeyedCombineFnBuilder
- CombineWithContext
- CombineWithContext.CombineFnWithContext
- CombineWithContext.Context
- CombineWithContext.KeyedCombineFnWithContext
- Count
- Count.PerElement
- Create
- Create.TimestampedValues
- Create.Values
- DoFn
- DoFnReflector
- DoFnTester
- DoFnTester.OutputElementWithTimestamp
- DoFnWithContext
- Filter
- FlatMapElements
- FlatMapElements.MissingOutputTypeDescriptor
- Flatten
- Flatten.FlattenIterables
- Flatten.FlattenPCollectionList
- GroupByKey
- GroupByKey.GroupAlsoByWindow
- GroupByKey.GroupByKeyOnly
- GroupByKey.ReifyTimestampsAndWindows
- GroupByKey.SortValuesByTimestamp
- IntraBundleParallelization
- IntraBundleParallelization.Bound
- IntraBundleParallelization.MultiThreadedIntraBundleProcessingDoFn
- IntraBundleParallelization.Unbound
- Keys
- KvSwap
- MapElements
- MapElements.MissingOutputTypeDescriptor
- Max
- Max.MaxDoubleFn
- Max.MaxFn
- Max.MaxIntegerFn
- Max.MaxLongFn
- Mean
- Min
- Min.MinDoubleFn
- Min.MinFn
- Min.MinIntegerFn
- Min.MinLongFn
- ParDo
- ParDo.Bound
- ParDo.BoundMulti
- ParDo.Unbound
- ParDo.UnboundMulti
- Partition
- PTransform
- RemoveDuplicates
- RemoveDuplicates.WithRepresentativeValues
- Sample
- Sample.FixedSizedSampleFn
- Sample.SampleAny
- SimpleFunction
- Sum
- Sum.SumDoubleFn
- Sum.SumIntegerFn
- Sum.SumLongFn
- Top
- Top.Largest
- Top.Smallest
- Top.TopCombineFn
- Values
- View
- View.AsIterable
- View.AsList
- View.AsMap
- View.AsMultimap
- View.AsSingleton
- View.CreatePCollectionView
- WithKeys
- WithTimestamps
- Write
Need help? Visit our