Deprecated tfdv.{DecodeCSV,DecodeTFExample}.

PiperOrigin-RevId: 354351169

Author: brills

RELEASE.md

@@ -22,6 +22,10 @@
 
 ## Deprecations
 
+*   `tfdv.DecodeCSV` and `tfdv.DecodeTFExample` are deprecated. Use
+    `tfx_bsl.public.tfxio.CsvTFXIO` and `tfx_bsl.public.tfxio.TFExampleRecord`
+    instead.
+
 # Version 0.26.0
 
 ## Major Features and Improvements

tensorflow_data_validation/__init__.py

@@ -32,8 +32,10 @@
 from tensorflow_data_validation.api.validation_api import validate_instance
 from tensorflow_data_validation.api.validation_api import validate_statistics
 
-# Import coders.
+# DecodeCSV is deprecated. Please use tfx_bsl.public.tfxio.CsvTFXIO instead.
 from tensorflow_data_validation.coders.csv_decoder import DecodeCSV
+# DecodeTFExample is deprecated. Please use tfx_bsl.public.tfxio.TFExampleRecord
+# instead.
 from tensorflow_data_validation.coders.tf_example_decoder import DecodeTFExample
 
 # Import stats generators.

tensorflow_data_validation/coders/csv_decoder.py

@@ -32,7 +32,10 @@
 @beam.typehints.with_input_types(Text)
 @beam.typehints.with_output_types(pa.RecordBatch)
 class DecodeCSV(beam.PTransform):
-  """Decodes CSV records into Arrow RecordBatches."""
+  """Decodes CSV records into Arrow RecordBatches.
+
+  DEPRECATED: please use tfx_bsl.public.CsvTFXIO instead.
+  """
 
   def __init__(self,
                column_names: List[types.FeatureName],

tensorflow_data_validation/coders/tf_example_decoder.py

@@ -34,6 +34,8 @@ def DecodeTFExample(
 ) -> beam.pvalue.PCollection:  # pylint: disable=invalid-name
   """Decodes serialized TF examples into Arrow RecordBatches.
 
+  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