From a0b2f591ef88b65d830cab8930cbe7dc5c3c9db9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=EA=B9=80=EB=B3=91=EA=B3=A4?= Date: Thu, 7 Sep 2023 23:04:35 +0900 Subject: [PATCH] =?UTF-8?q?Avro=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nifi/record/parquet/WriteParquetResult.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java b/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java index 30c8929..1d71b14 100644 --- a/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java +++ b/nifi-custom-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 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"; } -} - +} \ No newline at end of file