hkeebler commented on a change in pull request #1206: Fix #1181 Update
MasterMetadataUtil to use new Ample api
URL: https://github.com/apache/accumulo/pull/1206#discussion_r294804973
##########
File path:
server/base/src/main/java/org/apache/accumulo/server/util/MasterMetadataUtil.java
##########
@@ -69,34 +69,35 @@ public static void addNewTablet(ServerContext context,
KeyExtent extent, String
TServerInstance location, Map<FileRef,DataFileValue> datafileSizes,
Map<Long,? extends Collection<FileRef>> bulkLoadedFiles, String time,
long lastFlushID,
long lastCompactID, ZooLock zooLock) {
- Mutation m = extent.getPrevRowUpdateMutation();
- TabletsSection.ServerColumnFamily.DIRECTORY_COLUMN.put(m, new
Value(path.getBytes(UTF_8)));
- TabletsSection.ServerColumnFamily.TIME_COLUMN.put(m, new
Value(time.getBytes(UTF_8)));
+ TabletMutator mutator = context.getAmple().mutateTablet(extent);
+ mutator.putPrevEndRow(extent.getPrevEndRow());
+ mutator.putZooLock(zooLock);
+ mutator.putDir(path);
+ mutator.putTime(time);
+
if (lastFlushID > 0)
- TabletsSection.ServerColumnFamily.FLUSH_COLUMN.put(m,
- new Value(("" + lastFlushID).getBytes()));
+ mutator.putFlushId(lastFlushID);
+
if (lastCompactID > 0)
- TabletsSection.ServerColumnFamily.COMPACT_COLUMN.put(m,
- new Value(("" + lastCompactID).getBytes()));
+ mutator.putCompactionId(lastCompactID);
if (location != null) {
- location.putLocation(m);
- location.clearFutureLocation(m);
+ mutator.putLocation(location, LocationType.CURRENT);
+ mutator.deleteLocation(location, LocationType.FUTURE);
}
-
+ // are the following collections assumed not null? at least any empty
collection is passed?
for (Entry<FileRef,DataFileValue> entry : datafileSizes.entrySet()) {
Review comment:
thanks.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
