docs: private BatchObject initBatchObject(Identity identity, Class clazz) {
          if (EventData.class.equals(clazz)) {
              RowBatch rowbatch = new RowBatch();
              rowbatch.setIdentity(identity);
              return rowbatch;
          } else if (FileData.class.equals(clazz)) {
              FileBatch fileBatch = new FileBatch();
              fileBatch.setIdentity(identity);
              return fileBatch;
          } else {
              throw new TransformException("no support Data[" + clazz.getName() + "]");
          }
      }