From d87beaf7a84f05ca7111e3507ae91f10017dbd8b Mon Sep 17 00:00:00 2001 From: gaoxin Date: Tue, 7 Jan 2025 23:59:52 +0000 Subject: [PATCH] Fix style check --- .../SchemaConformingTransformerTest.java | 12 ++++++------ .../spi/config/table/ingestion/IngestionConfig.java | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/pinot-segment-local/src/test/java/org/apache/pinot/segment/local/recordtransformer/SchemaConformingTransformerTest.java b/pinot-segment-local/src/test/java/org/apache/pinot/segment/local/recordtransformer/SchemaConformingTransformerTest.java index 8c48faeada3f..1cb820d682cc 100644 --- a/pinot-segment-local/src/test/java/org/apache/pinot/segment/local/recordtransformer/SchemaConformingTransformerTest.java +++ b/pinot-segment-local/src/test/java/org/apache/pinot/segment/local/recordtransformer/SchemaConformingTransformerTest.java @@ -105,11 +105,11 @@ public class SchemaConformingTransformerTest { private static TableConfig createDefaultBasicTableConfig() { IngestionConfig ingestionConfig = new IngestionConfig(); - SchemaConformingTransformerConfig SchemaConformingTransformerConfig = + SchemaConformingTransformerConfig schemaConformingTransformerConfig = new SchemaConformingTransformerConfig(true, INDEXABLE_EXTRAS_FIELD_NAME, true, UNINDEXABLE_EXTRAS_FIELD_NAME, UNINDEXABLE_FIELD_SUFFIX, null, null, null, null, null, null, false, null, null, null, null, null, null, null, null, null, null); - ingestionConfig.setSchemaConformingTransformerConfig(SchemaConformingTransformerConfig); + ingestionConfig.setSchemaConformingTransformerConfig(schemaConformingTransformerConfig); return new TableConfigBuilder(TableType.OFFLINE).setTableName("testTable").setIngestionConfig(ingestionConfig) .build(); } @@ -120,14 +120,14 @@ private static TableConfig createDefaultTableConfig(String indexableExtrasField, String mergedTextIndexField, boolean useAnonymousDotInFieldNames, boolean optimizeCaseInsensitiveSearch, Boolean reverseTextIndexKeyValueOrder) { IngestionConfig ingestionConfig = new IngestionConfig(); - SchemaConformingTransformerConfig SchemaConformingTransformerConfig = + SchemaConformingTransformerConfig schemaConformingTransformerConfig = new SchemaConformingTransformerConfig(indexableExtrasField != null, indexableExtrasField, unindexableExtrasField != null, unindexableExtrasField, unindexableFieldSuffix, fieldPathsToDrop, fieldPathsToPreserve, fieldPathsToPreserveWithIndex, null, columnNameToJsonKeyPathMap, mergedTextIndexField, useAnonymousDotInFieldNames, optimizeCaseInsensitiveSearch, reverseTextIndexKeyValueOrder, null, null, null, null, null, JSON_KEY_VALUE_SEPARATOR, MERGED_TEXT_INDEX_BOD_ANCHOR, MERGED_TEXT_INDEX_EOD_ANCHOR); - ingestionConfig.setSchemaConformingTransformerConfig(SchemaConformingTransformerConfig); + ingestionConfig.setSchemaConformingTransformerConfig(schemaConformingTransformerConfig); return new TableConfigBuilder(TableType.OFFLINE).setTableName("testTable").setIngestionConfig(ingestionConfig) .build(); } @@ -971,9 +971,9 @@ private void testTransform(String indexableExtrasField, String unindexableExtras private GenericRow transformRow(TableConfig tableConfig, Schema schema, String inputRecordJSONString) { Map inputRecordMap = jsonStringToMap(inputRecordJSONString); GenericRow inputRecord = createRowFromMap(inputRecordMap); - SchemaConformingTransformer SchemaConformingTransformer = + SchemaConformingTransformer schemaConformingTransformer = new SchemaConformingTransformer(tableConfig, schema); - return SchemaConformingTransformer.transform(inputRecord); + return schemaConformingTransformer.transform(inputRecord); } /** diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/ingestion/IngestionConfig.java b/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/ingestion/IngestionConfig.java index 144741ff35ed..d2b6d4deebe0 100644 --- a/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/ingestion/IngestionConfig.java +++ b/pinot-spi/src/main/java/org/apache/pinot/spi/config/table/ingestion/IngestionConfig.java @@ -61,7 +61,7 @@ private void setSchemaConformingTransformerV2Config(JsonNode schemaConformingTra // Map _schemaConformingTransformerV2Config JSON into SchemaConformingTransformerConfig if (schemaConformingTransformerV2Config != null && _schemaConformingTransformerConfig == null) { ObjectMapper objectMapper = new ObjectMapper(); - this._schemaConformingTransformerConfig = + _schemaConformingTransformerConfig = objectMapper.convertValue(schemaConformingTransformerV2Config, SchemaConformingTransformerConfig.class); } }