Home
last modified time | relevance | path

Searched refs:BatchOp (Results 1 – 8 of 8) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Dbatch_op.cc31 BatchOp::Builder::Builder(int32_t batch_size) : builder_drop_(false), builder_pad_(false), builder_… in Builder()
38 Status BatchOp::Builder::Build(std::shared_ptr<BatchOp> *ptr) { in Build()
41 …*ptr = std::make_shared<BatchOp>(builder_batch_size_, builder_drop_, builder_pad_, builder_op_conn… in Build()
45 …*ptr = std::make_shared<BatchOp>(builder_batch_size_, builder_drop_, builder_pad_, builder_op_conn… in Build()
52 BatchOp::BatchOp(int32_t batch_size, bool drop, bool pad, int32_t op_queue_size, int32_t num_worker… in BatchOp() function in mindspore::dataset::BatchOp
77 BatchOp::BatchOp(int32_t batch_size, bool drop, bool pad, int32_t op_queue_size, int32_t num_worker… in BatchOp() function in mindspore::dataset::BatchOp
96 Status BatchOp::operator()() { in operator ()()
155 void BatchOp::Print(std::ostream &out, bool show_all) const { in Print()
169 Status BatchOp::BatchRows(const std::unique_ptr<TensorQTable> *src, TensorRow *dest, dsize_t batch_… in BatchRows()
229 Status BatchOp::WorkerEntry(int32_t workerId) { in WorkerEntry()
[all …]
Dbatch_op.h40 class BatchOp : public ParallelOp {
115 Status Build(std::shared_ptr<BatchOp> *);
153 BatchOp(int32_t batch_size, bool drop, bool pad, int32_t op_queue_size, int32_t num_workers,
157 BatchOp(int32_t batch_size, bool drop, bool pad, int32_t op_queue_size, int32_t num_workers,
162 ~BatchOp() {} in ~BatchOp()
182 friend std::ostream &operator<<(std::ostream &out, const BatchOp &bo) {
Dbucket_batch_by_length_op.cc155 RETURN_IF_NOT_OK(BatchOp::PadColumns(bucket, pad_info_copy, column_name_id_map_)); in PadAndBatchBucket()
158 RETURN_IF_NOT_OK(BatchOp::BatchRows(bucket, &batched_bucket, batch_size)); in PadAndBatchBucket()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/api/python/bindings/dataset/engine/datasetops/
Dbindings.cc24 (void)py::class_<BatchOp::CBatchInfo>(*m, "CBatchInfo") in __anonfdf8d3410102()
26 .def("get_epoch_num", &BatchOp::CBatchInfo::get_epoch_num) in __anonfdf8d3410102()
27 .def("get_batch_num", &BatchOp::CBatchInfo::get_batch_num) in __anonfdf8d3410102()
29 [](const BatchOp::CBatchInfo &p) { // __getstate__ in __anonfdf8d3410102()
36BatchOp::CBatchInfo p(t[0].cast<int64_t>(), t[1].cast<int64_t>(), t[2].cast<int64_t>()); in __anonfdf8d3410102()
/third_party/mindspore/tests/ut/cpp/dataset/common/
Dcommon.cc88 std::shared_ptr<mindspore::dataset::BatchOp> DatasetOpTesting::Batch(int32_t batch_size, bool drop, in Batch()
107 std::shared_ptr<mindspore::dataset::BatchOp> op; in Batch()
108 …rc = mindspore::dataset::BatchOp::Builder(batch_size).SetDrop(drop).SetPaddingMap(pad_map).Build(&… in Batch()
Dcommon.h103 std::shared_ptr<mindspore::dataset::BatchOp> Batch(int32_t batch_size = 1, bool drop = false,
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/ir/datasetops/
Dbatch_node.cc105 …auto op = std::make_shared<BatchOp>(batch_size_, drop_remainder_, pad_, connector_que_size_, num_w… in Build()
111 …node_ops->push_back(std::make_shared<BatchOp>(batch_size_, drop_remainder_, pad_, connector_que_si… in Build()
/third_party/mindspore/tests/ut/cpp/dataset/
Dbatch_op_test.cc52 const std::shared_ptr<de::BatchOp> &op = Batch(12); in TEST_F()
314 std::shared_ptr<BatchOp> op = Batch(batch_size, drop, m); in TEST_F()