Avro 추가

DataDynamics · Sep 7, 2023 · a0b2f59 · a0b2f59
1 parent eb90f23
commit a0b2f59
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...tom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java b/...tom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java
@@ -45,19 +45,20 @@ public WriteParquetResult(final Schema avroSchema, final RecordSchema recordSche
         ParquetUtils.applyCommonConfig(writerBuilder, conf, parquetConfig);
         parquetWriter = writerBuilder.build();
 
-        if (componentLogger.isInfoEnabled()) { // FIXED
-            componentLogger.info("[DFM] WriteParquetResult : Schema = {}", schema);
-            componentLogger.info("[DFM] WriteParquetResult : timestampFormatPropertyKeyName = {}, addHours = {}", this.timestampFormatPropertyKeyName, this.addHours);
+        if (componentLogger.isDebugEnabled()) {
+            componentLogger.debug("[DFM] WriteParquetResult : Schema = {}", schema);
+            componentLogger.debug("[DFM] WriteParquetResult : timestampFormatPropertyKeyName = {}, addHours = {}", this.timestampFormatPropertyKeyName, this.addHours);
         }
     }
 
     @Override
     protected Map<String, String> writeRecord(final Record record) throws IOException {
-        if (componentLogger.isInfoEnabled()) {
-            this.componentLogger.info("[DFM] [Write] Record = {}", record);
+        if (componentLogger.isDebugEnabled()) {
+            this.componentLogger.debug("[DFM] [Write] Record = {}", record);
         }
 
         final GenericRecord genericRecord = AvroTypeUtil.createAvroRecord(record, schema, timestampFormatPropertyKeyName, addHours);
+        parquetWriter.write(genericRecord);
         return Collections.emptyMap();
     }
 
@@ -81,5 +82,4 @@ public String getMimeType() {
         return "application/parquet";
     }
 
-}
-
+}