cassandra-pr mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ifesdjeen <...@git.apache.org>
Subject [GitHub] cassandra pull request #267: Consolidate batch write code
Date Fri, 21 Sep 2018 14:01:55 GMT
Github user ifesdjeen commented on a diff in the pull request:

    https://github.com/apache/cassandra/pull/267#discussion_r219508092
  
    --- Diff: src/java/org/apache/cassandra/service/StorageProxy.java ---
    @@ -780,8 +780,9 @@ public static void mutateMV(ByteBuffer dataKey, Collection<Mutation>
mutations,
                     ConsistencyLevel consistencyLevel = ConsistencyLevel.ONE;
     
                     //Since the base -> view replication is 1:1 we only need to store
the BL locally
    -                final Collection<InetAddressAndPort> batchlogEndpoints = Collections.singleton(FBUtilities.getBroadcastAddressAndPort());
    -                BatchlogResponseHandler.BatchlogCleanup cleanup = new BatchlogResponseHandler.BatchlogCleanup(mutations.size(),
() -> asyncRemoveFromBatchlog(batchlogEndpoints, batchUUID));
    +                ReplicaPlan.ForTokenWrite replicaPlan = ReplicaPlans.forLocalBatchlogWrite();
    +                BatchlogResponseHandler.BatchlogCleanup cleanup = new BatchlogResponseHandler.BatchlogCleanup(mutations.size(),
    --- End diff --
    
    
    Fixed


---

---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org


Mime
View raw message