@Override
    protected void onPersist(EntityMetadata entityMetadata, Object entity, Object id, List<RelationHolder> rlHolders)
    {
        // TODO Auto-generated method stub
        // handle persist object
        PersistenceUnitMetadata puMetadata = kunderaMetadata.getApplicationMetadata().getPersistenceUnitMetadata(
                persistenceUnit);
        String clientName = puMetadata.getProperty(DATA_CLIENT).toLowerCase();

        List listEntity = new ArrayList<>();
        listEntity.add(entity);

        SparkDataClient dataClient = SparkDataClientFactory.getDataClient(clientName);

        dataClient.persist(listEntity, entityMetadata, this);
    }
@ Override protected void onPersist ( EntityMetadata entityMetadata , Object entity , Object id , List < RelationHolder > rlHolders ) { PersistenceUnitMetadata puMetadata = kunderaMetadata . getApplicationMetadata ( ) . getPersistenceUnitMetadata ( persistenceUnit ) ; String clientName = puMetadata . getProperty ( DATA_CLIENT ) . toLowerCase ( ) ; List listEntity = new ArrayList < > ( ) ; listEntity . add ( entity ) ; SparkDataClient dataClient = SparkDataClientFactory . getDataClient ( clientName ) ; dataClient . persist ( listEntity , entityMetadata , this ) ; }
/*
(non-Javadoc)

@see
com.impetus.kundera.client.ClientBase#onPersist(com.impetus.kundera.metadata
.model.EntityMetadata, java.lang.Object, java.lang.Object,
java.util.List)