tf.data.experimental.parallel_interleave
| Просмотреть исходный код на GitHub |
Параллельная версия преобразования Dataset.interleave(). (устаревшее)
tf.data.experimental.parallel_interleave(
map_func, cycle_length, block_length=1, sloppy=False,
buffer_output_elements=None, prefetch_input_elements=None
)
parallel_interleave() отображает map_func по своему входу, чтобы создать вложенные наборы данных, и выводит их элементы, переплетённые между собой. В отличие от tf.data.Dataset.interleave, она получает элементы из cycle_length вложенных наборов данных параллельно, что повышает производительность, особенно при наличии задерживающихся элементов. Кроме того, аргумент sloppy может использоваться для повышения производительности, ослабляя требование о том, что выходные данные должны генерироваться в детерминированном порядке, и позволяя реализации пропускать вложенные наборы данных, элементы которых не доступны при запросе.
Пример использования:
# Preprocess 4 files concurrently.
filenames = tf.data.Dataset.list_files("/path/to/data/train*.tfrecords")
dataset = filenames.apply(
tf.data.experimental.parallel_interleave(
lambda filename: tf.data.TFRecordDataset(filename),
cycle_length=4))
| Аргументы | |
|---|---|
map_func | Функция, отображающая вложенную структуру тензоров на Dataset. |
cycle_length | Количество входных Dataset для параллельного переплетения. |
block_length | Количество последовательных элементов, которые нужно извлечь из входного Dataset перед переходом к следующему входному Dataset. |
sloppy | Если ложь, элементы генерируются в детерминированном порядке. В противном случае, для ускорения, реализация разрешается генерировать элементы в недетерминированном порядке. |
buffer_output_elements | Количество элементов, которое каждый итератор, подлежащий переплетению, должен буферизовать (аналогично преобразованию .prefetch() для каждого переплетённого итератора). |
prefetch_input_elements | Количество входных элементов, которые преобразуются в итераторы до их использования для переплетения. |
| Возвращаемое значение | |
|---|---|
Функция преобразования Dataset, которая может быть передана в tf.data.Dataset.apply. |
© 2020 The TensorFlow Authors. All rights reserved.
Licensed under the Creative Commons Attribution License 3.0.
Code samples licensed under the Apache 2.0 License.
https://www.tensorflow.org/versions/r1.15/api_docs/python/tf/data/experimental/parallel_interleave