def __init__(self, file_pattern, min_bundle_size, compression_type, strip_trailing_newlines, coder, buffer_size=DEFAULT_READ_BUFFER_SIZE, validate=True, skip_header_lines=0, header_processor_fns=(None, None)):
    'Initialize a _TextSource\n\n    Args:\n      header_processor_fns (tuple): a tuple of a `header_matcher` function\n        and a `header_processor` function. The `header_matcher` should\n        return `True` for all lines at the start of the file that are part\n        of the file header and `False` otherwise. These header lines will\n        not be yielded when reading records and instead passed into\n        `header_processor` to be handled. If `skip_header_lines` and a\n        `header_matcher` are both provided, the value of `skip_header_lines`\n        lines will be skipped and the header will be processed from\n        there.\n    Raises:\n      ValueError: if skip_lines is negative.\n\n    Please refer to documentation in class `ReadFromText` for the rest\n    of the arguments.\n    '
    super(_TextSource, self).__init__(file_pattern, min_bundle_size, compression_type=compression_type, validate=validate)
    self._strip_trailing_newlines = strip_trailing_newlines
    self._compression_type = compression_type
    self._coder = coder
    self._buffer_size = buffer_size
    if (skip_header_lines < 0):
        raise ValueError(('Cannot skip negative number of header lines: %d' % skip_header_lines))
    elif (skip_header_lines > 10):
        _LOGGER.warning('Skipping %d header lines. Skipping large number of header lines might significantly slow down processing.')
    self._skip_header_lines = skip_header_lines
    (self._header_matcher, self._header_processor) = header_processor_fns
Initialize a _TextSource

Args:
  header_processor_fns (tuple): a tuple of a `header_matcher` function
    and a `header_processor` function. The `header_matcher` should
    return `True` for all lines at the start of the file that are part
    of the file header and `False` otherwise. These header lines will
    not be yielded when reading records and instead passed into
    `header_processor` to be handled. If `skip_header_lines` and a
    `header_matcher` are both provided, the value of `skip_header_lines`
    lines will be skipped and the header will be processed from
    there.
Raises:
  ValueError: if skip_lines is negative.

Please refer to documentation in class `ReadFromText` for the rest
of the arguments.
def __init__(self, file_pattern, min_bundle_size, compression_type, strip_trailing_newlines, coder, buffer_size=DEFAULT_READ_BUFFER_SIZE, validate=True, skip_header_lines=0, header_processor_fns=(None, None)):
    'Initialize a _TextSource\n\n    Args:\n      header_processor_fns (tuple): a tuple of a `header_matcher` function\n        and a `header_processor` function. The `header_matcher` should\n        return `True` for all lines at the start of the file that are part\n        of the file header and `False` otherwise. These header lines will\n        not be yielded when reading records and instead passed into\n        `header_processor` to be handled. If `skip_header_lines` and a\n        `header_matcher` are both provided, the value of `skip_header_lines`\n        lines will be skipped and the header will be processed from\n        there.\n    Raises:\n      ValueError: if skip_lines is negative.\n\n    Please refer to documentation in class `ReadFromText` for the rest\n    of the arguments.\n    '
    super(_TextSource, self).__init__(file_pattern, min_bundle_size, compression_type=compression_type, validate=validate)
    self._strip_trailing_newlines = strip_trailing_newlines
    self._compression_type = compression_type
    self._coder = coder
    self._buffer_size = buffer_size
    if (skip_header_lines < 0):
        raise ValueError(('Cannot skip negative number of header lines: %d' % skip_header_lines))
    elif (skip_header_lines > 10):
        _LOGGER.warning('Skipping %d header lines. Skipping large number of header lines might significantly slow down processing.')
    self._skip_header_lines = skip_header_lines
    (self._header_matcher, self._header_processor) = header_processor_fns