def test_read_all_from_avro_many_file_patterns(self):
    file_pattern1 = self._write_pattern(5)
    file_pattern2 = self._write_pattern(2)
    file_pattern3 = self._write_pattern(3)
    with TestPipeline() as p:
        assert_that(((p | Create([file_pattern1, file_pattern2, file_pattern3])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to((self.RECORDS * 10)))
def test_read_all_from_avro_many_file_patterns(self):
    file_pattern1 = self._write_pattern(5)
    file_pattern2 = self._write_pattern(2)
    file_pattern3 = self._write_pattern(3)
    with TestPipeline() as p:
        assert_that(((p | Create([file_pattern1, file_pattern2, file_pattern3])) | avroio.ReadAllFromAvro(use_fastavro=self.use_fastavro)), equal_to((self.RECORDS * 10)))