transform

type Config struct {
	// Mapping 字段映射: 原字段名 -> 新字段名
	Mapping map[string]string `json:"mapping"`
	// Add 要添加的字段
	Add map[string]interface{} `json:"add"`
	// Remove 要删除的字段
	Remove []string `json:"remove"`

	// Extract 提取指定字段的值作为新记录（支持点号分隔的嵌套路径）
	Extract string `json:"extract"`
	// ExtractKeep 提取时保留的原始字段列表
	ExtractKeep []string `json:"extract_keep"`
	// ExtractFlatten 当提取的字段是数组时，展开为多条记录
	ExtractFlatten bool `json:"extract_flatten"`
}

type Processor struct {
	// contains filtered or unexported fields
}