Skip to content
Snippets Groups Projects
Commit db0f902f authored by Sören Henning's avatar Sören Henning
Browse files

Merge branch 'master' into feature/281-Add-Beam-Kubernetes-Benchmark-Definitions

parents 2278cc0c 2e2591ed
No related branches found
No related tags found
1 merge request!218Add Beam Kubernetes Benchmark Definitions
......@@ -527,7 +527,7 @@ data:
"steppedLine": false,
"targets": [
{
"expr": "sum by(topic) (kafka_topic_partitions >= 0)",
"expr": "kafka_topic_partitions",
"format": "time_series",
"intervalFactor": 1,
"legendFormat": "{{topic}}",
......
......@@ -34,7 +34,7 @@ final class DocumentMapper extends SimpleFunction<ActivePowerRecord, Document> {
private String createDocumentName(final String documentId) {
this.initFirestoreConfig();
return "projects/" + this.firestoreConfig.getProjectId()
+ "/databases/" + this.firestoreConfig.getDatabaseDdlRequest()
+ "/databases/" + this.firestoreConfig.getDatabase()
+ "/documents/" + this.collection
+ "/" + documentId;
}
......
......@@ -16,8 +16,8 @@ final class FirestoreConfig {
return this.firestoreOptions.getProjectId();
}
public String getDatabaseDdlRequest() {
return this.firestoreOptions.getProjectId();
public String getDatabase() {
return this.firestoreOptions.getDatabaseId();
}
public static FirestoreConfig createFromDefaults() throws IOException {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment