package
Version:
v0.10.2
Opens a new window with list of versions in this module.
Published: Jan 19, 2024
License: Apache-2.0
Opens a new window with license information.
Imports: 12
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
README
¶
cassandra
Usage
source:
name: cassandra
config:
user_id: admin
password: 1234
host: localhost
port: 9042
Key |
Value |
Example |
Description |
|
user_id |
string |
admin |
User ID to access the cassandra server |
required |
password |
string |
1234 |
Password for the cassandra Server |
required |
host |
string |
127.0.0.1 |
The Host address at which server is running |
required |
port |
int |
9042 |
The Port number at which server is running |
required |
Outputs
Field |
Sample Value |
resource.urn |
my_keyspace.my_table |
resource.name |
my_table |
resource.service |
cassandra |
description |
table description |
profile.total_rows |
2100 |
schema |
[]Column |
Column
Field |
Sample Value |
name |
total_price |
type |
text |
Contributing
Refer to the contribution guidelines for information on contributing to this module.
Documentation
¶
type Config struct {
UserID string `mapstructure:"user_id" validate:"required"`
Password string `mapstructure:"password" validate:"required"`
Host string `mapstructure:"host" validate:"required"`
Port int `mapstructure:"port" validate:"required"`
}
Config holds the set of configuration for the cassandra extractor
type Extractor struct {
}
Extractor manages the extraction of data from cassandra
New returns a pointer to an initialized Extractor Object
Extract checks if the extractor is configured and
if the connection to the DB is successful
and then starts the extraction process
Init initializes the extractor
Source Files
¶
Click to show internal directories.
Click to hide internal directories.