

def Write(self, line):
    line._file.write(self.sink.coder.encode(line))
    if self.sink.append_trailing_newlines:
        self._file.write('\n')

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/io/fileio.py TextFileWriter.Write/VarMisuse@12/13 `self`->`line`