{-# LANGUAGE DataKinds #-}
{-# LANGUAGE NoImplicitPrelude #-}
{-# LANGUAGE TypeOperators #-}
{-# OPTIONS_GHC -fno-warn-unused-imports #-}
{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}
module Network.Google.Dataflow
(
dataflowService
, computeScope
, userInfoEmailScope
, cloudPlatformScope
, computeReadOnlyScope
, DataflowAPI
, module Network.Google.Resource.Dataflow.Projects.Jobs.Aggregated
, module Network.Google.Resource.Dataflow.Projects.Jobs.Create
, module Network.Google.Resource.Dataflow.Projects.Jobs.Debug.GetConfig
, module Network.Google.Resource.Dataflow.Projects.Jobs.Debug.SendCapture
, module Network.Google.Resource.Dataflow.Projects.Jobs.Get
, module Network.Google.Resource.Dataflow.Projects.Jobs.GetMetrics
, module Network.Google.Resource.Dataflow.Projects.Jobs.List
, module Network.Google.Resource.Dataflow.Projects.Jobs.Messages.List
, module Network.Google.Resource.Dataflow.Projects.Jobs.Snapshot
, module Network.Google.Resource.Dataflow.Projects.Jobs.Update
, module Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.Lease
, module Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.ReportStatus
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Create
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Debug.GetConfig
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Debug.SendCapture
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Get
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.GetMetrics
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.List
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Messages.List
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Snapshot
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Update
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.WorkItems.Lease
, module Network.Google.Resource.Dataflow.Projects.Locations.Jobs.WorkItems.ReportStatus
, module Network.Google.Resource.Dataflow.Projects.Locations.Templates.Create
, module Network.Google.Resource.Dataflow.Projects.Locations.Templates.Get
, module Network.Google.Resource.Dataflow.Projects.Locations.Templates.Launch
, module Network.Google.Resource.Dataflow.Projects.Locations.WorkerMessages
, module Network.Google.Resource.Dataflow.Projects.Templates.Create
, module Network.Google.Resource.Dataflow.Projects.Templates.Get
, module Network.Google.Resource.Dataflow.Projects.Templates.Launch
, module Network.Google.Resource.Dataflow.Projects.WorkerMessages
, NameAndKindKind (..)
, JobExecutionInfoStages
, jobExecutionInfoStages
, jeisAddtional
, ComputationTopology
, computationTopology
, ctStateFamilies
, ctInputs
, ctKeyRanges
, ctOutputs
, ctComputationId
, ctSystemStageName
, SourceSplitResponse
, sourceSplitResponse
, ssrBundles
, ssrShards
, ssrOutcome
, ParameterMetadata
, parameterMetadata
, pmHelpText
, pmIsOptional
, pmName
, pmRegexes
, pmLabel
, CreateJobFromTemplateRequest
, createJobFromTemplateRequest
, cjftrLocation
, cjftrEnvironment
, cjftrJobName
, cjftrGcsPath
, cjftrParameters
, Status
, status
, sDetails
, sCode
, sMessage
, NameAndKind
, nameAndKind
, nakKind
, nakName
, IntegerList
, integerList
, ilElements
, WorkItem
, workItem
, wiJobId
, wiReportStatusInterval
, wiShellTask
, wiStreamingSetupTask
, wiInitialReportIndex
, wiMapTask
, wiPackages
, wiStreamingComputationTask
, wiSourceOperationTask
, wiId
, wiProjectId
, wiLeaseExpireTime
, wiConfiguration
, wiStreamingConfigTask
, wiSeqMapTask
, WorkerHealthReport
, workerHealthReport
, whrVMIsHealthy
, whrReportInterval
, whrPods
, whrVMStartupTime
, Snapshot
, snapshot
, sCreationTime
, sTtl
, sSourceJobId
, sId
, sProjectId
, SourceSplitOptions
, sourceSplitOptions
, ssoDesiredShardSizeBytes
, ssoDesiredBundleSizeBytes
, WorkerPoolMetadata
, workerPoolMetadata
, wpmAddtional
, AutoscalingSettings
, autoscalingSettings
, asMaxNumWorkers
, asAlgorithm
, JobExecutionStageInfo
, jobExecutionStageInfo
, jesiStepName
, InstructionOutput
, instructionOutput
, ioOnlyCountValueBytes
, ioCodec
, ioName
, ioSystemName
, ioOriginalName
, ioOnlyCountKeyBytes
, IntegerGauge
, integerGauge
, igValue
, igTimestamp
, LaunchTemplateParameters
, launchTemplateParameters
, ltpEnvironment
, ltpJobName
, ltpParameters
, ReportWorkItemStatusRequest
, reportWorkItemStatusRequest
, rwisrCurrentWorkerTime
, rwisrLocation
, rwisrWorkItemStatuses
, rwisrWorkerId
, JobType (..)
, EnvironmentVersion
, environmentVersion
, evAddtional
, StreamingApplianceSnapshotConfig
, streamingApplianceSnapshotConfig
, sascImportStateEndpoint
, sascSnapshotId
, Sink
, sink
, sCodec
, sSpec
, StringList
, stringList
, slElements
, WorkerHealthReportResponse
, workerHealthReportResponse
, whrrReportInterval
, DisplayData
, displayData
, ddDurationValue
, ddBoolValue
, ddTimestampValue
, ddURL
, ddNamespace
, ddJavaClassValue
, ddShortStrValue
, ddKey
, ddInt64Value
, ddFloatValue
, ddStrValue
, ddLabel
, SendDebugCaptureResponse
, sendDebugCaptureResponse
, StructuredMessage
, structuredMessage
, smMessageText
, smMessageKey
, smParameters
, JobLabels
, jobLabels
, jlAddtional
, MetricStructuredName
, metricStructuredName
, msnOrigin
, msnContext
, msnName
, BigQueryIODetails
, bigQueryIODetails
, bqiodDataSet
, bqiodQuery
, bqiodProjectId
, bqiodTable
, FileIODetails
, fileIODetails
, fiodFilePattern
, WorkerPoolTeardownPolicy (..)
, CounterStructuredName
, counterStructuredName
, csnOrigin
, csnOriginNamespace
, csnComponentStepName
, csnPortion
, csnOriginalStepName
, csnName
, csnExecutionStepName
, csnOriginalRequestingStepName
, csnInputIndex
, csnWorkerId
, JobMetadata
, jobMetadata
, jmSpannerDetails
, jmBigTableDetails
, jmSdkVersion
, jmPubsubDetails
, jmFileDetails
, jmBigQueryDetails
, jmDatastoreDetails
, GetTemplateResponse
, getTemplateResponse
, gtrStatus
, gtrMetadata
, WriteInstruction
, writeInstruction
, wiSink
, wiInput
, EnvironmentUserAgent
, environmentUserAgent
, euaAddtional
, Disk
, disk
, dSizeGb
, dDiskType
, dMountPoint
, MetricUpdate
, metricUpdate
, muMeanSum
, muInternal
, muSet
, muDistribution
, muCumulative
, muKind
, muGauge
, muUpdateTime
, muMeanCount
, muName
, muScalar
, SourceGetMetadataResponse
, sourceGetMetadataResponse
, sgmrMetadata
, TemplateMetadata
, templateMetadata
, tmName
, tmParameters
, tmDescription
, Environment
, environment
, eDataSet
, eExperiments
, eWorkerPools
, eClusterManagerAPIService
, eVersion
, eInternalExperiments
, eTempStoragePrefix
, eServiceAccountEmail
, eUserAgent
, eSdkPipelineOptions
, ConcatPosition
, concatPosition
, cpIndex
, cpPosition
, MetricStructuredNameContext
, metricStructuredNameContext
, msncAddtional
, CounterUpdate
, counterUpdate
, cuNameAndKind
, cuIntegerList
, cuFloatingPoint
, cuInternal
, cuStringList
, cuShortId
, cuIntegerGauge
, cuDistribution
, cuCumulative
, cuStructuredNameAndMetadata
, cuFloatingPointMean
, cuIntegerMean
, cuBoolean
, cuFloatingPointList
, cuInteger
, StreamingStageLocation
, streamingStageLocation
, sslStreamId
, AutoscalingSettingsAlgorithm (..)
, DerivedSource
, derivedSource
, dsDerivationMode
, dsSource
, JobMetrics
, jobMetrics
, jmMetrics
, jmMetricTime
, TransformSummaryKind (..)
, SendDebugCaptureRequest
, sendDebugCaptureRequest
, sdcrLocation
, sdcrData
, sdcrComponentId
, sdcrWorkerId
, WorkItemStatus
, workItemStatus
, wisReportedProgress
, wisProgress
, wisTotalThrottlerWaitTimeSeconds
, wisSourceOperationResponse
, wisStopPosition
, wisDynamicSourceSplit
, wisCompleted
, wisSourceFork
, wisReportIndex
, wisRequestedLeaseDuration
, wisErrors
, wisCounterUpdates
, wisMetricUpdates
, wisWorkItemId
, WorkerMessageLabels
, workerMessageLabels
, wmlAddtional
, FlattenInstruction
, flattenInstruction
, fiInputs
, WorkerMessageCode
, workerMessageCode
, wmcParameters
, wmcCode
, TransformSummary
, transformSummary
, tsDisplayData
, tsKind
, tsOutputCollectionName
, tsInputCollectionName
, tsName
, tsId
, JobTransformNameMApping
, jobTransformNameMApping
, jtnmaAddtional
, SourceSpec
, sourceSpec
, ssAddtional
, SourceMetadata
, sourceMetadata
, smEstimatedSizeBytes
, smProducesSortedKeys
, smInfinite
, EnvironmentInternalExperiments
, environmentInternalExperiments
, eieAddtional
, TaskRunnerSettings
, taskRunnerSettings
, trsContinueOnException
, trsHarnessCommand
, trsWorkflowFileName
, trsTaskGroup
, trsAlsologtostderr
, trsDataflowAPIVersion
, trsLogDir
, trsCommandlinesFileName
, trsVMId
, trsBaseURL
, trsOAuthScopes
, trsTaskUser
, trsStreamingWorkerMainClass
, trsBaseTaskDir
, trsLogUploadLocation
, trsTempStoragePrefix
, trsLogToSerialconsole
, trsParallelWorkerSettings
, trsLanguageHint
, StreamingComputationConfig
, streamingComputationConfig
, sccInstructions
, sccSystemName
, sccComputationId
, sccStageName
, EnvironmentSdkPipelineOptions
, environmentSdkPipelineOptions
, espoAddtional
, FloatingPointMean
, floatingPointMean
, fpmCount
, fpmSum
, CPUTime
, cpuTime
, ctTotalMs
, ctRate
, ctTimestamp
, LeaseWorkItemRequest
, leaseWorkItemRequest
, lwirWorkItemTypes
, lwirCurrentWorkerTime
, lwirLocation
, lwirWorkerCapabilities
, lwirRequestedLeaseDuration
, lwirWorkerId
, SourceOperationResponse
, sourceOperationResponse
, sorSplit
, sorGetMetadata
, CounterStructuredNamePortion (..)
, TopologyConfigUserStageToComputationNameMap
, topologyConfigUserStageToComputationNameMap
, tcustcnmAddtional
, ShellTask
, shellTask
, stCommand
, stExitCode
, JobMessageMessageImportance (..)
, DatastoreIODetails
, datastoreIODetails
, diodNamespace
, diodProjectId
, StatusDetailsItem
, statusDetailsItem
, sdiAddtional
, ReportedParallelism
, reportedParallelism
, rpValue
, rpIsInfinite
, StepProperties
, stepProperties
, spAddtional
, TopologyConfig
, topologyConfig
, tcDataDiskAssignments
, tcPersistentStateVersion
, tcForwardingKeyBits
, tcUserStageToComputationNameMap
, tcComputations
, ApproximateSplitRequest
, approximateSplitRequest
, asrFractionConsumed
, asrFractionOfRemainder
, asrPosition
, SplitInt64
, splitInt64
, siHighBits
, siLowBits
, WorkerSettings
, workerSettings
, wsServicePath
, wsBaseURL
, wsShuffleServicePath
, wsTempStoragePrefix
, wsReportingEnabled
, wsWorkerId
, GetDebugConfigResponse
, getDebugConfigResponse
, gdcrConfig
, SdkVersion
, sdkVersion
, svSdkSupportStatus
, svVersionDisplayName
, svVersion
, WorkItemServiceStateHarnessData
, workItemServiceStateHarnessData
, wisshdAddtional
, DataDiskAssignment
, dataDiskAssignment
, ddaVMInstance
, ddaDataDisks
, ResourceUtilizationReport
, resourceUtilizationReport
, rurCPUTime
, FailedLocation
, failedLocation
, flName
, SourceSplitResponseOutcome (..)
, WorkerMessageResponse
, workerMessageResponse
, wmrWorkerHealthReportResponse
, wmrWorkerMetricsResponse
, wmrWorkerShutdownNoticeResponse
, CreateJobFromTemplateRequestParameters
, createJobFromTemplateRequestParameters
, cjftrpAddtional
, BigTableIODetails
, bigTableIODetails
, btiodInstanceId
, btiodProjectId
, btiodTableId
, WorkItemServiceState
, workItemServiceState
, wissNextReportIndex
, wissReportStatusInterval
, wissHarnessData
, wissSuggestedStopPoint
, wissSuggestedStopPosition
, wissLeaseExpireTime
, wissSplitRequest
, wissMetricShortId
, LaunchTemplateResponse
, launchTemplateResponse
, ltrJob
, StreamingSetupTask
, streamingSetupTask
, sstStreamingComputationTopology
, sstReceiveWorkPort
, sstWorkerHarnessPort
, sstDrain
, sstSnapshotConfig
, PartialGroupByKeyInstructionInputElementCodec
, partialGroupByKeyInstructionInputElementCodec
, pgbkiiecAddtional
, MapTask
, mapTask
, mtInstructions
, mtCounterPrefix
, mtSystemName
, mtStageName
, MountedDataDisk
, mountedDataDisk
, mddDataDisk
, SinkCodec
, sinkCodec
, scAddtional
, SourceSplitShardDerivationMode (..)
, WorkerPoolDefaultPackageSet (..)
, IntegerMean
, integerMean
, imCount
, imSum
, CounterMetadataKind (..)
, WorkerHealthReportPodsItem
, workerHealthReportPodsItem
, whrpiAddtional
, ParDoInstructionUserFn
, parDoInstructionUserFn
, pdiufAddtional
, InstructionOutputCodec
, instructionOutputCodec
, iocAddtional
, StreamLocation
, streamLocation
, slStreamingStageLocation
, slSideInputLocation
, slCustomSourceLocation
, slPubsubLocation
, WorkerLifecycleEventMetadata
, workerLifecycleEventMetadata
, wlemAddtional
, WorkerPoolPoolArgs
, workerPoolPoolArgs
, wppaAddtional
, RuntimeEnvironment
, runtimeEnvironment
, reNumWorkers
, reNetwork
, reZone
, reBypassTempDirValidation
, reSubnetwork
, reMachineType
, reAdditionalUserLabels
, reServiceAccountEmail
, reAdditionalExperiments
, reMaxWorkers
, reTempLocation
, CounterMetadata
, counterMetadata
, cmKind
, cmDescription
, cmStandardUnits
, cmOtherUnits
, SendWorkerMessagesResponse
, sendWorkerMessagesResponse
, swmrWorkerMessageResponses
, JobCurrentState (..)
, StreamingSideInputLocation
, streamingSideInputLocation
, ssilTag
, ssilStateFamily
, GetDebugConfigRequest
, getDebugConfigRequest
, gdcrLocation
, gdcrComponentId
, gdcrWorkerId
, CounterStructuredNameAndMetadata
, counterStructuredNameAndMetadata
, csnamName
, csnamMetadata
, WorkerShutdownNotice
, workerShutdownNotice
, wsnReason
, StreamingComputationTask
, streamingComputationTask
, sctTaskType
, sctDataDisks
, sctComputationRanges
, PipelineDescription
, pipelineDescription
, pdExecutionPipelineStage
, pdDisplayData
, pdOriginalPipelineTransform
, JobMessage
, jobMessage
, jmTime
, jmMessageText
, jmMessageImportance
, jmId
, WorkerLifecycleEvent
, workerLifecycleEvent
, wleEvent
, wleContainerStartTime
, wleMetadata
, RuntimeEnvironmentAdditionalUserLabels
, runtimeEnvironmentAdditionalUserLabels
, reaulAddtional
, CounterMetadataStandardUnits (..)
, SeqMapTaskOutputInfo
, seqMapTaskOutputInfo
, smtoiSink
, smtoiTag
, PubSubIODetails
, pubSubIODetails
, psiodTopic
, psiodSubscription
, SourceGetMetadataRequest
, sourceGetMetadataRequest
, sgmrSource
, WorkerShutdownNoticeResponse
, workerShutdownNoticeResponse
, SeqMapTaskUserFn
, seqMapTaskUserFn
, smtufAddtional
, PartialGroupByKeyInstructionValueCombiningFn
, partialGroupByKeyInstructionValueCombiningFn
, pgbkivcfAddtional
, Job
, job
, jStepsLocation
, jCreatedFromSnapshotId
, jRequestedState
, jJobMetadata
, jLocation
, jStartTime
, jEnvironment
, jClientRequestId
, jStageStates
, jCurrentState
, jReplacedByJobId
, jTempFiles
, jSteps
, jPipelineDescription
, jExecutionInfo
, jName
, jTransformNameMApping
, jId
, jLabels
, jProjectId
, jType
, jCurrentStateTime
, jReplaceJobId
, jCreateTime
, AutoscalingEventEventType (..)
, ReadInstruction
, readInstruction
, riSource
, ApproximateReportedProgress
, approximateReportedProgress
, arpFractionConsumed
, arpConsumedParallelism
, arpRemainingParallelism
, arpPosition
, DerivedSourceDerivationMode (..)
, SinkSpec
, sinkSpec
, sAddtional
, WorkerPool
, workerPool
, wpAutoscalingSettings
, wpNumThreadsPerWorker
, wpDiskSizeGb
, wpKind
, wpTaskrunnerSettings
, wpNumWorkers
, wpNetwork
, wpZone
, wpIPConfiguration
, wpPackages
, wpOnHostMaintenance
, wpDiskSourceImage
, wpSubnetwork
, wpMachineType
, wpMetadata
, wpDiskType
, wpTeardownPolicy
, wpDefaultPackageSet
, wpPoolArgs
, wpWorkerHarnessContainerImage
, wpDataDisks
, Step
, step
, sKind
, sName
, sProperties
, ComponentSource
, componentSource
, csUserName
, csName
, csOriginalTransformOrCollection
, ExecutionStageSummaryKind (..)
, Xgafv (..)
, Package
, package
, pLocation
, pName
, ExecutionStageSummary
, executionStageSummary
, essOutputSource
, essKind
, essInputSource
, essName
, essComponentSource
, essId
, essComponentTransform
, WorkerMessageCodeParameters
, workerMessageCodeParameters
, wmcpAddtional
, DynamicSourceSplit
, dynamicSourceSplit
, dssResidual
, dssPrimary
, SnapshotJobRequest
, snapshotJobRequest
, sjrTtl
, sjrLocation
, ReportWorkItemStatusResponse
, reportWorkItemStatusResponse
, rwisrWorkItemServiceStates
, SourceFork
, sourceFork
, sfResidual
, sfPrimarySource
, sfPrimary
, sfResidualSource
, ResourceUtilizationReportResponse
, resourceUtilizationReportResponse
, StreamingComputationRanges
, streamingComputationRanges
, scrRangeAssignments
, scrComputationId
, ListJobsResponse
, listJobsResponse
, ljrNextPageToken
, ljrFailedLocation
, ljrJobs
, LaunchTemplateParametersParameters
, launchTemplateParametersParameters
, ltppAddtional
, Source
, source
, souDoesNotNeedSplitting
, souBaseSpecs
, souCodec
, souSpec
, souMetadata
, ApproximateProgress
, approximateProgress
, apRemainingTime
, apPercentComplete
, apPosition
, WorkerMessage
, workerMessage
, wmWorkerHealthReport
, wmTime
, wmWorkerMessageCode
, wmWorkerMetrics
, wmWorkerLifecycleEvent
, wmWorkerShutdownNotice
, wmLabels
, KeyRangeLocation
, keyRangeLocation
, krlDataDisk
, krlDeprecatedPersistentDirectory
, krlStart
, krlDeliveryEndpoint
, krlEnd
, Histogram
, histogram
, hBucketCounts
, hFirstBucketOffSet
, JobRequestedState (..)
, MultiOutputInfo
, multiOutputInfo
, moiTag
, PartialGroupByKeyInstruction
, partialGroupByKeyInstruction
, pgbkiValueCombiningFn
, pgbkiSideInputs
, pgbkiInput
, pgbkiOriginalCombineValuesStepName
, pgbkiInputElementCodec
, pgbkiOriginalCombineValuesInputStoreName
, WorkerLifecycleEventEvent (..)
, ExecutionStageStateExecutionStageState (..)
, ParDoInstruction
, parDoInstruction
, pdiNumOutputs
, pdiMultiOutputInfos
, pdiSideInputs
, pdiInput
, pdiUserFn
, CustomSourceLocation
, customSourceLocation
, cslStateful
, DistributionUpdate
, distributionUpdate
, duMax
, duCount
, duMin
, duHistogram
, duSumOfSquares
, duSum
, SourceBaseSpecsItem
, sourceBaseSpecsItem
, sbsiAddtional
, ParallelInstruction
, parallelInstruction
, piRead
, piWrite
, piParDo
, piPartialGroupByKey
, piOutputs
, piName
, piSystemName
, piFlatten
, piOriginalName
, SideInputInfoKind
, sideInputInfoKind
, siikAddtional
, StreamingConfigTask
, streamingConfigTask
, sctUserStepToStateFamilyNameMap
, sctStreamingComputationConfigs
, sctWindmillServiceEndpoint
, sctWindmillServicePort
, MetricShortId
, metricShortId
, msiShortId
, msiMetricIndex
, SendWorkerMessagesRequest
, sendWorkerMessagesRequest
, swmrLocation
, swmrWorkerMessages
, SourceSplitShard
, sourceSplitShard
, sssDerivationMode
, sssSource
, SideInputInfo
, sideInputInfo
, siiTag
, siiKind
, siiSources
, ComponentTransform
, componentTransform
, ctOriginalTransform
, ctUserName
, ctName
, WorkerPoolIPConfiguration (..)
, JobExecutionInfo
, jobExecutionInfo
, jeiStages
, SourceCodec
, sourceCodec
, souAddtional
, StateFamilyConfig
, stateFamilyConfig
, sfcIsRead
, sfcStateFamily
, KeyRangeDataDiskAssignment
, keyRangeDataDiskAssignment
, krddaDataDisk
, krddaStart
, krddaEnd
, AutoscalingEvent
, autoscalingEvent
, aeCurrentNumWorkers
, aeTime
, aeEventType
, aeTargetNumWorkers
, aeWorkerPool
, aeDescription
, SourceSplitRequest
, sourceSplitRequest
, ssrSource
, ssrOptions
, ListJobMessagesResponse
, listJobMessagesResponse
, ljmrJobMessages
, ljmrNextPageToken
, ljmrAutoscalingEvents
, PubsubLocation
, pubsubLocation
, plTrackingSubscription
, plDropLateData
, plTimestampLabel
, plIdLabel
, plTopic
, plWithAttributes
, plSubscription
, FloatingPointList
, floatingPointList
, fplElements
, CounterStructuredNameOrigin (..)
, InstructionInput
, instructionInput
, iiProducerInstructionIndex
, iiOutputNum
, SeqMapTask
, seqMapTask
, smtInputs
, smtName
, smtOutputInfos
, smtSystemName
, smtStageName
, smtUserFn
, StreamingComputationTaskTaskType (..)
, StreamingConfigTaskUserStepToStateFamilyNameMap
, streamingConfigTaskUserStepToStateFamilyNameMap
, sctustsfnmAddtional
, ExecutionStageState
, executionStageState
, essExecutionStageName
, essCurrentStateTime
, essExecutionStageState
, StageSource
, stageSource
, ssSizeBytes
, ssUserName
, ssName
, ssOriginalTransformOrCollection
, SourceOperationRequest
, sourceOperationRequest
, souSplit
, souGetMetadata
, souName
, souSystemName
, souStageName
, souOriginalName
, SdkVersionSdkSupportStatus (..)
, SpannerIODetails
, spannerIODetails
, siodInstanceId
, siodDatabaseId
, siodProjectId
, LeaseWorkItemResponse
, leaseWorkItemResponse
, lwirWorkItems
, Position
, position
, pByteOffSet
, pConcatPosition
, pRecordIndex
, pShufflePosition
, pKey
, pEnd
, Parameter
, parameter
, parValue
, parKey
) where
import Network.Google.Dataflow.Types
import Network.Google.Prelude
import Network.Google.Resource.Dataflow.Projects.Jobs.Aggregated
import Network.Google.Resource.Dataflow.Projects.Jobs.Create
import Network.Google.Resource.Dataflow.Projects.Jobs.Debug.GetConfig
import Network.Google.Resource.Dataflow.Projects.Jobs.Debug.SendCapture
import Network.Google.Resource.Dataflow.Projects.Jobs.Get
import Network.Google.Resource.Dataflow.Projects.Jobs.GetMetrics
import Network.Google.Resource.Dataflow.Projects.Jobs.List
import Network.Google.Resource.Dataflow.Projects.Jobs.Messages.List
import Network.Google.Resource.Dataflow.Projects.Jobs.Snapshot
import Network.Google.Resource.Dataflow.Projects.Jobs.Update
import Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.Lease
import Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.ReportStatus
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Create
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Debug.GetConfig
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Debug.SendCapture
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Get
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.GetMetrics
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.List
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Messages.List
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Snapshot
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.Update
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.WorkItems.Lease
import Network.Google.Resource.Dataflow.Projects.Locations.Jobs.WorkItems.ReportStatus
import Network.Google.Resource.Dataflow.Projects.Locations.Templates.Create
import Network.Google.Resource.Dataflow.Projects.Locations.Templates.Get
import Network.Google.Resource.Dataflow.Projects.Locations.Templates.Launch
import Network.Google.Resource.Dataflow.Projects.Locations.WorkerMessages
import Network.Google.Resource.Dataflow.Projects.Templates.Create
import Network.Google.Resource.Dataflow.Projects.Templates.Get
import Network.Google.Resource.Dataflow.Projects.Templates.Launch
import Network.Google.Resource.Dataflow.Projects.WorkerMessages
type DataflowAPI =
ProjectsTemplatesLaunchResource :<|>
ProjectsTemplatesGetResource
:<|> ProjectsTemplatesCreateResource
:<|> ProjectsJobsDebugGetConfigResource
:<|> ProjectsJobsDebugSendCaptureResource
:<|> ProjectsJobsWorkItemsLeaseResource
:<|> ProjectsJobsWorkItemsReportStatusResource
:<|> ProjectsJobsMessagesListResource
:<|> ProjectsJobsSnapshotResource
:<|> ProjectsJobsListResource
:<|> ProjectsJobsAggregatedResource
:<|> ProjectsJobsGetResource
:<|> ProjectsJobsCreateResource
:<|> ProjectsJobsUpdateResource
:<|> ProjectsJobsGetMetricsResource
:<|> ProjectsLocationsTemplatesLaunchResource
:<|> ProjectsLocationsTemplatesGetResource
:<|> ProjectsLocationsTemplatesCreateResource
:<|> ProjectsLocationsJobsDebugGetConfigResource
:<|> ProjectsLocationsJobsDebugSendCaptureResource
:<|> ProjectsLocationsJobsWorkItemsLeaseResource
:<|>
ProjectsLocationsJobsWorkItemsReportStatusResource
:<|> ProjectsLocationsJobsMessagesListResource
:<|> ProjectsLocationsJobsSnapshotResource
:<|> ProjectsLocationsJobsListResource
:<|> ProjectsLocationsJobsGetResource
:<|> ProjectsLocationsJobsCreateResource
:<|> ProjectsLocationsJobsUpdateResource
:<|> ProjectsLocationsJobsGetMetricsResource
:<|> ProjectsLocationsWorkerMessagesResource
:<|> ProjectsWorkerMessagesResource