Network.Google.Dataflow.Types

Service Configuration

dataflowService

OAuth Scopes

userInfoEmailScope

cloudPlatformScope

JobExecutionInfoStages

data JobExecutionInfoStages

jobExecutionInfoStages

jeisAddtional

ComputationTopology

data ComputationTopology

computationTopology

ctStateFamilies

ctUserStageName

ctInputs

ctKeyRanges

ctOutputs

ctComputationId

ctSystemStageName

SourceSplitResponse

data SourceSplitResponse

sourceSplitResponse

ssrBundles

ssrShards

ssrOutcome

ResourceUtilizationReportMetricsItem

data ResourceUtilizationReportMetricsItem

resourceUtilizationReportMetricsItem

rurmiAddtional

CreateJobFromTemplateRequest

data CreateJobFromTemplateRequest

createJobFromTemplateRequest

cjftrEnvironment

cjftrJobName

cjftrGcsPath

cjftrParameters

Status

data Status

status

sDetails

sCode

sMessage

NameAndKind

data NameAndKind

nameAndKind

nakKind

nakName

IntegerList

data IntegerList

integerList

ilElements

WorkItem

data WorkItem

workItem

wiJobId

wiReportStatusInterval

wiShellTask

wiStreamingSetupTask

wiInitialReportIndex

wiMapTask

wiPackages

wiStreamingComputationTask

wiSourceOperationTask

wiId

wiProjectId

wiLeaseExpireTime

wiConfiguration

wiStreamingConfigTask

wiSeqMapTask

WorkerHealthReport

data WorkerHealthReport

workerHealthReport

whrVMIsHealthy

whrReportInterval

whrPods

whrVMStartupTime

SourceSplitOptions

data SourceSplitOptions

sourceSplitOptions

ssoDesiredShardSizeBytes

ssoDesiredBundleSizeBytes

WorkerPoolMetadata

data WorkerPoolMetadata

workerPoolMetadata

wpmAddtional

AutoscalingSettings

data AutoscalingSettings

autoscalingSettings

asMaxNumWorkers

asAlgorithm

JobExecutionStageInfo

data JobExecutionStageInfo

jobExecutionStageInfo

jesiStepName

InstructionOutput

data InstructionOutput

instructionOutput

ioOnlyCountValueBytes

ioCodec

ioName

ioSystemName

ioOriginalName

ioOnlyCountKeyBytes

ReportWorkItemStatusRequest

data ReportWorkItemStatusRequest

reportWorkItemStatusRequest

rwisrCurrentWorkerTime

rwisrLocation

rwisrWorkItemStatuses

rwisrWorkerId

EnvironmentVersion

data EnvironmentVersion

environmentVersion

evAddtional

Sink

data Sink

sink

sCodec

sSpec

StringList

data StringList

stringList

slElements

WorkerHealthReportResponse

data WorkerHealthReportResponse

workerHealthReportResponse

whrrReportInterval

SendDebugCaptureResponse

data SendDebugCaptureResponse

sendDebugCaptureResponse

JobLabels

data JobLabels

jobLabels

jlAddtional

MetricStructuredName

data MetricStructuredName

metricStructuredName

msnOrigin

msnContext

msnName

CounterStructuredName

data CounterStructuredName

counterStructuredName

csnStandardOrigin

csnComponentStepName

csnOtherOrigin

csnPortion

csnOriginalStepName

csnName

csnExecutionStepName

csnWorkerId

WriteInstruction

data WriteInstruction

writeInstruction

wiSink

wiInput

EnvironmentUserAgent

data EnvironmentUserAgent

environmentUserAgent

euaAddtional

Disk

data Disk

disk

dSizeGb

dDiskType

dMountPoint

MetricUpdate

data MetricUpdate

metricUpdate

muMeanSum

muInternal

muSet

muCumulative

muKind

muUpdateTime

muMeanCount

muName

muScalar

SourceGetMetadataResponse

data SourceGetMetadataResponse

sourceGetMetadataResponse

sgmrMetadata

Environment

data Environment

environment

eDataSet

eExperiments

eWorkerPools

eClusterManagerAPIService

eVersion

eInternalExperiments

eTempStoragePrefix

eServiceAccountEmail

eUserAgent

eSdkPipelineOptions

ConcatPosition

data ConcatPosition

concatPosition

cpIndex

cpPosition

MetricStructuredNameContext

data MetricStructuredNameContext

metricStructuredNameContext

msncAddtional

CounterUpdate

data CounterUpdate

counterUpdate

cuNameAndKind

cuIntegerList

cuFloatingPoint

cuInternal

cuStringList

cuShortId

cuDistribution

cuCumulative

cuStructuredNameAndMetadata

cuFloatingPointMean

cuIntegerMean

cuBoolean

cuFloatingPointList

cuInteger

StreamingStageLocation

data StreamingStageLocation

streamingStageLocation

sslStreamId

DerivedSource

data DerivedSource

derivedSource

dsDerivationMode

dsSource

JobMetrics

data JobMetrics

jobMetrics

jmMetrics

jmMetricTime

SendDebugCaptureRequest

data SendDebugCaptureRequest

sendDebugCaptureRequest

sdcrData

sdcrComponentId

sdcrWorkerId

WorkItemStatus

data WorkItemStatus

workItemStatus

wisReportedProgress

wisProgress

wisSourceOperationResponse

wisStopPosition

wisDynamicSourceSplit

wisCompleted

wisSourceFork

wisReportIndex

wisRequestedLeaseDuration

wisErrors

wisCounterUpdates

wisMetricUpdates

wisWorkItemId

WorkerMessageLabels

data WorkerMessageLabels

workerMessageLabels

wmlAddtional

FlattenInstruction

data FlattenInstruction

flattenInstruction

fiInputs

WorkerMessageCode

data WorkerMessageCode

workerMessageCode

wmcParameters

wmcCode

JobTransformNameMApping

data JobTransformNameMApping

jobTransformNameMApping

jtnmaAddtional

SourceSpec

data SourceSpec

sourceSpec

ssAddtional

SourceMetadata

data SourceMetadata

sourceMetadata

smEstimatedSizeBytes

smProducesSortedKeys

smInfinite

EnvironmentInternalExperiments

data EnvironmentInternalExperiments

environmentInternalExperiments

eieAddtional

TaskRunnerSettings

data TaskRunnerSettings

taskRunnerSettings

trsContinueOnException

trsHarnessCommand

trsWorkflowFileName

trsTaskGroup

trsAlsologtostderr

trsDataflowAPIVersion

trsLogDir

trsCommandlinesFileName

trsVMId

trsBaseURL

trsOAuthScopes

trsTaskUser

trsStreamingWorkerMainClass

trsBaseTaskDir

trsLogUploadLocation

trsTempStoragePrefix

trsLogToSerialconsole

trsParallelWorkerSettings

trsLanguageHint

StreamingComputationConfig

data StreamingComputationConfig

streamingComputationConfig

sccInstructions

sccSystemName

sccComputationId

sccStageName

EnvironmentSdkPipelineOptions

data EnvironmentSdkPipelineOptions

environmentSdkPipelineOptions

espoAddtional

FloatingPointMean

data FloatingPointMean

floatingPointMean

fpmCount

fpmSum

LeaseWorkItemRequest

data LeaseWorkItemRequest

leaseWorkItemRequest

lwirWorkItemTypes

lwirCurrentWorkerTime

lwirLocation

lwirWorkerCapabilities

lwirRequestedLeaseDuration

lwirWorkerId

SourceOperationResponse

data SourceOperationResponse

sourceOperationResponse

sorSplit

sorGetMetadata

TopologyConfigUserStageToComputationNameMap

data TopologyConfigUserStageToComputationNameMap

topologyConfigUserStageToComputationNameMap

tcustcnmAddtional

ShellTask

data ShellTask

shellTask

stCommand

stExitCode

StatusDetailsItem

data StatusDetailsItem

statusDetailsItem

sdiAddtional

ReportedParallelism

data ReportedParallelism

reportedParallelism

rpValue

rpIsInfinite

StepProperties

data StepProperties

stepProperties

spAddtional

TopologyConfig

data TopologyConfig

topologyConfig

tcDataDiskAssignments

tcPersistentStateVersion

tcForwardingKeyBits

tcUserStageToComputationNameMap

tcComputations

ApproximateSplitRequest

data ApproximateSplitRequest

approximateSplitRequest

asrFractionConsumed

asrPosition

SplitInt64

data SplitInt64

splitInt64

siHighBits

siLowBits

WorkerSettings

data WorkerSettings

workerSettings

wsServicePath

wsBaseURL

wsShuffleServicePath

wsTempStoragePrefix

wsReportingEnabled

wsWorkerId

GetDebugConfigResponse

data GetDebugConfigResponse

getDebugConfigResponse

gdcrConfig

WorkItemServiceStateHarnessData

data WorkItemServiceStateHarnessData

workItemServiceStateHarnessData

wisshdAddtional

DataDiskAssignment

data DataDiskAssignment

dataDiskAssignment

ddaVMInstance

ddaDataDisks

ResourceUtilizationReport

data ResourceUtilizationReport

resourceUtilizationReport

rurMetrics

FailedLocation

data FailedLocation

failedLocation

flName

WorkerMessageResponse

data WorkerMessageResponse

workerMessageResponse

wmrWorkerHealthReportResponse

wmrWorkerMetricsResponse

CreateJobFromTemplateRequestParameters

data CreateJobFromTemplateRequestParameters

createJobFromTemplateRequestParameters

cjftrpAddtional

WorkItemServiceState

data WorkItemServiceState

workItemServiceState

wissNextReportIndex

wissReportStatusInterval

wissHarnessData

wissSuggestedStopPoint

wissSuggestedStopPosition

wissLeaseExpireTime

wissSplitRequest

wissMetricShortId

StreamingSetupTask

data StreamingSetupTask

streamingSetupTask

sstStreamingComputationTopology

sstReceiveWorkPort

sstWorkerHarnessPort

sstDrain

PartialGroupByKeyInstructionInputElementCodec

data PartialGroupByKeyInstructionInputElementCodec

partialGroupByKeyInstructionInputElementCodec

pgbkiiecAddtional

MapTask

data MapTask

mapTask

mtInstructions

mtSystemName

mtStageName

MountedDataDisk

data MountedDataDisk

mountedDataDisk

mddDataDisk

SinkCodec

data SinkCodec

sinkCodec

scAddtional

IntegerMean

data IntegerMean

integerMean

imCount

imSum

WorkerHealthReportPodsItem

data WorkerHealthReportPodsItem

workerHealthReportPodsItem

whrpiAddtional

ParDoInstructionUserFn

data ParDoInstructionUserFn

parDoInstructionUserFn

pdiufAddtional

InstructionOutputCodec

data InstructionOutputCodec

instructionOutputCodec

iocAddtional

StreamLocation

data StreamLocation

streamLocation

slStreamingStageLocation

slSideInputLocation

slCustomSourceLocation

slPubsubLocation

WorkerPoolPoolArgs

data WorkerPoolPoolArgs

workerPoolPoolArgs

wppaAddtional

RuntimeEnvironment

data RuntimeEnvironment

runtimeEnvironment

reZone

reBypassTempDirValidation

reServiceAccountEmail

reMaxWorkers

reTempLocation

CounterMetadata

data CounterMetadata

counterMetadata

cmKind

cmDescription

cmStandardUnits

cmOtherUnits

SendWorkerMessagesResponse

data SendWorkerMessagesResponse

sendWorkerMessagesResponse

swmrWorkerMessageResponses

StreamingSideInputLocation

data StreamingSideInputLocation

streamingSideInputLocation

ssilTag

ssilStateFamily

GetDebugConfigRequest

data GetDebugConfigRequest

getDebugConfigRequest

gdcrComponentId

gdcrWorkerId

CounterStructuredNameAndMetadata

data CounterStructuredNameAndMetadata

counterStructuredNameAndMetadata

csnamName

csnamMetadata

StreamingComputationTask

data StreamingComputationTask

streamingComputationTask

sctTaskType

sctDataDisks

sctComputationRanges

JobMessage

data JobMessage

jobMessage

jmTime

jmMessageText

jmMessageImportance

jmId

SeqMapTaskOutputInfo

data SeqMapTaskOutputInfo

seqMapTaskOutputInfo

smtoiSink

smtoiTag

SourceGetMetadataRequest

data SourceGetMetadataRequest

sourceGetMetadataRequest

sgmrSource

SeqMapTaskUserFn

data SeqMapTaskUserFn

seqMapTaskUserFn

smtufAddtional

PartialGroupByKeyInstructionValueCombiningFn

data PartialGroupByKeyInstructionValueCombiningFn

partialGroupByKeyInstructionValueCombiningFn

pgbkivcfAddtional

Job

data Job

job

jRequestedState

jLocation

jEnvironment

jClientRequestId

jCurrentState

jReplacedByJobId

jTempFiles

jSteps

jExecutionInfo

jName

jTransformNameMApping

jId

jLabels

jProjectId

jType

jCurrentStateTime

jReplaceJobId

jCreateTime

ReadInstruction

data ReadInstruction

readInstruction

riSource

ApproximateReportedProgress

data ApproximateReportedProgress

approximateReportedProgress

arpFractionConsumed

arpConsumedParallelism

arpRemainingParallelism

arpPosition

SinkSpec

data SinkSpec

sinkSpec

sAddtional

WorkerPool

data WorkerPool

workerPool

wpAutoscalingSettings

wpNumThreadsPerWorker

wpDiskSizeGb

wpKind

wpTaskrunnerSettings

wpNumWorkers

wpNetwork

wpZone

wpIPConfiguration

wpPackages

wpOnHostMaintenance

wpDiskSourceImage

wpSubnetwork

wpMachineType

wpMetadata

wpDiskType

wpTeardownPolicy

wpDefaultPackageSet

wpPoolArgs

wpWorkerHarnessContainerImage

wpDataDisks

Step

data Step

step

sKind

sName

sProperties

Package

data Package

package

pLocation

pName

WorkerMessageCodeParameters

data WorkerMessageCodeParameters

workerMessageCodeParameters

wmcpAddtional

DynamicSourceSplit

data DynamicSourceSplit

dynamicSourceSplit

dssResidual

dssPrimary

ReportWorkItemStatusResponse

data ReportWorkItemStatusResponse

reportWorkItemStatusResponse

rwisrWorkItemServiceStates

SourceFork

data SourceFork

sourceFork

sfResidual

sfPrimarySource

sfPrimary

sfResidualSource

ResourceUtilizationReportResponse

data ResourceUtilizationReportResponse

resourceUtilizationReportResponse

StreamingComputationRanges

data StreamingComputationRanges

streamingComputationRanges

scrRangeAssignments

scrComputationId

ListJobsResponse

data ListJobsResponse

listJobsResponse

ljrNextPageToken

ljrFailedLocation

ljrJobs

Source

data Source

source

souDoesNotNeedSplitting

souBaseSpecs

souCodec

souSpec

souMetadata

ApproximateProgress

data ApproximateProgress

approximateProgress

apRemainingTime

apPercentComplete

apPosition

WorkerMessage

data WorkerMessage

workerMessage

wmWorkerHealthReport

wmTime

wmWorkerMessageCode

wmWorkerMetrics

wmLabels

KeyRangeLocation

data KeyRangeLocation

keyRangeLocation

krlPersistentDirectory

krlDataDisk

krlStart

krlDeliveryEndpoint

krlEnd

MultiOutputInfo

data MultiOutputInfo

multiOutputInfo

moiTag

PartialGroupByKeyInstruction

data PartialGroupByKeyInstruction

partialGroupByKeyInstruction

pgbkiValueCombiningFn

pgbkiSideInputs

pgbkiInput

pgbkiOriginalCombineValuesStepName

pgbkiInputElementCodec

pgbkiOriginalCombineValuesInputStoreName

ParDoInstruction

data ParDoInstruction

parDoInstruction

pdiNumOutputs

pdiMultiOutputInfos

pdiSideInputs

pdiInput

pdiUserFn

CustomSourceLocation

data CustomSourceLocation

customSourceLocation

cslStateful

DistributionUpdate

data DistributionUpdate

distributionUpdate

duMax

duCount

duMin

duSumOfSquares

duSum

SourceBaseSpecsItem

data SourceBaseSpecsItem

sourceBaseSpecsItem

sbsiAddtional

ParallelInstruction

data ParallelInstruction

parallelInstruction

piRead

piWrite

piParDo

piPartialGroupByKey

piOutputs

piName

piSystemName

piFlatten

piOriginalName

SideInputInfoKind

data SideInputInfoKind

sideInputInfoKind

siikAddtional

StreamingConfigTask

data StreamingConfigTask

streamingConfigTask

sctUserStepToStateFamilyNameMap

sctStreamingComputationConfigs

MetricShortId

data MetricShortId

metricShortId

msiShortId

msiMetricIndex

SendWorkerMessagesRequest

data SendWorkerMessagesRequest

sendWorkerMessagesRequest

swmrWorkerMessages

SourceSplitShard

data SourceSplitShard

sourceSplitShard

sssDerivationMode

sssSource

SideInputInfo

data SideInputInfo

sideInputInfo

siiTag

siiKind

siiSources

JobExecutionInfo

data JobExecutionInfo

jobExecutionInfo

jeiStages

SourceCodec

data SourceCodec

sourceCodec

souAddtional

StateFamilyConfig

data StateFamilyConfig

stateFamilyConfig

sfcIsRead

sfcStateFamily

KeyRangeDataDiskAssignment

data KeyRangeDataDiskAssignment

keyRangeDataDiskAssignment

krddaDataDisk

krddaStart

krddaEnd

SourceSplitRequest

data SourceSplitRequest

sourceSplitRequest

ssrSource

ssrOptions

ListJobMessagesResponse

data ListJobMessagesResponse

listJobMessagesResponse

ljmrJobMessages

ljmrNextPageToken

PubsubLocation

data PubsubLocation

pubsubLocation

plTrackingSubscription

plDropLateData

plTimestampLabel

plIdLabel

plTopic

plWithAttributes

plSubscription

FloatingPointList

data FloatingPointList

floatingPointList

fplElements

InstructionInput

data InstructionInput

instructionInput

iiProducerInstructionIndex

iiOutputNum

SeqMapTask

data SeqMapTask

seqMapTask

smtInputs

smtName

smtOutputInfos

smtSystemName

smtStageName

smtUserFn

StreamingConfigTaskUserStepToStateFamilyNameMap

data StreamingConfigTaskUserStepToStateFamilyNameMap

streamingConfigTaskUserStepToStateFamilyNameMap

sctustsfnmAddtional

SourceOperationRequest

data SourceOperationRequest

sourceOperationRequest

sSplit

sGetMetadata

LeaseWorkItemResponse

data LeaseWorkItemResponse

leaseWorkItemResponse

lwirWorkItems

Position

data Position

position

pByteOffSet

pConcatPosition

pRecordIndex

pShufflePosition

pKey

pEnd