code: @Override
      protected int onExecuteUpdate()
      {
          Map<String, Object> persistDetails = new HashMap<String, Object>();
          DataFrame dataFrame;
          try
          {
              String query = getJPAQuery();// .toLowerCase();
  
              persistDetails = parseInsertIntoQuery(query);
  
              dataFrame = getDataFrameToPersist(query, (String) persistDetails.get("fetchQuery"));
  
              String clientName = (String) persistDetails.get("client");
  
              SparkDataClient dataClient = SparkDataClientFactory.getDataClient(clientName);
              dataClient.saveDataFrame(dataFrame, getEntityMetadata().getEntityClazz(), persistDetails);
          }
          catch (Exception e)
          {
              logger.error("Error during executing query, Caused by:", e);
              throw new QueryHandlerException(e);
          }
  
          return getDataFrameSize(dataFrame);
      }
docs: /*
  (non-Javadoc)
  
  @see com.impetus.kundera.query.QueryImpl#onExecuteUpdate()