[improve][writer][elasticsearch] remove unused variable.

JinRudy · Feb 2, 2024 · a9f5b5a · a9f5b5a
1 parent 114fb7f
commit a9f5b5a
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...archwriter/src/main/java/com/wgzhao/addax/plugin/writer/elasticsearchwriter/ESWriter.java b/...archwriter/src/main/java/com/wgzhao/addax/plugin/writer/elasticsearchwriter/ESWriter.java
@@ -323,7 +323,7 @@ public void startWrite(RecordReceiver recordReceiver)
 
         private String getDateStr(ESColumn esColumn, Column column)
         {
-            DateTime date = null;
+            DateTime date;
             DateTimeZone dtz = DateTimeZone.getDefault();
             if (esColumn.getTimezone() != null) {
                 // 所有时区参考 http://www.joda.org/joda-time/timezones.html
@@ -345,7 +345,7 @@ else if (column.getType() == Column.Type.DATE) {
 
         private long doBatchInsert(final List<Record> writerBuffer)
         {
-            Map<String, Object> data = null;
+            Map<String, Object> data;
             final Bulk.Builder bulkAction = new Bulk.Builder().defaultIndex(this.index).defaultType(this.type);
             for (Record record : writerBuffer) {
                 data = new HashMap<>();
@@ -403,8 +403,6 @@ private long doBatchInsert(final List<Record> writerBuffer)
                                 data.put(columnName, column.asLong());
                                 break;
                             case INTEGER:
-                                data.put(columnName, column.asBigInteger());
-                                break;
                             case SHORT:
                                 data.put(columnName, column.asBigInteger());
                                 break;