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
Click to show internal directories.
Click to hide internal directories.