cassandra

package
v0.0.0-...-3cc9250 Latest Latest
Warning

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

Go to latest
Published: Jan 23, 2017 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL