def process_argspec_fn(self):
    raise NotImplementedError
Returns an argspec of the function actually consuming the data.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/transforms/ptransform.py/PTransformWithSideInputs.process_argspec_fn