geist-connector-bigtable

README

GEIST Bigtable Connector

GEIST Bigtable Connector enables Bigtable as a sink type in stream specs when using GEIST.

Note that this connector previously resided in the geist-connector-gcp repo, but was moved out to its own for improved maintainability and ease of use.

Usage

See GEIST core repo for general information.

Install with:

go get github.com/zpiroux/geist-connector-bigtable

GEIST Integration

Register connector prior to starting up GEIST with (error handling omitted):

import (
	"github.com/zpiroux/geist"
	"github.com/zpiroux/geist-connector-bigtable/gbigtable"
)

...
geistConfig := geist.NewConfig()

btConfig := &gbigtable.Config{ /* add config */ }

err = geistConfig.RegisterExtractorType(gbigtable.NewExtractorFactory(btConfig))
err = geistConfig.RegisterLoaderType(gbigtable.NewLoaderFactory(btConfig))

g, err := geist.New(ctx, geistConfig)
...

Stream Spec Configuration

See stream spec examples here.

Contact

info @ zpiroux . com

License

GEIST Bigtable Connector source code is available under the MIT License.