def METHOD_NAME(self, pcol):
    """Fetch files based on the file pattern, read the contents from matching files
    Args:
     pcol: PCollection containing list of file patterns
    Returns:
     PCollection of type Json objects that represents data read from the files
    """
    # yapf: disable
    return (pcol
            | "Match files" >> beam.FlatMap(self._match_files).with_output_types(beamfs.FileMetadata)
            | "Read Matches" >> beam.Map(
                    lambda metadata: ReadableFile(metadata, self.compression)
                )
            | "Read Contents" >> beam.FlatMap(self._readfile)
           )
    # yapf: enable