MCPcopy Index your code
hub / github.com/GoogleCloudPlatform/cloud-bigtable-examples

github.com/GoogleCloudPlatform/cloud-bigtable-examples @0.3.0

Chat with this repo
repository ↗ · DeepWiki ↗ · release 0.3.0 ↗ · + Follow
333 symbols 627 edges 48 files 102 documented · 31%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Google Cloud Bigtable examples

ghit.me

There are many examples / sample / demo programs here, each with its own README.

Quickstart

Quickstart/HBase - Create a Cloud Bigtable Cluster and the hbase shell from within a docker container on your local machine

Java

  • Simple-CLI - A simple command line interface for Cloud Bigtable that shows you how to do basic operations with the native HBase API
  • Hello World - A minimal application that demonstrates using the native HBase API to create a temporary table, write some rows, read them back and clean up
  • Import HBase Sequence files Import HBase sequence files directly to Cloud Bigtable using Dataflow.
  • Dataproc Wordcount using Map/Reduce - How to load data to Cloud Bigtable using Dataproc on GCE
  • GAE Flexible-Hello World - Accessing Cloud Bigtable from a Managed VM / JSON Upload / Download

Dataflow

  • Connector-Examples - Using the cloud dataflow connector for Bigtable, do write Hello World to two rows, Use Cloud Pub / Sub to count Shakespeare, and count the number of rows in a Table.
  • Pardo-HelloWorld - example of using Cloud Dataflow without the connector.
  • dataflow-coinbase - An end to end example that takes the last four hours of Bitcoin data and sends it to Google Cloud Dataflow, which process it and sends it to Google Cloud Bigtable. Then there is a Managed VM application that displays the data in an angularJS app.

Go

  • cbt doc Basic command line interactions with Cloud Bigtable - A really great place to start learning the Go Client.
  • Bigtable-Hello - Accessing Cloud Bigtable from a Managed VM
  • search - Create and search a Cloud Bigtable.

Python

  • Thrift - Setup an HBase Thrift server(s) to use Cloud Bigtable and access that from Python to do basic operations.
  • AppEngine SSL Gateway - Shows how to setup and secure an HBase Thrift gateway and then access it from App Engine.
  • REST - Setup an HBase REST server(s) to use Cloud Bigtable and access it from Python and do basic operations.

Scala / Spark

  • PubSub – Integrating Spark Streaming with Cloud Pubsub
  • Standalone-Wordcount – Simple Spark job that counts the number of times a word appears in a text file
  • Streaming-Wordcount – Pulls new files from a GCS directory every 30 seconds and perform a simple Spark job that counts the number of times a word appears in each new file

Contributing changes

Licensing

Extension points exported contracts — how you extend this code

CountOptions (Interface)
Options needed for running the pipelne. It needs a
java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/SourceRowCount.java
CloudBigtableOptions (Interface)
(no doc)
java/dataflow-coinbase/dataflow/src/main/java/com/google/cloud/examples/coinflow/sources/CoinbaseSource.java
CloudBigtableOptions (Interface)
(no doc)
java/dataflow-pardo-helloworld/src/main/java/com/example/bigtable/dataflow/pardo/HelloWorldBigtablePardo.java
BigtablePubsubOptions (Interface)
(no doc)
java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/PubsubWordCount.java

Core symbols most depended-on inside this repo

get
called by 37
python/thrift/appengine-ssl-gateway/appengine/bigtable.py
close
called by 12
java/dataflow-coinbase/dataflow/src/main/java/com/google/cloud/examples/coinflow/sources/CoinbaseSocket.java
run
called by 9
java/dataproc-wordcount/src/main/java/com.example.bigtable.sample/CellCounter.java
start
called by 7
java/dataflow-coinbase/dataflow/src/main/java/com/google/cloud/examples/coinflow/sources/CoinbaseSocket.java
print
called by 7
java/hello-world/src/main/java/com/example/cloud/bigtable/helloworld/HelloWorld.java
delete
called by 6
python/rest/rest_client.py
getName
called by 6
java/simple-cli/src/main/java/com/example/bigtable/simplecli/HBaseCLI.java
usage
called by 5
java/simple-cli/src/main/java/com/example/bigtable/simplecli/HBaseCLI.java

Shape

Method 257
Class 62
Function 8
Interface 4
Enum 1
Route 1

Languages

Java91%
Python9%

Modules by API surface

java/simple-cli/src/main/java/com/example/bigtable/simplecli/HBaseCLI.java38 symbols
java/dataflow-coinbase/dataflow/src/main/java/com/google/cloud/examples/coinflow/data/CoinbaseData.java31 symbols
java/storm/src/main/java/com/example/bigtable/storm/data/CoinbaseData.java29 symbols
java/dataflow-coinbase/dataflow/src/main/java/com/google/cloud/examples/coinflow/sources/CoinbaseSource.java24 symbols
java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/PubsubWordCount.java19 symbols
java/dataflow-pardo-helloworld/src/main/java/com/example/bigtable/dataflow/pardo/HelloWorldBigtablePardo.java16 symbols
java/dataflow-coinbase/dataflow/src/main/java/com/google/cloud/examples/coinflow/sources/CoinbaseSocket.java15 symbols
java/dataproc-wordcount/src/main/java/com.example.bigtable.sample/CellCounter.java12 symbols
python/thrift/appengine-ssl-gateway/appengine/bigtable.py9 symbols
java/jetty-managed-vm/src/main/java/com/example/cloud/bigtable/helloworld/JsonServlet.java8 symbols
java/gae-flexible-helloworld/src/main/java/com/example/cloud/bigtable/helloworld/JsonServlet.java8 symbols
python/thrift/client.py7 symbols

For agents

$ claude mcp add cloud-bigtable-examples \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact