Returns a factory function that creates Iterator[pa.RecordBatch].
tfx.components.util.tfxio_utils.get_record_batch_factory_from_artifact(
examples: List[tfx.types.Artifact
],
telemetry_descriptors: List[Text]
) -> Callable[[List[Text], dataset_options.RecordBatchesOptions, Optional[
schema_pb2.Schema]], Iterator[pa.RecordBatch]]
Args |
examples
|
The Examples artifacts that the TFXIO from which the Dataset is
created from is intended to access.
|
telemetry_descriptors
|
A set of descriptors that identify the component that
is instantiating the TFXIO. These will be used to construct the namespace
to contain metrics for profiling and are therefore expected to be
identifiers of the component itself and not individual instances of source
use.
|