From 4b81fc531746f3242cee9d42f45af945934b3aa5 Mon Sep 17 00:00:00 2001 From: Dinu John <86094133+dinujoh@users.noreply.github.com> Date: Thu, 31 Oct 2024 13:27:22 -0500 Subject: [PATCH] Rename variable Signed-off-by: Dinu John <86094133+dinujoh@users.noreply.github.com> --- .../dataprepper/plugins/source/rds/schema/SchemaManager.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java b/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java index f6aa59d6db..1ed848beee 100644 --- a/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java +++ b/data-prepper-plugins/rds-source/src/main/java/org/opensearch/dataprepper/plugins/source/rds/schema/SchemaManager.java @@ -27,8 +27,7 @@ public class SchemaManager { static final String BINLOG_POSITION = "Position"; static final int NUM_OF_RETRIES = 3; static final int BACKOFF_IN_MILLIS = 500; - public static final String COLUMN_NAME1 = "COLUMN_NAME"; - public static final String TYPE_NAME = "TYPE_NAME"; + static final String TYPE_NAME = "TYPE_NAME"; private final ConnectionManager connectionManager; public SchemaManager(ConnectionManager connectionManager) { @@ -66,7 +65,7 @@ public Map getColumnDataTypes(final String database, final Strin try (ResultSet columns = metaData.getColumns(database, null, tableName, null)) { while (columns.next()) { columnsToDataType.put( - columns.getString(COLUMN_NAME1), + columns.getString(COLUMN_NAME), columns.getString(TYPE_NAME) ); }