def get_bond_length_distribution_inner(input_fname, output_fname):
    'Generate bond length distibutions.\n\n  Args:\n    input_fname: An existing TFRecord file containing Conformer protos.\n    output_fname: An output file that will be created that contains all bond\n      length distributions - all bond types, all atom types. Requires\n      post-processing to generate bond length distribution files.\n  '
    print('Reading from {input_fname} output to {output_fname}')
    options = PipelineOptions(direct_num_workers=6, direct_running_mode='multi_processing')
    with beam.Pipeline(options=options) as p:
        protos = (((((p | beam.io.tfrecordio.ReadFromTFRecord(input_fname, coder=beam.coders.ProtoCoder(dataset_pb2.Conformer().__class__))) | beam.ParDo(bond_lengths.GetBondLengthDistribution())) | beam.CombinePerKey(sum)) | beam.ParDo(BondDistToString())) | beam.io.WriteToText(output_fname))
        print(protos)
Generate bond length distibutions.

Args:
  input_fname: An existing TFRecord file containing Conformer protos.
  output_fname: An output file that will be created that contains all bond
    length distributions - all bond types, all atom types. Requires
    post-processing to generate bond length distribution files.
def get_bond_length_distribution_inner(input_fname, output_fname):
    'Generate bond length distibutions.\n\n  Args:\n    input_fname: An existing TFRecord file containing Conformer protos.\n    output_fname: An output file that will be created that contains all bond\n      length distributions - all bond types, all atom types. Requires\n      post-processing to generate bond length distribution files.\n  '
    print('Reading from {input_fname} output to {output_fname}')
    options = PipelineOptions(direct_num_workers=6, direct_running_mode='multi_processing')
    with beam.Pipeline(options=options) as p:
        protos = (((((p | beam.io.tfrecordio.ReadFromTFRecord(input_fname, coder=beam.coders.ProtoCoder(dataset_pb2.Conformer().__class__))) | beam.ParDo(bond_lengths.GetBondLengthDistribution())) | beam.CombinePerKey(sum)) | beam.ParDo(BondDistToString())) | beam.io.WriteToText(output_fname))
        print(protos)