private DataFrame getDataFrameToPersist ( String query , String subQuery ) { EntityMetadata entityMetadata = getEntityMetadata ( ) ; Client client = entityMetadata != null ? persistenceDelegeator . getClient ( entityMetadata ) : persistenceDelegeator . getClient ( kunderaQuery . getPersistenceUnit ( ) ) ; return ( ( SparkClient ) client ) . getDataFrame ( subQuery , entityMetadata , getKunderaQuery ( ) ) ; }
Gets the data frame to persist .