clickhousereader

package

v1.4.0 Latest Latest Go to latest Published: Sep 29, 2025 License: MIT Imports: 11 Imported by: 0

Details

View Source

const (
	DefaultFetchSize = 1024
)

This section is empty.

This section is empty.

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

ClickHouseReaderJob ClickHouse读取作业

func NewClickHouseReaderJob() *ClickHouseReaderJob

func (job *ClickHouseReaderJob) Destroy() error

func (job *ClickHouseReaderJob) Init(config config.Configuration) error

func (job *ClickHouseReaderJob) Post() error

func (job *ClickHouseReaderJob) Prepare() error

func (job *ClickHouseReaderJob) Split(adviceNumber int) ([]config.Configuration, error)

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

ClickHouseReaderTask ClickHouse读取任务

func NewClickHouseReaderTask() *ClickHouseReaderTask

func (task *ClickHouseReaderTask) Destroy() error

func (task *ClickHouseReaderTask) Init(config config.Configuration) error

func (task *ClickHouseReaderTask) Post() error

func (task *ClickHouseReaderTask) Prepare() error

func (task *ClickHouseReaderTask) StartRead(recordSender plugin.RecordSender) error

type UclickhouseReaderJobFactory struct{}

UclickhouseReaderJobFactory 实现ReaderJobFactory接口

func (f *UclickhouseReaderJobFactory) CreateReaderJob() plugin.ReaderJob

type UclickhouseReaderTaskFactory struct{}

UclickhouseReaderTaskFactory 实现ReaderTaskFactory接口

func (f *UclickhouseReaderTaskFactory) CreateReaderTask() plugin.ReaderTask