org.apache.beam.sdk.util.construction

Interface ParDoTranslation.ParDoLike

Enclosing class:

ParDoTranslation

public static interface ParDoTranslation.ParDoLike

These methods drive to-proto translation from Java and from rehydrated ParDos.

Method Summary

Modifier and Type	Method and Description
boolean	isRequiresStableInput()
boolean	isRequiresTimeSortedInput()
boolean	isSplittable()
boolean	isStateful()
boolean	requestsFinalization()
org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec	translateDoFn(SdkComponents newComponents)
java.lang.String	translateRestrictionCoderId(SdkComponents newComponents)
java.util.Map<java.lang.String,org.apache.beam.model.pipeline.v1.RunnerApi.SideInput>	translateSideInputs(SdkComponents components)
java.util.Map<java.lang.String,org.apache.beam.model.pipeline.v1.RunnerApi.StateSpec>	translateStateSpecs(SdkComponents components)
ParDoTranslation.ParDoLikeTimerFamilySpecs	translateTimerFamilySpecs(SdkComponents newComponents)

Method Detail

translateDoFn

org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translateDoFn(SdkComponents newComponents)

translateSideInputs

java.util.Map<java.lang.String,org.apache.beam.model.pipeline.v1.RunnerApi.SideInput> translateSideInputs(SdkComponents components)

translateStateSpecs

java.util.Map<java.lang.String,org.apache.beam.model.pipeline.v1.RunnerApi.StateSpec> translateStateSpecs(SdkComponents components)
                                                                                                   throws java.io.IOException

Throws:

java.io.IOException

translateTimerFamilySpecs

ParDoTranslation.ParDoLikeTimerFamilySpecs translateTimerFamilySpecs(SdkComponents newComponents)

isStateful

boolean isStateful()

isSplittable

boolean isSplittable()

isRequiresStableInput

boolean isRequiresStableInput()

isRequiresTimeSortedInput

boolean isRequiresTimeSortedInput()

requestsFinalization

boolean requestsFinalization()

translateRestrictionCoderId

java.lang.String translateRestrictionCoderId(SdkComponents newComponents)