fn build_impl()

in src/ops/ops_impl.rs [103707:103769]

• 63 lines of code
• 18 McCabe index (conditional complexity)

    fn build_impl(
        &self,
        input_dataset: crate::Output,
        path: crate::Output,
        scope: &mut crate::Scope,
    ) -> crate::Result<crate::Operation> {
        scope.new_operation("SnapshotDataset", |nd| {
            nd.add_input(input_dataset);
            nd.add_input(path);
            for op in &self.control_inputs {
                nd.add_control_input(op);
            }
            if let ::std::option::Option::Some(value) = &self.output_types {
                nd.set_attr_type_list("output_types", value)?;
            }
            if let ::std::option::Option::Some(value) = &self.output_shapes {
                nd.set_attr_shape_list("output_shapes", value)?;
            }
            if let ::std::option::Option::Some(value) = &self.compression {
                nd.set_attr_string("compression", value)?;
            }
            if let ::std::option::Option::Some(value) = &self.reader_path_prefix {
                nd.set_attr_string("reader_path_prefix", value)?;
            }
            if let ::std::option::Option::Some(value) = &self.writer_path_prefix {
                nd.set_attr_string("writer_path_prefix", value)?;
            }
            if let ::std::option::Option::Some(value) = &self.shard_size_bytes {
                nd.set_attr_int("shard_size_bytes", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.pending_snapshot_expiry_seconds {
                nd.set_attr_int("pending_snapshot_expiry_seconds", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.num_reader_threads {
                nd.set_attr_int("num_reader_threads", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.reader_buffer_size {
                nd.set_attr_int("reader_buffer_size", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.num_writer_threads {
                nd.set_attr_int("num_writer_threads", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.writer_buffer_size {
                nd.set_attr_int("writer_buffer_size", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.shuffle_on_read {
                nd.set_attr_bool("shuffle_on_read", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.seed {
                nd.set_attr_int("seed", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.seed2 {
                nd.set_attr_int("seed2", *value)?;
            }
            if let ::std::option::Option::Some(value) = &self.mode {
                nd.set_attr_string("mode", value)?;
            }
            if let ::std::option::Option::Some(value) = &self.snapshot_name {
                nd.set_attr_string("snapshot_name", value)?;
            }
            ::std::result::Result::Ok(())
        })
    }