Method CreateProcessor

input/kcl.go:251–257

CreateProcessor implements interfaces.IRecordProcessorFactory.

()

// CreateProcessor implements interfaces.IRecordProcessorFactory.
func (k *KCL) CreateProcessor() interfaces.IRecordProcessor {
	return &recordProcessor{
		inch:    k.inch,
		metrics: &k.metrics,
		nlines:  &k.nlines,
	}
}

// recordProcessor implements KCL IRecordProcessor.
type recordProcessor struct {