docs: private List<RowBatch> split(RowBatch rowBatch) {
          final Identity identity = rowBatch.getIdentity();
          Map<DataMediaSource, RowBatch> result = OtterMigrateMap.makeComputingMap(new Function<DataMediaSource, RowBatch>() {
  
              public RowBatch apply(DataMediaSource input) {
                  RowBatch rowBatch = new RowBatch();
                  rowBatch.setIdentity(identity);
                  return rowBatch;
              }
          });
  
          for (EventData eventData : rowBatch.getDatas()) {
              // 获取介质信息
              DataMedia media = ConfigHelper.findDataMedia(configClientService.findPipeline(identity.getPipelineId()),
                                                           eventData.getTableId());
              result.get(media.getSource()).merge(eventData); // 归类
          }
  
          return new ArrayList<RowBatch>(result.values());
      }