You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2016/11/04 22:17:18 UTC
[41/48] accumulo git commit: ACCUMULO-4514 Remove unnecessary code
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/data/ValueTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/data/ValueTest.java b/core/src/test/java/org/apache/accumulo/core/data/ValueTest.java
index 81e7b08..80b7b3b 100644
--- a/core/src/test/java/org/apache/accumulo/core/data/ValueTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/data/ValueTest.java
@@ -201,7 +201,7 @@ public class ValueTest {
@Test
@Deprecated
public void testToArray() {
- List<byte[]> l = new java.util.ArrayList<byte[]>();
+ List<byte[]> l = new java.util.ArrayList<>();
byte[] one = toBytes("one");
byte[] two = toBytes("two");
byte[] three = toBytes("three");
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java b/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
index ca388e5..88ee8fe 100644
--- a/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/file/BloomFilterLayerLookupTest.java
@@ -59,12 +59,12 @@ public class BloomFilterLayerLookupTest {
@Test
public void test() throws IOException {
- HashSet<Integer> valsSet = new HashSet<Integer>();
+ HashSet<Integer> valsSet = new HashSet<>();
for (int i = 0; i < 100000; i++) {
valsSet.add(random.nextInt(Integer.MAX_VALUE));
}
- ArrayList<Integer> vals = new ArrayList<Integer>(valsSet);
+ ArrayList<Integer> vals = new ArrayList<>(valsSet);
Collections.sort(vals);
ConfigurationCopy acuconf = new ConfigurationCopy(AccumuloConfiguration.getDefaultConfiguration());
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/file/rfile/CreateCompatTestFile.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/file/rfile/CreateCompatTestFile.java b/core/src/test/java/org/apache/accumulo/core/file/rfile/CreateCompatTestFile.java
index 3eadc06..53c33d4 100644
--- a/core/src/test/java/org/apache/accumulo/core/file/rfile/CreateCompatTestFile.java
+++ b/core/src/test/java/org/apache/accumulo/core/file/rfile/CreateCompatTestFile.java
@@ -32,7 +32,7 @@ import org.apache.hadoop.fs.Path;
public class CreateCompatTestFile {
public static Set<ByteSequence> ncfs(String... colFams) {
- HashSet<ByteSequence> cfs = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> cfs = new HashSet<>();
for (String cf : colFams) {
cfs.add(new ArrayByteSequence(cf));
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/file/rfile/MultiThreadedRFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/file/rfile/MultiThreadedRFileTest.java b/core/src/test/java/org/apache/accumulo/core/file/rfile/MultiThreadedRFileTest.java
index a0efeed..69ff2d4 100644
--- a/core/src/test/java/org/apache/accumulo/core/file/rfile/MultiThreadedRFileTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/file/rfile/MultiThreadedRFileTest.java
@@ -60,7 +60,7 @@ import static org.junit.Assert.assertTrue;
public class MultiThreadedRFileTest {
private static final Logger LOG = Logger.getLogger(MultiThreadedRFileTest.class);
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
@Rule
public TemporaryFolder tempFolder = new TemporaryFolder(new File(System.getProperty("user.dir") + "/target"));
@@ -193,8 +193,8 @@ public class MultiThreadedRFileTest {
@Test
public void testMultipleReaders() throws IOException {
final List<Throwable> threadExceptions = Collections.synchronizedList(new ArrayList<Throwable>());
- Map<String,MutableInt> messages = new HashMap<String,MutableInt>();
- Map<String,String> stackTrace = new HashMap<String,String>();
+ Map<String,MutableInt> messages = new HashMap<>();
+ Map<String,String> stackTrace = new HashMap<>();
final TestRFile trfBase = new TestRFile(conf);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/file/rfile/RFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/file/rfile/RFileTest.java b/core/src/test/java/org/apache/accumulo/core/file/rfile/RFileTest.java
index 15729c5..c700e6b 100644
--- a/core/src/test/java/org/apache/accumulo/core/file/rfile/RFileTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/file/rfile/RFileTest.java
@@ -75,7 +75,7 @@ import com.google.common.primitives.Bytes;
public class RFileTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
@Rule
public TemporaryFolder tempFolder = new TemporaryFolder(new File(System.getProperty("user.dir") + "/target"));
@@ -326,8 +326,8 @@ public class RFileTest {
int val = 0;
- ArrayList<Key> expectedKeys = new ArrayList<Key>(10000);
- ArrayList<Value> expectedValues = new ArrayList<Value>(10000);
+ ArrayList<Key> expectedKeys = new ArrayList<>(10000);
+ ArrayList<Value> expectedValues = new ArrayList<>(10000);
for (int row = 0; row < 4; row++) {
String rowS = nf("r_", row);
@@ -750,7 +750,7 @@ public class RFileTest {
}
public static Set<ByteSequence> ncfs(String... colFams) {
- HashSet<ByteSequence> cfs = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> cfs = new HashSet<>();
for (String cf : colFams) {
cfs.add(new ArrayByteSequence(cf));
@@ -1348,7 +1348,7 @@ public class RFileTest {
}
private Set<ByteSequence> t18ncfs(int... colFams) {
- HashSet<ByteSequence> cfs = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> cfs = new HashSet<>();
for (int i : colFams) {
cfs.add(new ArrayByteSequence(t18ncf(i)));
}
@@ -1365,7 +1365,7 @@ public class RFileTest {
private void t18Verify(Set<ByteSequence> cfs, SortedKeyValueIterator<Key,Value> iter, Reader reader, HashSet<ByteSequence> allCf, int eialg, int eealg)
throws IOException {
- HashSet<ByteSequence> colFamsSeen = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> colFamsSeen = new HashSet<>();
iter.seek(new Range(), cfs, true);
assertEquals(eialg, reader.getNumLocalityGroupsSeeked());
@@ -1375,7 +1375,7 @@ public class RFileTest {
iter.next();
}
- HashSet<ByteSequence> expected = new HashSet<ByteSequence>(allCf);
+ HashSet<ByteSequence> expected = new HashSet<>(allCf);
expected.retainAll(cfs);
assertEquals(expected, colFamsSeen);
@@ -1388,7 +1388,7 @@ public class RFileTest {
iter.next();
}
- HashSet<ByteSequence> nonExcluded = new HashSet<ByteSequence>(allCf);
+ HashSet<ByteSequence> nonExcluded = new HashSet<>(allCf);
nonExcluded.removeAll(cfs);
assertEquals(nonExcluded, colFamsSeen);
}
@@ -1401,7 +1401,7 @@ public class RFileTest {
trf.openWriter(false);
- HashSet<ByteSequence> allCf = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> allCf = new HashSet<>();
trf.writer.startNewLocalityGroup("lg1", t18ncfs(0));
for (int i = 0; i < 1; i++)
@@ -1771,7 +1771,7 @@ public class RFileTest {
@Test
public void testBigKeys() throws IOException {
// this test ensures that big keys do not end up index
- ArrayList<Key> keys = new ArrayList<Key>();
+ ArrayList<Key> keys = new ArrayList<>();
for (int i = 0; i < 1000; i++) {
String row = String.format("r%06d", i);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/file/rfile/RelativeKeyTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/file/rfile/RelativeKeyTest.java b/core/src/test/java/org/apache/accumulo/core/file/rfile/RelativeKeyTest.java
index e413448..5e839e0 100644
--- a/core/src/test/java/org/apache/accumulo/core/file/rfile/RelativeKeyTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/file/rfile/RelativeKeyTest.java
@@ -121,9 +121,9 @@ public class RelativeKeyTest {
baos = new ByteArrayOutputStream();
DataOutputStream out = new DataOutputStream(baos);
- expectedKeys = new ArrayList<Key>(initialListSize);
- expectedValues = new ArrayList<Value>(initialListSize);
- expectedPositions = new ArrayList<Integer>(initialListSize);
+ expectedKeys = new ArrayList<>(initialListSize);
+ expectedValues = new ArrayList<>(initialListSize);
+ expectedPositions = new ArrayList<>(initialListSize);
Key prev = null;
int val = 0;
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/AggregatingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/AggregatingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/AggregatingIteratorTest.java
index e39d0d5..09064a5 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/AggregatingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/AggregatingIteratorTest.java
@@ -39,7 +39,7 @@ import org.junit.Test;
public class AggregatingIteratorTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
/**
* @deprecated since 1.4; visible only for testing
@@ -101,7 +101,7 @@ public class AggregatingIteratorTest {
@Test
public void test1() throws IOException {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that do not aggregate
nkv(tm1, 1, 1, 1, 1, false, "2");
@@ -162,7 +162,7 @@ public class AggregatingIteratorTest {
@SuppressWarnings("deprecation")
@Test
public void test2() throws IOException {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, "2");
@@ -171,7 +171,7 @@ public class AggregatingIteratorTest {
AggregatingIterator ai = new AggregatingIterator();
- Map<String,String> opts = new HashMap<String,String>();
+ Map<String,String> opts = new HashMap<>();
opts.put("cf001", SummationAggregator.class.getName());
@@ -224,7 +224,7 @@ public class AggregatingIteratorTest {
@Test
public void test3() throws IOException {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, "2");
@@ -237,7 +237,7 @@ public class AggregatingIteratorTest {
AggregatingIterator ai = new AggregatingIterator();
- Map<String,String> opts = new HashMap<String,String>();
+ Map<String,String> opts = new HashMap<>();
opts.put("cf001", SummationAggregator.class.getName());
@@ -290,7 +290,7 @@ public class AggregatingIteratorTest {
@Test
public void test4() throws IOException {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that do not aggregate
nkv(tm1, 0, 0, 1, 1, false, "7");
@@ -306,7 +306,7 @@ public class AggregatingIteratorTest {
AggregatingIterator ai = new AggregatingIterator();
- Map<String,String> opts = new HashMap<String,String>();
+ Map<String,String> opts = new HashMap<>();
opts.put("cf001", SummationAggregator.class.getName());
@@ -367,20 +367,20 @@ public class AggregatingIteratorTest {
// try aggregating across multiple data sets that contain
// the exact same keys w/ different values
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
nkv(tm1, 1, 1, 1, 1, false, "2");
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
nkv(tm2, 1, 1, 1, 1, false, "3");
- TreeMap<Key,Value> tm3 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm3 = new TreeMap<>();
nkv(tm3, 1, 1, 1, 1, false, "4");
AggregatingIterator ai = new AggregatingIterator();
- Map<String,String> opts = new HashMap<String,String>();
+ Map<String,String> opts = new HashMap<>();
opts.put("cf001", SummationAggregator.class.getName());
- List<SortedKeyValueIterator<Key,Value>> sources = new ArrayList<SortedKeyValueIterator<Key,Value>>(3);
+ List<SortedKeyValueIterator<Key,Value>> sources = new ArrayList<>(3);
sources.add(new SortedMapIterator(tm1));
sources.add(new SortedMapIterator(tm2));
sources.add(new SortedMapIterator(tm3));
@@ -397,7 +397,7 @@ public class AggregatingIteratorTest {
@SuppressWarnings("deprecation")
@Test
public void test6() throws IOException {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, "2");
@@ -406,7 +406,7 @@ public class AggregatingIteratorTest {
AggregatingIterator ai = new AggregatingIterator();
- Map<String,String> opts = new HashMap<String,String>();
+ Map<String,String> opts = new HashMap<>();
opts.put("cf001", SummationAggregator.class.getName());
@@ -425,7 +425,7 @@ public class AggregatingIteratorTest {
public void test7() throws IOException {
// test that delete is not aggregated
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
nkv(tm1, 1, 1, 1, 2, true, "");
nkv(tm1, 1, 1, 1, 3, false, "4");
@@ -433,7 +433,7 @@ public class AggregatingIteratorTest {
AggregatingIterator ai = new AggregatingIterator();
- Map<String,String> opts = new HashMap<String,String>();
+ Map<String,String> opts = new HashMap<>();
opts.put("cf001", SummationAggregator.class.getName());
@@ -453,7 +453,7 @@ public class AggregatingIteratorTest {
ai.next();
assertFalse(ai.hasTop());
- tm1 = new TreeMap<Key,Value>();
+ tm1 = new TreeMap<>();
nkv(tm1, 1, 1, 1, 2, true, "");
ai = new AggregatingIterator();
ai.init(new SortedMapIterator(tm1), opts, new DefaultIteratorEnvironment());
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowIteratorTest.java
index 74f7462..53c7abb 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowIteratorTest.java
@@ -84,12 +84,12 @@ public class FirstEntryInRowIteratorTest {
@Test
public void test() throws IOException {
- TreeMap<Key,Value> sourceMap = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> sourceMap = new TreeMap<>();
Value emptyValue = new Value("".getBytes());
sourceMap.put(new Key("r1", "cf", "cq"), emptyValue);
sourceMap.put(new Key("r2", "cf", "cq"), emptyValue);
sourceMap.put(new Key("r3", "cf", "cq"), emptyValue);
- TreeMap<Key,Value> resultMap = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> resultMap = new TreeMap<>();
long numSourceEntries = sourceMap.size();
long numNexts = process(sourceMap, resultMap, new Range(), 10);
assertEquals(numNexts, numSourceEntries);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowTest.java
index 8214c2c..9a5174b 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/FirstEntryInRowTest.java
@@ -34,8 +34,8 @@ import org.apache.hadoop.io.Text;
import org.junit.Test;
public class FirstEntryInRowTest {
- private static final Map<String,String> EMPTY_MAP = new HashMap<String,String>();
- private static final Collection<ByteSequence> EMPTY_SET = new HashSet<ByteSequence>();
+ private static final Map<String,String> EMPTY_MAP = new HashMap<>();
+ private static final Collection<ByteSequence> EMPTY_SET = new HashSet<>();
private Key nk(String row, String cf, String cq, long time) {
return new Key(new Text(row), new Text(cf), new Text(cq), time);
@@ -73,7 +73,7 @@ public class FirstEntryInRowTest {
@Test
public void test1() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 5, "v2");
put(tm1, "r2", "cf1", "cq1", 5, "v3");
@@ -94,7 +94,7 @@ public class FirstEntryInRowTest {
@Test
public void test2() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
for (int r = 0; r < 5; r++) {
for (int cf = r; cf < 100; cf++) {
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/IteratorUtilTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/IteratorUtilTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/IteratorUtilTest.java
index 87ad392..65deb63 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/IteratorUtilTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/IteratorUtilTest.java
@@ -46,7 +46,7 @@ import org.junit.Test;
public class IteratorUtilTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
static class WrappedIter implements SortedKeyValueIterator<Key,Value> {
@@ -132,7 +132,7 @@ public class IteratorUtilTest {
conf.set(Property.TABLE_ITERATOR_PREFIX + IteratorScope.minc.name() + ".addIter", "1," + AddingIter.class.getName());
conf.set(Property.TABLE_ITERATOR_PREFIX + IteratorScope.minc.name() + ".sqIter", "2," + SquaringIter.class.getName());
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
MultiIteratorTest.nkv(tm, 1, 0, false, "1");
MultiIteratorTest.nkv(tm, 2, 0, false, "2");
@@ -164,7 +164,7 @@ public class IteratorUtilTest {
// try loading for a different scope
AccumuloConfiguration conf = new ConfigurationCopy();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
MultiIteratorTest.nkv(tm, 1, 0, false, "1");
MultiIteratorTest.nkv(tm, 2, 0, false, "2");
@@ -197,7 +197,7 @@ public class IteratorUtilTest {
ConfigurationCopy conf = new ConfigurationCopy();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
MultiIteratorTest.nkv(tm, 1, 0, false, "1");
MultiIteratorTest.nkv(tm, 2, 0, false, "2");
@@ -236,7 +236,7 @@ public class IteratorUtilTest {
conf.set(Property.TABLE_ITERATOR_PREFIX + IteratorScope.minc.name() + ".addIter.opt.amount", "7");
conf.set(Property.TABLE_ITERATOR_PREFIX + IteratorScope.minc.name() + ".sqIter", "2," + SquaringIter.class.getName());
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
MultiIteratorTest.nkv(tm, 1, 0, false, "1");
MultiIteratorTest.nkv(tm, 2, 0, false, "2");
@@ -272,7 +272,7 @@ public class IteratorUtilTest {
conf.set(Property.TABLE_ITERATOR_PREFIX + IteratorScope.minc.name() + ".filter.opt.ttl", "100");
conf.set(Property.TABLE_ITERATOR_PREFIX + IteratorScope.minc.name() + ".filter.opt.currentTime", "1000");
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
MultiIteratorTest.nkv(tm, 1, 850, false, "1");
MultiIteratorTest.nkv(tm, 2, 950, false, "2");
@@ -293,7 +293,7 @@ public class IteratorUtilTest {
@Test
public void onlyReadsRelevantIteratorScopeConfigurations() throws Exception {
- Map<String,String> data = new HashMap<String,String>();
+ Map<String,String> data = new HashMap<>();
// Make some configuration items, one with a bogus scope
data.put(Property.TABLE_ITERATOR_SCAN_PREFIX + "foo", "50," + SummingCombiner.class.getName());
@@ -303,8 +303,8 @@ public class IteratorUtilTest {
AccumuloConfiguration conf = new ConfigurationCopy(data);
- List<IterInfo> iterators = new ArrayList<IterInfo>();
- Map<String,Map<String,String>> options = new HashMap<String,Map<String,String>>();
+ List<IterInfo> iterators = new ArrayList<>();
+ Map<String,Map<String,String>> options = new HashMap<>();
IteratorUtil.parseIterConf(IteratorScope.scan, iterators, options, conf);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFamilySkippingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFamilySkippingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFamilySkippingIteratorTest.java
index fbe7fd5..33c398f 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFamilySkippingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFamilySkippingIteratorTest.java
@@ -32,7 +32,7 @@ import org.apache.hadoop.io.Text;
public class ColumnFamilySkippingIteratorTest extends TestCase {
- private static final Collection<ByteSequence> EMPTY_SET = new HashSet<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_SET = new HashSet<>();
Key nk(String row, String cf, String cq, long time) {
return new Key(new Text(row), new Text(cf), new Text(cq), time);
@@ -62,7 +62,7 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
}
public void test1() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 5, "v2");
put(tm1, "r2", "cf1", "cq1", 5, "v3");
@@ -77,14 +77,14 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
cfi.seek(new Range(), EMPTY_SET, false);
assertTrue(cfi.hasTop());
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
while (cfi.hasTop()) {
tm2.put(cfi.getTopKey(), cfi.getTopValue());
cfi.next();
}
assertEquals(tm1, tm2);
- HashSet<ByteSequence> colfams = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> colfams = new HashSet<>();
colfams.add(new ArrayByteSequence("cf2"));
cfi.seek(new Range(), colfams, true);
aten(cfi, "r2", "cf2", "cq4", 5, "v4");
@@ -108,7 +108,7 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
}
public void test2() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
for (int r = 0; r < 10; r++) {
for (int cf = 0; cf < 1000; cf++) {
@@ -118,13 +118,13 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
}
}
- HashSet<ByteSequence> allColfams = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> allColfams = new HashSet<>();
for (int cf = 0; cf < 1000; cf++) {
allColfams.add(new ArrayByteSequence(String.format("%06d", cf)));
}
ColumnFamilySkippingIterator cfi = new ColumnFamilySkippingIterator(new SortedMapIterator(tm1));
- HashSet<ByteSequence> colfams = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> colfams = new HashSet<>();
runTest(cfi, 30000, 0, allColfams, colfams);
@@ -162,11 +162,11 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
private void runTest(ColumnFamilySkippingIterator cfi, int total, int expected, HashSet<ByteSequence> allColfams, HashSet<ByteSequence> colfams)
throws Exception {
cfi.seek(new Range(), colfams, true);
- HashSet<ByteSequence> excpected1 = new HashSet<ByteSequence>(colfams);
+ HashSet<ByteSequence> excpected1 = new HashSet<>(colfams);
excpected1.retainAll(allColfams);
runTest(cfi, expected, excpected1);
- HashSet<ByteSequence> excpected2 = new HashSet<ByteSequence>(allColfams);
+ HashSet<ByteSequence> excpected2 = new HashSet<>(allColfams);
excpected2.removeAll(colfams);
cfi.seek(new Range(), colfams, false);
runTest(cfi, total - expected, excpected2);
@@ -175,7 +175,7 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
private void runTest(ColumnFamilySkippingIterator cfi, int expected, HashSet<ByteSequence> colfams) throws Exception {
int count = 0;
- HashSet<ByteSequence> ocf = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> ocf = new HashSet<>();
while (cfi.hasTop()) {
count++;
@@ -189,7 +189,7 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
public void test3() throws Exception {
// construct test where ColumnFamilySkippingIterator might try to seek past the end of the user supplied range
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
for (int r = 0; r < 3; r++) {
for (int cf = 4; cf < 1000; cf++) {
@@ -201,7 +201,7 @@ public class ColumnFamilySkippingIteratorTest extends TestCase {
CountingIterator ci = new CountingIterator(new SortedMapIterator(tm1));
ColumnFamilySkippingIterator cfi = new ColumnFamilySkippingIterator(ci);
- HashSet<ByteSequence> colfams = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> colfams = new HashSet<>();
colfams.add(new ArrayByteSequence(String.format("%06d", 4)));
Range range = new Range(nk(0, 4, 0, 6), true, nk(0, 400, 0, 6), true);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFilterTest.java
index 3fd66b4..cfed90f 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/ColumnFilterTest.java
@@ -40,7 +40,7 @@ public class ColumnFilterTest extends TestCase {
}
public void test1() {
- HashSet<Column> columns = new HashSet<Column>();
+ HashSet<Column> columns = new HashSet<>();
columns.add(nc("cf1"));
@@ -52,7 +52,7 @@ public class ColumnFilterTest extends TestCase {
}
public void test2() {
- HashSet<Column> columns = new HashSet<Column>();
+ HashSet<Column> columns = new HashSet<>();
columns.add(nc("cf1"));
columns.add(nc("cf2", "cq1"));
@@ -65,7 +65,7 @@ public class ColumnFilterTest extends TestCase {
}
public void test3() {
- HashSet<Column> columns = new HashSet<Column>();
+ HashSet<Column> columns = new HashSet<>();
columns.add(nc("cf2", "cq1"));
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/DeletingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/DeletingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/DeletingIteratorTest.java
index 4fd48d5..9082a36 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/DeletingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/DeletingIteratorTest.java
@@ -33,7 +33,7 @@ import org.apache.hadoop.io.Text;
public class DeletingIteratorTest extends TestCase {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
public void test1() {
Text colf = new Text("a");
@@ -42,7 +42,7 @@ public class DeletingIteratorTest extends TestCase {
Value dvDel = new Value("old".getBytes());
Value dvNew = new Value("new".getBytes());
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
Key k;
for (int i = 0; i < 2; i++) {
@@ -67,7 +67,7 @@ public class DeletingIteratorTest extends TestCase {
DeletingIterator it = new DeletingIterator(new SortedMapIterator(tm), false);
it.seek(new Range(), EMPTY_COL_FAMS, false);
- TreeMap<Key,Value> tmOut = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tmOut = new TreeMap<>();
while (it.hasTop()) {
tmOut.put(it.getTopKey(), it.getTopValue());
it.next();
@@ -88,7 +88,7 @@ public class DeletingIteratorTest extends TestCase {
try {
DeletingIterator it = new DeletingIterator(new SortedMapIterator(tm), true);
it.seek(new Range(), EMPTY_COL_FAMS, false);
- TreeMap<Key,Value> tmOut = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tmOut = new TreeMap<>();
while (it.hasTop()) {
tmOut.put(it.getTopKey(), it.getTopValue());
it.next();
@@ -115,7 +115,7 @@ public class DeletingIteratorTest extends TestCase {
// seek test
public void test2() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
nkv(tm, "r000", 4, false, "v4");
nkv(tm, "r000", 3, false, "v3");
@@ -165,7 +165,7 @@ public class DeletingIteratorTest extends TestCase {
// test delete with same timestamp as existing key
public void test3() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
nkv(tm, "r000", 3, false, "v3");
nkv(tm, "r000", 2, false, "v2");
@@ -190,7 +190,7 @@ public class DeletingIteratorTest extends TestCase {
// test range inclusiveness
public void test4() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
nkv(tm, "r000", 3, false, "v3");
nkv(tm, "r000", 2, false, "v2");
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/MultiIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/MultiIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/MultiIteratorTest.java
index 3fbf92d..f257690 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/MultiIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/MultiIteratorTest.java
@@ -36,7 +36,7 @@ import org.apache.hadoop.io.Text;
public class MultiIteratorTest extends TestCase {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
public static Key nk(int row, long ts) {
return new Key(nr(row), ts);
@@ -57,7 +57,7 @@ public class MultiIteratorTest extends TestCase {
}
void verify(int start, int end, Key seekKey, Text endRow, Text prevEndRow, boolean init, boolean incrRow, List<TreeMap<Key,Value>> maps) throws IOException {
- List<SortedKeyValueIterator<Key,Value>> iters = new ArrayList<SortedKeyValueIterator<Key,Value>>(maps.size());
+ List<SortedKeyValueIterator<Key,Value>> iters = new ArrayList<>(maps.size());
for (TreeMap<Key,Value> map : maps) {
iters.add(new SortedMapIterator(map));
@@ -121,14 +121,14 @@ public class MultiIteratorTest extends TestCase {
public void test1() throws IOException {
// TEST non overlapping inputs
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
- List<TreeMap<Key,Value>> tmpList = new ArrayList<TreeMap<Key,Value>>(2);
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
+ List<TreeMap<Key,Value>> tmpList = new ArrayList<>(2);
for (int i = 0; i < 4; i++) {
nkv(tm1, 0, i, false, "v" + i);
}
tmpList.add(tm1);
- tm1 = new TreeMap<Key,Value>();
+ tm1 = new TreeMap<>();
for (int i = 4; i < 8; i++) {
nkv(tm1, 0, i, false, "v" + i);
}
@@ -144,9 +144,9 @@ public class MultiIteratorTest extends TestCase {
public void test2() throws IOException {
// TEST overlapping inputs
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
- List<TreeMap<Key,Value>> tmpList = new ArrayList<TreeMap<Key,Value>>(2);
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
+ List<TreeMap<Key,Value>> tmpList = new ArrayList<>(2);
for (int i = 0; i < 8; i++) {
if (i % 2 == 0)
@@ -167,8 +167,8 @@ public class MultiIteratorTest extends TestCase {
public void test3() throws IOException {
// TEST single input
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
- List<TreeMap<Key,Value>> tmpList = new ArrayList<TreeMap<Key,Value>>(2);
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
+ List<TreeMap<Key,Value>> tmpList = new ArrayList<>(2);
for (int i = 0; i < 8; i++) {
nkv(tm1, 0, i, false, "v" + i);
@@ -186,9 +186,9 @@ public class MultiIteratorTest extends TestCase {
public void test4() throws IOException {
// TEST empty input
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
- List<SortedKeyValueIterator<Key,Value>> skvil = new ArrayList<SortedKeyValueIterator<Key,Value>>(1);
+ List<SortedKeyValueIterator<Key,Value>> skvil = new ArrayList<>(1);
skvil.add(new SortedMapIterator(tm1));
MultiIterator mi = new MultiIterator(skvil, true);
@@ -201,9 +201,9 @@ public class MultiIteratorTest extends TestCase {
public void test5() throws IOException {
// TEST overlapping inputs AND prevRow AND endRow AND seek
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
- List<TreeMap<Key,Value>> tmpList = new ArrayList<TreeMap<Key,Value>>(2);
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
+ List<TreeMap<Key,Value>> tmpList = new ArrayList<>(2);
for (int i = 0; i < 8; i++) {
if (i % 2 == 0)
@@ -257,12 +257,12 @@ public class MultiIteratorTest extends TestCase {
public void test6() throws IOException {
// TEst setting an endKey
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
nkv(tm1, 3, 0, false, "1");
nkv(tm1, 4, 0, false, "2");
nkv(tm1, 6, 0, false, "3");
- List<SortedKeyValueIterator<Key,Value>> skvil = new ArrayList<SortedKeyValueIterator<Key,Value>>(1);
+ List<SortedKeyValueIterator<Key,Value>> skvil = new ArrayList<>(1);
skvil.add(new SortedMapIterator(tm1));
MultiIterator mi = new MultiIterator(skvil, true);
mi.seek(new Range(null, true, nk(5, 9), false), EMPTY_COL_FAMS, false);
@@ -330,7 +330,7 @@ public class MultiIteratorTest extends TestCase {
public void test7() throws IOException {
// TEst setting an endKey
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
nkv(tm1, 0, 3, false, "1");
nkv(tm1, 0, 2, false, "2");
nkv(tm1, 0, 1, false, "3");
@@ -341,7 +341,7 @@ public class MultiIteratorTest extends TestCase {
nkv(tm1, 2, 1, false, "8");
nkv(tm1, 2, 0, false, "9");
- List<SortedKeyValueIterator<Key,Value>> skvil = new ArrayList<SortedKeyValueIterator<Key,Value>>(1);
+ List<SortedKeyValueIterator<Key,Value>> skvil = new ArrayList<>(1);
skvil.add(new SortedMapIterator(tm1));
KeyExtent extent = new KeyExtent(new Text("tablename"), nr(1), nr(0));
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/SourceSwitchingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/SourceSwitchingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/SourceSwitchingIteratorTest.java
index 7567871..1ebf9df 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/SourceSwitchingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/SourceSwitchingIteratorTest.java
@@ -60,7 +60,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
DataSource next;
SortedKeyValueIterator<Key,Value> iter;
- List<TestDataSource> copies = new ArrayList<TestDataSource>();
+ List<TestDataSource> copies = new ArrayList<>();
AtomicBoolean iflag;
TestDataSource(SortedKeyValueIterator<Key,Value> iter) {
@@ -111,7 +111,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
}
public void test1() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 5, "v2");
put(tm1, "r2", "cf1", "cq1", 5, "v3");
@@ -128,7 +128,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
}
public void test2() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 5, "v2");
put(tm1, "r2", "cf1", "cq1", 5, "v3");
@@ -140,7 +140,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
ssi.seek(new Range(), new ArrayList<ByteSequence>(), false);
ane(ssi, "r1", "cf1", "cq1", 5, "v1", true);
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
put(tm2, "r1", "cf1", "cq1", 5, "v4");
put(tm2, "r1", "cf1", "cq3", 5, "v5");
put(tm2, "r2", "cf1", "cq1", 5, "v6");
@@ -157,7 +157,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
public void test3() throws Exception {
// test switching after a row
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq2", 5, "v2");
put(tm1, "r1", "cf1", "cq3", 5, "v3");
@@ -172,7 +172,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
ssi.seek(new Range(), new ArrayList<ByteSequence>(), false);
ane(ssi, "r1", "cf1", "cq1", 5, "v1", true);
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>(tm1);
+ TreeMap<Key,Value> tm2 = new TreeMap<>(tm1);
put(tm2, "r1", "cf1", "cq5", 5, "v7"); // should not see this because it should not switch until the row is finished
put(tm2, "r2", "cf1", "cq1", 5, "v8"); // should see this new row after it switches
@@ -192,7 +192,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
public void test4() throws Exception {
// ensure switch is done on initial seek
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq2", 5, "v2");
@@ -200,7 +200,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
TestDataSource tds = new TestDataSource(smi);
SourceSwitchingIterator ssi = new SourceSwitchingIterator(tds, false);
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
put(tm2, "r1", "cf1", "cq1", 6, "v3");
put(tm2, "r1", "cf1", "cq2", 6, "v4");
@@ -217,7 +217,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
public void test5() throws Exception {
// esnure switchNow() works w/ deepCopy()
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq2", 5, "v2");
@@ -227,7 +227,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
SortedKeyValueIterator<Key,Value> dc1 = ssi.deepCopy(null);
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
put(tm2, "r1", "cf1", "cq1", 6, "v3");
put(tm2, "r2", "cf1", "cq2", 6, "v4");
@@ -248,7 +248,7 @@ public class SourceSwitchingIteratorTest extends TestCase {
public void testSetInterrupt() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "cf1", "cq1", 5, "v1");
SortedMapIterator smi = new SortedMapIterator(tm1);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/TimeSettingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/TimeSettingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/TimeSettingIteratorTest.java
index 3dbe7ca..9a363a1 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/TimeSettingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/TimeSettingIteratorTest.java
@@ -34,7 +34,7 @@ public class TimeSettingIteratorTest {
@Test
public void test1() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
tm1.put(new Key("r0", "cf1", "cq1", 9l), new Value("v0".getBytes()));
tm1.put(new Key("r1", "cf1", "cq1", Long.MAX_VALUE), new Value("v1".getBytes()));
@@ -87,7 +87,7 @@ public class TimeSettingIteratorTest {
@Test
public void testAvoidKeyCopy() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
final Key k = new Key("r0", "cf1", "cq1", 9l);
tm1.put(k, new Value("v0".getBytes()));
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/system/VisibilityFilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/system/VisibilityFilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/system/VisibilityFilterTest.java
index 667aa5f..68323c6 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/system/VisibilityFilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/system/VisibilityFilterTest.java
@@ -34,7 +34,7 @@ import org.apache.log4j.Logger;
public class VisibilityFilterTest extends TestCase {
public void testBadVisibility() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
tm.put(new Key("r1", "cf1", "cq1", "A&"), new Value(new byte[0]));
VisibilityFilter filter = new VisibilityFilter(new SortedMapIterator(tm), new Authorizations("A"), "".getBytes());
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/BigDecimalCombinerTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/BigDecimalCombinerTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/BigDecimalCombinerTest.java
index dfcb869..861ce02 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/BigDecimalCombinerTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/BigDecimalCombinerTest.java
@@ -42,7 +42,7 @@ import org.junit.Test;
public class BigDecimalCombinerTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
private static double delta = 0.00001;
Encoder<BigDecimal> encoder;
@@ -53,7 +53,7 @@ public class BigDecimalCombinerTest {
@Before
public void setup() {
encoder = new BigDecimalCombiner.BigDecimalEncoder();
- tm1 = new TreeMap<Key,Value>();
+ tm1 = new TreeMap<>();
columns = Collections.singletonList(new IteratorSetting.Column("cf001"));
// keys that will aggregate
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/ColumnSliceFilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/ColumnSliceFilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/ColumnSliceFilterTest.java
index 11ad192..698d9ec 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/ColumnSliceFilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/ColumnSliceFilterTest.java
@@ -40,9 +40,9 @@ import org.junit.Test;
public class ColumnSliceFilterTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
- private static final SortedMap<Key,Value> TEST_DATA = new TreeMap<Key,Value>();
+ private static final SortedMap<Key,Value> TEST_DATA = new TreeMap<>();
private static final Key KEY_1 = nkv(TEST_DATA, "boo1", "yup", "20080201", "dog");
private static final Key KEY_2 = nkv(TEST_DATA, "boo1", "yap", "20080202", "cat");
private static final Key KEY_3 = nkv(TEST_DATA, "boo2", "yap", "20080203", "hamster");
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/CombinerTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/CombinerTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/CombinerTest.java
index a442534..6300532 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/CombinerTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/CombinerTest.java
@@ -58,7 +58,7 @@ import org.junit.Test;
public class CombinerTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
static class CombinerIteratorEnvironment extends DefaultIteratorEnvironment {
@@ -115,7 +115,7 @@ public class CombinerTest {
public void test1() throws IOException {
Encoder<Long> encoder = LongCombiner.VAR_LEN_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that do not aggregate
nkv(tm1, 1, 1, 1, 1, false, 2l, encoder);
@@ -180,7 +180,7 @@ public class CombinerTest {
public void test2() throws IOException {
Encoder<Long> encoder = LongCombiner.VAR_LEN_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, 2l, encoder);
@@ -242,7 +242,7 @@ public class CombinerTest {
public void test3() throws IOException {
Encoder<Long> encoder = LongCombiner.FIXED_LEN_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, 2l, encoder);
@@ -308,7 +308,7 @@ public class CombinerTest {
public void testDeepCopy() throws IOException {
Encoder<Long> encoder = LongCombiner.FIXED_LEN_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, 2l, encoder);
@@ -376,7 +376,7 @@ public class CombinerTest {
public void test4() throws IOException {
Encoder<Long> encoder = LongCombiner.STRING_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that do not aggregate
nkv(tm1, 0, 0, 1, 1, false, 7l, encoder);
@@ -481,13 +481,13 @@ public class CombinerTest {
// try aggregating across multiple data sets that contain
// the exact same keys w/ different values
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
nkv(tm1, 1, 1, 1, 1, false, 2l, encoder);
- TreeMap<Key,Value> tm2 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm2 = new TreeMap<>();
nkv(tm2, 1, 1, 1, 1, false, 3l, encoder);
- TreeMap<Key,Value> tm3 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm3 = new TreeMap<>();
nkv(tm3, 1, 1, 1, 1, false, 4l, encoder);
Combiner ai = new SummingCombiner();
@@ -496,7 +496,7 @@ public class CombinerTest {
LongCombiner.setEncodingType(is, StringEncoder.class);
Combiner.setColumns(is, Collections.singletonList(new IteratorSetting.Column("cf001")));
- List<SortedKeyValueIterator<Key,Value>> sources = new ArrayList<SortedKeyValueIterator<Key,Value>>(3);
+ List<SortedKeyValueIterator<Key,Value>> sources = new ArrayList<>(3);
sources.add(new SortedMapIterator(tm1));
sources.add(new SortedMapIterator(tm2));
sources.add(new SortedMapIterator(tm3));
@@ -513,7 +513,7 @@ public class CombinerTest {
@Test
public void test6() throws IOException {
Encoder<Long> encoder = LongCombiner.VAR_LEN_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, 2l, encoder);
@@ -542,7 +542,7 @@ public class CombinerTest {
// test that delete is not aggregated
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
nkv(tm1, 1, 1, 1, 2, true, 0l, encoder);
nkv(tm1, 1, 1, 1, 3, false, 4l, encoder);
@@ -570,7 +570,7 @@ public class CombinerTest {
ai.next();
assertFalse(ai.hasTop());
- tm1 = new TreeMap<Key,Value>();
+ tm1 = new TreeMap<>();
nkv(tm1, 1, 1, 1, 2, true, 0l, encoder);
ai = new SummingCombiner();
ai.init(new SortedMapIterator(tm1), is.getOptions(), SCAN_IE);
@@ -587,7 +587,7 @@ public class CombinerTest {
@Test
public void valueIteratorTest() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
tm.put(new Key("r", "f", "q", 1), new Value("1".getBytes()));
tm.put(new Key("r", "f", "q", 2), new Value("2".getBytes()));
SortedMapIterator smi = new SortedMapIterator(tm);
@@ -600,7 +600,7 @@ public class CombinerTest {
@Test
public void sumAllColumns() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
tm.put(new Key("r", "count", "a", 1), new Value("1".getBytes()));
tm.put(new Key("r", "count", "a", 2), new Value("1".getBytes()));
tm.put(new Key("r", "count", "b", 3), new Value("1".getBytes()));
@@ -636,7 +636,7 @@ public class CombinerTest {
public void maxMinTest() throws IOException {
Encoder<Long> encoder = LongCombiner.VAR_LEN_ENCODER;
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, 4l, encoder);
@@ -675,7 +675,7 @@ public class CombinerTest {
}
public static List<Long> nal(Long... longs) {
- List<Long> al = new ArrayList<Long>(longs.length);
+ List<Long> al = new ArrayList<>(longs.length);
for (Long l : longs) {
al.add(l);
}
@@ -692,7 +692,7 @@ public class CombinerTest {
IllegalAccessException {
Encoder<List<Long>> encoder = encoderClass.newInstance();
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
// keys that aggregate
nkv(tm1, 1, 1, 1, 1, false, nal(1l, 2l), encoder);
@@ -773,11 +773,11 @@ public class CombinerTest {
@Override
public List<Long> decode(byte[] b) {
- return new ArrayList<Long>();
+ return new ArrayList<>();
}
public List<Long> decode(byte[] b, int offset, int len) {
- return new ArrayList<Long>();
+ return new ArrayList<>();
}
}
@@ -821,7 +821,7 @@ public class CombinerTest {
}
private TreeMap<Key,Value> readAll(SortedKeyValueIterator<Key,Value> combiner) throws Exception {
- TreeMap<Key,Value> ret = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> ret = new TreeMap<>();
combiner.seek(new Range(), EMPTY_COL_FAMS, false);
@@ -895,7 +895,7 @@ public class CombinerTest {
public void testDeleteHandling() throws Exception {
Encoder<Long> encoder = LongCombiner.STRING_ENCODER;
- TreeMap<Key,Value> input = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> input = new TreeMap<>();
IteratorEnvironment paritalMajcIe = new CombinerIteratorEnvironment(IteratorScope.majc, false);
IteratorEnvironment fullMajcIe = new CombinerIteratorEnvironment(IteratorScope.majc, true);
@@ -906,7 +906,7 @@ public class CombinerTest {
nkv(input, 1, 1, 1, 3, false, 2l, encoder);
nkv(input, 1, 1, 1, 4, false, 9l, encoder);
- TreeMap<Key,Value> expected = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> expected = new TreeMap<>();
nkv(expected, 1, 1, 1, 1, false, 4l, encoder);
nkv(expected, 1, 1, 1, 2, true, 0l, encoder);
nkv(expected, 1, 1, 1, 4, false, 11l, encoder);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/FilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/FilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/FilterTest.java
index 0c4ffa2..61d98e6 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/FilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/FilterTest.java
@@ -48,8 +48,8 @@ import org.junit.Test;
public class FilterTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
- private static final Map<String,String> EMPTY_OPTS = new HashMap<String,String>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
+ private static final Map<String,String> EMPTY_OPTS = new HashMap<>();
public static class SimpleFilter extends Filter {
@Override
@@ -85,7 +85,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
for (int i = 0; i < 1000; i++) {
Key k = new Key(new Text(String.format("%03d", i)), colf, colq);
@@ -120,7 +120,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
for (int i = 0; i < 1000; i++) {
Key k = new Key(new Text(String.format("%03d", i)), colf, colq);
@@ -157,7 +157,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
for (int i = 0; i < 1000; i++) {
Key k = new Key(new Text(String.format("%03d", i)), colf, colq);
@@ -185,7 +185,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
for (int i = 0; i < 1000; i++) {
Key k = new Key(new Text(String.format("%03d", i)), colf, colq);
@@ -218,7 +218,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
IteratorSetting is = new IteratorSetting(1, ColumnAgeOffFilter.class);
ColumnAgeOffFilter.addTTL(is, new IteratorSetting.Column("a"), 901l);
long ts = System.currentTimeMillis();
@@ -253,8 +253,8 @@ public class FilterTest {
@Test
public void test3() throws IOException {
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
- HashSet<Column> hsc = new HashSet<Column>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
+ HashSet<Column> hsc = new HashSet<>();
hsc.add(new Column("c".getBytes(), null, null));
Text colf1 = new Text("a");
@@ -281,14 +281,14 @@ public class FilterTest {
a.seek(new Range(), EMPTY_COL_FAMS, false);
assertEquals(size(a), 1000);
- hsc = new HashSet<Column>();
+ hsc = new HashSet<>();
hsc.add(new Column("a".getBytes(), "b".getBytes(), null));
a = new ColumnQualifierFilter(new SortedMapIterator(tm), hsc);
a.seek(new Range(), EMPTY_COL_FAMS, false);
int size = size(a);
assertTrue("size was " + size, size == 500);
- hsc = new HashSet<Column>();
+ hsc = new HashSet<>();
a = new ColumnQualifierFilter(new SortedMapIterator(tm), hsc);
a.seek(new Range(), EMPTY_COL_FAMS, false);
size = size(a);
@@ -298,7 +298,7 @@ public class FilterTest {
@Test
public void test4() throws IOException {
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
ColumnVisibility le1 = new ColumnVisibility("L1");
ColumnVisibility le2 = new ColumnVisibility("L0&OFFICIAL");
@@ -320,7 +320,7 @@ public class FilterTest {
}
private ColumnQualifierFilter ncqf(TreeMap<Key,Value> tm, Column... columns) throws IOException {
- HashSet<Column> hsc = new HashSet<Column>();
+ HashSet<Column> hsc = new HashSet<>();
for (Column column : columns) {
hsc.add(column);
@@ -334,7 +334,7 @@ public class FilterTest {
@Test
public void test5() throws IOException {
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
tm.put(new Key(new Text(String.format("%03d", 1)), new Text("a"), new Text("x")), dv);
tm.put(new Key(new Text(String.format("%03d", 2)), new Text("a"), new Text("y")), dv);
@@ -365,7 +365,7 @@ public class FilterTest {
@Test
public void testNoVisFilter() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
Value v = new Value();
for (int i = 0; i < 1000; i++) {
Key k = new Key(String.format("%03d", i), "a", "b", i % 10 == 0 ? "vis" : "");
@@ -385,7 +385,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
for (int i = 0; i < 100; i++) {
Key k = new Key(new Text(String.format("%02d", i)), colf, colq);
@@ -482,7 +482,7 @@ public class FilterTest {
Text colf = new Text("a");
Text colq = new Text("b");
Value dv = new Value();
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
Key k = new Key(new Text("0"), colf, colq);
tm.put(k, dv);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/GrepIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/GrepIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/GrepIteratorTest.java
index 23af994..3a47f5a 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/GrepIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/GrepIteratorTest.java
@@ -38,14 +38,14 @@ import org.junit.Before;
import org.junit.Test;
public class GrepIteratorTest {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
SortedMap<Key,Value> input;
SortedMap<Key,Value> output;
@Before
public void init() {
- input = new TreeMap<Key,Value>();
- output = new TreeMap<Key,Value>();
+ input = new TreeMap<>();
+ output = new TreeMap<>();
input.put(new Key("abcdef", "xyz", "xyz", 0), new Value("xyz".getBytes()));
output.put(new Key("abcdef", "xyz", "xyz", 0), new Value("xyz".getBytes()));
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/IndexedDocIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/IndexedDocIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/IndexedDocIteratorTest.java
index 117fcac..cb6d3f7 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/IndexedDocIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/IndexedDocIteratorTest.java
@@ -46,7 +46,7 @@ public class IndexedDocIteratorTest extends TestCase {
private static final Logger log = Logger.getLogger(IndexedDocIteratorTest.class);
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
private static final byte[] nullByte = {0};
private static IteratorEnvironment env = new DefaultIteratorEnvironment();
@@ -71,7 +71,7 @@ public class IndexedDocIteratorTest extends TestCase {
StringBuilder sb = new StringBuilder();
Random r = new Random();
Value v = new Value(new byte[0]);
- TreeMap<Key,Value> map = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> map = new TreeMap<>();
boolean[] negateMask = new boolean[columnFamilies.length];
for (int i = 0; i < columnFamilies.length; i++) {
@@ -189,7 +189,7 @@ public class IndexedDocIteratorTest extends TestCase {
otherColumnFamilies[3] = new Text("F");
float hitRatio = 0.5f;
- HashSet<Text> docs = new HashSet<Text>();
+ HashSet<Text> docs = new HashSet<>();
SortedKeyValueIterator<Key,Value> source = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs);
IteratorSetting is = new IteratorSetting(1, IndexedDocIterator.class);
IndexedDocIterator.setColumnFamilies(is, columnFamilies);
@@ -227,7 +227,7 @@ public class IndexedDocIteratorTest extends TestCase {
otherColumnFamilies[3] = new Text("F");
float hitRatio = 0.5f;
- HashSet<Text> docs = new HashSet<Text>();
+ HashSet<Text> docs = new HashSet<>();
SortedKeyValueIterator<Key,Value> source = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs);
IteratorSetting is = new IteratorSetting(1, IndexedDocIterator.class);
IndexedDocIterator.setColumnFamilies(is, columnFamilies);
@@ -264,10 +264,10 @@ public class IndexedDocIteratorTest extends TestCase {
otherColumnFamilies[3] = new Text("F");
float hitRatio = 0.5f;
- HashSet<Text> docs = new HashSet<Text>();
+ HashSet<Text> docs = new HashSet<>();
SortedKeyValueIterator<Key,Value> source = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs);
SortedKeyValueIterator<Key,Value> source2 = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs);
- ArrayList<SortedKeyValueIterator<Key,Value>> sourceIters = new ArrayList<SortedKeyValueIterator<Key,Value>>();
+ ArrayList<SortedKeyValueIterator<Key,Value>> sourceIters = new ArrayList<>();
sourceIters.add(source);
sourceIters.add(source2);
MultiIterator mi = new MultiIterator(sourceIters, false);
@@ -310,7 +310,7 @@ public class IndexedDocIteratorTest extends TestCase {
otherColumnFamilies[3] = new Text("F");
float hitRatio = 0.5f;
- HashSet<Text> docs = new HashSet<Text>();
+ HashSet<Text> docs = new HashSet<>();
SortedKeyValueIterator<Key,Value> source = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs, negatedColumns);
IteratorSetting is = new IteratorSetting(1, IndexedDocIterator.class);
IndexedDocIterator.setColumnFamilies(is, columnFamilies, notFlags);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/IntersectingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/IntersectingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/IntersectingIteratorTest.java
index 365cee4..63c38a7 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/IntersectingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/IntersectingIteratorTest.java
@@ -52,12 +52,12 @@ import org.apache.log4j.Logger;
public class IntersectingIteratorTest extends TestCase {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
private static final Logger log = Logger.getLogger(IntersectingIterator.class);
private static IteratorEnvironment env = new DefaultIteratorEnvironment();
TreeMap<Key,Value> map;
- HashSet<Text> docs = new HashSet<Text>();
+ HashSet<Text> docs = new HashSet<>();
Text[] columnFamilies;
Text[] negatedColumns;
Text[] otherColumnFamilies;
@@ -74,7 +74,7 @@ public class IntersectingIteratorTest extends TestCase {
HashSet<Text> docs, Text[] negatedColumns) {
Random r = new Random();
Value v = new Value(new byte[0]);
- TreeMap<Key,Value> map = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> map = new TreeMap<>();
boolean[] negateMask = new boolean[columnFamilies.length];
for (int i = 0; i < columnFamilies.length; i++) {
@@ -214,7 +214,7 @@ public class IntersectingIteratorTest extends TestCase {
float hitRatio = 0.5f;
SortedKeyValueIterator<Key,Value> source = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs);
SortedKeyValueIterator<Key,Value> source2 = createIteratorStack(hitRatio, NUM_ROWS, NUM_DOCIDS, columnFamilies, otherColumnFamilies, docs);
- ArrayList<SortedKeyValueIterator<Key,Value>> sourceIters = new ArrayList<SortedKeyValueIterator<Key,Value>>();
+ ArrayList<SortedKeyValueIterator<Key,Value>> sourceIters = new ArrayList<>();
sourceIters.add(source);
sourceIters.add(source2);
MultiIterator mi = new MultiIterator(sourceIters, false);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/LargeRowFilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/LargeRowFilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/LargeRowFilterTest.java
index af610ca..1d5a108 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/LargeRowFilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/LargeRowFilterTest.java
@@ -66,18 +66,18 @@ public class LargeRowFilterTest extends TestCase {
}
public void testBasic() throws Exception {
- TreeMap<Key,Value> testData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> testData = new TreeMap<>();
genTestData(testData, 20);
for (int i = 1; i <= 20; i++) {
- TreeMap<Key,Value> expectedData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> expectedData = new TreeMap<>();
genTestData(expectedData, i);
LargeRowFilter lrfi = setupIterator(testData, i, IteratorScope.scan);
lrfi.seek(new Range(), LocalityGroupUtil.EMPTY_CF_SET, false);
- TreeMap<Key,Value> filteredData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> filteredData = new TreeMap<>();
while (lrfi.hasTop()) {
filteredData.put(lrfi.getTopKey(), lrfi.getTopValue());
@@ -89,17 +89,17 @@ public class LargeRowFilterTest extends TestCase {
}
public void testSeek() throws Exception {
- TreeMap<Key,Value> testData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> testData = new TreeMap<>();
genTestData(testData, 20);
for (int i = 1; i <= 20; i++) {
- TreeMap<Key,Value> expectedData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> expectedData = new TreeMap<>();
genTestData(expectedData, i);
LargeRowFilter lrfi = setupIterator(testData, i, IteratorScope.scan);
- TreeMap<Key,Value> filteredData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> filteredData = new TreeMap<>();
// seek to each row... rows that exceed max columns should be filtered
for (int j = 1; j <= i; j++) {
@@ -117,7 +117,7 @@ public class LargeRowFilterTest extends TestCase {
}
public void testSeek2() throws Exception {
- TreeMap<Key,Value> testData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> testData = new TreeMap<>();
genTestData(testData, 20);
@@ -130,10 +130,10 @@ public class LargeRowFilterTest extends TestCase {
lrfi.seek(new Range(new Key(genRow(10), "cf001", genCQ(4), 5), true, new Key(genRow(10)).followingKey(PartialKey.ROW), false),
LocalityGroupUtil.EMPTY_CF_SET, false);
- TreeMap<Key,Value> expectedData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> expectedData = new TreeMap<>();
genRow(expectedData, 10, 4, 10);
- TreeMap<Key,Value> filteredData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> filteredData = new TreeMap<>();
while (lrfi.hasTop()) {
filteredData.put(lrfi.getTopKey(), lrfi.getTopValue());
lrfi.next();
@@ -143,14 +143,14 @@ public class LargeRowFilterTest extends TestCase {
}
public void testCompaction() throws Exception {
- TreeMap<Key,Value> testData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> testData = new TreeMap<>();
genTestData(testData, 20);
LargeRowFilter lrfi = setupIterator(testData, 13, IteratorScope.majc);
lrfi.seek(new Range(), LocalityGroupUtil.EMPTY_CF_SET, false);
- TreeMap<Key,Value> compactedData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> compactedData = new TreeMap<>();
while (lrfi.hasTop()) {
compactedData.put(lrfi.getTopKey(), lrfi.getTopValue());
lrfi.next();
@@ -167,10 +167,10 @@ public class LargeRowFilterTest extends TestCase {
lrfi.seek(new Range(), LocalityGroupUtil.EMPTY_CF_SET, false);
// only expect to see 13 rows
- TreeMap<Key,Value> expectedData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> expectedData = new TreeMap<>();
genTestData(expectedData, 13);
- TreeMap<Key,Value> filteredData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> filteredData = new TreeMap<>();
while (lrfi.hasTop()) {
filteredData.put(lrfi.getTopKey(), lrfi.getTopValue());
lrfi.next();
@@ -185,7 +185,7 @@ public class LargeRowFilterTest extends TestCase {
assertFalse(lrfi.hasTop());
// test seeking w/ column families
- HashSet<ByteSequence> colfams = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> colfams = new HashSet<>();
colfams.add(new ArrayByteSequence("cf001"));
lrfi.seek(new Range(new Key(genRow(15), "cf001", genCQ(4), 5), true, new Key(genRow(15)).followingKey(PartialKey.ROW), false), colfams, true);
assertFalse(lrfi.hasTop());
@@ -194,20 +194,20 @@ public class LargeRowFilterTest extends TestCase {
// in other test data is generated in such a way that once a row
// is suppressed, all subsequent rows are suppressed
public void testSuppressInner() throws Exception {
- TreeMap<Key,Value> testData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> testData = new TreeMap<>();
genRow(testData, 1, 0, 2);
genRow(testData, 2, 0, 50);
genRow(testData, 3, 0, 15);
genRow(testData, 4, 0, 5);
- TreeMap<Key,Value> expectedData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> expectedData = new TreeMap<>();
genRow(expectedData, 1, 0, 2);
genRow(expectedData, 4, 0, 5);
LargeRowFilter lrfi = setupIterator(testData, 13, IteratorScope.scan);
lrfi.seek(new Range(), LocalityGroupUtil.EMPTY_CF_SET, false);
- TreeMap<Key,Value> filteredData = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> filteredData = new TreeMap<>();
while (lrfi.hasTop()) {
filteredData.put(lrfi.getTopKey(), lrfi.getTopValue());
lrfi.next();
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/RegExFilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/RegExFilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/RegExFilterTest.java
index 2649f90..742d339 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/RegExFilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/RegExFilterTest.java
@@ -50,7 +50,7 @@ import org.junit.Test;
public class RegExFilterTest extends TestCase {
- private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<ByteSequence>();
+ private static final Collection<ByteSequence> EMPTY_COL_FAMS = new ArrayList<>();
private Key nkv(TreeMap<Key,Value> tm, String row, String cf, String cq, String val) {
Key k = nk(row, cf, cq);
@@ -63,7 +63,7 @@ public class RegExFilterTest extends TestCase {
}
public void test1() throws IOException {
- TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm = new TreeMap<>();
Key k1 = nkv(tm, "boo1", "yup", "20080201", "dog");
Key k2 = nkv(tm, "boo1", "yap", "20080202", "cat");
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/RowDeletingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/RowDeletingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/RowDeletingIteratorTest.java
index a3c1cca..ae77c0b 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/RowDeletingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/RowDeletingIteratorTest.java
@@ -98,7 +98,7 @@ public class RowDeletingIteratorTest extends TestCase {
public void test1() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "", "", 10, RowDeletingIterator.DELETE_ROW_VALUE);
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 5, "v1");
@@ -137,7 +137,7 @@ public class RowDeletingIteratorTest extends TestCase {
public void test2() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "", "", 10, RowDeletingIterator.DELETE_ROW_VALUE);
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 15, "v1");
@@ -178,7 +178,7 @@ public class RowDeletingIteratorTest extends TestCase {
public void test3() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "", "", 10, RowDeletingIterator.DELETE_ROW_VALUE);
put(tm1, "r1", "", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq1", 5, "v1");
@@ -188,7 +188,7 @@ public class RowDeletingIteratorTest extends TestCase {
RowDeletingIterator rdi = new RowDeletingIterator();
rdi.init(new ColumnFamilySkippingIterator(new SortedMapIterator(tm1)), null, new TestIE(IteratorScope.scan, false));
- HashSet<ByteSequence> cols = new HashSet<ByteSequence>();
+ HashSet<ByteSequence> cols = new HashSet<>();
cols.add(new ArrayByteSequence("cf1".getBytes()));
rdi.seek(new Range(), cols, true);
@@ -208,7 +208,7 @@ public class RowDeletingIteratorTest extends TestCase {
public void test4() throws Exception {
- TreeMap<Key,Value> tm1 = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> tm1 = new TreeMap<>();
put(tm1, "r1", "", "", 10, RowDeletingIterator.DELETE_ROW_VALUE);
put(tm1, "r1", "cf1", "cq1", 5, "v1");
put(tm1, "r1", "cf1", "cq3", 15, "v1");
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/RowEncodingIteratorTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/RowEncodingIteratorTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/RowEncodingIteratorTest.java
index 8f228f5..f7f88af 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/RowEncodingIteratorTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/RowEncodingIteratorTest.java
@@ -86,9 +86,9 @@ public class RowEncodingIteratorTest {
public static SortedMap<Key,Value> decodeRow(Key rowKey, Value rowValue) throws IOException {
DataInputStream dis = new DataInputStream(new ByteArrayInputStream(rowValue.get()));
int numKeys = dis.readInt();
- List<Key> decodedKeys = new ArrayList<Key>();
- List<Value> decodedValues = new ArrayList<Value>();
- SortedMap<Key,Value> out = new TreeMap<Key,Value>();
+ List<Key> decodedKeys = new ArrayList<>();
+ List<Value> decodedValues = new ArrayList<>();
+ SortedMap<Key,Value> out = new TreeMap<>();
for (int i = 0; i < numKeys; i++) {
Key k = new Key();
k.readFields(dis);
@@ -139,26 +139,26 @@ public class RowEncodingIteratorTest {
public void testEncodeAll() throws IOException {
byte[] kbVal = new byte[1024];
// This code is shamelessly borrowed from the WholeRowIteratorTest.
- SortedMap<Key,Value> map1 = new TreeMap<Key,Value>();
+ SortedMap<Key,Value> map1 = new TreeMap<>();
pkv(map1, "row1", "cf1", "cq1", "cv1", 5, kbVal);
pkv(map1, "row1", "cf1", "cq2", "cv1", 6, kbVal);
- SortedMap<Key,Value> map2 = new TreeMap<Key,Value>();
+ SortedMap<Key,Value> map2 = new TreeMap<>();
pkv(map2, "row2", "cf1", "cq1", "cv1", 5, kbVal);
pkv(map2, "row2", "cf1", "cq2", "cv1", 6, kbVal);
- SortedMap<Key,Value> map3 = new TreeMap<Key,Value>();
+ SortedMap<Key,Value> map3 = new TreeMap<>();
pkv(map3, "row3", "cf1", "cq1", "cv1", 5, kbVal);
pkv(map3, "row3", "cf1", "cq2", "cv1", 6, kbVal);
- SortedMap<Key,Value> map = new TreeMap<Key,Value>();
+ SortedMap<Key,Value> map = new TreeMap<>();
map.putAll(map1);
map.putAll(map2);
map.putAll(map3);
SortedMapIterator src = new SortedMapIterator(map);
Range range = new Range(new Text("row1"), true, new Text("row2"), true);
RowEncodingIteratorImpl iter = new RowEncodingIteratorImpl();
- Map<String,String> bigBufferOpts = new HashMap<String,String>();
+ Map<String,String> bigBufferOpts = new HashMap<>();
bigBufferOpts.put(RowEncodingIterator.MAX_BUFFER_SIZE_OPT, "3K");
iter.init(src, bigBufferOpts, new DummyIteratorEnv());
iter.seek(range, new ArrayList<ByteSequence>(), false);
@@ -183,16 +183,16 @@ public class RowEncodingIteratorTest {
public void testEncodeSome() throws IOException {
byte[] kbVal = new byte[1024];
// This code is shamelessly borrowed from the WholeRowIteratorTest.
- SortedMap<Key,Value> map1 = new TreeMap<Key,Value>();
+ SortedMap<Key,Value> map1 = new TreeMap<>();
pkv(map1, "row1", "cf1", "cq1", "cv1", 5, kbVal);
pkv(map1, "row1", "cf1", "cq2", "cv1", 6, kbVal);
- SortedMap<Key,Value> map = new TreeMap<Key,Value>();
+ SortedMap<Key,Value> map = new TreeMap<>();
map.putAll(map1);
SortedMapIterator src = new SortedMapIterator(map);
Range range = new Range(new Text("row1"), true, new Text("row2"), true);
RowEncodingIteratorImpl iter = new RowEncodingIteratorImpl();
- Map<String,String> bigBufferOpts = new HashMap<String,String>();
+ Map<String,String> bigBufferOpts = new HashMap<>();
bigBufferOpts.put(RowEncodingIterator.MAX_BUFFER_SIZE_OPT, "1K");
iter.init(src, bigBufferOpts, new DummyIteratorEnv());
iter.seek(range, new ArrayList<ByteSequence>(), false);
http://git-wip-us.apache.org/repos/asf/accumulo/blob/717febbf/core/src/test/java/org/apache/accumulo/core/iterators/user/RowFilterTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/accumulo/core/iterators/user/RowFilterTest.java b/core/src/test/java/org/apache/accumulo/core/iterators/user/RowFilterTest.java
index 7914ec0..e16ace7 100644
--- a/core/src/test/java/org/apache/accumulo/core/iterators/user/RowFilterTest.java
+++ b/core/src/test/java/org/apache/accumulo/core/iterators/user/RowFilterTest.java
@@ -92,7 +92,7 @@ public class RowFilterTest {
}
public static class RowZeroOrOneFilter extends RowFilter {
- private static final Set<String> passRows = new HashSet<String>(Arrays.asList("0", "1"));
+ private static final Set<String> passRows = new HashSet<>(Arrays.asList("0", "1"));
@Override
public boolean acceptRow(SortedKeyValueIterator<Key,Value> rowIterator) throws IOException {
@@ -101,7 +101,7 @@ public class RowFilterTest {
}
public static class RowOneOrTwoFilter extends RowFilter {
- private static final Set<String> passRows = new HashSet<String>(Arrays.asList("1", "2"));
+ private static final Set<String> passRows = new HashSet<>(Arrays.asList("1", "2"));
@Override
public boolean acceptRow(SortedKeyValueIterator<Key,Value> rowIterator) throws IOException {
@@ -117,7 +117,7 @@ public class RowFilterTest {
}
public List<Mutation> createMutations() {
- List<Mutation> mutations = new LinkedList<Mutation>();
+ List<Mutation> mutations = new LinkedList<>();
Mutation m = new Mutation("0");
m.put("cf1", "cq1", "1");
m.put("cf1", "cq2", "1");
@@ -166,7 +166,7 @@ public class RowFilterTest {
public TreeMap<Key,Value> createKeyValues() {
List<Mutation> mutations = createMutations();
- TreeMap<Key,Value> keyValues = new TreeMap<Key,Value>();
+ TreeMap<Key,Value> keyValues = new TreeMap<>();
final Text cf = new Text(), cq = new Text();
for (Mutation m : mutations) {
@@ -200,10 +200,10 @@ public class RowFilterTest {
conn.tableOperations().attachIterator("table1", is);
Scanner scanner = conn.createScanner("table1", Authorizations.EMPTY);
- assertEquals(new HashSet<String>(Arrays.asList("2", "3")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("2", "3")), getRows(scanner));
scanner.fetchColumn(new Text("cf1"), new Text("cq2"));
- assertEquals(new HashSet<String>(Arrays.asList("1", "3")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("1", "3")), getRows(scanner));
scanner.clearColumns();
scanner.fetchColumn(new Text("cf1"), new Text("cq1"));
@@ -211,11 +211,11 @@ public class RowFilterTest {
scanner.setRange(new Range("0", "4"));
scanner.clearColumns();
- assertEquals(new HashSet<String>(Arrays.asList("2", "3")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("2", "3")), getRows(scanner));
scanner.setRange(new Range("2"));
scanner.clearColumns();
- assertEquals(new HashSet<String>(Arrays.asList("2")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("2")), getRows(scanner));
scanner.setRange(new Range("4"));
scanner.clearColumns();
@@ -225,7 +225,7 @@ public class RowFilterTest {
scanner.clearColumns();
scanner.fetchColumn(new Text("cf1"), new Text("cq2"));
scanner.fetchColumn(new Text("cf1"), new Text("cq4"));
- assertEquals(new HashSet<String>(Arrays.asList("4")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("4")), getRows(scanner));
}
@@ -242,7 +242,7 @@ public class RowFilterTest {
conn.tableOperations().attachIterator("chained_row_filters", new IteratorSetting(40, "trueFilter1", TrueFilter.class));
conn.tableOperations().attachIterator("chained_row_filters", new IteratorSetting(41, "trueFilter2", TrueFilter.class));
Scanner scanner = conn.createScanner("chained_row_filters", Authorizations.EMPTY);
- assertEquals(new HashSet<String>(Arrays.asList("0", "1", "2", "3", "4")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("0", "1", "2", "3", "4")), getRows(scanner));
}
@Test
@@ -258,7 +258,7 @@ public class RowFilterTest {
conn.tableOperations().attachIterator("filter_conjunction", new IteratorSetting(40, "rowZeroOrOne", RowZeroOrOneFilter.class));
conn.tableOperations().attachIterator("filter_conjunction", new IteratorSetting(41, "rowOneOrTwo", RowOneOrTwoFilter.class));
Scanner scanner = conn.createScanner("filter_conjunction", Authorizations.EMPTY);
- assertEquals(new HashSet<String>(Arrays.asList("1")), getRows(scanner));
+ assertEquals(new HashSet<>(Arrays.asList("1")), getRows(scanner));
}
@Test
@@ -308,7 +308,7 @@ public class RowFilterTest {
}
private HashSet<String> getRows(Scanner scanner) {
- HashSet<String> rows = new HashSet<String>();
+ HashSet<String> rows = new HashSet<>();
for (Entry<Key,Value> entry : scanner) {
rows.add(entry.getKey().getRow().toString());
}