- APIs & reference
- All APIs
- SDK 2.x for Java
- SDK 2.x for Python
- REST API
- Présentation
- REST Resources
- projects.jobs
- projects.jobs.messages
- projects.locations.jobs
- projects.locations.jobs.messages
- projects.locations.templates
- projects.templates
- Types
- Filter
- GetTemplateResponse
- InvalidTemplateParameters
- JobExecutionStageInfo
- JobMessageImportance
- JobMetrics
- JobView
- LaunchTemplateParameters
- LaunchTemplateResponse
- ListJobMessagesResponse
- ListJobsResponse
- MetricUpdate
- RuntimeEnvironment
- Status
- TemplateView
- Cloud Dataflow SQL reference
- SDK 1.x for Java
- Overview
- com.google.cloud.dataflow.sdk
- com.google.cloud.dataflow.sdk.annotations
- com.google.cloud.dataflow.sdk.coders
- com.google.cloud.dataflow.sdk.coders.protobuf
- com.google.cloud.dataflow.sdk.io
- com.google.cloud.dataflow.sdk.io.bigtable
- com.google.cloud.dataflow.sdk.io.datastore
- com.google.cloud.dataflow.sdk.io.range
- com.google.cloud.dataflow.sdk.options
- com.google.cloud.dataflow.sdk.runners
- com.google.cloud.dataflow.sdk.runners.inprocess
- com.google.cloud.dataflow.sdk.testing
- com.google.cloud.dataflow.sdk.transforms
- com.google.cloud.dataflow.sdk.transforms.display
- com.google.cloud.dataflow.sdk.transforms.join
- com.google.cloud.dataflow.sdk.transforms.windowing
- com.google.cloud.dataflow.sdk.values
- Class Hierarchy
- Constant Values
- Deprecated List
- Index
- All
- AfterAll
- AfterDelayFromFirstElement
- AfterEach
- AfterFirst
- AfterPane
- AfterProcessingTime
- AfterWatermark
- AfterWatermark.AfterWatermarkEarly
- AfterWatermark.AfterWatermarkLate
- AfterWatermark.FromEndOfWindow
- Aggregator
- AggregatorPipelineExtractor
- AggregatorRetrievalException
- AggregatorRetriever
- AggregatorValues
- ApplicationNameOptions
- AppliedPTransform
- ApproximateQuantiles
- ApproximateQuantiles.ApproximateQuantilesCombineFn
- ApproximateUnique
- ApproximateUnique.ApproximateUniqueCombineFn
- ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique
- AtomicCoder
- AvroCoder
- AvroIO
- AvroIO.Read
- AvroIO.Read.Bound
- AvroIO.Write
- AvroIO.Write.Bound
- AvroSource
- AvroSource.AvroReader
- BigEndianIntegerCoder
- BigEndianLongCoder
- BigQueryIO
- BigQueryIO.Read
- BigQueryIO.Read.Bound
- BigQueryIO.Write
- BigQueryIO.Write.Bound
- BigQueryIO.Write.CreateDisposition
- BigQueryIO.Write.WriteDisposition
- BigQueryOptions
- BigtableIO
- BigtableIO.Read
- BigtableIO.Write
- BlockBasedSource
- BlockBasedSource.Block
- BlockBasedSource.BlockBasedReader
- BlockingDataflowPipelineOptions
- BlockingDataflowPipelineOptions.StandardOutputFactory
- BlockingDataflowPipelineRunner
- BoundedSource
- BoundedSource.BoundedReader
- BoundedWindow
- ByteArrayCoder
- ByteCoder
- ByteKey
- ByteKeyRange
- ByteKeyRangeTracker
- ByteStringCoder
- CalendarWindows
- CalendarWindows.DaysWindows
- CalendarWindows.MonthsWindows
- CalendarWindows.YearsWindows
- CannotProvideCoderException
- CannotProvideCoderException.ReasonCode
- Clock
- CloudDebuggerOptions
- CoGbkResult
- CoGbkResult.CoGbkResultCoder
- CoGbkResultSchema
- CoGroupByKey
- Coder
- Coder.Context
- Coder.NonDeterministicException
- CoderException
- CoderFactories
- CoderFactory
- CoderProperties
- CoderProvider
- CoderProviders
- CoderRegistry
- CollectionCoder
- Combine
- Combine.AccumulatingCombineFn
- Combine.AccumulatingCombineFn.Accumulator
- 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
- CombineFnBase.GlobalCombineFn
- CombineFnBase.PerKeyCombineFn
- CombineFns
- CombineFns.CoCombineResult
- CombineFns.ComposeCombineFnBuilder
- CombineFns.ComposeKeyedCombineFnBuilder
- CombineFns.ComposedCombineFn
- CombineFns.ComposedCombineFnWithContext
- CombineFns.ComposedKeyedCombineFn
- CombineFns.ComposedKeyedCombineFnWithContext
- CombineWithContext
- CombineWithContext.CombineFnWithContext
- CombineWithContext.Context
- CombineWithContext.KeyedCombineFnWithContext
- CombineWithContext.RequiresContextInternal
- CompressedSource
- CompressedSource.CompressedReader
- CompressedSource.CompressionMode
- CompressedSource.DecompressingChannelFactory
- Count
- Count.PerElement
- CountingInput
- CountingInput.BoundedCountingInput
- CountingInput.UnboundedCountingInput
- CountingSource
- CountingSource.CounterMark
- Create
- Create.TimestampedValues
- Create.Values
- CustomCoder
- DataflowAssert
- DataflowAssert.GroupThenAssert
- DataflowAssert.GroupThenAssertForSingleton
- DataflowAssert.IterableAssert
- DataflowAssert.OneSideInputAssert
- DataflowAssert.SingletonAssert
- DataflowJobAlreadyExistsException
- DataflowJobAlreadyUpdatedException
- DataflowJobCancelledException
- DataflowJobException
- DataflowJobExecutionException
- DataflowJobUpdatedException
- DataflowPipeline
- DataflowPipelineDebugOptions
- DataflowPipelineDebugOptions.DataflowClientFactory
- DataflowPipelineDebugOptions.PathValidatorFactory
- DataflowPipelineDebugOptions.StagerFactory
- DataflowPipelineJob
- DataflowPipelineOptions
- DataflowPipelineOptions.JobNameFactory
- DataflowPipelineRegistrar
- DataflowPipelineRegistrar.Options
- DataflowPipelineRegistrar.Runner
- DataflowPipelineRunner
- DataflowPipelineRunner.BatchBigQueryIONativeReadTranslator
- DataflowPipelineRunnerHooks
- DataflowPipelineTranslator
- DataflowPipelineTranslator.JobSpecification
- DataflowPipelineTranslator.TransformTranslator
- DataflowPipelineTranslator.TranslationContext
- DataflowPipelineWorkerPoolOptions
- DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType
- DataflowPipelineWorkerPoolOptions.TeardownPolicy
- DataflowPipelineWorkerPoolOptions.WorkerHarnessContainerImageFactory
- DataflowProfilingOptions
- DataflowProfilingOptions.DataflowProfilingAgentConfiguration
- DataflowServiceException
- DataflowWorkerHarnessOptions
- DataflowWorkerLoggingOptions
- DataflowWorkerLoggingOptions.Level
- DataflowWorkerLoggingOptions.WorkerLogLevelOverrides
- DatastoreIO
- DatastoreIO
- DatastoreIO.DatastoreReader
- DatastoreIO.Sink
- DatastoreIO.Source
- DatastoreV1
- DatastoreV1.DeleteEntity
- DatastoreV1.DeleteKey
- DatastoreV1.Read
- DatastoreV1.Write
- Default
- Default.Boolean
- Default.Byte
- Default.Character
- Default.Class
- Default.Double
- Default.Enum
- Default.Float
- Default.InstanceFactory
- Default.Integer
- Default.Long
- Default.Short
- Default.String
- DefaultCoder
- DefaultTrigger
- DefaultValueFactory
- DelegateCoder
- DelegateCoder.CodingFunction
- Description
- DeterministicStandardCoder
- DirectPipeline
- DirectPipelineOptions
- DirectPipelineRegistrar
- DirectPipelineRegistrar.Options
- DirectPipelineRegistrar.Runner
- DirectPipelineRunner
- DirectPipelineRunner.EvaluationContext
- DirectPipelineRunner.EvaluationResults
- DirectPipelineRunner.TestCombineDoFn
- DirectPipelineRunner.TransformEvaluator
- DirectPipelineRunner.ValueWithMetadata
- DisplayData
- DisplayData.Builder
- DisplayData.Identifier
- DisplayData.Item
- DisplayData.Type
- DoFn
- DoFn.Context
- DoFn.ProcessContext
- DoFn.RequiresWindowAccess
- DoFnReflector
- DoFnTester
- DoFnTester.CloningBehavior
- DoFnTester.OutputElementWithTimestamp
- DoFnWithContext
- DoFnWithContext.Context
- DoFnWithContext.ExtraContextFactory
- DoFnWithContext.FinishBundle
- DoFnWithContext.ProcessContext
- DoFnWithContext.ProcessElement
- DoFnWithContext.StartBundle
- DoubleCoder
- DurationCoder
- EntityCoder
- ExecutorServiceFactory
- Experimental
- Experimental.Kind
- FileBasedSink
- FileBasedSink.FileBasedWriteOperation
- FileBasedSink.FileBasedWriteOperation.TemporaryFileRetention
- FileBasedSink.FileBasedWriter
- FileBasedSink.FileResult
- FileBasedSource
- FileBasedSource.FileBasedReader
- FileBasedSource.Mode
- Filter
- FixedWindows
- FlatMapElements
- FlatMapElements.MissingOutputTypeDescriptor
- Flatten
- Flatten.FlattenIterables
- Flatten.FlattenPCollectionList
- ForwardingPTransform
- GcpOptions
- GcpOptions.CredentialDirFactory
- GcpOptions.DefaultProjectFactory
- GcpOptions.GcpUserCredentialsFactory
- GcsOptions
- GcsOptions.ExecutorServiceFactory
- GlobalWindow
- GlobalWindow.Coder
- GlobalWindows
- GoogleApiDebugOptions
- GoogleApiDebugOptions.GoogleApiTracer
- GroupByKey
- GroupByKey.GroupAlsoByWindow
- GroupByKey.GroupByKeyOnly
- GroupByKey.ReifyTimestampsAndWindows
- GroupByKey.SortValuesByTimestamp
- HasDisplayData
- Hidden
- InProcessPipelineOptions
- InProcessPipelineRunner
- InProcessPipelineRunner.CommittedBundle
- InProcessPipelineRunner.InProcessPipelineResult
- InProcessPipelineRunner.PCollectionViewWriter
- InProcessPipelineRunner.UncommittedBundle
- InProcessRegistrar
- InProcessRegistrar.InProcessOptions
- InProcessRegistrar.InProcessRunner
- InstantCoder
- IntervalWindow
- IntraBundleParallelization
- IntraBundleParallelization.Bound
- IntraBundleParallelization.MultiThreadedIntraBundleProcessingDoFn
- IntraBundleParallelization.Unbound
- InvalidWindows
- IterableCoder
- IterableLikeCoder
- JAXBCoder
- KV
- KV.OrderByKey
- KV.OrderByValue
- KeyedPCollectionTuple
- KeyedPCollectionTuple.TaggedKeyedPCollection
- Keys
- KvCoder
- KvCoderBase
- KvSwap
- ListCoder
- MapCoder
- MapCoderBase
- MapElements
- MapElements.MissingOutputTypeDescriptor
- Max
- Max.MaxDoubleFn
- Max.MaxFn
- Max.MaxIntegerFn
- Max.MaxLongFn
- Mean
- MergeOverlappingIntervalWindows
- Min
- Min.MinDoubleFn
- Min.MinFn
- Min.MinIntegerFn
- Min.MinLongFn
- ModelEnforcement
- ModelEnforcementFactory
- NanosOffsetClock
- Never
- NonMergingWindowFn
- NullableCoder
- OffsetBasedSource
- OffsetBasedSource.OffsetBasedReader
- OffsetRangeTracker
- OutputTimeFn
- OutputTimeFn.Defaults
- OutputTimeFn.DependsOnlyOnWindow
- OutputTimeFns
- PBegin
- PCollection
- PCollection.IsBounded
- PCollectionList
- PCollectionTuple
- PCollectionView
- PDone
- PInput
- POutput
- POutputValueBase
- PTransform
- PValue
- PValueBase
- PaneInfo
- PaneInfo.PaneInfoCoder
- PaneInfo.Timing
- ParDo
- ParDo.Bound
- ParDo.BoundMulti
- ParDo.Unbound
- ParDo.UnboundMulti
- Partition
- Partition.PartitionFn
- PartitioningWindowFn
- Pipeline
- Pipeline.PipelineExecutionException
- Pipeline.PipelineVisitor
- PipelineOptions
- PipelineOptions.AtomicLongFactory
- PipelineOptions.CheckEnabled
- PipelineOptionsFactory
- PipelineOptionsFactory.Builder
- PipelineOptionsRegistrar
- PipelineOptionsValidator
- PipelineResult
- PipelineResult.State
- PipelineRunner
- PipelineRunnerRegistrar
- Proto2Coder
- ProtoCoder
- PubsubIO
- PubsubIO.PubsubSubscription
- PubsubIO.PubsubTopic
- PubsubIO.Read
- PubsubIO.Read.Bound
- PubsubIO.Read.Bound.PubsubReader
- PubsubIO.Write
- PubsubIO.Write.Bound
- PubsubIO.Write.Bound.PubsubWriter
- PubsubUnboundedSink
- PubsubUnboundedSource
- RangeTracker
- RawUnionValue
- Read
- Read.Bounded
- Read.Builder
- Read.Unbounded
- RecordingPipelineVisitor
- RemoveDuplicates
- RemoveDuplicates.WithRepresentativeValues
- Repeatedly
- RunnableOnService
- Sample
- Sample.FixedSizedSampleFn
- Sample.SampleAny
- SerializableCoder
- SerializableComparator
- SerializableFunction
- Sessions
- SetCoder
- ShardNameTemplate
- SimpleFunction
- Sink
- Sink.WriteOperation
- Sink.Writer
- SlidingWindows
- Source
- Source.Reader
- SourceTestUtils
- SourceTestUtils.ExpectedSplitOutcome
- StandardCoder
- StepTransformResult
- StepTransformResult.Builder
- StreamingOptions
- StringDelegateCoder
- StringUtf8Coder
- StructuralByteArray
- Sum
- Sum.SumDoubleFn
- Sum.SumIntegerFn
- Sum.SumLongFn
- TableRowJsonCoder
- TemplatingDataflowPipelineRunner
- TemplatingDataflowPipelineRunner.Runner
- TestDataflowPipelineOptions
- TestDataflowPipelineRunner
- TestPipeline
- TestStream
- TestStream.Builder
- TestStream.ElementEvent
- TestStream.Event
- TestStream.EventType
- TestStream.ProcessingTimeEvent
- TestStream.WatermarkEvent
- TextIO
- TextIO.CompressionType
- TextIO.Read
- TextIO.Read.Bound
- TextIO.Write
- TextIO.Write.Bound
- TextualIntegerCoder
- TimestampedValue
- TimestampedValue.TimestampedValueCoder
- Top
- Top.Largest
- Top.Smallest
- Top.TopCombineFn
- TransformHierarchy
- TransformTreeNode
- Trigger
- Trigger.MergingTriggerInfo
- Trigger.OnElementContext
- Trigger.OnMergeContext
- Trigger.OnceTrigger
- Trigger.TriggerContext
- Trigger.TriggerInfo
- TriggerBuilder
- TupleTag
- TupleTagList
- TypeDescriptor
- TypedPValue
- UnboundedSource
- UnboundedSource.CheckpointMark
- UnboundedSource.UnboundedReader
- UnionCoder
- Validation
- Validation.Required
- ValueProvider
- ValueProvider.Deserializer
- ValueProvider.NestedValueProvider
- ValueProvider.RuntimeValueProvider
- ValueProvider.Serializer
- ValueProvider.StaticValueProvider
- ValueProviderUtils
- Values
- VarIntCoder
- VarLongCoder
- View
- View.AsIterable
- View.AsList
- View.AsMap
- View.AsMultimap
- View.AsSingleton
- View.CreatePCollectionView
- VoidCoder
- Window
- Window.Bound
- Window.ClosingBehavior
- Window.Remerge
- Window.Unbound
- WindowFn
- WindowFn.AssignContext
- WindowFn.MergeContext
- WindowFnTestUtils
- WithKeys
- WithTimestamps
- Write
- Write
- Write.Bound
- XmlSink
- XmlSink.Bound
- XmlSink.XmlWriteOperation
- XmlSink.XmlWriter
- XmlSource
- com.google.cloud.dataflow.sdk
- com.google.cloud.dataflow.sdk.annotations
- com.google.cloud.dataflow.sdk.coders
- com.google.cloud.dataflow.sdk.coders.protobuf
- com.google.cloud.dataflow.sdk.io
- com.google.cloud.dataflow.sdk.io.bigtable
- com.google.cloud.dataflow.sdk.io.datastore
- com.google.cloud.dataflow.sdk.io.range
- com.google.cloud.dataflow.sdk.options
- com.google.cloud.dataflow.sdk.runners
- com.google.cloud.dataflow.sdk.runners.inprocess
- com.google.cloud.dataflow.sdk.testing
- com.google.cloud.dataflow.sdk.transforms
- com.google.cloud.dataflow.sdk.transforms.display
- com.google.cloud.dataflow.sdk.transforms.join
- com.google.cloud.dataflow.sdk.transforms.windowing
- com.google.cloud.dataflow.sdk.values
- API Help
- Serialized Form