

def _get_side_input_encoding(self, input_encoding):
    "Returns an encoding for the output of a view transform.\n\n    Args:\n      input_encoding: encoding of current transform's input. Side inputs need\n        this because the service will check that input and output types match.\n\n    Returns:\n      An encoding that matches the output and input encoding. This is essential\n      for the View transforms introduced to produce side inputs to a ParDo.\n    "
    return {
        '@type': self['@type'],
        'component_encodings': [input_encoding],
    }

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineRunner._get_side_input_encoding/VarMisuse@19/171 `input_encoding`->`self`