code: @SuppressWarnings("unchecked")
      @Override
      public Cells transformElement(Pair<Map<String, ByteBuffer>, Map<String, ByteBuffer>> elem,
                                    CassandraDeepJobConfig<Cells> config) {
  
          Cells cells = new Cells(config.getNameSpace());
          Map<String, Cell> columnDefinitions = config.columnDefinitions();
  
          for (Map.Entry<String, ByteBuffer> entry : elem.left.entrySet()) {
              Cell cd = columnDefinitions.get(entry.getKey());
              cells.add(CassandraUtils.createFromByteBuffer(cd, entry.getValue()));
          }
  
          for (Map.Entry<String, ByteBuffer> entry : elem.right.entrySet()) {
              Cell cd = columnDefinitions.get(entry.getKey());
              if (cd == null) {
                  continue;
              }
  
              cells.add(CassandraUtils.createFromByteBuffer(cd, entry.getValue()));
          }
  
          return cells;
      }
docs: {@inheritDoc}