public EntityId upsert()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractUpsertCommandHandler.java [45:53]


  public EntityId upsert(Request<T> input) {
    Map<String, Object> entityMap = entityConverter.entityToMap(input.getPayload());
    Object entityId = entityMap.remove(tableDataProvider.pkColumnName());
    if (entityId == null) {
      return createCommandHandler.save(input);
    }
    updateCommandHandler.update(input);
    return new EntityId(UUID.fromString(entityId.toString()));
  }