cassandra

package
Version: v0.0.0-...-404dc1e Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2017 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MapperReadShard = gio.RegisterMapper(readShard)
)

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL