Documentation
¶
Index ¶
- Variables
- type CassandraShardInfo
- type 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
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
Source Files
Click to show internal directories.
Click to hide internal directories.