Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id C2FC3200B45 for ; Fri, 1 Jul 2016 03:59:01 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id C1D05160A52; Fri, 1 Jul 2016 01:59:01 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 5343D160A72 for ; Fri, 1 Jul 2016 03:58:59 +0200 (CEST) Received: (qmail 70994 invoked by uid 500); 1 Jul 2016 01:58:58 -0000 Mailing-List: contact commits-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list commits@accumulo.apache.org Received: (qmail 70718 invoked by uid 99); 1 Jul 2016 01:58:58 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Jul 2016 01:58:58 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 1B617E38AD; Fri, 1 Jul 2016 01:58:58 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: ctubbsii@apache.org To: commits@accumulo.apache.org Date: Fri, 01 Jul 2016 01:59:02 -0000 Message-Id: <92449e447d1a4e379357c33d8df2e79c@git.apache.org> In-Reply-To: <564c5b739f274484a0df4b80e4d99b65@git.apache.org> References: <564c5b739f274484a0df4b80e4d99b65@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [05/32] accumulo git commit: ACCUMULO-4357 Remove unneeded code for readability archived-at: Fri, 01 Jul 2016 01:59:01 -0000 http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/CompactionQueue.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/CompactionQueue.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/CompactionQueue.java index f87131e..3d820dd 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/CompactionQueue.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/CompactionQueue.java @@ -33,7 +33,7 @@ import org.apache.htrace.wrappers.TraceRunnable; */ class CompactionQueue extends AbstractQueue implements BlockingQueue { - private List task = new LinkedList(); + private List task = new LinkedList<>(); private static final Comparator comparator = new Comparator() { @SuppressWarnings("unchecked") http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/ConditionalMutationSet.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/ConditionalMutationSet.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/ConditionalMutationSet.java index 82e5057..e1a8de8 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/ConditionalMutationSet.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/ConditionalMutationSet.java @@ -54,8 +54,8 @@ public class ConditionalMutationSet { static void defer(Map> updates, Map> deferredMutations, DeferFilter filter) { for (Entry> entry : updates.entrySet()) { List scml = entry.getValue(); - List okMutations = new ArrayList(scml.size()); - List deferred = new ArrayList(); + List okMutations = new ArrayList<>(scml.size()); + List deferred = new ArrayList<>(); filter.defer(scml, okMutations, deferred); if (deferred.size() > 0) { http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/FileManager.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/FileManager.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/FileManager.java index 699b5a7..8bc0fed 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/FileManager.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/FileManager.java @@ -125,7 +125,7 @@ public class FileManager { long curTime = System.currentTimeMillis(); - ArrayList filesToClose = new ArrayList(); + ArrayList filesToClose = new ArrayList<>(); // determine which files to close in a sync block, and then close the // files outside of the sync block @@ -176,8 +176,8 @@ public class FileManager { this.maxOpen = maxOpen; this.fs = fs; - this.openFiles = new HashMap>(); - this.reservedReaders = new HashMap(); + this.openFiles = new HashMap<>(); + this.reservedReaders = new HashMap<>(); this.maxIdleTime = context.getConfiguration().getTimeInMillis(Property.TSERV_MAX_IDLE); SimpleTimer.getInstance(context.getConfiguration()).schedule(new IdleFileCloser(), maxIdleTime, maxIdleTime / 2); @@ -196,7 +196,7 @@ public class FileManager { private List takeLRUOpenFiles(int numToTake) { - ArrayList openReaders = new ArrayList(); + ArrayList openReaders = new ArrayList<>(); for (Entry> entry : openFiles.entrySet()) { openReaders.addAll(entry.getValue()); @@ -204,7 +204,7 @@ public class FileManager { Collections.sort(openReaders); - ArrayList ret = new ArrayList(); + ArrayList ret = new ArrayList<>(); for (int i = 0; i < numToTake && i < openReaders.size(); i++) { OpenReader or = openReaders.get(i); @@ -227,7 +227,7 @@ public class FileManager { private static List getFileList(String file, Map> files) { List ofl = files.get(file); if (ofl == null) { - ofl = new ArrayList(); + ofl = new ArrayList<>(); files.put(file, ofl); } @@ -245,7 +245,7 @@ public class FileManager { } private List takeOpenFiles(Collection files, List reservedFiles, Map readersReserved) { - List filesToOpen = new LinkedList(files); + List filesToOpen = new LinkedList<>(files); for (Iterator iterator = filesToOpen.iterator(); iterator.hasNext();) { String file = iterator.next(); @@ -280,8 +280,8 @@ public class FileManager { List filesToOpen = null; List filesToClose = Collections.emptyList(); - List reservedFiles = new ArrayList(); - Map readersReserved = new HashMap(); + List reservedFiles = new ArrayList<>(); + Map readersReserved = new HashMap<>(); if (!tablet.isMeta()) { filePermits.acquireUninterruptibly(files.size()); @@ -401,7 +401,7 @@ public class FileManager { FileDataSource(String file, SortedKeyValueIterator iter) { this.file = file; this.iter = iter; - this.deepCopies = new ArrayList(); + this.deepCopies = new ArrayList<>(); } public FileDataSource(IteratorEnvironment env, SortedKeyValueIterator deepCopy, ArrayList deepCopies) { @@ -470,8 +470,8 @@ public class FileManager { private boolean continueOnFailure; ScanFileManager(KeyExtent tablet) { - tabletReservedReaders = new ArrayList(); - dataSources = new ArrayList(); + tabletReservedReaders = new ArrayList<>(); + dataSources = new ArrayList<>(); this.tablet = tablet; continueOnFailure = context.getServerConfigurationFactory().getTableConfiguration(tablet).getBoolean(Property.TABLE_FAILURES_IGNORE); @@ -482,7 +482,7 @@ public class FileManager { } private List openFileRefs(Collection files) throws TooManyFilesException, IOException { - List strings = new ArrayList(files.size()); + List strings = new ArrayList<>(files.size()); for (FileRef ref : files) strings.add(ref.path().toString()); return openFiles(strings); @@ -508,7 +508,7 @@ public class FileManager { List newlyReservedReaders = openFileRefs(files.keySet()); - ArrayList iters = new ArrayList(); + ArrayList iters = new ArrayList<>(); for (FileSKVIterator reader : newlyReservedReaders) { String filename = getReservedReadeFilename(reader); @@ -554,17 +554,17 @@ public class FileManager { if (tabletReservedReaders.size() != 0) throw new IllegalStateException(); - Collection files = new ArrayList(); + Collection files = new ArrayList<>(); for (FileDataSource fds : dataSources) files.add(fds.file); List newlyReservedReaders = openFiles(files); - Map> map = new HashMap>(); + Map> map = new HashMap<>(); for (FileSKVIterator reader : newlyReservedReaders) { String fileName = getReservedReadeFilename(reader); List list = map.get(fileName); if (list == null) { - list = new LinkedList(); + list = new LinkedList<>(); map.put(fileName, list); } http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java index a87586b..c1ae9e6 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/InMemoryMap.java @@ -297,7 +297,7 @@ public class InMemoryMap { this.groupFams = new PreAllocatedArray<>(groups.size()); this.maps = new SimpleMap[groups.size() + 1]; this.partitioned = new PreAllocatedArray<>(groups.size() + 1); - this.nonDefaultColumnFamilies = new HashSet(); + this.nonDefaultColumnFamilies = new HashSet<>(); for (int i = 0; i < maps.length; i++) { maps[i] = newMap(useNativeMap); @@ -305,7 +305,7 @@ public class InMemoryMap { int count = 0; for (Set cfset : groups.values()) { - HashMap map = new HashMap(); + HashMap map = new HashMap<>(); for (ByteSequence bs : cfset) map.put(bs, new MutableLong(1)); this.groupFams.set(count++, map); @@ -394,7 +394,7 @@ public class InMemoryMap { } private static class DefaultMap implements SimpleMap { - private ConcurrentSkipListMap map = new ConcurrentSkipListMap(new MemKeyComparator()); + private ConcurrentSkipListMap map = new ConcurrentSkipListMap<>(new MemKeyComparator()); private AtomicLong bytesInMemory = new AtomicLong(); private AtomicInteger size = new AtomicInteger(); @@ -809,7 +809,7 @@ public class InMemoryMap { InterruptibleIterator iter = map.skvIterator(null); - HashSet allfams = new HashSet(); + HashSet allfams = new HashSet<>(); for (Entry> entry : lggroups.entrySet()) { allfams.addAll(entry.getValue()); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/NativeMap.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/NativeMap.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/NativeMap.java index 3c00b67..00f6ba8 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/NativeMap.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/NativeMap.java @@ -69,7 +69,7 @@ public class NativeMap implements Iterable> { // Load native library static { // Check standard directories - List directories = new ArrayList(Arrays.asList(new File[] {new File("/usr/lib64"), new File("/usr/lib")})); + List directories = new ArrayList<>(Arrays.asList(new File[] {new File("/usr/lib64"), new File("/usr/lib")})); // Check in ACCUMULO_HOME location, too String envAccumuloHome = System.getenv("ACCUMULO_HOME"); if (envAccumuloHome != null) { @@ -106,7 +106,7 @@ public class NativeMap implements Iterable> { public static void loadNativeLib(List searchPath) { if (!isLoaded()) { List names = getValidLibraryNames(); - List tryList = new ArrayList(searchPath.size() * names.size()); + List tryList = new ArrayList<>(searchPath.size() * names.size()); for (File p : searchPath) if (p.exists() && p.isDirectory()) @@ -131,7 +131,7 @@ public class NativeMap implements Iterable> { } private static List getValidLibraryNames() { - ArrayList names = new ArrayList(3); + ArrayList names = new ArrayList<>(3); String libname = System.mapLibraryName("accumulo"); names.add(libname); @@ -199,7 +199,7 @@ public class NativeMap implements Iterable> { private static synchronized long createNativeMap() { if (!init) { - allocatedNativeMaps = new HashSet(); + allocatedNativeMaps = new HashSet<>(); Runnable r = new Runnable() { @Override @@ -452,7 +452,7 @@ public class NativeMap implements Iterable> { hasNext = nmiNext(nmiPointer, fieldsLens); - return new SimpleImmutableEntry(k, v); + return new SimpleImmutableEntry<>(k, v); } @Override http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/RowLocks.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/RowLocks.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/RowLocks.java index 03707d1..62f321e 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/RowLocks.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/RowLocks.java @@ -34,7 +34,7 @@ import org.apache.accumulo.tserver.data.ServerConditionalMutation; */ class RowLocks { - private Map rowLocks = new HashMap(); + private Map rowLocks = new HashMap<>(); static class RowLock { ReentrantLock rlock; @@ -82,7 +82,7 @@ class RowLocks { } List acquireRowlocks(Map> updates, Map> deferred) { - ArrayList locks = new ArrayList(); + ArrayList locks = new ArrayList<>(); // assume that mutations are in sorted order to avoid deadlock synchronized (rowLocks) { @@ -100,7 +100,7 @@ class RowLocks { for (RowLock rowLock : locks) { if (!rowLock.tryLock()) { if (rowsNotLocked == null) - rowsNotLocked = new HashSet(); + rowsNotLocked = new HashSet<>(); rowsNotLocked.add(rowLock.rowSeq); } } @@ -126,8 +126,8 @@ class RowLocks { } }); - ArrayList filteredLocks = new ArrayList(); - ArrayList locksToReturn = new ArrayList(); + ArrayList filteredLocks = new ArrayList<>(); + ArrayList locksToReturn = new ArrayList<>(); for (RowLock rowLock : locks) { if (rowsNotLocked.contains(rowLock.rowSeq)) { locksToReturn.add(rowLock); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletIteratorEnvironment.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletIteratorEnvironment.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletIteratorEnvironment.java index f9081b4..445391e 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletIteratorEnvironment.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletIteratorEnvironment.java @@ -97,7 +97,7 @@ public class TabletIteratorEnvironment implements IteratorEnvironment { this.config = config; this.fullMajorCompaction = fullMajC; this.authorizations = Authorizations.EMPTY; - this.topLevelIterators = new ArrayList>(); + this.topLevelIterators = new ArrayList<>(); } @Override @@ -138,7 +138,7 @@ public class TabletIteratorEnvironment implements IteratorEnvironment { public SortedKeyValueIterator getTopLevelIterator(SortedKeyValueIterator iter) { if (topLevelIterators.isEmpty()) return iter; - ArrayList> allIters = new ArrayList>(topLevelIterators); + ArrayList> allIters = new ArrayList<>(topLevelIterators); allIters.add(iter); return new MultiIterator(allIters, false); } http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java index 5626f12..94e2ed9 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServer.java @@ -301,7 +301,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { private final TabletServerResourceManager resourceManager; private final SecurityOperation security; - private final BlockingDeque masterMessages = new LinkedBlockingDeque(); + private final BlockingDeque masterMessages = new LinkedBlockingDeque<>(); private Thread majorCompactorThread; @@ -430,12 +430,12 @@ public class TabletServer extends AccumuloServerContext implements Runnable { if (!security.canPerformSystemActions(credentials)) throw new ThriftSecurityException(credentials.getPrincipal(), SecurityErrorCode.PERMISSION_DENIED); - List failures = new ArrayList(); + List failures = new ArrayList<>(); for (Entry> entry : files.entrySet()) { TKeyExtent tke = entry.getKey(); Map fileMap = entry.getValue(); - Map fileRefMap = new HashMap(); + Map fileRefMap = new HashMap<>(); for (Entry mapping : fileMap.entrySet()) { Path path = new Path(mapping.getKey()); FileSystem ns = fs.getVolumeByPath(path).getFileSystem(); @@ -491,7 +491,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { if (tablet == null) throw new NotServingTabletException(textent); - Set columnSet = new HashSet(); + Set columnSet = new HashSet<>(); for (TColumn tcolumn : columns) { columnSet.add(new Column(tcolumn)); } @@ -616,7 +616,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { List ssiList, Map> ssio, List authorizations, boolean waitForWrites, TSamplerConfiguration tSamplerConfig, long batchTimeOut, String context) throws ThriftSecurityException, TSampleNotPresentException { // find all of the tables that need to be scanned - final HashSet tables = new HashSet(); + final HashSet tables = new HashSet<>(); for (TKeyExtent keyExtent : tbatch.keySet()) { tables.add(new String(keyExtent.getTable(), UTF_8)); } @@ -636,8 +636,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { log.error("{} is not authorized", credentials.getPrincipal(), tse); throw tse; } - Map> batch = Translator.translate(tbatch, new TKeyExtentTranslator(), new Translator.ListTranslator( - new TRangeTranslator())); + Map> batch = Translator.translate(tbatch, new TKeyExtentTranslator(), new Translator.ListTranslator<>(new TRangeTranslator())); // This is used to determine which thread pool to use KeyExtent threadPoolExtent = batch.keySet().iterator().next(); @@ -839,7 +838,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { private void flush(UpdateSession us) { int mutationCount = 0; - Map sendables = new HashMap(); + Map sendables = new HashMap<>(); Throwable error = null; long pt1 = System.currentTimeMillis(); @@ -1117,7 +1116,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { results.add(new TCMResult(scm.getID(), TCMStatus.IGNORED)); iter.remove(); } else { - final List okMutations = new ArrayList(entry.getValue().size()); + final List okMutations = new ArrayList<>(entry.getValue().size()); final List resultsSubList = results.subList(results.size(), results.size()); ConditionChecker checker = checkerContext.newChecker(entry.getValue(), okMutations, resultsSubList); @@ -1145,7 +1144,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { private void writeConditionalMutations(Map> updates, ArrayList results, ConditionalSession sess) { Set>> es = updates.entrySet(); - Map sendables = new HashMap(); + Map sendables = new HashMap<>(); boolean sessionCanceled = sess.interruptFlag.get(); @@ -1239,7 +1238,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { // sort each list of mutations, this is done to avoid deadlock and doing seeks in order is more efficient and detect duplicate rows. ConditionalMutationSet.sortConditionalMutations(updates); - Map> deferred = new HashMap>(); + Map> deferred = new HashMap<>(); // can not process two mutations for the same row, because one will not see what the other writes ConditionalMutationSet.deferDuplicatesRows(updates, deferred); @@ -1309,14 +1308,14 @@ public class TabletServer extends AccumuloServerContext implements Runnable { long opid = writeTracker.startWrite(TabletType.type(new KeyExtent(tid, null, null))); try { - Map> updates = Translator.translate(mutations, Translators.TKET, - new Translator.ListTranslator(ServerConditionalMutation.TCMT)); + Map> updates = Translator.translate(mutations, Translators.TKET, new Translator.ListTranslator<>( + ServerConditionalMutation.TCMT)); for (KeyExtent ke : updates.keySet()) if (!ke.getTableId().equals(tid)) throw new IllegalArgumentException("Unexpected table id " + tid + " != " + ke.getTableId()); - ArrayList results = new ArrayList(); + ArrayList results = new ArrayList<>(); Map> deferred = conditionalUpdate(cs, updates, results, symbols); @@ -1396,9 +1395,9 @@ public class TabletServer extends AccumuloServerContext implements Runnable { public List getTabletStats(TInfo tinfo, TCredentials credentials, String tableId) throws ThriftSecurityException, TException { TreeMap onlineTabletsCopy; synchronized (onlineTablets) { - onlineTabletsCopy = new TreeMap(onlineTablets); + onlineTabletsCopy = new TreeMap<>(onlineTablets); } - List result = new ArrayList(); + List result = new ArrayList<>(); String text = tableId; KeyExtent start = new KeyExtent(text, new Text(), null); for (Entry entry : onlineTabletsCopy.tailMap(start).entrySet()) { @@ -1490,7 +1489,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { Set openingOverlapping = KeyExtent.findOverlapping(extent, openingTablets); Set onlineOverlapping = KeyExtent.findOverlapping(extent, onlineTablets); - Set all = new HashSet(); + Set all = new HashSet<>(); all.addAll(unopenedOverlapping); all.addAll(openingOverlapping); all.addAll(onlineOverlapping); @@ -1572,7 +1571,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { throw new RuntimeException(e); } - ArrayList tabletsToFlush = new ArrayList(); + ArrayList tabletsToFlush = new ArrayList<>(); KeyExtent ke = new KeyExtent(tableId, ByteBufferUtil.toText(endRow), ByteBufferUtil.toText(startRow)); @@ -1694,7 +1693,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { KeyExtent ke = new KeyExtent(tableId, ByteBufferUtil.toText(endRow), ByteBufferUtil.toText(startRow)); - ArrayList tabletsToCompact = new ArrayList(); + ArrayList tabletsToCompact = new ArrayList<>(); synchronized (onlineTablets) { for (Tablet tablet : onlineTablets.values()) if (ke.overlaps(tablet.getExtent())) @@ -1728,7 +1727,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { } List compactions = Compactor.getRunningCompactions(); - List ret = new ArrayList(compactions.size()); + List ret = new ArrayList<>(compactions.size()); for (CompactionInfo compactionInfo : compactions) { ret.add(compactionInfo.toThrift()); @@ -1805,7 +1804,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { try { sleepUninterruptibly(getConfiguration().getTimeInMillis(Property.TSERV_MAJC_DELAY), TimeUnit.MILLISECONDS); - TreeMap copyOnlineTablets = new TreeMap(); + TreeMap copyOnlineTablets = new TreeMap<>(); synchronized (onlineTablets) { copyOnlineTablets.putAll(onlineTablets); // avoid @@ -2078,7 +2077,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { // check Metadata table before accepting assignment Text locationToOpen = null; - SortedMap tabletsKeyValues = new TreeMap(); + SortedMap tabletsKeyValues = new TreeMap<>(); try { Pair pair = verifyTabletInformation(TabletServer.this, extent, TabletServer.this.getTabletSession(), tabletsKeyValues, getClientAddressString(), getLock()); @@ -2089,7 +2088,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { openingTablets.remove(extent); openingTablets.notifyAll(); // it expected that the new extent will overlap the old one... if it does not, it should not be added to unopenedTablets - if (!KeyExtent.findOverlapping(extent, new TreeSet(Arrays.asList(pair.getSecond()))).contains(pair.getSecond())) { + if (!KeyExtent.findOverlapping(extent, new TreeSet<>(Arrays.asList(pair.getSecond()))).contains(pair.getSecond())) { throw new IllegalStateException("Fixed split does not overlap " + extent + " " + pair.getSecond()); } unopenedTablets.add(pair.getSecond()); @@ -2264,9 +2263,9 @@ public class TabletServer extends AccumuloServerContext implements Runnable { final Processor processor; if (ThriftServerType.SASL == getThriftServerType()) { Iface tcredProxy = TCredentialsUpdatingWrapper.service(rpcProxy, ThriftClientHandler.class, getConfiguration()); - processor = new Processor(tcredProxy); + processor = new Processor<>(tcredProxy); } else { - processor = new Processor(rpcProxy); + processor = new Processor<>(rpcProxy); } HostAndPort address = startServer(getServerConfigurationFactory().getConfiguration(), clientAddress.getHostText(), Property.TSERV_CLIENTPORT, processor, "Thrift Client Server"); @@ -2278,7 +2277,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { final ReplicationServicerHandler handler = new ReplicationServicerHandler(this); ReplicationServicer.Iface rpcProxy = RpcWrapper.service(handler, new ReplicationServicer.Processor(handler)); ReplicationServicer.Iface repl = TCredentialsUpdatingWrapper.service(rpcProxy, handler.getClass(), getConfiguration()); - ReplicationServicer.Processor processor = new ReplicationServicer.Processor(repl); + ReplicationServicer.Processor processor = new ReplicationServicer.Processor<>(repl); AccumuloConfiguration conf = getServerConfigurationFactory().getConfiguration(); Property maxMessageSizeProperty = (conf.get(Property.TSERV_MAX_MESSAGE_SIZE) != null ? Property.TSERV_MAX_MESSAGE_SIZE : Property.GENERAL_MAX_MESSAGE_SIZE); ServerAddress sp = TServerUtils.startServer(this, clientAddress.getHostText(), Property.REPLICATION_RECEIPT_SERVICE_PORT, processor, @@ -2574,7 +2573,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { } try { - return new Pair(new Text(MetadataTableUtil.getRootTabletDir()), null); + return new Pair<>(new Text(MetadataTableUtil.getRootTabletDir()), null); } catch (IOException e) { throw new AccumuloException(e); } @@ -2595,7 +2594,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { TabletsSection.TabletColumnFamily.PREV_ROW_COLUMN, TabletsSection.TabletColumnFamily.SPLIT_RATIO_COLUMN, TabletsSection.TabletColumnFamily.OLD_PREV_ROW_COLUMN, TabletsSection.ServerColumnFamily.TIME_COLUMN}); - TreeMap tkv = new TreeMap(); + TreeMap tkv = new TreeMap<>(); try (ScannerImpl scanner = new ScannerImpl(context, tableToVerify, Authorizations.EMPTY)) { scanner.setRange(extent.toMetadataRange()); for (Entry entry : scanner) @@ -2636,7 +2635,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { } if (!fke.equals(extent)) { - return new Pair(null, fke); + return new Pair<>(null, fke); } // reread and reverify metadata entries now that metadata entries were fixed @@ -2644,7 +2643,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { return verifyTabletInformation(context, fke, instance, tabletsKeyValues, clientAddress, lock); } - return new Pair(new Text(dir.get()), null); + return new Pair<>(new Text(dir.get()), null); } static Value checkTabletMetadata(KeyExtent extent, TServerInstance instance, SortedMap tabletsKeyValues, Text metadataEntry) @@ -2759,7 +2758,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { public void run() { Set contextProperties = getServerConfigurationFactory().getConfiguration().getAllPropertiesWithPrefix(Property.VFS_CONTEXT_CLASSPATH_PROPERTY) .keySet(); - Set configuredContexts = new HashSet(); + Set configuredContexts = new HashSet<>(); for (String prop : contextProperties) { configuredContexts.add(prop.substring(Property.VFS_CONTEXT_CLASSPATH_PROPERTY.name().length())); } @@ -2793,7 +2792,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { ArrayList tablets; synchronized (onlineTablets) { - tablets = new ArrayList(onlineTablets.values()); + tablets = new ArrayList<>(onlineTablets.values()); } for (Tablet tablet : tablets) { @@ -2810,9 +2809,9 @@ public class TabletServer extends AccumuloServerContext implements Runnable { Map onlineTabletsCopy; synchronized (this.onlineTablets) { - onlineTabletsCopy = new HashMap(this.onlineTablets); + onlineTabletsCopy = new HashMap<>(this.onlineTablets); } - Map tables = new HashMap(); + Map tables = new HashMap<>(); for (Entry entry : onlineTabletsCopy.entrySet()) { String tableId = entry.getKey().getTableId(); @@ -2859,7 +2858,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { table.scans.running += entry.getValue().get(ScanRunState.RUNNING); } - ArrayList offlineTabletsCopy = new ArrayList(); + ArrayList offlineTabletsCopy = new ArrayList<>(); synchronized (this.unopenedTablets) { synchronized (this.openingTablets) { offlineTabletsCopy.addAll(this.unopenedTablets); @@ -2955,8 +2954,8 @@ public class TabletServer extends AccumuloServerContext implements Runnable { public void recover(VolumeManager fs, KeyExtent extent, TableConfiguration tconf, List logEntries, Set tabletFiles, MutationReceiver mutationReceiver) throws IOException { - List recoveryLogs = new ArrayList(); - List sorted = new ArrayList(logEntries); + List recoveryLogs = new ArrayList<>(); + List sorted = new ArrayList<>(logEntries); Collections.sort(sorted, new Comparator() { @Override public int compare(LogEntry e1, LogEntry e2) { @@ -3007,7 +3006,7 @@ public class TabletServer extends AccumuloServerContext implements Runnable { public Collection getOnlineTablets() { synchronized (onlineTablets) { - return new ArrayList(onlineTablets.values()); + return new ArrayList<>(onlineTablets.values()); } } http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java index b3b02ea..97606ea 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java @@ -84,7 +84,7 @@ public class TabletServerResourceManager { private final ExecutorService assignMetaDataPool; private final ExecutorService readAheadThreadPool; private final ExecutorService defaultReadAheadThreadPool; - private final Map threadPools = new TreeMap(); + private final Map threadPools = new TreeMap<>(); private final ConcurrentHashMap activeAssignments; @@ -207,7 +207,7 @@ public class TabletServerResourceManager { assignMetaDataPool = createEs(0, 1, 60, "metadata tablet assignment"); - activeAssignments = new ConcurrentHashMap(); + activeAssignments = new ConcurrentHashMap<>(); readAheadThreadPool = createEs(Property.TSERV_READ_AHEAD_MAXCONCURRENT, "tablet read ahead"); defaultReadAheadThreadPool = createEs(Property.TSERV_METADATA_READ_AHEAD_MAXCONCURRENT, "metadata tablets read ahead"); @@ -332,7 +332,7 @@ public class TabletServerResourceManager { MemoryManagementFramework() { tabletReports = Collections.synchronizedMap(new HashMap()); - memUsageReports = new LinkedBlockingQueue(); + memUsageReports = new LinkedBlockingQueue<>(); maxMem = conf.getConfiguration().getMemoryInBytes(Property.TSERV_MAXMEM); Runnable r1 = new Runnable() { @@ -408,7 +408,7 @@ public class TabletServerResourceManager { Map tabletReportsCopy = null; try { synchronized (tabletReports) { - tabletReportsCopy = new HashMap(tabletReports); + tabletReportsCopy = new HashMap<>(tabletReports); } ArrayList tabletStates = new ArrayList(tabletReportsCopy.values()); mma = memoryManager.getMemoryManagementActions(tabletStates); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/WriteTracker.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/WriteTracker.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/WriteTracker.java index db02526..c999c09 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/WriteTracker.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/WriteTracker.java @@ -39,7 +39,7 @@ class WriteTracker { private static final Logger log = LoggerFactory.getLogger(WriteTracker.class); private static final AtomicLong operationCounter = new AtomicLong(1); - private final Map> inProgressWrites = new EnumMap>(TabletType.class); + private final Map> inProgressWrites = new EnumMap<>(TabletType.class); WriteTracker() { for (TabletType ttype : TabletType.values()) { @@ -87,7 +87,7 @@ class WriteTracker { if (keySet.size() == 0) return -1; - List extents = new ArrayList(keySet.size()); + List extents = new ArrayList<>(keySet.size()); for (Tablet tablet : keySet) extents.add(tablet.getExtent()); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/CompactionPlan.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/CompactionPlan.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/CompactionPlan.java index 8f98761..845d779 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/CompactionPlan.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/CompactionPlan.java @@ -31,8 +31,8 @@ import com.google.common.collect.Sets; * create the resulting output file. */ public class CompactionPlan { - public final List inputFiles = new ArrayList(); - public final List deleteFiles = new ArrayList(); + public final List inputFiles = new ArrayList<>(); + public final List deleteFiles = new ArrayList<>(); public WriteParameters writeParameters = null; @Override @@ -67,8 +67,8 @@ public class CompactionPlan { * thrown when validation fails. */ public final void validate(Set allFiles) { - Set inputSet = new HashSet(inputFiles); - Set deleteSet = new HashSet(deleteFiles); + Set inputSet = new HashSet<>(inputFiles); + Set deleteSet = new HashSet<>(deleteFiles); if (!allFiles.containsAll(inputSet)) { inputSet.removeAll(allFiles); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/DefaultCompactionStrategy.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/DefaultCompactionStrategy.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/DefaultCompactionStrategy.java index 1f0dc3a..faf9534 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/DefaultCompactionStrategy.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/DefaultCompactionStrategy.java @@ -60,16 +60,16 @@ public class DefaultCompactionStrategy extends CompactionStrategy { private List findMapFilesToCompact(MajorCompactionRequest request) { MajorCompactionReason reason = request.getReason(); if (reason == MajorCompactionReason.USER) { - return new ArrayList(request.getFiles().keySet()); + return new ArrayList<>(request.getFiles().keySet()); } if (reason == MajorCompactionReason.CHOP) { // should not happen, but this is safe - return new ArrayList(request.getFiles().keySet()); + return new ArrayList<>(request.getFiles().keySet()); } if (request.getFiles().size() <= 1) return null; - TreeSet candidateFiles = new TreeSet(new Comparator() { + TreeSet candidateFiles = new TreeSet<>(new Comparator() { @Override public int compare(CompactionFile o1, CompactionFile o2) { if (o1 == o2) @@ -95,7 +95,7 @@ public class DefaultCompactionStrategy extends CompactionStrategy { totalSize += mfi.size; } - List files = new ArrayList(); + List files = new ArrayList<>(); while (candidateFiles.size() > 1) { CompactionFile max = candidateFiles.last(); @@ -121,7 +121,7 @@ public class DefaultCompactionStrategy extends CompactionStrategy { if (files.size() < totalFilesToCompact) { - TreeMap tfc = new TreeMap(); + TreeMap tfc = new TreeMap<>(); for (Entry entry : request.getFiles().entrySet()) { tfc.put(entry.getKey(), entry.getValue().getSize()); } http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/SizeLimitCompactionStrategy.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/SizeLimitCompactionStrategy.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/SizeLimitCompactionStrategy.java index 6cc9025..69e3269 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/SizeLimitCompactionStrategy.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/compaction/SizeLimitCompactionStrategy.java @@ -39,7 +39,7 @@ public class SizeLimitCompactionStrategy extends DefaultCompactionStrategy { } private MajorCompactionRequest filterFiles(MajorCompactionRequest mcr) { - Map filteredFiles = new HashMap(); + Map filteredFiles = new HashMap<>(); for (Entry entry : mcr.getFiles().entrySet()) { if (entry.getValue().getSize() <= limit) { filteredFiles.put(entry.getKey(), entry.getValue()); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/constraints/ConstraintChecker.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/constraints/ConstraintChecker.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/constraints/ConstraintChecker.java index 13e7c4f..9d065c7 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/constraints/ConstraintChecker.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/constraints/ConstraintChecker.java @@ -47,7 +47,7 @@ public class ConstraintChecker { private AtomicLong lastCheck = new AtomicLong(0); public ConstraintChecker(TableConfiguration conf) { - constrains = new ArrayList(); + constrains = new ArrayList<>(); this.conf = conf; http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java index d8a4dc6..5280d41 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/DfsLogger.java @@ -134,7 +134,7 @@ public class DfsLogger implements Comparable { VolumeManager getFileSystem(); } - private final LinkedBlockingQueue workQueue = new LinkedBlockingQueue(); + private final LinkedBlockingQueue workQueue = new LinkedBlockingQueue<>(); private final Object closeLock = new Object(); @@ -149,7 +149,7 @@ public class DfsLogger implements Comparable { @Override public void run() { - ArrayList work = new ArrayList(); + ArrayList work = new ArrayList<>(); boolean sawClosedMarker = false; while (!sawClosedMarker) { work.clear(); @@ -375,7 +375,7 @@ public class DfsLogger implements Comparable { // If it's null, we won't have any parameters whatsoever. First, let's attempt to read // parameters - Map opts = new HashMap(); + Map opts = new HashMap<>(); int count = input.readInt(); for (int i = 0; i < count; i++) { String key = input.readUTF(); @@ -628,7 +628,7 @@ public class DfsLogger implements Comparable { public LoggerOperation logManyTablets(List mutations) throws IOException { Durability durability = Durability.NONE; - List> data = new ArrayList>(); + List> data = new ArrayList<>(); for (TabletMutations tabletMutations : mutations) { LogFileKey key = new LogFileKey(); key.event = MANY_MUTATIONS; @@ -636,7 +636,7 @@ public class DfsLogger implements Comparable { key.tid = tabletMutations.getTid(); LogFileValue value = new LogFileValue(); value.mutations = tabletMutations.getMutations(); - data.add(new Pair(key, value)); + data.add(new Pair<>(key, value)); if (tabletMutations.getDurability().ordinal() > durability.ordinal()) { durability = tabletMutations.getDurability(); } @@ -659,7 +659,7 @@ public class DfsLogger implements Comparable { key.event = COMPACTION_FINISH; key.seq = seq; key.tid = tid; - return logFileData(Collections.singletonList(new Pair(key, EMPTY)), durability); + return logFileData(Collections.singletonList(new Pair<>(key, EMPTY)), durability); } public LoggerOperation minorCompactionStarted(int seq, int tid, String fqfn, Durability durability) throws IOException { @@ -668,7 +668,7 @@ public class DfsLogger implements Comparable { key.seq = seq; key.tid = tid; key.filename = fqfn; - return logFileData(Collections.singletonList(new Pair(key, EMPTY)), durability); + return logFileData(Collections.singletonList(new Pair<>(key, EMPTY)), durability); } public String getLogger() { http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java index f152f9c..11097ce 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java @@ -132,7 +132,7 @@ public class LogSorter { final long bufferSize = conf.getMemoryInBytes(Property.TSERV_SORT_BUFFER_SIZE); Thread.currentThread().setName("Sorting " + name + " for recovery"); while (true) { - final ArrayList> buffer = new ArrayList>(); + final ArrayList> buffer = new ArrayList<>(); try { long start = input.getPos(); while (input.getPos() - start < bufferSize) { @@ -140,7 +140,7 @@ public class LogSorter { LogFileValue value = new LogFileValue(); key.readFields(decryptingInput); value.readFields(decryptingInput); - buffer.add(new Pair(key, value)); + buffer.add(new Pair<>(key, value)); } writeBuffer(destPath, buffer, part++); buffer.clear(); @@ -236,7 +236,7 @@ public class LogSorter { } public List getLogSorts() { - List result = new ArrayList(); + List result = new ArrayList<>(); synchronized (currentWork) { for (Entry entries : currentWork.entrySet()) { RecoveryStatus status = new RecoveryStatus(); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/log/SortedLogRecovery.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/SortedLogRecovery.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/SortedLogRecovery.java index ab3dea2..3d403e0 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/SortedLogRecovery.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/SortedLogRecovery.java @@ -69,7 +69,7 @@ public class SortedLogRecovery { private enum Status { INITIAL, LOOKING_FOR_FINISH, COMPLETE - }; + } private static class LastStartToFinish { long lastStart = -1; @@ -152,7 +152,7 @@ public class SortedLogRecovery { int findLastStartToFinish(MultiReader reader, int fileno, KeyExtent extent, Set tabletFiles, LastStartToFinish lastStartToFinish) throws IOException, EmptyMapFileException, UnusedException { - HashSet suffixes = new HashSet(); + HashSet suffixes = new HashSet<>(); for (String path : tabletFiles) suffixes.add(getPathSuffix(path)); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java index 3b0f9d7..a4cd6b0 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/log/TabletServerLogger.java @@ -159,7 +159,7 @@ public class TabletServerLogger { } private DfsLogger initializeLoggers(final AtomicInteger logIdOut) throws IOException { - final AtomicReference result = new AtomicReference(); + final AtomicReference result = new AtomicReference<>(); testLockAndRun(logIdLock, new TestCallWithWriteLock() { @Override boolean test() { @@ -490,7 +490,7 @@ public class TabletServerLogger { public int logManyTablets(Map mutations) throws IOException { - final Map loggables = new HashMap(mutations); + final Map loggables = new HashMap<>(mutations); for (Entry entry : mutations.entrySet()) { if (entry.getValue().getDurability() == Durability.NONE) { loggables.remove(entry.getKey()); @@ -502,7 +502,7 @@ public class TabletServerLogger { int seq = write(loggables.keySet(), false, new Writer() { @Override public LoggerOperation write(DfsLogger logger, int ignored) throws Exception { - List copy = new ArrayList(loggables.size()); + List copy = new ArrayList<>(loggables.size()); for (Entry entry : loggables.entrySet()) { CommitSession cs = entry.getKey(); Durability durability = entry.getValue().getDurability(); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogFileValue.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogFileValue.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogFileValue.java index 87e17b3..f49eb71 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogFileValue.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogFileValue.java @@ -39,7 +39,7 @@ public class LogFileValue implements Writable { @Override public void readFields(DataInput in) throws IOException { int count = in.readInt(); - mutations = new ArrayList(count); + mutations = new ArrayList<>(count); for (int i = 0; i < count; i++) { ServerMutation mutation = new ServerMutation(); mutation.readFields(in); http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogReader.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogReader.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogReader.java index 01db8aa..d5a4db9 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogReader.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/logger/LogReader.java @@ -59,7 +59,7 @@ public class LogReader { @Parameter(names = "-p", description = "search for a row that matches the given regex") String regexp; @Parameter(description = " { ... }") - List files = new ArrayList(); + List files = new ArrayList<>(); } /** @@ -91,7 +91,7 @@ public class LogReader { rowMatcher = pattern.matcher(""); } - Set tabletIds = new HashSet(); + Set tabletIds = new HashSet<>(); for (String file : opts.files) { http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java index 589f07f..5808f2e 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/replication/AccumuloReplicaSystem.java @@ -691,7 +691,7 @@ public class AccumuloReplicaSystem implements ReplicaSystem { protected WalReplication getWalEdits(ReplicationTarget target, DataInputStream wal, Path p, Status status, long sizeLimit, Set desiredTids) throws IOException { WalEdits edits = new WalEdits(); - edits.edits = new ArrayList(); + edits.edits = new ArrayList<>(); long size = 0l; long entriesConsumed = 0l; long numUpdates = 0l; http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/LookupTask.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/LookupTask.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/LookupTask.java index 378e98d..139512f 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/LookupTask.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/LookupTask.java @@ -78,9 +78,9 @@ public class LookupTask extends ScanTask { long startTime = System.currentTimeMillis(); - List results = new ArrayList(); - Map> failures = new HashMap>(); - List fullScans = new ArrayList(); + List results = new ArrayList<>(); + Map> failures = new HashMap<>(); + List fullScans = new ArrayList<>(); KeyExtent partScan = null; Key partNextKey = null; boolean partNextKeyInclusive = false; @@ -146,10 +146,10 @@ public class LookupTask extends ScanTask { session.numEntries += results.size(); // convert everything to thrift before adding result - List retResults = new ArrayList(); + List retResults = new ArrayList<>(); for (KVEntry entry : results) retResults.add(new TKeyValue(entry.getKey().toThrift(), ByteBuffer.wrap(entry.getValue().get()))); - Map> retFailures = Translator.translate(failures, Translators.KET, new Translator.ListTranslator(Translators.RT)); + Map> retFailures = Translator.translate(failures, Translators.KET, new Translator.ListTranslator<>(Translators.RT)); List retFullScans = Translator.translate(fullScans, Translators.KET); TKeyExtent retPartScan = null; TKey retPartNextKey = null; http://git-wip-us.apache.org/repos/asf/accumulo/blob/b102e760/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java ---------------------------------------------------------------------- diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java index 6d5adce..cd99ba2 100644 --- a/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java +++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/scan/ScanTask.java @@ -43,9 +43,9 @@ public abstract class ScanTask implements RunnableFuture { ScanTask(TabletServer server) { this.server = server; interruptFlag = new AtomicBoolean(false); - runState = new AtomicReference(ScanRunState.QUEUED); + runState = new AtomicReference<>(ScanRunState.QUEUED); state = new AtomicInteger(INITIAL); - resultQueue = new ArrayBlockingQueue