def _get_coder(self, typehint, window_value=True):
    if window_value:
      coder = coders.registry.get_windowed_coder(typehint)
    else:
      coder = coders.registry.get_coder(typehint)
    return coder
Returns a coder based on a typehint onject.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py/DataflowPipelineRunner._get_coder