cassandrareader

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 29, 2025 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultPort           = 9042
	DefaultConsistency    = "LOCAL_QUORUM"
	DefaultConnectTimeout = 5 * time.Second
	DefaultSocketTimeout  = 10 * time.Second
)
View Source
const (
	KeyUsername         = "username"
	KeyPassword         = "password"
	KeyHost             = "host"
	KeyPort             = "port"
	KeyUseSSL           = "useSSL"
	KeyKeyspace         = "keyspace"
	KeyTable            = "table"
	KeyColumn           = "column"
	KeyWhere            = "where"
	KeyAllowFiltering   = "allowFiltering"
	KeyConsistencyLevel = "consistancyLevel"
	KeyMinToken         = "minToken"
	KeyMaxToken         = "maxToken"
)

Configuration keys matching Java implementation exactly

Variables

This section is empty.

Functions

This section is empty.

Types

type CassandraReaderJob

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

CassandraReaderJob Cassandra读取作业,复制Java实现行为

func NewCassandraReaderJob

func NewCassandraReaderJob() *CassandraReaderJob

func (*CassandraReaderJob) Destroy

func (job *CassandraReaderJob) Destroy() error

func (*CassandraReaderJob) Init

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

func (*CassandraReaderJob) Post

func (job *CassandraReaderJob) Post() error

func (*CassandraReaderJob) Split

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

Split 任务分割,复制Java版本的分割逻辑

type CassandraReaderJobFactory

type CassandraReaderJobFactory struct{}

CassandraReaderJobFactory 实现ReaderJobFactory接口

func (*CassandraReaderJobFactory) CreateReaderJob

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

type CassandraReaderTask

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

CassandraReaderTask Cassandra读取任务,复制Java实现

func NewCassandraReaderTask

func NewCassandraReaderTask() *CassandraReaderTask

func (*CassandraReaderTask) Destroy

func (task *CassandraReaderTask) Destroy() error

func (*CassandraReaderTask) Init

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

func (*CassandraReaderTask) Post

func (task *CassandraReaderTask) Post() error

func (*CassandraReaderTask) StartRead

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

type CassandraReaderTaskFactory

type CassandraReaderTaskFactory struct{}

CassandraReaderTaskFactory 实现ReaderTaskFactory接口

func (*CassandraReaderTaskFactory) CreateReaderTask

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL