def init_ops(self):
self.input_ops = []
for thread_num in range(self.n_threads):
op = {}
for attr_num in range(self.n_attrs):
fq = self.file_queues[thread_num][attr_num]
args = self.read_args[attr_num]
kwargs = self.read_kwargs[attr_num]
_op = self.get_input_op(fq, *args, **kwargs)
if self.trans_dicts and self.trans_dicts[attr_num]:
td = self.trans_dicts[attr_num]
for k in td:
if k in _op:
_op[td[k]] = _op.pop(k)
op.update(_op)
self.input_ops.append(op)
self.apply_postprocessing()
return self.input_ops
评论列表
文章目录