accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [6/8] ACCUMULO-2408 organize static final members of abstract class to a concrete implementation
Date Wed, 26 Feb 2014 19:40:51 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/4e725160/server/tserver/src/main/java/org/apache/accumulo/tserver/mastermessage/SplitReportMessage.java
----------------------------------------------------------------------
diff --cc server/tserver/src/main/java/org/apache/accumulo/tserver/mastermessage/SplitReportMessage.java
index f71cbe2,0000000..2eb1077
mode 100644,000000..100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/mastermessage/SplitReportMessage.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/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.tserver.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);
 +  }
 +  
 +}


Mime
View raw message