data_juicer.ops.base_op module

data_juicer.ops.base_op.convert_list_dict_to_dict_list(samples)

data_juicer.ops.base_op.convert_dict_list_to_list_dict(samples)

data_juicer.ops.base_op.convert_arrow_to_python(method)

data_juicer.ops.base_op.catch_map_batches_exception(method, skip_op_error=False, op_name=None)

For batched-map sample-level fault tolerance.

data_juicer.ops.base_op.catch_map_single_exception(method, return_sample=True, skip_op_error=False, op_name=None)

For single-map sample-level fault tolerance. The input sample is expected batch_size = 1.

class data_juicer.ops.base_op.OP(*args, **kwargs)

基类：object

__init__(*args, **kwargs)

Base class of operators.

参数:

• text_key -- the key name of field that stores sample texts to be processed.

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

• index_key -- index the samples before process if not None

• batch_size -- the batch size for processing

• work_dir -- the working directory for this operator

is_batched_op()

process(*args, **kwargs)

use_cuda()

runtime_np()

remove_extra_parameters(param_dict, keys=None)

at the beginning of the init of the mapper op, call self.remove_extra_parameters(locals()) to get the init parameter dict of the op for convenience

add_parameters(init_parameter_dict, **extra_param_dict)

add parameters for each sample, need to keep extra_param_dict and init_parameter_dict unchanged.

run(dataset)

empty_history()

class data_juicer.ops.base_op.Mapper(*args, **kwargs)

基类：OP

__init__(*args, **kwargs)

Base class that conducts data editing.

参数:

• text_key -- the key name of field that stores sample texts to be processed.

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

process_batched(samples, *args, **kwargs)

process_single(sample)

For sample level, sample --> sample

参数:

sample -- sample to process

返回:

processed sample

run(dataset, *, exporter=None, tracer=None)

class data_juicer.ops.base_op.Filter(*args, **kwargs)

基类：OP

__init__(*args, **kwargs)

Base class that removes specific info.

参数:

• text_key -- the key name of field that stores sample texts to be processed

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

• min_closed_interval -- whether the min_val of the specified filter range is a closed interval. It's True by default.

• max_closed_interval -- whether the max_val of the specified filter range is a closed interval. It's True by default.

• reversed_range -- whether to reverse the target range [min_val, max_val] to (-∞, min_val) or (max_val, +∞). It's False by default.

get_keep_boolean(val, min_val=None, max_val=None)

compute_stats_batched(samples, *args, **kwargs)

process_batched(samples)

compute_stats_single(sample, context=False)

Compute stats for the sample which is used as a metric to decide whether to filter this sample.

参数:

• sample -- input sample.

• context -- whether to store context information of intermediate vars in the sample temporarily.

返回:

sample with computed stats

process_single(sample)

For sample level, sample --> Boolean.

参数:

sample -- sample to decide whether to filter

返回:

true for keeping and false for filtering

run(dataset, *, exporter=None, tracer=None, reduce=True)

class data_juicer.ops.base_op.Deduplicator(*args, **kwargs)

基类：OP

__init__(*args, **kwargs)

Base class that conducts deduplication.

参数:

• text_key -- the key name of field that stores sample texts to be processed

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

compute_hash(sample)

Compute hash values for the sample.

参数:

sample -- input sample

返回:

sample with computed hash value.

process(dataset, show_num=0)

For doc-level, dataset --> dataset.

参数:

• dataset -- input dataset

• show_num -- number of traced samples used when tracer is open.

返回:

deduplicated dataset and the sampled duplicate pairs.

run(dataset, *, exporter=None, tracer=None, reduce=True)

class data_juicer.ops.base_op.Selector(*args, **kwargs)

基类：OP

__init__(*args, **kwargs)

Base class that conducts selection in dataset-level.

参数:

• text_key -- the key name of field that stores sample texts to be processed

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

process(dataset)

Dataset --> dataset.

参数:

dataset -- input dataset

返回:

selected dataset.

run(dataset, *, exporter=None, tracer=None)

class data_juicer.ops.base_op.Grouper(*args, **kwargs)

基类：OP

__init__(*args, **kwargs)

Base class that group samples.

参数:

• text_key -- the key name of field that stores sample texts to be processed

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

process(dataset)

Dataset --> dataset.

参数:

dataset -- input dataset

返回:

dataset of batched samples.

run(dataset, *, exporter=None, tracer=None)

class data_juicer.ops.base_op.Aggregator(*args, **kwargs)

基类：OP

__init__(*args, **kwargs)

Base class that group samples.

参数:

• text_key -- the key name of field that stores sample texts to be processed

• image_key -- the key name of field that stores sample image list to be processed

• audio_key -- the key name of field that stores sample audio list to be processed

• video_key -- the key name of field that stores sample video list to be processed

• image_bytes_key -- the key name of field that stores sample image bytes list to be processed

• query_key -- the key name of field that stores sample queries

• response_key -- the key name of field that stores responses

• history_key -- the key name of field that stores history of queries and responses

process_single(sample)

For sample level, batched sample --> sample, the input must be the output of some Grouper OP.

参数:

sample -- batched sample to aggregate

返回:

aggregated sample

run(dataset, *, exporter=None, tracer=None)