假设我们有这样的工作：

class MRjob(JobTask):
  def output(self):
    return ...

  def requires(self):
    return ...

  def mapper(self, line):
    # some line process
    yield key, (...information, stored in hashable type...)

  def reducer(self,key,values):
    # some reduce logic... for example this
    unique = set(values)
    for elem in unique:
      yield key, elem[0], elem[1]

在output方法中，我应该如何将数据插入现有的表分区（表也是以orc格式存储的）？我想跳过将数据转换成orc的过程，所以我试着

return HivePartitionTarget(self.insert_table, database=self.database_name, partition=partition)

但这不管用。我还发现luigi试图将输出传递给某个文件。使用hivepartitiontarget时，luigi返回错误，如“object has no attribute write”，因此我的假设是hivepartitiontarget不包含write方法。因此，我认为我做错了什么，应该使用另一种方法，但没有找到一个单一的例子