WatermarkEstimator DoFn parameter.
tfx.orchestration.beam.beam_dag_runner.PipelineNodeAsDoFn.WatermarkEstimatorParam(
watermark_estimator_provider: typing.Optional[WatermarkEstimatorProvider] = None
)
Methods
__eq__
__eq__(
other
)
Return self==value.
__ne__
__ne__(
other
)
Return self!=value.