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

Status

data Status

status

sDetails

sCode

sMessage

WorkItem

data WorkItem

workItem

wiJobId

wiReportStatusInterval

wiShellTask

wiStreamingSetupTask

wiInitialReportIndex

wiMapTask

wiPackages

wiStreamingComputationTask

wiSourceOperationTask

wiId

wiProjectId

wiLeaseExpireTime

wiConfiguration

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

ioCodec

ioName

ioSystemName

ReportWorkItemStatusRequest

data ReportWorkItemStatusRequest

reportWorkItemStatusRequest

rwisrCurrentWorkerTime

rwisrWorkItemStatuses

rwisrWorkerId

EnvironmentVersion

data EnvironmentVersion

environmentVersion

evAddtional

Sink

data Sink

sink

sCodec

sSpec

WorkerHealthReportResponse

data WorkerHealthReportResponse

workerHealthReportResponse

whrrReportInterval

MetricStructuredName

data MetricStructuredName

metricStructuredName

msnOrigin

msnContext

msnName

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

eUserAgent

eSdkPipelineOptions

ConcatPosition

data ConcatPosition

concatPosition

cpIndex

cpPosition

MetricStructuredNameContext

data MetricStructuredNameContext

metricStructuredNameContext

msncAddtional

StreamingStageLocation

data StreamingStageLocation

streamingStageLocation

sslStreamId

DerivedSource

data DerivedSource

derivedSource

dsDerivationMode

dsSource

JobMetrics

data JobMetrics

jobMetrics

jmMetrics

jmMetricTime

WorkItemStatus

data WorkItemStatus

workItemStatus

wisReportedProgress

wisProgress

wisSourceOperationResponse

wisStopPosition

wisDynamicSourceSplit

wisCompleted

wisSourceFork

wisReportIndex

wisRequestedLeaseDuration

wisErrors

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

EnvironmentSdkPipelineOptions

data EnvironmentSdkPipelineOptions

environmentSdkPipelineOptions

espoAddtional

LeaseWorkItemRequest

data LeaseWorkItemRequest

leaseWorkItemRequest

lwirWorkItemTypes

lwirCurrentWorkerTime

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

WorkerSettings

data WorkerSettings

workerSettings

wsServicePath

wsBaseURL

wsShuffleServicePath

wsTempStoragePrefix

wsReportingEnabled

wsWorkerId

WorkItemServiceStateHarnessData

data WorkItemServiceStateHarnessData

workItemServiceStateHarnessData

wisshdAddtional

DataDiskAssignment

data DataDiskAssignment

dataDiskAssignment

ddaVMInstance

ddaDataDisks

WorkerMessageResponse

data WorkerMessageResponse

workerMessageResponse

wmrWorkerHealthReportResponse

WorkItemServiceState

data WorkItemServiceState

workItemServiceState

wissNextReportIndex

wissReportStatusInterval

wissHarnessData

wissSuggestedStopPoint

wissSuggestedStopPosition

wissLeaseExpireTime

wissSplitRequest

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

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

SendWorkerMessagesResponse

data SendWorkerMessagesResponse

sendWorkerMessagesResponse

swmrWorkerMessageResponses

StreamingSideInputLocation

data StreamingSideInputLocation

streamingSideInputLocation

ssilTag

ssilStateFamily

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

jEnvironment

jClientRequestId

jCurrentState

jReplacedByJobId

jTempFiles

jSteps

jExecutionInfo

jName

jTransformNameMApping

jId

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

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

StreamingComputationRanges

data StreamingComputationRanges

streamingComputationRanges

scrRangeAssignments

scrComputationId

ListJobsResponse

data ListJobsResponse

listJobsResponse

ljrNextPageToken

ljrJobs

Source

data Source

source

souDoesNotNeedSplitting

souBaseSpecs

souCodec

souSpec

souMetadata

ApproximateProgress

data ApproximateProgress

approximateProgress

apRemainingTime

apPercentComplete

apPosition

WorkerMessage

data WorkerMessage

workerMessage

wmWorkerHealthReport

wmTime

wmWorkerMessageCode

wmLabels

KeyRangeLocation

data KeyRangeLocation

keyRangeLocation

krlPersistentDirectory

krlDataDisk

krlStart

krlDeliveryEndpoint

krlEnd

MultiOutputInfo

data MultiOutputInfo

multiOutputInfo

moiTag

PartialGroupByKeyInstruction

data PartialGroupByKeyInstruction

partialGroupByKeyInstruction

pgbkiValueCombiningFn

pgbkiSideInputs

pgbkiInput

pgbkiInputElementCodec

ParDoInstruction

data ParDoInstruction

parDoInstruction

pdiNumOutputs

pdiMultiOutputInfos

pdiSideInputs

pdiInput

pdiUserFn

CustomSourceLocation

data CustomSourceLocation

customSourceLocation

cslStateful

SourceBaseSpecsItem

data SourceBaseSpecsItem

sourceBaseSpecsItem

sbsiAddtional

ParallelInstruction

data ParallelInstruction

parallelInstruction

piRead

piWrite

piParDo

piPartialGroupByKey

piOutputs

piName

piSystemName

piFlatten

SideInputInfoKind

data SideInputInfoKind

sideInputInfoKind

siikAddtional

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

plSubscription

InstructionInput

data InstructionInput

instructionInput

iiProducerInstructionIndex

iiOutputNum

SeqMapTask

data SeqMapTask

seqMapTask

smtInputs

smtName

smtOutputInfos

smtSystemName

smtStageName

smtUserFn

SourceOperationRequest

data SourceOperationRequest

sourceOperationRequest

sSplit

sGetMetadata

LeaseWorkItemResponse

data LeaseWorkItemResponse

leaseWorkItemResponse

lwirWorkItems

Position

data Position

position

pByteOffSet

pConcatPosition

pRecordIndex

pShufflePosition

pKey

pEnd