tdenginereader

package

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

Details

View Source

const (
	DateTimeFormat = "2006-01-02 15:04:05"
	DefaultWhere   = "_c0 > -9223372036854775808" // Long.MIN_VALUE equivalent
)

This section is empty.

This section is empty.

type ConnectionConfig struct {
	JdbcUrls []string
	Tables   []string
	QuerySql []string
}

ConnectionConfig 连接配置

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

TDengineReaderJob TDengine读取作业

func NewTDengineReaderJob() *TDengineReaderJob

func (job *TDengineReaderJob) Destroy() error

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

func (job *TDengineReaderJob) Post() error

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

type TDengineReaderJobFactory struct{}

TDengineReaderJobFactory 实现ReaderJobFactory接口

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

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

TDengineReaderTask TDengine读取任务

func NewTDengineReaderTask() *TDengineReaderTask

func (task *TDengineReaderTask) Destroy() error

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

func (task *TDengineReaderTask) Post() error

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

type TDengineReaderTaskFactory struct{}

TDengineReaderTaskFactory 实现ReaderTaskFactory接口

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