arcus-java-client FEATURE: Create new api asyncBopPipedUpsert.

Motivation

아래 캐시 동기화에 필요한 기능 이슈를 해결하기 위해 구현한다. https://github.com/jam2in/arcus-works/issues/426

구현 로직

캐시 서버는 bop insert와 bop upsert 요청에 대해 아래와 같이 동일한 인자와 형식을 가지고 있습니다.

bop insert <key> <bkey> [<eflag>] <bytes> [create <attributes>] [noreply|pipe|getrim]\r\n<data>\r\n
bop upsert <key> <bkey> [<eflag>] <bytes> [create <attributes>] [noreply|pipe|getrim]\r\n<data>\r\n

그래서 기존의 asyncCollectionPipedInsert()를 활용하여 piped upsert를 가능하도록 구현하였습니다.

단건 upsert의 경우도 아래와 같이 asyncCollectionInsert를 사용하여 구현되어 있습니다.

@Override
  public CollectionFuture<Boolean> asyncBopUpsert(String key, long bkey,
                                                  byte[] elementFlag, Object value,
                                                  CollectionAttributes attributesForCreate) {

    BTreeUtil.validateBkey(bkey);
    BTreeUpsert<Object> bTreeUpsert = new BTreeUpsert<Object>(value, elementFlag, null, attributesForCreate);

    return asyncCollectionInsert(key, String.valueOf(bkey), bTreeUpsert,
            collectionTranscoder);
  }

즉, 이러한 구현이 단건과 다건 api에 대한 일관적으로 구현된 형태입니다.