写一个自定义的Mapper()函数来对输入的数据进行处理

自定义的Mapper()函数可以根据具体的需求对输入的数据进行处理，例如进行数据清洗、转换、筛选等操作。下面是一个简单的例子来说明如何自定义一个Mapper()函数，并使用它对输入的数据进行处理。

def custom_mapper(data):
    result = []
    for line in data:
        # 对每一行数据进行处理
        processed_line = line.strip().split(',')  # 去除空格，并按逗号分割数据
        if len(processed_line) >= 3:  # 筛选长度大于等于3的数据行
            result.append(processed_line)  # 将处理结果加入到结果列表中
    return result

上述自定义的Mapper()函数接受一个数据列表作为输入参数，然后遍历数据列表中的每一行数据，对每一行数据进行处理。在本例中，我们对每一行数据进行了以下处理：

1. 使用strip()函数去除每行数据开头和结尾的空格。

2. 使用split(',')函数将每一行数据按逗号分割成一个列表。

3. 使用if语句筛选出长度大于等于3的数据行。

4. 将处理后的结果加入到结果列表中。

使用自定义的Mapper()函数可以很方便地对输入的数据进行处理，下面是一个使用该函数的例子：

input_data = ["1, John, Male", "2, Lisa, Female", "3, David, Male", "4, Sarah, Female"]

result = custom_mapper(input_data)
print(result)

运行结果：

[['1', 'John', 'Male'], ['2', 'Lisa', 'Female'], ['3', 'David', 'Male'], ['4', 'Sarah', 'Female']]

上述例子中，我们将一个包含四个元素的数据列表作为输入参数传递给自定义的Mapper()函数。函数返回一个结果列表，其中每个元素都是经过处理后的数据行。最后，我们将结果打印出来。

通过自定义Mapper()函数，我们可以根据需求对输入的数据进行灵活的处理，实现不同的数据转换和筛选效果。