com.google.cloud.dataflow.sdk.transforms Class Hierarchy (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, Dataflow will not run jobs using Dataflow 1.x and below. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

Hierarchy For Package com.google.cloud.dataflow.sdk.transforms

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • com.google.cloud.dataflow.sdk.transforms.AggregatorRetriever
  • com.google.cloud.dataflow.sdk.transforms.AppliedPTransform<InputT,OutputT,TransformT>
  • com.google.cloud.dataflow.sdk.transforms.ApproximateQuantiles
  • com.google.cloud.dataflow.sdk.transforms.ApproximateUnique
  • com.google.cloud.dataflow.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique (implements java.io.Serializable)
  • com.google.cloud.dataflow.sdk.transforms.Combine
  • com.google.cloud.dataflow.sdk.transforms.Combine.CombineFn<InputT,AccumT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn<T>
    • com.google.cloud.dataflow.sdk.transforms.Combine.AccumulatingCombineFn<InputT,AccumT,OutputT>
      • com.google.cloud.dataflow.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn<T,ComparatorT>
      • com.google.cloud.dataflow.sdk.transforms.Top.TopCombineFn<T,ComparatorT>
    • com.google.cloud.dataflow.sdk.transforms.Combine.BinaryCombineDoubleFn
      • com.google.cloud.dataflow.sdk.transforms.Sum.SumDoubleFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
    • com.google.cloud.dataflow.sdk.transforms.Combine.BinaryCombineFn<V>
      • com.google.cloud.dataflow.sdk.transforms.Max.MaxFn<T>
        • com.google.cloud.dataflow.sdk.transforms.Max.MaxDoubleFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
        • com.google.cloud.dataflow.sdk.transforms.Max.MaxIntegerFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
        • com.google.cloud.dataflow.sdk.transforms.Max.MaxLongFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
      • com.google.cloud.dataflow.sdk.transforms.Min.MinFn<T>
        • com.google.cloud.dataflow.sdk.transforms.Min.MinDoubleFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
        • com.google.cloud.dataflow.sdk.transforms.Min.MinIntegerFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
        • com.google.cloud.dataflow.sdk.transforms.Min.MinLongFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
    • com.google.cloud.dataflow.sdk.transforms.Combine.BinaryCombineIntegerFn
      • com.google.cloud.dataflow.sdk.transforms.Sum.SumIntegerFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
    • com.google.cloud.dataflow.sdk.transforms.Combine.BinaryCombineLongFn
      • com.google.cloud.dataflow.sdk.transforms.Sum.SumLongFn (implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<T>)
    • com.google.cloud.dataflow.sdk.transforms.Combine.IterableCombineFn<V>
      • com.google.cloud.dataflow.sdk.transforms.Combine.SimpleCombineFn<V>
    • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposedCombineFn<DataT>
    • com.google.cloud.dataflow.sdk.transforms.Sample.FixedSizedSampleFn<T>
  • com.google.cloud.dataflow.sdk.transforms.Combine.Holder<V>
  • com.google.cloud.dataflow.sdk.transforms.Combine.KeyedCombineFn<K,InputT,AccumT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposedKeyedCombineFn<DataT,K>
  • com.google.cloud.dataflow.sdk.transforms.CombineFnBase
  • com.google.cloud.dataflow.sdk.transforms.CombineFns
  • com.google.cloud.dataflow.sdk.transforms.CombineFns.CoCombineResult (implements java.io.Serializable)
  • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposeCombineFnBuilder
  • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposeKeyedCombineFnBuilder
  • com.google.cloud.dataflow.sdk.transforms.CombineWithContext
  • com.google.cloud.dataflow.sdk.transforms.CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> (implements com.google.cloud.dataflow.sdk.transforms.CombineWithContext.RequiresContextInternal)
    • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposedCombineFnWithContext<DataT>
  • com.google.cloud.dataflow.sdk.transforms.CombineWithContext.Context
  • com.google.cloud.dataflow.sdk.transforms.CombineWithContext.KeyedCombineFnWithContext<K,InputT,AccumT,OutputT> (implements com.google.cloud.dataflow.sdk.transforms.CombineWithContext.RequiresContextInternal)
    • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposedKeyedCombineFnWithContext<DataT,K>
  • com.google.cloud.dataflow.sdk.transforms.Count
  • com.google.cloud.dataflow.sdk.transforms.Create<T>
  • com.google.cloud.dataflow.sdk.transforms.DoFn<InputT,OutputT> (implements com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • com.google.cloud.dataflow.sdk.transforms.IntraBundleParallelization.MultiThreadedIntraBundleProcessingDoFn<InputT,OutputT>
  • com.google.cloud.dataflow.sdk.transforms.DoFn.Context
    • com.google.cloud.dataflow.sdk.transforms.DoFn.ProcessContext
  • com.google.cloud.dataflow.sdk.transforms.DoFnReflector
  • com.google.cloud.dataflow.sdk.transforms.DoFnTester<InputT,OutputT>
  • com.google.cloud.dataflow.sdk.transforms.DoFnTester.OutputElementWithTimestamp<OutputT>
  • com.google.cloud.dataflow.sdk.transforms.DoFnWithContext<InputT,OutputT> (implements com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData, java.io.Serializable)
  • com.google.cloud.dataflow.sdk.transforms.DoFnWithContext.Context
    • com.google.cloud.dataflow.sdk.transforms.DoFnWithContext.ProcessContext
  • com.google.cloud.dataflow.sdk.transforms.FlatMapElements.MissingOutputTypeDescriptor<InputT,OutputT>
  • com.google.cloud.dataflow.sdk.transforms.Flatten
  • com.google.cloud.dataflow.sdk.transforms.IntraBundleParallelization
  • com.google.cloud.dataflow.sdk.transforms.IntraBundleParallelization.Unbound
  • com.google.cloud.dataflow.sdk.transforms.MapElements.MissingOutputTypeDescriptor<InputT,OutputT>
  • com.google.cloud.dataflow.sdk.transforms.Max
  • com.google.cloud.dataflow.sdk.transforms.Mean
  • com.google.cloud.dataflow.sdk.transforms.Min
  • com.google.cloud.dataflow.sdk.transforms.ParDo
  • com.google.cloud.dataflow.sdk.transforms.ParDo.Unbound
  • com.google.cloud.dataflow.sdk.transforms.ParDo.UnboundMulti<OutputT>
  • com.google.cloud.dataflow.sdk.transforms.PTransform<InputT,OutputT> (implements com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • com.google.cloud.dataflow.sdk.transforms.Combine.Globally<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Combine.GloballyAsSingletonView<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Combine.GroupedValues<K,InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Combine.PerKey<K,InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Combine.PerKeyWithHotKeyFanout<K,InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Count.PerElement<T>
    • com.google.cloud.dataflow.sdk.transforms.Create.Values<T>
      • com.google.cloud.dataflow.sdk.transforms.Create.TimestampedValues<T>
    • com.google.cloud.dataflow.sdk.transforms.Filter<T>
    • com.google.cloud.dataflow.sdk.transforms.FlatMapElements<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Flatten.FlattenIterables<T>
    • com.google.cloud.dataflow.sdk.transforms.Flatten.FlattenPCollectionList<T>
    • com.google.cloud.dataflow.sdk.transforms.GroupByKey<K,V>
    • com.google.cloud.dataflow.sdk.transforms.GroupByKey.GroupAlsoByWindow<K,V>
    • com.google.cloud.dataflow.sdk.transforms.GroupByKey.GroupByKeyOnly<K,V>
    • com.google.cloud.dataflow.sdk.transforms.GroupByKey.ReifyTimestampsAndWindows<K,V>
    • com.google.cloud.dataflow.sdk.transforms.GroupByKey.SortValuesByTimestamp<K,V>
    • com.google.cloud.dataflow.sdk.transforms.IntraBundleParallelization.Bound<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Keys<K>
    • com.google.cloud.dataflow.sdk.transforms.KvSwap<K,V>
    • com.google.cloud.dataflow.sdk.transforms.MapElements<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.ParDo.Bound<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.ParDo.BoundMulti<InputT,OutputT>
    • com.google.cloud.dataflow.sdk.transforms.Partition<T>
    • com.google.cloud.dataflow.sdk.transforms.RemoveDuplicates<T>
    • com.google.cloud.dataflow.sdk.transforms.RemoveDuplicates.WithRepresentativeValues<T,IdT>
    • com.google.cloud.dataflow.sdk.transforms.Sample.SampleAny<T>
    • com.google.cloud.dataflow.sdk.transforms.Values<V>
    • com.google.cloud.dataflow.sdk.transforms.View.AsIterable<T>
    • com.google.cloud.dataflow.sdk.transforms.View.AsList<T>
    • com.google.cloud.dataflow.sdk.transforms.View.AsMap<K,V>
    • com.google.cloud.dataflow.sdk.transforms.View.AsMultimap<K,V>
    • com.google.cloud.dataflow.sdk.transforms.View.AsSingleton<T>
    • com.google.cloud.dataflow.sdk.transforms.View.CreatePCollectionView<ElemT,ViewT>
    • com.google.cloud.dataflow.sdk.transforms.WithKeys<K,V>
    • com.google.cloud.dataflow.sdk.transforms.WithTimestamps<T>
  • com.google.cloud.dataflow.sdk.transforms.Sample
  • com.google.cloud.dataflow.sdk.transforms.SimpleFunction<InputT,OutputT> (implements com.google.cloud.dataflow.sdk.transforms.SerializableFunction<InputT,OutputT>)
  • com.google.cloud.dataflow.sdk.transforms.Sum
  • com.google.cloud.dataflow.sdk.transforms.Top
  • com.google.cloud.dataflow.sdk.transforms.Top.Largest<T> (implements java.util.Comparator<T>, java.io.Serializable)
  • com.google.cloud.dataflow.sdk.transforms.Top.Smallest<T> (implements java.util.Comparator<T>, java.io.Serializable)
  • com.google.cloud.dataflow.sdk.transforms.View
  • com.google.cloud.dataflow.sdk.io.Write
    • com.google.cloud.dataflow.sdk.transforms.Write

Interface Hierarchy

• com.google.cloud.dataflow.sdk.transforms.Aggregator<InputT,OutputT>
• com.google.cloud.dataflow.sdk.transforms.Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT>
• com.google.cloud.dataflow.sdk.transforms.CombineWithContext.RequiresContextInternal
• java.util.Comparator<T>
  • com.google.cloud.dataflow.sdk.transforms.SerializableComparator<T> (also extends java.io.Serializable)
• com.google.cloud.dataflow.sdk.transforms.DoFn.RequiresWindowAccess
• com.google.cloud.dataflow.sdk.transforms.DoFnWithContext.ExtraContextFactory<InputT,OutputT>
• com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData
  • com.google.cloud.dataflow.sdk.transforms.CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> (also extends java.io.Serializable)
  • com.google.cloud.dataflow.sdk.transforms.CombineFnBase.PerKeyCombineFn<K,InputT,AccumT,OutputT> (also extends java.io.Serializable)
• java.io.Serializable
  • com.google.cloud.dataflow.sdk.transforms.CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> (also extends com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData)
  • com.google.cloud.dataflow.sdk.transforms.CombineFnBase.PerKeyCombineFn<K,InputT,AccumT,OutputT> (also extends com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData)
  • com.google.cloud.dataflow.sdk.transforms.Partition.PartitionFn<T>
  • com.google.cloud.dataflow.sdk.transforms.SerializableComparator<T> (also extends java.util.Comparator<T>)
  • com.google.cloud.dataflow.sdk.transforms.SerializableFunction<InputT,OutputT>

Annotation Type Hierarchy

• com.google.cloud.dataflow.sdk.transforms.DoFnWithContext.StartBundle (implements java.lang.annotation.Annotation)
• com.google.cloud.dataflow.sdk.transforms.DoFnWithContext.ProcessElement (implements java.lang.annotation.Annotation)
• com.google.cloud.dataflow.sdk.transforms.DoFnWithContext.FinishBundle (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.google.cloud.dataflow.sdk.transforms.DoFnTester.CloningBehavior