mergejob

Documentation

Index

• type MergeWithDeduplicationJob
  • func NewMergeWithDeduplicationJob() *MergeWithDeduplicationJob
  • func (j *MergeWithDeduplicationJob) Do(ctx mapreduce.JobContext, in mapreduce.Reader, out []mapreduce.Writer) error

Types

type MergeWithDeduplicationJob

type MergeWithDeduplicationJob struct {
	mapreduce.Untyped
}

func NewMergeWithDeduplicationJob

func NewMergeWithDeduplicationJob() *MergeWithDeduplicationJob

func (*MergeWithDeduplicationJob) Do

func (j *MergeWithDeduplicationJob) Do(ctx mapreduce.JobContext, in mapreduce.Reader, out []mapreduce.Writer) error