def __init__(self, min_bundle_size=0, desired_bundle_size=DEFAULT_DESIRED_BUNDLE_SIZE, compression_type=CompressionTypes.AUTO, strip_trailing_newlines=True, coder=coders.StrUtf8Coder(), skip_header_lines=0, **kwargs):
    "Initialize the ``ReadAllFromText`` transform.\n\n    Args:\n      min_bundle_size: Minimum size of bundles that should be generated when\n        splitting this source into bundles. See ``FileBasedSource`` for more\n        details.\n      desired_bundle_size: Desired size of bundles that should be generated when\n        splitting this source into bundles. See ``FileBasedSource`` for more\n        details.\n      compression_type: Used to handle compressed input files. Typical value\n        is ``CompressionTypes.AUTO``, in which case the underlying file_path's\n        extension will be used to detect the compression.\n      strip_trailing_newlines: Indicates whether this source should remove\n        the newline char in each line it reads before decoding that line.\n      validate: flag to verify that the files exist during the pipeline\n        creation time.\n      skip_header_lines: Number of header lines to skip. Same number is skipped\n        from each source file. Must be 0 or higher. Large number of skipped\n        lines might impact performance.\n      coder: Coder used to decode each line.\n    "
    super(ReadAllFromText, self).__init__(**kwargs)
    source_from_file = partial(_create_text_source, min_bundle_size=min_bundle_size, compression_type=compression_type, strip_trailing_newlines=strip_trailing_newlines, coder=coder, skip_header_lines=skip_header_lines)
    self._desired_bundle_size = desired_bundle_size
    self._min_bundle_size = min_bundle_size
    self._compression_type = compression_type
    self._read_all_files = ReadAllFiles(True, compression_type, desired_bundle_size, min_bundle_size, source_from_file)
Initialize the ``ReadAllFromText`` transform.

Args:
  min_bundle_size: Minimum size of bundles that should be generated when
    splitting this source into bundles. See ``FileBasedSource`` for more
    details.
  desired_bundle_size: Desired size of bundles that should be generated when
    splitting this source into bundles. See ``FileBasedSource`` for more
    details.
  compression_type: Used to handle compressed input files. Typical value
    is ``CompressionTypes.AUTO``, in which case the underlying file_path's
    extension will be used to detect the compression.
  strip_trailing_newlines: Indicates whether this source should remove
    the newline char in each line it reads before decoding that line.
  validate: flag to verify that the files exist during the pipeline
    creation time.
  skip_header_lines: Number of header lines to skip. Same number is skipped
    from each source file. Must be 0 or higher. Large number of skipped
    lines might impact performance.
  coder: Coder used to decode each line.
def __init__(self, min_bundle_size=0, desired_bundle_size=DEFAULT_DESIRED_BUNDLE_SIZE, compression_type=CompressionTypes.AUTO, strip_trailing_newlines=True, coder=coders.StrUtf8Coder(), skip_header_lines=0, **kwargs):
    "Initialize the ``ReadAllFromText`` transform.\n\n    Args:\n      min_bundle_size: Minimum size of bundles that should be generated when\n        splitting this source into bundles. See ``FileBasedSource`` for more\n        details.\n      desired_bundle_size: Desired size of bundles that should be generated when\n        splitting this source into bundles. See ``FileBasedSource`` for more\n        details.\n      compression_type: Used to handle compressed input files. Typical value\n        is ``CompressionTypes.AUTO``, in which case the underlying file_path's\n        extension will be used to detect the compression.\n      strip_trailing_newlines: Indicates whether this source should remove\n        the newline char in each line it reads before decoding that line.\n      validate: flag to verify that the files exist during the pipeline\n        creation time.\n      skip_header_lines: Number of header lines to skip. Same number is skipped\n        from each source file. Must be 0 or higher. Large number of skipped\n        lines might impact performance.\n      coder: Coder used to decode each line.\n    "
    super(ReadAllFromText, self).__init__(**kwargs)
    source_from_file = partial(_create_text_source, min_bundle_size=min_bundle_size, compression_type=compression_type, strip_trailing_newlines=strip_trailing_newlines, coder=coder, skip_header_lines=skip_header_lines)
    self._desired_bundle_size = desired_bundle_size
    self._min_bundle_size = min_bundle_size
    self._compression_type = compression_type
    self._read_all_files = ReadAllFiles(True, compression_type, desired_bundle_size, min_bundle_size, source_from_file)