You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by tu...@apache.org on 2021/03/19 16:56:46 UTC
[nifi] branch main updated: NIFI-8308 Remove unnecessary field
adjustments from QuestDB row creation
This is an automated email from the ASF dual-hosted git repository.
turcsanyi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 4d68509 NIFI-8308 Remove unnecessary field adjustments from QuestDB row creation
4d68509 is described below
commit 4d68509212335d2c4fa28910ffab891d595be9af
Author: Bence Simon <si...@gmail.com>
AuthorDate: Wed Mar 10 17:01:17 2021 +0100
NIFI-8308 Remove unnecessary field adjustments from QuestDB row creation
This closes #4888.
Signed-off-by: Peter Turcsanyi <tu...@apache.org>
---
.../status/history/storage/questdb/StorageStatusWritingTemplate.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/storage/questdb/StorageStatusWritingTemplate.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/storage/questdb/StorageStatusWritingTemplate.java
index eaa560a..55f96d6 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/storage/questdb/StorageStatusWritingTemplate.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/storage/questdb/StorageStatusWritingTemplate.java
@@ -38,7 +38,6 @@ class StorageStatusWritingTemplate extends QuestDbWritingTemplate<Pair<Instant,
for (final StorageStatus contentRepository : entry.getRight().getContentRepositories()) {
final long capturedAt = TimeUnit.MILLISECONDS.toMicros(entry.getLeft().toEpochMilli());
final TableWriter.Row row = tableWriter.newRow(capturedAt);
- row.putTimestamp(0, capturedAt);
row.putSym(1, contentRepository.getName());
row.putShort(2, Integer.valueOf(0).shortValue());
row.putLong(3, contentRepository.getFreeSpace());
@@ -49,7 +48,6 @@ class StorageStatusWritingTemplate extends QuestDbWritingTemplate<Pair<Instant,
for (final StorageStatus provenanceRepository : entry.getRight().getProvenanceRepositories()) {
final long capturedAt = TimeUnit.MILLISECONDS.toMicros(entry.getLeft().toEpochMilli());
final TableWriter.Row row = tableWriter.newRow(capturedAt);
- row.putTimestamp(0, capturedAt);
row.putSym(1, provenanceRepository.getName());
row.putShort(2, Integer.valueOf(1).shortValue());
row.putLong(3, provenanceRepository.getFreeSpace());