cassandra

Documentation

Index

• type CassandraAdapter
  • func NewCassandraAdapter() *CassandraAdapter
  • func (c *CassandraAdapter) GetSplits(connectionId string, aq adapter.AdapterQuery) (splits []adapter.Split, err error)
  • func (c *CassandraAdapter) LoadConfiguration(config map[string]string)
  • func (c *CassandraAdapter) ReadSplit(split adapter.Split, writer io.Writer) error
• type CassandraDataSplit
  • func (cs CassandraDataSplit) GetConfiguration() map[string]string
• type Query
  • func (q *Query) GetParallelLimit() int

Types

type CassandraAdapter

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

func NewCassandraAdapter

func NewCassandraAdapter() *CassandraAdapter

func (*CassandraAdapter) GetSplits

func (c *CassandraAdapter) GetSplits(connectionId string, aq adapter.AdapterQuery) (splits []adapter.Split, err error)

func (*CassandraAdapter) LoadConfiguration

func (c *CassandraAdapter) LoadConfiguration(config map[string]string)

func (*CassandraAdapter) ReadSplit

func (c *CassandraAdapter) ReadSplit(split adapter.Split, writer io.Writer) error

type CassandraDataSplit

type CassandraDataSplit struct {
	Config                         map[string]string
	StartToken, StopToken          string
	Select, Keyspace, Table, Where string
	PartitionKeys                  []string
}

func (CassandraDataSplit) GetConfiguration

func (cs CassandraDataSplit) GetConfiguration() map[string]string

type Query

type Query struct {
	Select    string
	Keyspace  string
	Table     string
	Where     string
	Partition int
	Parallel  int
}

func (*Query) GetParallelLimit

func (q *Query) GetParallelLimit() int