Creates a dataset that applies f
to the outputs of input_dataset
.
View aliases
Compat aliases for migration
See Migration guide for more details.
tf.raw_ops.ExperimentalParallelInterleaveDataset(
input_dataset,
other_arguments,
cycle_length,
block_length,
sloppy,
buffer_output_elements,
prefetch_input_elements,
f,
output_types,
output_shapes,
name=None
)
The resulting dataset is similar to the InterleaveDataset
, with the exception
that if retrieving the next value from a dataset would cause the requester to
block, it will skip that input dataset. This dataset is especially useful
when loading data from a variable-latency datastores (e.g. HDFS, GCS), as it
allows the training step to proceed so long as some data is available.
!! WARNING !! This dataset is not deterministic!
Args | |
---|---|
input_
|
A Tensor of type variant .
|
other_
|
A list of Tensor objects.
|
cycle_
|
A Tensor of type int64 .
|
block_
|
A Tensor of type int64 .
|
sloppy
|
A Tensor of type bool .
|
buffer_
|
A Tensor of type int64 .
|
prefetch_
|
A Tensor of type int64 .
|
f
|
A function decorated with @Defun.
A function mapping elements of input_ , concatenated with
other_ , to a Dataset variant that contains elements matching
output_ and output_ .
|
output_
|
A list of tf. that has length >= 1 .
|
output_
|
A list of shapes (each a tf.TensorShape or list of ints ) that has length >= 1 .
|
name
|
A name for the operation (optional). |
Returns | |
---|---|
A Tensor of type variant .
|