package esstream

import "github.com/pingcap/tep/pkg/utils/es/query"

type ESToCSV interface {
	Header() []string

	//maybe we can use the write interface as the func parameter
	ToCSV(r *query.QueryResponse) [][]string
}