public void write ( Cells keys , Cells values ) { if ( ! hasCurrentTask ) { String localCql = queryBuilder . prepareQuery ( keys , values ) ; currentTask = new WriteTask ( localCql ) ; hasCurrentTask = true ; } // add primary key columns to the bind variables List < Object > allValues = new ArrayList <> ( values . getCellValues ( ) ) ; allValues . addAll ( keys . getCellValues ( ) ) ; currentTask . add ( allValues ) ; if ( isBatchSizeReached ( ) ) { executeTaskAsync ( ) ; } }
Adds the provided row to a batch . If the batch size reaches the threshold configured in IDeepJobConfig . getBatchSize the batch will be sent to the data store .