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
DEPRECATED: please use tfx_bsl.public.TFExampleRecord instead.
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.
|