据我所知，调用context.write需要一定数量的步骤
在驱动程序中，我们必须指定输出格式。现在让我们看看如果我们想写入一个文件会发生什么
对于写入文本文件，我们指定如下内容

job.setOutputFormatClass(TextOutputFormat.class);

现在，如果我们看到textoutputformat类的实现，它扩展了fileoutputformat（抽象类），fileoutputformat实现了outputformat接口，outputformat接口提供了两种方法

1) getRecordWriter
2) checkOutputSpecs

现在，outputformatclass只会告诉您要写什么样的记录，以及记录编写器是如何给出的，对于记录编写器来说，它只是 Object Key, Object Value 其中的值可以是单个的，也可以是一个列表，在记录编写器的实现中，我们指定了实际的逻辑，比如应该如何编写这个记录。
现在回到最初的问题，在我的例子中，记录应该如何写入数据库
我创建了一个自定义输出格式

public class AerospikeOutputFormat extends OutputFormat {
    //Return a new instance of record writer
    @Override
    public RecordWriter getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException {
        return new AerospikeRecordWriter(context.getConfiguration(), new Progressable() {
        @Override
        public void progress() {

        }
    });
    }

}

现在我们必须定义一个定制的记录编写器，它将获得一个键和一个值，并将数据写入数据库

public class RSRVRecordWriter<KK,VV> extends RecordWriter<KK, VV> {

    @Override
    public void write(KK key, VV value) throws IOException {
        //Now here we can have an instance of aerospikeclient from a singleton class and then we could do client.put()

    }

以上代码只是一个片段，必须采取适当的设计策略。
附言：aerospike已经提供了一个录音机，可以扩展到这个链接，以满足您的需要