cassandra

Documentation

Index

• Variables
• type CassandraShardInfo
  • func (s *CassandraShardInfo) ReadSplit() error
• type CassandraSource
  • func Hosts(hosts string) *CassandraSource
  • func (s *CassandraSource) From(table string) *CassandraSource
  • func (s *CassandraSource) Generate(f *flow.Flow) *flow.Dataset
  • func (s *CassandraSource) Keyspace(keyspace string) *CassandraSource
  • func (s *CassandraSource) Select(selectClause string) *CassandraSource
  • func (s *CassandraSource) Where(whereClause string) *CassandraSource

Variables

var (
	MapperReadShard = gio.RegisterMapper(readShard)
)

Types

type CassandraShardInfo

type CassandraShardInfo struct {
	Hosts                 string
	StartToken, StopToken string
	PartitionKeys         []string
	TimeoutSeconds        int

	Select   string
	Keyspace string
	Table    string
	Where    string
	Limit    int
}

func (*CassandraShardInfo) ReadSplit

func (s *CassandraShardInfo) ReadSplit() error

type CassandraSource

type CassandraSource struct {
	Concurrency      int
	ShardCount       int
	LimitInEachShard int
	TimeoutSeconds   int
	// contains filtered or unexported fields
}

func Hosts

func Hosts(hosts string) *CassandraSource

func (*CassandraSource) From

func (s *CassandraSource) From(table string) *CassandraSource

func (*CassandraSource) Generate

func (s *CassandraSource) Generate(f *flow.Flow) *flow.Dataset

Generate generates data shard info, partitions them via round robin, and reads each shard on each executor

func (*CassandraSource) Keyspace

func (s *CassandraSource) Keyspace(keyspace string) *CassandraSource

func (*CassandraSource) Select

func (s *CassandraSource) Select(selectClause string) *CassandraSource

func (*CassandraSource) Where

func (s *CassandraSource) Where(whereClause string) *CassandraSource