code: @Override
      public void run() {
          try {
              for (Map<String, Object> row : dataDecoder) {
                  dataEncoder.write(applyFilters(row));
              }
  
              dataDecoder.close();
              dataEncoder.close();
          } catch (IOException ioe) {
              logger.error("Unable to complete conversion.", ioe);
          }
  
      }
docs: Run the converter.