-
Notifications
You must be signed in to change notification settings - Fork 178
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Initial commit of Cloud Bigtable/Dataflow connector. #394
Conversation
@@ -0,0 +1,3 @@ | |||
# Bigtable Dataflow | |||
|
|||
This project contains the core [Bigtable](https://cloud.google.com/bigtable/)-[Dataflow](https://cloud.google.com/dataflow/) integration. The main class you should care about is: [CloudBigtableIO](https://github.com/GoogleCloudPlatform/cloud-bigtable-cdf/blob/master/bigtable-dataflow/src/main/java/com/google/cloud/dataflow/sdk/io/CloudBigtableIO.java). It contains the Cloud Bigtable Sink and Source. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
update link to point to the right repo
} | ||
|
||
/** | ||
* Reads rows for a specific {@link Table}, potentially filted by a Scan and/or a start/stop key |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
"filted" ?
752e59c
to
1c658c0
Compare
.setProjectId(getProjectId()) | ||
.setZoneId(getZoneId()) | ||
.setClusterId(getClusterId()) | ||
.setUserAgent("CloudBigtableGrpcIO") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Maybe mention dataflow? Why IO?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Updated.
private static String clusterId = System.getProperty(BIGTABLE_CLUSTER_KEY); | ||
|
||
public static TableName newTestTableName() { | ||
return TableName.valueOf("test_table-" + UUID.randomUUID().toString()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
its useful to specify which test created the table in the name.
LGTM |
bda626e
to
b89b829
Compare
Initial commit of Cloud Bigtable/Dataflow connector.
No description provided.