![]() |
Decodes serialized TF examples into Arrow RecordBatches.
tfdv.DecodeTFExample(
examples: beam.pvalue.PCollection,
desired_batch_size: int = constants.DEFAULT_DESIRED_INPUT_BATCH_SIZE
) -> beam.pvalue.PCollection
Args | |
---|---|
examples
|
A PCollection of strings representing serialized TF examples. |
desired_batch_size
|
Batch size. The output Arrow RecordBatches will have as
many rows as the desired_batch_size .
|
Returns | |
---|---|
A PCollection of Arrow RecordBatches. |