gaussdbreader

package

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

Details

View Source

const (
	DefaultFetchSize = 1000 // 匹配Java版本的DEFAULT_FETCH_SIZE
)

This section is empty.

This section is empty.

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

GaussDBReaderJob GaussDB读取作业

func NewGaussDBReaderJob() *GaussDBReaderJob

func (job *GaussDBReaderJob) Destroy() error

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

func (job *GaussDBReaderJob) Post() error

func (job *GaussDBReaderJob) Prepare() error

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

type GaussDBReaderJobFactory struct{}

GaussDBReaderJobFactory 实现ReaderJobFactory接口

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

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

GaussDBReaderTask GaussDB读取任务

func NewGaussDBReaderTask() *GaussDBReaderTask

func (task *GaussDBReaderTask) Destroy() error

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

func (task *GaussDBReaderTask) Post() error

func (task *GaussDBReaderTask) Prepare() error

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

type GaussDBReaderTaskFactory struct{}

GaussDBReaderTaskFactory 实现ReaderTaskFactory接口

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