http://git-wip-us.apache.org/repos/asf/accumulo/blob/0bd62e39/server/src/main/java/org/apache/accumulo/server/tabletserver/mastermessage/SplitReportMessage.java
----------------------------------------------------------------------
diff --cc 
server/src/main/java/org/apache/accumulo/server/tabletserver/mastermessage/SplitReportMessage.java
index 7b83576,0000000..f0dbd62
mode 100644,000000..100644
--- 
a/server/src/main/java/org/apache/accumulo/server/tabletserver/mastermessage/SplitReportMessage.java
+++ 
b/server/src/main/java/org/apache/accumulo/server/tabletserver/mastermessage/SplitReportMessage.java
@@@ -1,55 -1,0 +1,56 @@@
 +/*
 + * Licensed to the Apache Software Foundation (ASF) under one or more
 + * contributor license agreements.  See the NOTICE file distributed with
 + * this work for additional information regarding copyright ownership.
 + * The ASF licenses this file to You under the Apache License, Version 2.0
 + * (the "License"); you may not use this file except in compliance with
 + * the License.  You may obtain a copy of the License at
 + *
 + *     http://www.apache.org/licenses/LICENSE-2.0
 + *
 + * Unless required by applicable law or agreed to in writing, software
 + * distributed under the License is distributed on an "AS IS" BASIS,
 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + * See the License for the specific language governing permissions and
 + * limitations under the License.
 + */
 +package org.apache.accumulo.server.tabletserver.mastermessage;
 +
 +import java.util.Map;
 +import java.util.TreeMap;
 +
 +import org.apache.accumulo.trace.instrument.Tracer;
 +import org.apache.accumulo.core.client.impl.Translator;
 +import org.apache.accumulo.core.client.impl.thrift.ThriftSecurityException;
++import org.apache.accumulo.core.client.impl.Translators;
 +import org.apache.accumulo.core.data.KeyExtent;
 +import org.apache.accumulo.core.master.thrift.MasterClientService;
 +import org.apache.accumulo.core.master.thrift.TabletSplit;
 +import org.apache.accumulo.core.security.thrift.TCredentials;
 +import org.apache.hadoop.io.Text;
 +import org.apache.thrift.TException;
 +
 +public class SplitReportMessage implements MasterMessage {
 +  Map<KeyExtent,Text> extents;
 +  KeyExtent old_extent;
 +  
 +  public SplitReportMessage(KeyExtent old_extent, Map<KeyExtent,Text> 
newExtents) {
 +    this.old_extent = old_extent;
 +    extents = new TreeMap<KeyExtent,Text>(newExtents);
 +  }
 +  
 +  public SplitReportMessage(KeyExtent old_extent, KeyExtent ne1, Text np1, 
KeyExtent ne2, Text np2) {
 +    this.old_extent = old_extent;
 +    extents = new TreeMap<KeyExtent,Text>();
 +    extents.put(ne1, np1);
 +    extents.put(ne2, np2);
 +  }
 +  
 +  public void send(TCredentials credentials, String serverName, 
MasterClientService.Iface client) throws TException, ThriftSecurityException {
 +    TabletSplit split = new TabletSplit();
 +    split.oldTablet = old_extent.toThrift();
-     split.newTablets = Translator.translate(extents.keySet(), Translator.KET);
++    split.newTablets = Translator.translate(extents.keySet(), 
Translators.KET);
 +    client.reportSplitExtent(Tracer.traceInfo(), credentials, serverName, 
split);
 +  }
 +  
 +}

Reply via email to