salesforce-lib/src/main/java/com/streamsets/pipeline/stage/destination/salesforce/ForceTarget.java
@Override
  public void write(Batch batch) throws StageException {
    Multimap<String, Record> partitions = ELUtils.partitionBatchByExpression(sObjectNameEval,
        sObjectNameVars,
        conf.sObjectNameTemplate,
        batch
    );
    Set<String> sObjectNames = partitions.keySet();
    for (String sObjectName : sObjectNames) {
      List<OnRecordErrorException> errors = writer.writeBatch(
          sObjectName,
          partitions.get(sObjectName),
          this
      );
      for (OnRecordErrorException error : errors) {
        errorRecordHandler.onError(error);
      }
    }
  }
@Override
  public void write(Batch batch) throws StageException {
    Multimap<String, Record> partitions = ELUtils.partitionBatchByExpression(sObjectNameEval,
        sObjectNameVars,
        conf.sObjectNameTemplate,
        batch
    );
    Set<String> sObjectNames = partitions.keySet();
    for (String sObjectName : sObjectNames) {
      List<OnRecordErrorException> errors = writer.writeBatch(
          sObjectName,
          partitions.get(sObjectName),
          this
      );
      for (OnRecordErrorException error : errors) {
        errorRecordHandler.onError(error);
      }
    }
  }
@ Override public void write ( Batch batch ) throws StageException { Multimap < String , Record > partitions = ELUtils . partitionBatchByExpression ( sObjectNameEval , sObjectNameVars , conf . sObjectNameTemplate , batch ) ; Set < String > sObjectNames = partitions . keySet ( ) ; for ( String sObjectName : sObjectNames ) { List < OnRecordErrorException > errors = writer . writeBatch ( sObjectName , partitions . get ( sObjectName ) , this ) ; for ( OnRecordErrorException error : errors ) { errorRecordHandler . onError ( error ) ; } } }
{@inheritDoc}
{