Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DorisReaderJob ¶
type DorisReaderJob struct {
// contains filtered or unexported fields
}
DorisReaderJob Doris读取作业
func NewDorisReaderJob ¶
func NewDorisReaderJob() *DorisReaderJob
func (*DorisReaderJob) Destroy ¶
func (job *DorisReaderJob) Destroy() error
func (*DorisReaderJob) Init ¶
func (job *DorisReaderJob) Init(config config.Configuration) error
func (*DorisReaderJob) Post ¶
func (job *DorisReaderJob) Post() error
func (*DorisReaderJob) Prepare ¶
func (job *DorisReaderJob) Prepare() error
func (*DorisReaderJob) Split ¶
func (job *DorisReaderJob) Split(adviceNumber int) ([]config.Configuration, error)
type DorisReaderTask ¶
type DorisReaderTask struct {
// contains filtered or unexported fields
}
DorisReaderTask Doris读取任务
func NewDorisReaderTask ¶
func NewDorisReaderTask() *DorisReaderTask
func (*DorisReaderTask) Destroy ¶
func (task *DorisReaderTask) Destroy() error
func (*DorisReaderTask) Init ¶
func (task *DorisReaderTask) Init(config config.Configuration) error
func (*DorisReaderTask) Post ¶
func (task *DorisReaderTask) Post() error
func (*DorisReaderTask) Prepare ¶
func (task *DorisReaderTask) Prepare() error
func (*DorisReaderTask) StartRead ¶
func (task *DorisReaderTask) StartRead(recordSender plugin.RecordSender) error
type UdorisReaderJobFactory ¶
type UdorisReaderJobFactory struct{}
UdorisReaderJobFactory 实现ReaderJobFactory接口
func (*UdorisReaderJobFactory) CreateReaderJob ¶
func (f *UdorisReaderJobFactory) CreateReaderJob() plugin.ReaderJob
type UdorisReaderTaskFactory ¶
type UdorisReaderTaskFactory struct{}
UdorisReaderTaskFactory 实现ReaderTaskFactory接口
func (*UdorisReaderTaskFactory) CreateReaderTask ¶
func (f *UdorisReaderTaskFactory) CreateReaderTask() plugin.ReaderTask
Source Files
Click to show internal directories.
Click to hide internal directories.