Compare commits

..

1 Commits

Author SHA1 Message Date
coolneng e9582d0883
Parallelize dataset transformations 2021-06-24 19:54:19 +02:00
1 changed files with 1 additions and 1 deletions

View File

@ -105,8 +105,8 @@ def read_dataset(filepath) -> TFRecordDataset:
Read TFRecords files and generate a dataset Read TFRecords files and generate a dataset
""" """
data_input = TFRecordDataset(filenames=filepath) data_input = TFRecordDataset(filenames=filepath)
shuffled_dataset = dataset.shuffle(buffer_size=10000, seed=42)
dataset = data_input.map(map_func=process_input, num_parallel_calls=AUTOTUNE) dataset = data_input.map(map_func=process_input, num_parallel_calls=AUTOTUNE)
shuffled_dataset = dataset.shuffle(buffer_size=10000, seed=42)
batched_dataset = shuffled_dataset.batch(batch_size=BATCH_SIZE).repeat(count=EPOCHS) batched_dataset = shuffled_dataset.batch(batch_size=BATCH_SIZE).repeat(count=EPOCHS)
return batched_dataset return batched_dataset