You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gora.apache.org by le...@apache.org on 2015/09/05 18:05:49 UTC
[1/3] gora git commit: Java 7 changes and improvements including
diamond operators, automatic resource handling, unnecessary boxing,
collapsing exceptions, and iterations.
Repository: gora
Updated Branches:
refs/heads/master 550c89589 -> e201926a3
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/mapreduce/MapReduceTestUtils.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/mapreduce/MapReduceTestUtils.java b/gora-core/src/test/java/org/apache/gora/mapreduce/MapReduceTestUtils.java
index c04f615..f75fa9e 100644
--- a/gora-core/src/test/java/org/apache/gora/mapreduce/MapReduceTestUtils.java
+++ b/gora-core/src/test/java/org/apache/gora/mapreduce/MapReduceTestUtils.java
@@ -55,7 +55,7 @@ public class MapReduceTestUtils {
//create input
WebPageDataCreator.createWebPageData(dataStore);
- QueryCounter<String,WebPage> counter = new QueryCounter<String,WebPage>(conf);
+ QueryCounter<String,WebPage> counter = new QueryCounter<>(conf);
Query<String,WebPage> query = dataStore.newQuery();
List<Field> fields = WebPage.SCHEMA$.getFields();
String[] fieldNames = new String[fields.size() - 1];
@@ -89,7 +89,7 @@ public class MapReduceTestUtils {
wordCount.wordCount(inStore, outStore);
//assert results
- HashMap<String, Integer> actualCounts = new HashMap<String, Integer>();
+ HashMap<String, Integer> actualCounts = new HashMap<>();
for(String content : WebPageDataCreator.CONTENTS) {
if (content != null) {
for(String token:content.split(" ")) {
@@ -119,7 +119,7 @@ public class MapReduceTestUtils {
wordCount.wordCount(inStore, outStore);
//assert results
- HashMap<String, Integer> actualCounts = new HashMap<String, Integer>();
+ HashMap<String, Integer> actualCounts = new HashMap<>();
for(String content : WebPageDataCreator.CONTENTS) {
if (content != null) {
for(String token:content.split(" ")) {
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/mapreduce/TestGoraInputFormat.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/mapreduce/TestGoraInputFormat.java b/gora-core/src/test/java/org/apache/gora/mapreduce/TestGoraInputFormat.java
index 74512b0..7e44d8d 100644
--- a/gora-core/src/test/java/org/apache/gora/mapreduce/TestGoraInputFormat.java
+++ b/gora-core/src/test/java/org/apache/gora/mapreduce/TestGoraInputFormat.java
@@ -54,7 +54,7 @@ public class TestGoraInputFormat {
GoraInputFormat.setInput(job, query, false);
GoraInputFormat<String, MockPersistent> inputFormat
- = new GoraInputFormat<String, MockPersistent>();
+ = new GoraInputFormat<>();
inputFormat.setConf(job.getConfiguration());
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/memory/store/MemStoreTest.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/memory/store/MemStoreTest.java b/gora-core/src/test/java/org/apache/gora/memory/store/MemStoreTest.java
index f715280..3007298 100644
--- a/gora-core/src/test/java/org/apache/gora/memory/store/MemStoreTest.java
+++ b/gora-core/src/test/java/org/apache/gora/memory/store/MemStoreTest.java
@@ -12,7 +12,7 @@ public class MemStoreTest {
@Test
public void testGetMissingValue() {
- DataStore<String, WebPage> store = new MemStore<String, WebPage>();
+ DataStore<String, WebPage> store = new MemStore<>();
WebPage nullWebPage = store.get("missing", new String[0]);
assertNull(nullWebPage);
store.close();
@@ -21,7 +21,7 @@ public class MemStoreTest {
@Test
public void testPutGet() throws Exception {
String key = "org.apache.gora:http:/";
- DataStore<String, WebPage> store = new MemStore<String, WebPage>();
+ DataStore<String, WebPage> store = new MemStore<>();
assumeTrue(store.get(key, new String[0]) == null);
store.put(key, WebPage.newBuilder().build());
assertNotNull(store.get(key, new String[0]));
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/mock/store/MockDataStore.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/mock/store/MockDataStore.java b/gora-core/src/test/java/org/apache/gora/mock/store/MockDataStore.java
index 6bdd1ee..7a7bc93 100644
--- a/gora-core/src/test/java/org/apache/gora/mock/store/MockDataStore.java
+++ b/gora-core/src/test/java/org/apache/gora/mock/store/MockDataStore.java
@@ -111,10 +111,10 @@ public class MockDataStore extends DataStoreBase<String, MockPersistent> {
Query<String, MockPersistent> query) throws IOException {
ArrayList<PartitionQuery<String, MockPersistent>> list =
- new ArrayList<PartitionQuery<String,MockPersistent>>();
+ new ArrayList<>();
for(int i=0; i<NUM_PARTITIONS; i++) {
- list.add(new PartitionQueryImpl<String, MockPersistent>(query, LOCATIONS[i]));
+ list.add(new PartitionQueryImpl<>(query, LOCATIONS[i]));
}
return list;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/query/impl/TestPartitionQueryImpl.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/query/impl/TestPartitionQueryImpl.java b/gora-core/src/test/java/org/apache/gora/query/impl/TestPartitionQueryImpl.java
index 316684b..8975f46 100644
--- a/gora-core/src/test/java/org/apache/gora/query/impl/TestPartitionQueryImpl.java
+++ b/gora-core/src/test/java/org/apache/gora/query/impl/TestPartitionQueryImpl.java
@@ -40,7 +40,7 @@ public class TestPartitionQueryImpl {
baseQuery.setLimit(42);
PartitionQueryImpl<String, MockPersistent>
- query = new PartitionQueryImpl<String, MockPersistent>(baseQuery);
+ query = new PartitionQueryImpl<>(baseQuery);
TestWritable.testWritable(query);
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java b/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
index 13ab390..0d4a0e6 100644
--- a/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
+++ b/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
@@ -215,12 +215,12 @@ public class DataStoreTestUtil {
throws Exception {
Employee employee = DataStoreTestUtil.createEmployee(dataStore);
- WebPage webpage = new BeanFactoryImpl<String,WebPage>(String.class,WebPage.class).newPersistent() ;
+ WebPage webpage = new BeanFactoryImpl<>(String.class,WebPage.class).newPersistent() ;
webpage.setUrl(new Utf8("url..")) ;
webpage.setContent(ByteBuffer.wrap("test content".getBytes(Charset.defaultCharset()))) ;
webpage.setParsedContent(new ArrayList<CharSequence>());
- Metadata metadata = new BeanFactoryImpl<String,Metadata>(String.class,Metadata.class).newPersistent();
+ Metadata metadata = new BeanFactoryImpl<>(String.class,Metadata.class).newPersistent();
webpage.setMetadata(metadata) ;
employee.setWebpage(webpage) ;
@@ -541,9 +541,9 @@ public class DataStoreTestUtil {
String anchor = "anchor";
// putting evens
- for (int i = 0; i < urls.length; i++) {
+ for (String url : urls) {
WebPage webPage = WebPage.newBuilder().build();
- webPage.setUrl(new Utf8(urls[i]));
+ webPage.setUrl(new Utf8(url));
for (int j = 0; j < urls.length; j += 2) {
webPage.getOutlinks().put(new Utf8(anchor + j), new Utf8(urls[j]));
}
@@ -552,8 +552,8 @@ public class DataStoreTestUtil {
dataStore.flush();
// putting odds
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
webPage.getOutlinks().clear();
for (int j = 1; j < urls.length; j += 2) {
webPage.getOutlinks().put(new Utf8(anchor + j), new Utf8(urls[j]));
@@ -566,8 +566,8 @@ public class DataStoreTestUtil {
}
dataStore.flush();
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
int count = 0;
for (int j = 1; j < urls.length; j += 2) {
CharSequence link = webPage.getOutlinks().get(new Utf8(anchor + j));
@@ -589,10 +589,10 @@ public class DataStoreTestUtil {
String[] headers = { "firstHeader", "secondHeader", "thirdHeader",
"fourthHeader", "fifthHeader", "sixthHeader" };
- for (int i = 0; i < urls.length; i++) {
+ for (String url : urls) {
WebPage webPage = WebPage.newBuilder().build();
- webPage.setUrl(new Utf8(urls[i]));
- //test put for nullable map field
+ webPage.setUrl(new Utf8(url));
+ //test put for nullable map field
// we put data to the 'headers' field which is a Map with default value of 'null'
webPage.setHeaders(new HashMap<CharSequence, CharSequence>());
for (int j = 0; j < headers.length; j += 2) {
@@ -603,8 +603,8 @@ public class DataStoreTestUtil {
dataStore.flush();
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
//webPage.getHeaders().clear(); //TODO clear method does not work
webPage.setHeaders(new HashMap<CharSequence, CharSequence>());
for (int j = 1; j < headers.length; j += 2) {
@@ -615,8 +615,8 @@ public class DataStoreTestUtil {
dataStore.flush();
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
int count = 0;
for (int j = 1; j < headers.length; j += 2) {
CharSequence headerSample = webPage.getHeaders().get(new Utf8(header + j));
@@ -636,9 +636,9 @@ public class DataStoreTestUtil {
"http://d.com/d", "http://e.com/e", "http://f.com/f", "http://g.com/g" };
String anchor = "anchor";
- for (int i = 0; i < urls.length; i++) {
+ for (String url : urls) {
WebPage webPage = WebPage.newBuilder().build();
- webPage.setUrl(new Utf8(urls[i]));
+ webPage.setUrl(new Utf8(url));
for (int j = 0; j < urls.length; j++) {
webPage.getOutlinks().put(new Utf8(anchor + j), new Utf8(urls[j]));
}
@@ -648,8 +648,8 @@ public class DataStoreTestUtil {
dataStore.flush();
// map entry removal test
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
for (int j = 1; j < urls.length; j += 2) {
webPage.getOutlinks().remove(new Utf8(anchor + j));
}
@@ -658,9 +658,9 @@ public class DataStoreTestUtil {
dataStore.flush();
- for (int i = 0; i < urls.length; i++) {
+ for (String url : urls) {
int count = 0;
- WebPage webPage = dataStore.get(urls[i]);
+ WebPage webPage = dataStore.get(url);
for (int j = 1; j < urls.length; j += 2) {
CharSequence link = webPage.getOutlinks().get(new Utf8(anchor + j));
assertNull(link);
@@ -681,9 +681,9 @@ public class DataStoreTestUtil {
String[] headers = { "firstHeader", "secondHeader", "thirdHeader",
"fourthHeader", "fifthHeader", "sixthHeader" };
- for (int i = 0; i < urls.length; i++) {
+ for (String url : urls) {
WebPage webPage = WebPage.newBuilder().build();
- webPage.setUrl(new Utf8(urls[i]));
+ webPage.setUrl(new Utf8(url));
webPage.setHeaders(new HashMap<CharSequence, CharSequence>());
for (int j = 0; j < headers.length; j++) {
webPage.getHeaders().put(new Utf8(header + j), new Utf8(headers[j]));
@@ -694,16 +694,16 @@ public class DataStoreTestUtil {
dataStore.flush();
// nullable map field removal test
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
webPage.setHeaders(null);
dataStore.put(webPage.getUrl().toString(), webPage);
}
dataStore.flush();
- for (int i = 0; i < urls.length; i++) {
- WebPage webPage = dataStore.get(urls[i]);
+ for (String url : urls) {
+ WebPage webPage = dataStore.get(url);
assertNull(webPage.getHeaders());
}
}
@@ -800,10 +800,8 @@ public class DataStoreTestUtil {
createWebPageData(store);
//create sorted set of urls
- List<String> sortedUrls = new ArrayList<String>();
- for(String url: URLS) {
- sortedUrls.add(url);
- }
+ List<String> sortedUrls = new ArrayList<>();
+ Collections.addAll(sortedUrls, URLS);
Collections.sort(sortedUrls);
//try all ranges
@@ -911,8 +909,8 @@ public class DataStoreTestUtil {
throws Exception {
int count = 0, partitionsCount = 0;
- Map<String, Integer> results = new HashMap<String, Integer>();
- Map<String, Integer> partitionResults = new HashMap<String, Integer>();
+ Map<String, Integer> results = new HashMap<>();
+ Map<String, Integer> partitionResults = new HashMap<>();
//execute query and count results
Result<String, WebPage> result = store.execute(query);
@@ -1049,18 +1047,18 @@ public class DataStoreTestUtil {
assertNumResults(store.newQuery(), URLS.length);
//assert that data is deleted
- for (int i = 0; i < SORTED_URLS.length; i++) {
- WebPage page = store.get(SORTED_URLS[i]);
+ for (String SORTED_URL : SORTED_URLS) {
+ WebPage page = store.get(SORTED_URL);
assertNotNull(page);
assertNotNull(page.getUrl());
- assertEquals(page.getUrl().toString(), SORTED_URLS[i]);
+ assertEquals(page.getUrl().toString(), SORTED_URL);
assertEquals("Map of Outlinks should have a size of '0' as the deleteByQuery "
+ "not only removes the data but also the data structure.", 0, page.getOutlinks().size());
assertEquals(0, page.getParsedContent().size());
- if(page.getContent() != null) {
+ if (page.getContent() != null) {
LOG.info("url:" + page.getUrl().toString());
- LOG.info( "limit:" + page.getContent().limit());
+ LOG.info("limit:" + page.getContent().limit());
} else {
assertNull(page.getContent());
}
@@ -1189,7 +1187,7 @@ public class DataStoreTestUtil {
public static String[] getFields(List<Field> schemaFields) {
- List<Field> list = new ArrayList<Field>();
+ List<Field> list = new ArrayList<>();
for (Field field : schemaFields) {
if (!Persistent.DIRTY_BYTES_FIELD_NAME.equalsIgnoreCase(field.name())) {
list.add(field);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/store/TestDataStoreFactory.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/store/TestDataStoreFactory.java b/gora-core/src/test/java/org/apache/gora/store/TestDataStoreFactory.java
index f5e2305..1ec5d1d 100644
--- a/gora-core/src/test/java/org/apache/gora/store/TestDataStoreFactory.java
+++ b/gora-core/src/test/java/org/apache/gora/store/TestDataStoreFactory.java
@@ -94,7 +94,7 @@ public class TestDataStoreFactory {
public void testFindProperty() {
Properties properties = DataStoreFactory.createProps();
- DataStore<String, MockPersistent> store = new DataFileAvroStore<String, MockPersistent>();
+ DataStore<String, MockPersistent> store = new DataFileAvroStore<>();
String fooValue = DataStoreFactory.findProperty(properties, store,
"foo_property", "foo_default");
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java b/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java
index 03ccd1b..9e06557 100644
--- a/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java
+++ b/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java
@@ -159,7 +159,7 @@ public class TestIOUtils {
@Test
public void testJavaSerializableSerde() throws Exception {
- Integer integer = Integer.valueOf(42);
+ Integer integer = 42;
testSerializeDeserialize(integer);
}
@@ -194,7 +194,7 @@ public class TestIOUtils {
public void testReadWriteNullFieldsInfo() throws IOException {
Integer n = null; //null
- Integer nn = new Integer(42); //not null
+ Integer nn = 42; //not null
testNullFieldsWith(nn);
testNullFieldsWith(n);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-goraci/src/main/java/org/apache/gora/goraci/Generator.java
----------------------------------------------------------------------
diff --git a/gora-goraci/src/main/java/org/apache/gora/goraci/Generator.java b/gora-goraci/src/main/java/org/apache/gora/goraci/Generator.java
index e3b86cd..c13f4c9 100644
--- a/gora-goraci/src/main/java/org/apache/gora/goraci/Generator.java
+++ b/gora-goraci/src/main/java/org/apache/gora/goraci/Generator.java
@@ -141,7 +141,7 @@ public class Generator extends Configured implements Tool {
public List<InputSplit> getSplits(JobContext job) throws IOException, InterruptedException {
int numMappers = job.getConfiguration().getInt("org.apache.gora.goraci.generator.mappers", 1);
- ArrayList<InputSplit> splits = new ArrayList<InputSplit>(numMappers);
+ ArrayList<InputSplit> splits = new ArrayList<>(numMappers);
for (int i = 0; i < numMappers; i++) {
splits.add(new GeneratorInputSplit());
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java
----------------------------------------------------------------------
diff --git a/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java b/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java
index b2e64f3..181e4b6 100644
--- a/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java
+++ b/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java
@@ -77,7 +77,7 @@ public class Verify extends Configured implements Tool {
String[] entries = context.getConfiguration().getStrings("org.apache.gora.goraci.verify.flushed");
if (entries != null && entries.length > 0) {
- flushed = new HashMap<Utf8,Long>();
+ flushed = new HashMap<>();
for (String entry : entries) {
String[] kv = entry.split(":");
flushed.put(new Utf8(kv[0]), Long.parseLong(kv[1]));
@@ -111,7 +111,7 @@ public class Verify extends Configured implements Tool {
}
public static class VerifyReducer extends Reducer<LongWritable,VLongWritable,Text,Text> {
- private ArrayList<Long> refs = new ArrayList<Long>();
+ private ArrayList<Long> refs = new ArrayList<>();
public void reduce(LongWritable key, Iterable<VLongWritable> values, Context context) throws IOException, InterruptedException {
@@ -245,7 +245,7 @@ public class Verify extends Configured implements Tool {
Query<Utf8,Flushed> query = flushedTable.newQuery();
Result<Utf8,Flushed> result = flushedTable.execute(query);
- ArrayList<String> flushedEntries = new ArrayList<String>();
+ ArrayList<String> flushedEntries = new ArrayList<>();
while (result.next()) {
flushedEntries.add(result.getKey() + ":" + result.get().getCount());
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseMapping.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseMapping.java b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseMapping.java
index 28d4cf1..d4cd449 100644
--- a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseMapping.java
+++ b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseMapping.java
@@ -66,9 +66,9 @@ public class HBaseMapping {
*/
public static class HBaseMappingBuilder {
private Map<String, Map<String, HColumnDescriptor>> tableToFamilies =
- new HashMap<String, Map<String, HColumnDescriptor>>();
+ new HashMap<>();
private Map<String, HBaseColumn> columnMap =
- new HashMap<String, HBaseColumn>();
+ new HashMap<>();
private TableName tableName;
@@ -148,7 +148,7 @@ public class HBaseMapping {
Map<String, HColumnDescriptor> families;
families = tableToFamilies.get(tableName);
if (families == null) {
- families = new HashMap<String, HColumnDescriptor>();
+ families = new HashMap<>();
tableToFamilies.put(tableName, families);
}
return families;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java
index f8e82d0..c294691 100644
--- a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java
+++ b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseStore.java
@@ -114,7 +114,7 @@ implements Configurable {
this.conf = HBaseConfiguration.create(getConf());
admin = new HBaseAdmin(this.conf);
mapping = readMapping(getConf().get(PARSE_MAPPING_FILE_KEY, DEFAULT_MAPPING_FILE));
- filterUtil = new HBaseFilterUtil<K, T>(this.conf);
+ filterUtil = new HBaseFilterUtil<>(this.conf);
} catch (FileNotFoundException ex) {
try {
mapping = readMapping(getConf().get(PARSE_MAPPING_FILE_KEY, DEPRECATED_MAPPING_FILE));
@@ -357,7 +357,7 @@ implements Configurable {
org.apache.gora.query.Result<K, T> result = null;
result = query.execute();
- ArrayList<Delete> deletes = new ArrayList<Delete>();
+ ArrayList<Delete> deletes = new ArrayList<>();
while(result.next()) {
Delete delete = new Delete(toBytes(result.getKey()));
deletes.add(delete);
@@ -384,7 +384,7 @@ implements Configurable {
@Override
public Query<K, T> newQuery() {
- return new HBaseQuery<K, T>(this);
+ return new HBaseQuery<>(this);
}
@Override
@@ -400,7 +400,7 @@ implements Configurable {
if (table == null) {
throw new IOException("No table was provided.");
}
- List<PartitionQuery<K,T>> partitions = new ArrayList<PartitionQuery<K,T>>(keys.getFirst().length);
+ List<PartitionQuery<K,T>> partitions = new ArrayList<>(keys.getFirst().length);
for (int i = 0; i < keys.getFirst().length; i++) {
String regionLocation = table.getRegionLocation(keys.getFirst()[i]).getHostname();
byte[] startRow = query.getStartKey() != null ? toBytes(query.getStartKey())
@@ -427,7 +427,7 @@ implements Configurable {
K endKey = Arrays.equals(HConstants.EMPTY_END_ROW, splitStop) ?
null : HBaseByteInterface.fromBytes(keyClass, splitStop);
- PartitionQueryImpl<K, T> partition = new PartitionQueryImpl<K, T>(
+ PartitionQueryImpl<K, T> partition = new PartitionQueryImpl<>(
query, startKey, endKey, regionLocation);
partition.setConf(getConf());
@@ -449,12 +449,12 @@ implements Configurable {
addFields(get, query.getFields());
addTimeRange(get, query);
Result result = table.get(get);
- return new HBaseGetResult<K,T>(this, query, result);
+ return new HBaseGetResult<>(this, query, result);
} else {
ResultScanner scanner = createScanner(query);
org.apache.gora.query.Result<K,T> result
- = new HBaseScannerResult<K,T>(this, query, scanner);
+ = new HBaseScannerResult<>(this, query, scanner);
return result;
}
@@ -642,7 +642,7 @@ implements Configurable {
return;
}
Schema valueSchema = fieldSchema.getValueType();
- Map<Utf8, Object> map = new HashMap<Utf8, Object>();
+ Map<Utf8, Object> map = new HashMap<>();
for (Entry<byte[], byte[]> e : qualMap.entrySet()) {
map.put(new Utf8(Bytes.toString(e.getKey())),
fromBytes(valueSchema, e.getValue()));
@@ -655,8 +655,8 @@ implements Configurable {
return;
}
valueSchema = fieldSchema.getElementType();
- ArrayList<Object> arrayList = new ArrayList<Object>();
- DirtyListWrapper<Object> dirtyListWrapper = new DirtyListWrapper<Object>(arrayList);
+ ArrayList<Object> arrayList = new ArrayList<>();
+ DirtyListWrapper<Object> dirtyListWrapper = new DirtyListWrapper<>(arrayList);
for (Entry<byte[], byte[]> e : qualMap.entrySet()) {
dirtyListWrapper.add(fromBytes(valueSchema, e.getValue()));
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
index 0f625ff..6803827 100644
--- a/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
+++ b/gora-hbase/src/main/java/org/apache/gora/hbase/store/HBaseTableConnection.java
@@ -68,7 +68,7 @@ public class HBaseTableConnection implements HTableInterface {
private final Configuration conf;
private final ThreadLocal<HTable> tables;
- private final BlockingQueue<HTable> pool = new LinkedBlockingQueue<HTable>();
+ private final BlockingQueue<HTable> pool = new LinkedBlockingQueue<>();
private final boolean autoFlush;
private final TableName tableName;
@@ -83,7 +83,7 @@ public class HBaseTableConnection implements HTableInterface {
public HBaseTableConnection(Configuration conf, String tableName, boolean autoflush)
throws IOException {
this.conf = conf;
- this.tables = new ThreadLocal<HTable>();
+ this.tables = new ThreadLocal<>();
this.tableName = TableName.valueOf(tableName);
this.autoFlush = autoflush;
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/main/java/org/apache/gora/hbase/util/DefaultFactory.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/util/DefaultFactory.java b/gora-hbase/src/main/java/org/apache/gora/hbase/util/DefaultFactory.java
index 43f4bd2..de26e58 100644
--- a/gora-hbase/src/main/java/org/apache/gora/hbase/util/DefaultFactory.java
+++ b/gora-hbase/src/main/java/org/apache/gora/hbase/util/DefaultFactory.java
@@ -40,7 +40,7 @@ public class DefaultFactory <K, T extends PersistentBase> extends BaseFactory<K,
@Override
public List<String> getSupportedFilters() {
- List<String> filters = new ArrayList<String>();
+ List<String> filters = new ArrayList<>();
filters.add(SingleFieldValueFilter.class.getCanonicalName());
filters.add(MapFieldValueFilter.class.getCanonicalName());
filters.add(FilterList.class.getCanonicalName());
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseByteInterface.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseByteInterface.java b/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseByteInterface.java
index 5256e37..c20383b 100644
--- a/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseByteInterface.java
+++ b/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseByteInterface.java
@@ -46,12 +46,12 @@ public class HBaseByteInterface {
* Threadlocals maintaining reusable binary decoders and encoders.
*/
private static ThreadLocal<ByteArrayOutputStream> outputStream =
- new ThreadLocal<ByteArrayOutputStream>();
+ new ThreadLocal<>();
public static final ThreadLocal<BinaryDecoder> decoders =
- new ThreadLocal<BinaryDecoder>();
+ new ThreadLocal<>();
public static final ThreadLocal<BinaryEncoder> encoders =
- new ThreadLocal<BinaryEncoder>();
+ new ThreadLocal<>();
/*
* Create a threadlocal map for the datum readers and writers, because
* they are not thread safe, at least not before Avro 1.4.0 (See AVRO-650).
@@ -60,10 +60,10 @@ public class HBaseByteInterface {
*/
public static final ConcurrentHashMap<String, SpecificDatumReader<?>> readerMap =
- new ConcurrentHashMap<String, SpecificDatumReader<?>>();
+ new ConcurrentHashMap<>();
public static final ConcurrentHashMap<String, SpecificDatumWriter<?>> writerMap =
- new ConcurrentHashMap<String, SpecificDatumWriter<?>>();
+ new ConcurrentHashMap<>();
/**
* Deserializes an array of bytes matching the given schema to the proper basic
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseFilterUtil.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseFilterUtil.java b/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseFilterUtil.java
index 6e26607..c850fd7 100644
--- a/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseFilterUtil.java
+++ b/gora-hbase/src/main/java/org/apache/gora/hbase/util/HBaseFilterUtil.java
@@ -33,7 +33,7 @@ import java.util.Map;
public class HBaseFilterUtil<K, T extends PersistentBase> {
private static final Log LOG = LogFactory.getLog(HBaseFilterUtil.class);
- private Map<String, FilterFactory<K, T>> factories = new LinkedHashMap<String, FilterFactory<K, T>>();
+ private Map<String, FilterFactory<K, T>> factories = new LinkedHashMap<>();
public HBaseFilterUtil(Configuration conf) throws GoraException {
String[] factoryClassNames = conf.getStrings("gora.hbase.filter.factories", "org.apache.gora.hbase.util.DefaultFactory");
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-hbase/src/test/java/org/apache/gora/hbase/util/TestHBaseByteInterface.java
----------------------------------------------------------------------
diff --git a/gora-hbase/src/test/java/org/apache/gora/hbase/util/TestHBaseByteInterface.java b/gora-hbase/src/test/java/org/apache/gora/hbase/util/TestHBaseByteInterface.java
index e25a267..7333342 100644
--- a/gora-hbase/src/test/java/org/apache/gora/hbase/util/TestHBaseByteInterface.java
+++ b/gora-hbase/src/test/java/org/apache/gora/hbase/util/TestHBaseByteInterface.java
@@ -75,7 +75,7 @@ public class TestHBaseByteInterface {
//metadata
CharSequence key = new Utf8("theKey");
CharSequence value = new Utf8("theValue " + RANDOM.nextLong());
- HashMap<CharSequence, CharSequence> data = new HashMap<CharSequence, CharSequence>();
+ HashMap<CharSequence, CharSequence> data = new HashMap<>();
data.put(key, value);
Metadata m = Metadata.newBuilder().build();
m.setData(data);
@@ -95,7 +95,7 @@ public class TestHBaseByteInterface {
ExecutorService pool = Executors.newFixedThreadPool(numThreads);
// define a list of tasks
- Collection<Callable<Integer>> tasks = new ArrayList<Callable<Integer>>();
+ Collection<Callable<Integer>> tasks = new ArrayList<>();
for (int i = 0; i < numThreads; i++) {
tasks.add(new Callable<Integer>() {
@Override
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/DefaultFactory.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/DefaultFactory.java b/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/DefaultFactory.java
index 1e697f2..597f7e9 100644
--- a/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/DefaultFactory.java
+++ b/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/DefaultFactory.java
@@ -37,7 +37,7 @@ public class DefaultFactory<K, T extends PersistentBase> extends
@Override
public List<String> getSupportedFilters() {
- List<String> filters = new ArrayList<String>();
+ List<String> filters = new ArrayList<>();
filters.add(SingleFieldValueFilter.class.getCanonicalName());
filters.add(MapFieldValueFilter.class.getCanonicalName());
filters.add(FilterList.class.getCanonicalName());
@@ -158,7 +158,7 @@ public class DefaultFactory<K, T extends PersistentBase> extends
* @see <a href="https://issues.apache.org/jira/browse/GORA-388">GORA-388</a>
*/
private List<String> convertOperandsToString(List<Object> rawOperands) {
- List<String> operands = new ArrayList<String>(rawOperands.size());
+ List<String> operands = new ArrayList<>(rawOperands.size());
for (Object rawOperand : rawOperands) {
if (rawOperand != null) {
operands.add(rawOperand.toString());
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/MongoFilterUtil.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/MongoFilterUtil.java b/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/MongoFilterUtil.java
index 126dc4c..96a4ef1 100644
--- a/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/MongoFilterUtil.java
+++ b/gora-mongodb/src/main/java/org/apache/gora/mongodb/filters/MongoFilterUtil.java
@@ -60,7 +60,7 @@ public class MongoFilterUtil<K, T extends PersistentBase> {
*/
private static final Log LOG = LogFactory.getLog(MongoFilterUtil.class);
- private Map<String, FilterFactory<K, T>> factories = new LinkedHashMap<String, FilterFactory<K, T>>();
+ private Map<String, FilterFactory<K, T>> factories = new LinkedHashMap<>();
public MongoFilterUtil(final Configuration conf) throws GoraException {
String[] factoryClassNames = conf.getStrings(
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoMapping.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoMapping.java b/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoMapping.java
index 7f754ff..17f5d83 100644
--- a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoMapping.java
+++ b/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoMapping.java
@@ -52,17 +52,17 @@ public class MongoMapping {
/**
* Mapping between the class fields and the Mongo document fields
*/
- private HashMap<String, String> classToDocument = new HashMap<String, String>();
+ private HashMap<String, String> classToDocument = new HashMap<>();
/**
* Mapping between the Mongo document fields and the class fields
*/
- private HashMap<String, String> documentToClass = new HashMap<String, String>();
+ private HashMap<String, String> documentToClass = new HashMap<>();
/**
* Mongo document description
*/
- private HashMap<String, DocumentFieldType> documentFields = new HashMap<String, DocumentFieldType>();
+ private HashMap<String, DocumentFieldType> documentFields = new HashMap<>();
/**
* Change the name of the collection.
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java b/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
index ebaf010..8e34776 100644
--- a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
+++ b/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
@@ -80,7 +80,7 @@ public class MongoStore<K, T extends PersistentBase> extends
/**
* MongoDB client
*/
- private static ConcurrentHashMap<String, MongoClient> mapsOfClients = new ConcurrentHashMap<String, MongoClient>();
+ private static ConcurrentHashMap<String, MongoClient> mapsOfClients = new ConcurrentHashMap<>();
private DB mongoClientDB;
@@ -109,10 +109,10 @@ public class MongoStore<K, T extends PersistentBase> extends
MongoStoreParameters parameters = MongoStoreParameters.load(properties, getConf());
super.initialize(keyClass, pPersistentClass, properties);
- filterUtil = new MongoFilterUtil<K, T>(getConf());
+ filterUtil = new MongoFilterUtil<>(getConf());
// Load the mapping
- MongoMappingBuilder<K, T> builder = new MongoMappingBuilder<K, T>(this);
+ MongoMappingBuilder<K, T> builder = new MongoMappingBuilder<>(this);
LOG.debug("Initializing Mongo store with mapping {}.",
new Object[] { parameters.getMappingFile() });
builder.fromFile(parameters.getMappingFile());
@@ -156,11 +156,11 @@ public class MongoStore<K, T extends PersistentBase> extends
// If configuration contains a login + secret, try to authenticated with DB
List<MongoCredential> credentials = null;
if (params.getLogin() != null && params.getSecret() != null) {
- credentials = new ArrayList<MongoCredential>();
+ credentials = new ArrayList<>();
credentials.add(MongoCredential.createCredential(params.getLogin(), params.getDbname(), params.getSecret().toCharArray()));
}
// Build server address
- List<ServerAddress> addrs = new ArrayList<ServerAddress>();
+ List<ServerAddress> addrs = new ArrayList<>();
Iterable<String> serversArray = Splitter.on(",").split(params.getServers());
if (serversArray != null) {
for (String server : serversArray) {
@@ -410,7 +410,7 @@ public class MongoStore<K, T extends PersistentBase> extends
cursor.addOption(Bytes.QUERYOPTION_NOTIMEOUT);
// Build the result
- MongoDBResult<K, T> mongoResult = new MongoDBResult<K, T>(this, query);
+ MongoDBResult<K, T> mongoResult = new MongoDBResult<>(this, query);
mongoResult.setCursor(cursor);
return mongoResult;
@@ -421,7 +421,7 @@ public class MongoStore<K, T extends PersistentBase> extends
*/
@Override
public Query<K, T> newQuery() {
- MongoDBQuery<K, T> query = new MongoDBQuery<K, T>(this);
+ MongoDBQuery<K, T> query = new MongoDBQuery<>(this);
query.setFields(getFieldsToQuery(null));
return query;
}
@@ -435,8 +435,8 @@ public class MongoStore<K, T extends PersistentBase> extends
throws IOException {
// FIXME: for now, there is only one partition as we do not handle
// MongoDB sharding configuration
- List<PartitionQuery<K, T>> partitions = new ArrayList<PartitionQuery<K, T>>();
- PartitionQueryImpl<K, T> partitionQuery = new PartitionQueryImpl<K, T>(
+ List<PartitionQuery<K, T>> partitions = new ArrayList<>();
+ PartitionQueryImpl<K, T> partitionQuery = new PartitionQueryImpl<>(
query);
partitionQuery.setConf(getConf());
partitions.add(partitionQuery);
@@ -603,7 +603,7 @@ public class MongoStore<K, T extends PersistentBase> extends
/* pp */ Object fromMongoList(final String docf, final Schema fieldSchema,
final BSONDecorator easybson, final Field f) {
List<Object> list = easybson.getDBList(docf);
- List<Object> rlist = new ArrayList<Object>();
+ List<Object> rlist = new ArrayList<>();
if (list == null) {
return new DirtyListWrapper(rlist);
}
@@ -615,13 +615,13 @@ public class MongoStore<K, T extends PersistentBase> extends
"item", new BSONDecorator(new BasicDBObject("item", item)));
rlist.add(o);
}
- return new DirtyListWrapper<Object>(rlist);
+ return new DirtyListWrapper<>(rlist);
}
/* pp */ Object fromMongoMap(final String docf, final Schema fieldSchema,
final BSONDecorator easybson, final Field f) {
BasicDBObject map = easybson.getDBObject(docf);
- Map<Utf8, Object> rmap = new HashMap<Utf8, Object>();
+ Map<Utf8, Object> rmap = new HashMap<>();
if (map == null) {
return new DirtyMapWrapper(rmap);
}
@@ -634,7 +634,7 @@ public class MongoStore<K, T extends PersistentBase> extends
new BSONDecorator(map));
rmap.put(new Utf8(decodedMapKey), o);
}
- return new DirtyMapWrapper<Utf8, Object>(rmap);
+ return new DirtyMapWrapper<>(rmap);
}
private Object fromMongoString(final DocumentFieldType storeType,
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-mongodb/src/test/java/org/apache/gora/mongodb/filters/DefaultFactoryTest.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/test/java/org/apache/gora/mongodb/filters/DefaultFactoryTest.java b/gora-mongodb/src/test/java/org/apache/gora/mongodb/filters/DefaultFactoryTest.java
index b6642b9..bb0f06d 100644
--- a/gora-mongodb/src/test/java/org/apache/gora/mongodb/filters/DefaultFactoryTest.java
+++ b/gora-mongodb/src/test/java/org/apache/gora/mongodb/filters/DefaultFactoryTest.java
@@ -39,12 +39,12 @@ public class DefaultFactoryTest {
@Before
public void setUp() throws Exception {
- filterFactory = new DefaultFactory<String, WebPage>();
+ filterFactory = new DefaultFactory<>();
filterFactory.setFilterUtil(new MongoFilterUtil<String, WebPage>(
new Configuration()));
// Create dummy mapping for unit testing
- store = new MongoStore<String, WebPage>();
+ store = new MongoStore<>();
store.getMapping().addClassField(null, "headers", "h", "document");
store.getMapping().addClassField(null, "url", "url", "string");
}
@@ -97,7 +97,7 @@ public class DefaultFactoryTest {
@Test
public void testCreateFilter_list_empty() throws Exception {
- FilterList<String, WebPage> filter = new FilterList<String, WebPage>();
+ FilterList<String, WebPage> filter = new FilterList<>();
DBObject dbObject = filterFactory.createFilter(filter, store);
assertEquals("{ }", dbObject.toString());
@@ -105,7 +105,7 @@ public class DefaultFactoryTest {
@Test
public void testCreateFilter_list_2() throws Exception {
- FilterList<String, WebPage> filter = new FilterList<String, WebPage>();
+ FilterList<String, WebPage> filter = new FilterList<>();
MapFieldValueFilter<String, WebPage> hFilter = createHeadersFilter();
hFilter.setFilterIfMissing(true);
hFilter.setFilterOp(FilterOp.EQUALS);
@@ -127,7 +127,7 @@ public class DefaultFactoryTest {
*/
@Test
public void testCreateFilter_handlingUtf8() throws Exception {
- SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<String, WebPage>();
+ SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<>();
filter.setFieldName(WebPage.Field.URL.toString());
filter.setFilterOp(FilterOp.EQUALS);
filter.getOperands().add(new Utf8("http://www.example.com"));
@@ -139,7 +139,7 @@ public class DefaultFactoryTest {
}
private MapFieldValueFilter<String, WebPage> createHeadersFilter() {
- MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<String, WebPage>();
+ MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<>();
filter.setFieldName(WebPage.Field.HEADERS.toString());
filter.setMapKey(new Utf8("C.T"));
filter.getOperands().add("text/html");
@@ -147,7 +147,7 @@ public class DefaultFactoryTest {
}
private SingleFieldValueFilter<String, WebPage> createUrlFilter() {
- SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<String, WebPage>();
+ SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<>();
filter.setFieldName(WebPage.Field.URL.toString());
filter.getOperands().add("http://www.example.com");
return filter;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-mongodb/src/test/java/org/apache/gora/mongodb/store/TestMongoMappingBuilder.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/test/java/org/apache/gora/mongodb/store/TestMongoMappingBuilder.java b/gora-mongodb/src/test/java/org/apache/gora/mongodb/store/TestMongoMappingBuilder.java
index cb04d46..6ba4108 100644
--- a/gora-mongodb/src/test/java/org/apache/gora/mongodb/store/TestMongoMappingBuilder.java
+++ b/gora-mongodb/src/test/java/org/apache/gora/mongodb/store/TestMongoMappingBuilder.java
@@ -29,10 +29,10 @@ public class TestMongoMappingBuilder {
@Test
public void testMultiMapping_Webpage() throws IOException {
- MongoStore<String, WebPage> store = new MongoStore<String, WebPage>();
+ MongoStore<String, WebPage> store = new MongoStore<>();
store.setKeyClass(String.class);
store.setPersistentClass(WebPage.class);
- MongoMappingBuilder<String, WebPage> builder = new MongoMappingBuilder<String, WebPage>(
+ MongoMappingBuilder<String, WebPage> builder = new MongoMappingBuilder<>(
store);
builder.fromFile("/multimapping.xml");
MongoMapping mapping = builder.build();
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-shims-hadoop/src/main/java/org/apache/gora/shims/hadoop/HadoopShimFactory.java
----------------------------------------------------------------------
diff --git a/gora-shims-hadoop/src/main/java/org/apache/gora/shims/hadoop/HadoopShimFactory.java b/gora-shims-hadoop/src/main/java/org/apache/gora/shims/hadoop/HadoopShimFactory.java
index b2c5213..57533cd 100644
--- a/gora-shims-hadoop/src/main/java/org/apache/gora/shims/hadoop/HadoopShimFactory.java
+++ b/gora-shims-hadoop/src/main/java/org/apache/gora/shims/hadoop/HadoopShimFactory.java
@@ -30,7 +30,7 @@ public class HadoopShimFactory {
/**
* Hadoop shim version mapping.
*/
- private static final Map<String, String> HADOOP_VERSION_TO_IMPL_MAP = new HashMap<String, String>();
+ private static final Map<String, String> HADOOP_VERSION_TO_IMPL_MAP = new HashMap<>();
static {
HADOOP_VERSION_TO_IMPL_MAP.put("1",
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-solr/src/main/java/org/apache/gora/solr/query/SolrResult.java
----------------------------------------------------------------------
diff --git a/gora-solr/src/main/java/org/apache/gora/solr/query/SolrResult.java b/gora-solr/src/main/java/org/apache/gora/solr/query/SolrResult.java
index 9480540..38c1fca 100644
--- a/gora-solr/src/main/java/org/apache/gora/solr/query/SolrResult.java
+++ b/gora-solr/src/main/java/org/apache/gora/solr/query/SolrResult.java
@@ -56,7 +56,7 @@ public class SolrResult<K, T extends PersistentBase> extends ResultBase<K, T> {
if (fields == null) {
params.set(CommonParams.FL, "*");
} else {
- HashSet<String> uniqFields = new HashSet<String>(Arrays.asList(fields));
+ HashSet<String> uniqFields = new HashSet<>(Arrays.asList(fields));
String keyFld = ((SolrStore<K, T>)dataStore).getMapping().getPrimaryKey();
uniqFields.add(keyFld); // return also primary key
StringBuilder sb = new StringBuilder();
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-solr/src/main/java/org/apache/gora/solr/store/SolrMapping.java
----------------------------------------------------------------------
diff --git a/gora-solr/src/main/java/org/apache/gora/solr/store/SolrMapping.java b/gora-solr/src/main/java/org/apache/gora/solr/store/SolrMapping.java
index 65802a4..424ae71 100644
--- a/gora-solr/src/main/java/org/apache/gora/solr/store/SolrMapping.java
+++ b/gora-solr/src/main/java/org/apache/gora/solr/store/SolrMapping.java
@@ -25,7 +25,7 @@ public class SolrMapping {
String primaryKey;
public SolrMapping() {
- mapping = new HashMap<String,String>();
+ mapping = new HashMap<>();
}
public void addField(String goraField, String solrField) {
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-solr/src/main/java/org/apache/gora/solr/store/SolrStore.java
----------------------------------------------------------------------
diff --git a/gora-solr/src/main/java/org/apache/gora/solr/store/SolrStore.java b/gora-solr/src/main/java/org/apache/gora/solr/store/SolrStore.java
index ad923b6..b437299 100644
--- a/gora-solr/src/main/java/org/apache/gora/solr/store/SolrStore.java
+++ b/gora-solr/src/main/java/org/apache/gora/solr/store/SolrStore.java
@@ -175,9 +175,9 @@ public class SolrStore<K, T extends PersistentBase> extends DataStoreBase<K, T>
* pair for every schema, instead of one for every thread.
*/
- public static final ConcurrentHashMap<String, SpecificDatumReader<?>> readerMap = new ConcurrentHashMap<String, SpecificDatumReader<?>>();
+ public static final ConcurrentHashMap<String, SpecificDatumReader<?>> readerMap = new ConcurrentHashMap<>();
- public static final ConcurrentHashMap<String, SpecificDatumWriter<?>> writerMap = new ConcurrentHashMap<String, SpecificDatumWriter<?>>();
+ public static final ConcurrentHashMap<String, SpecificDatumWriter<?>> writerMap = new ConcurrentHashMap<>();
@Override
public void initialize(Class<K> keyClass, Class<T> persistentClass,
@@ -276,7 +276,7 @@ public class SolrStore<K, T extends PersistentBase> extends DataStoreBase<K, T>
LOG.warn("Invalid batch size '{}', using default {}", batchSizeString, DEFAULT_BATCH_SIZE);
}
}
- batch = new ArrayList<SolrInputDocument>(batchSize);
+ batch = new ArrayList<>(batchSize);
String commitWithinString = DataStoreFactory.findProperty(properties, this,
SOLR_COMMIT_WITHIN_PROPERTY, null);
if (commitWithinString != null) {
@@ -681,9 +681,8 @@ public class SolrStore<K, T extends PersistentBase> extends DataStoreBase<K, T>
*/
private int getUnionSchema(Object pValue, Schema pUnionSchema) {
int unionSchemaPos = 0;
- Iterator<Schema> it = pUnionSchema.getTypes().iterator();
- while (it.hasNext()) {
- Type schemaType = it.next().getType();
+ for (Schema currentSchema : pUnionSchema.getTypes()) {
+ Type schemaType = currentSchema.getType();
if (pValue instanceof Utf8 && schemaType.equals(Type.STRING))
return unionSchemaPos;
else if (pValue instanceof ByteBuffer && schemaType.equals(Type.BYTES))
@@ -742,7 +741,7 @@ public class SolrStore<K, T extends PersistentBase> extends DataStoreBase<K, T>
@Override
public Result<K, T> execute(Query<K, T> query) {
try {
- return new SolrResult<K, T>(this, query, server, resultsSize);
+ return new SolrResult<>(this, query, server, resultsSize);
} catch (IOException e) {
LOG.error(e.getMessage(), e);
}
@@ -751,7 +750,7 @@ public class SolrStore<K, T extends PersistentBase> extends DataStoreBase<K, T>
@Override
public Query<K, T> newQuery() {
- return new SolrQuery<K, T>(this);
+ return new SolrQuery<>(this);
}
@Override
@@ -759,8 +758,8 @@ public class SolrStore<K, T extends PersistentBase> extends DataStoreBase<K, T>
throws IOException {
// TODO: implement this using Hadoop DB support
- ArrayList<PartitionQuery<K, T>> partitions = new ArrayList<PartitionQuery<K, T>>();
- PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<K, T>(query);
+ ArrayList<PartitionQuery<K, T>> partitions = new ArrayList<>();
+ PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<>(query);
pqi.setConf(getConf());
partitions.add(pqi);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-solr/src/test/java/org/apache/gora/solr/store/TestSolrStore.java
----------------------------------------------------------------------
diff --git a/gora-solr/src/test/java/org/apache/gora/solr/store/TestSolrStore.java b/gora-solr/src/test/java/org/apache/gora/solr/store/TestSolrStore.java
index 95a7078..da33e6b 100644
--- a/gora-solr/src/test/java/org/apache/gora/solr/store/TestSolrStore.java
+++ b/gora-solr/src/test/java/org/apache/gora/solr/store/TestSolrStore.java
@@ -36,7 +36,7 @@ public class TestSolrStore extends DataStoreTestBase {
@Override
protected DataStore<String, Employee> createEmployeeDataStore()
throws IOException {
- SolrStore<String, Employee> store = new SolrStore<String, Employee>();
+ SolrStore<String, Employee> store = new SolrStore<>();
store.initialize(String.class, Employee.class, DataStoreFactory.createProps());
return store;
}
@@ -44,7 +44,7 @@ public class TestSolrStore extends DataStoreTestBase {
@Override
protected DataStore<String, WebPage> createWebPageDataStore()
throws IOException {
- SolrStore<String, WebPage> store = new SolrStore<String, WebPage>();
+ SolrStore<String, WebPage> store = new SolrStore<>();
store.initialize(String.class, WebPage.class, DataStoreFactory.createProps());
return store;
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogManager.java
----------------------------------------------------------------------
diff --git a/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogManager.java b/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogManager.java
index f94d79a..f089afb 100644
--- a/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogManager.java
+++ b/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogManager.java
@@ -82,25 +82,22 @@ public class LogManager {
*/
private void parse(String input) throws Exception {
log.info("Parsing file: {}", input);
- BufferedReader reader = new BufferedReader(new InputStreamReader(
- new FileInputStream(input), Charset.defaultCharset()));
- long lineCount = 0;
- try {
- String line = reader.readLine();
- do {
- Pageview pageview = parseLine(line);
-
- if(pageview != null) {
- //store the pageview
- storePageview(lineCount++, pageview);
- }
-
- line = reader.readLine();
- } while(line != null);
-
- } finally {
- reader.close();
- }
+ long lineCount = 0;
+ try (BufferedReader reader = new BufferedReader(new InputStreamReader(
+ new FileInputStream(input), Charset.defaultCharset()))) {
+ String line = reader.readLine();
+ do {
+ Pageview pageview = parseLine(line);
+
+ if (pageview != null) {
+ //store the pageview
+ storePageview(lineCount++, pageview);
+ }
+
+ line = reader.readLine();
+ } while (line != null);
+
+ }
log.info("finished parsing file. Total number of log lines: {}", lineCount);
}
[2/3] gora git commit: Java 7 changes and improvements including
diamond operators, automatic resource handling, unnecessary boxing,
collapsing exceptions, and iterations.
Posted by le...@apache.org.
Java 7 changes and improvements including diamond operators, automatic resource handling, unnecessary boxing, collapsing exceptions, and iterations.
Project: http://git-wip-us.apache.org/repos/asf/gora/repo
Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/f681764a
Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/f681764a
Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/f681764a
Branch: refs/heads/master
Commit: f681764a1b3fb9daeac57266418a874794d22809
Parents: 550c895
Author: Furkan KAMACI <fu...@gmail.com>
Authored: Sat Sep 5 18:45:33 2015 +0300
Committer: Furkan KAMACI <fu...@gmail.com>
Committed: Sat Sep 5 18:45:33 2015 +0300
----------------------------------------------------------------------
.../gora/accumulo/encoders/HexEncoder.java | 10 +--
.../gora/accumulo/store/AccumuloMapping.java | 6 +-
.../gora/accumulo/store/AccumuloStore.java | 54 +++++---------
.../accumulo/util/SignedBinaryEncoderTest.java | 4 +-
.../gora/cassandra/query/CassandraResult.java | 8 +--
.../cassandra/query/CassandraResultSet.java | 2 +-
.../cassandra/query/CassandraSuperColumn.java | 10 +--
.../serializers/AvroSerializerUtil.java | 10 +--
.../cassandra/serializers/ListSerializer.java | 8 +--
.../cassandra/serializers/MapSerializer.java | 10 +--
.../serializers/SpecificFixedSerializer.java | 2 +-
.../gora/cassandra/store/CassandraClient.java | 10 +--
.../gora/cassandra/store/CassandraMapping.java | 12 ++--
.../store/CassandraMappingManager.java | 9 +--
.../gora/cassandra/store/CassandraStore.java | 33 +++++----
.../org/apache/gora/compiler/GoraCompiler.java | 15 ++--
.../gora/compiler/utils/LicenseHeaders.java | 13 +---
.../gora/examples/WebPageDataCreator.java | 2 +-
.../org/apache/gora/avro/store/AvroStore.java | 8 +--
.../gora/avro/store/DataFileAvroStore.java | 8 +--
.../java/org/apache/gora/filter/FilterList.java | 4 +-
.../apache/gora/filter/MapFieldValueFilter.java | 5 +-
.../gora/filter/SingleFieldValueFilter.java | 7 +-
.../apache/gora/mapreduce/GoraInputFormat.java | 4 +-
.../gora/mapreduce/PersistentDeserializer.java | 2 +-
.../gora/mapreduce/PersistentSerializer.java | 2 +-
.../org/apache/gora/memory/store/MemStore.java | 12 ++--
.../impl/DirtyCollectionWrapper.java | 2 +-
.../gora/persistency/impl/DirtyListWrapper.java | 6 +-
.../gora/persistency/impl/DirtyMapWrapper.java | 4 +-
.../persistency/ws/impl/BeanFactoryWSImpl.java | 5 +-
.../persistency/ws/impl/PersistentWSBase.java | 6 +-
.../apache/gora/store/impl/DataStoreBase.java | 12 ++--
.../store/impl/FileBackedDataStoreBase.java | 4 +-
.../java/org/apache/gora/util/AvroUtils.java | 6 +-
.../main/java/org/apache/gora/util/IOUtils.java | 14 ++--
.../java/org/apache/gora/util/NodeWalker.java | 2 +-
.../java/org/apache/gora/util/StringUtils.java | 6 +-
.../java/org/apache/gora/GoraTestDriver.java | 2 +-
.../TestDataFileAvroStoreMapReduce.java | 2 +-
.../apache/gora/avro/store/TestAvroStore.java | 4 +-
.../gora/avro/store/TestDataFileAvroStore.java | 4 +-
.../gora/examples/TestWebPageDataCreator.java | 2 +-
.../gora/filter/TestMapFieldValueFilter.java | 8 +--
.../gora/filter/TestSingleFieldValueFilter.java | 8 +--
.../gora/mapreduce/MapReduceTestUtils.java | 6 +-
.../gora/mapreduce/TestGoraInputFormat.java | 2 +-
.../apache/gora/memory/store/MemStoreTest.java | 4 +-
.../apache/gora/mock/store/MockDataStore.java | 4 +-
.../gora/query/impl/TestPartitionQueryImpl.java | 2 +-
.../apache/gora/store/DataStoreTestUtil.java | 76 ++++++++++----------
.../apache/gora/store/TestDataStoreFactory.java | 2 +-
.../java/org/apache/gora/util/TestIOUtils.java | 4 +-
.../java/org/apache/gora/goraci/Generator.java | 2 +-
.../java/org/apache/gora/goraci/Verify.java | 6 +-
.../apache/gora/hbase/store/HBaseMapping.java | 6 +-
.../org/apache/gora/hbase/store/HBaseStore.java | 20 +++---
.../gora/hbase/store/HBaseTableConnection.java | 4 +-
.../apache/gora/hbase/util/DefaultFactory.java | 2 +-
.../gora/hbase/util/HBaseByteInterface.java | 10 +--
.../apache/gora/hbase/util/HBaseFilterUtil.java | 2 +-
.../gora/hbase/util/TestHBaseByteInterface.java | 4 +-
.../gora/mongodb/filters/DefaultFactory.java | 4 +-
.../gora/mongodb/filters/MongoFilterUtil.java | 2 +-
.../apache/gora/mongodb/store/MongoMapping.java | 6 +-
.../apache/gora/mongodb/store/MongoStore.java | 26 +++----
.../mongodb/filters/DefaultFactoryTest.java | 14 ++--
.../mongodb/store/TestMongoMappingBuilder.java | 4 +-
.../gora/shims/hadoop/HadoopShimFactory.java | 2 +-
.../org/apache/gora/solr/query/SolrResult.java | 2 +-
.../org/apache/gora/solr/store/SolrMapping.java | 2 +-
.../org/apache/gora/solr/store/SolrStore.java | 19 +++--
.../apache/gora/solr/store/TestSolrStore.java | 4 +-
.../apache/gora/tutorial/log/LogManager.java | 35 +++++----
74 files changed, 296 insertions(+), 347 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-accumulo/src/main/java/org/apache/gora/accumulo/encoders/HexEncoder.java
----------------------------------------------------------------------
diff --git a/gora-accumulo/src/main/java/org/apache/gora/accumulo/encoders/HexEncoder.java b/gora-accumulo/src/main/java/org/apache/gora/accumulo/encoders/HexEncoder.java
index d2291c5..6db5295 100644
--- a/gora-accumulo/src/main/java/org/apache/gora/accumulo/encoders/HexEncoder.java
+++ b/gora-accumulo/src/main/java/org/apache/gora/accumulo/encoders/HexEncoder.java
@@ -43,9 +43,9 @@ public class HexEncoder implements Encoder {
private long decode(byte[] a) {
long b = 0;
- for (int i = 0; i < a.length; i++) {
+ for (byte anA : a) {
b = b << 4;
- b |= fromChar(a[i]);
+ b |= fromChar(anA);
}
return b;
@@ -183,9 +183,9 @@ public class HexEncoder implements Encoder {
byte[] hex = new byte[bin.length * 2];
int j = 0;
- for (int i = 0; i < bin.length; i++) {
- hex[j++] = chars[0x0f & (bin[i] >>> 4)];
- hex[j++] = chars[0x0f & bin[i]];
+ for (byte aBin : bin) {
+ hex[j++] = chars[0x0f & (aBin >>> 4)];
+ hex[j++] = chars[0x0f & aBin];
}
return hex;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloMapping.java
----------------------------------------------------------------------
diff --git a/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloMapping.java b/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloMapping.java
index 08911e0..e0744b6 100644
--- a/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloMapping.java
+++ b/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloMapping.java
@@ -23,9 +23,9 @@ import org.apache.accumulo.core.util.Pair;
import org.apache.hadoop.io.Text;
public class AccumuloMapping {
- Map<String,Pair<Text,Text>> fieldMap = new HashMap<String,Pair<Text,Text>>();
- Map<Pair<Text,Text>,String> columnMap = new HashMap<Pair<Text,Text>,String>();
- Map<String,String> tableConfig = new HashMap<String,String>();
+ Map<String,Pair<Text,Text>> fieldMap = new HashMap<>();
+ Map<Pair<Text,Text>,String> columnMap = new HashMap<>();
+ Map<String,String> tableConfig = new HashMap<>();
String tableName;
String encoder;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloStore.java
----------------------------------------------------------------------
diff --git a/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloStore.java b/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloStore.java
index 6b213db..31141c3 100644
--- a/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloStore.java
+++ b/gora-accumulo/src/main/java/org/apache/gora/accumulo/store/AccumuloStore.java
@@ -349,11 +349,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
} else {
try {
encoder = (Encoder) getClass().getClassLoader().loadClass(mapping.encoder).newInstance();
- } catch (InstantiationException e) {
- throw new IOException(e);
- } catch (IllegalAccessException e) {
- throw new IOException(e);
- } catch (ClassNotFoundException e) {
+ } catch (InstantiationException | IllegalAccessException | ClassNotFoundException e) {
throw new IOException(e);
}
}
@@ -371,9 +367,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
if (autoCreateSchema && !schemaExists())
createSchema();
- } catch (AccumuloException e) {
- throw new IOException(e);
- } catch (AccumuloSecurityException e) {
+ } catch (AccumuloException | AccumuloSecurityException e) {
throw new IOException(e);
}
} catch(IOException e){
@@ -411,7 +405,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
if (qualifier.equals(""))
qualifier = null;
- Pair<Text,Text> col = new Pair<Text,Text>(new Text(family), qualifier == null ? null : new Text(qualifier));
+ Pair<Text,Text> col = new Pair<>(new Text(family), qualifier == null ? null : new Text(qualifier));
mapping.fieldMap.put(name, col);
mapping.columnMap.put(col, name);
}
@@ -458,11 +452,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
conn.tableOperations().setProperty(mapping.tableName, entry.getKey(), entry.getValue());
}
- } catch (AccumuloException e) {
- LOG.error(e.getMessage(), e);
- } catch (AccumuloSecurityException e) {
- LOG.error(e.getMessage(), e);
- } catch (TableExistsException e) {
+ } catch (AccumuloException | AccumuloSecurityException | TableExistsException e) {
LOG.error(e.getMessage(), e);
}
}
@@ -474,11 +464,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
batchWriter.close();
batchWriter = null;
conn.tableOperations().delete(mapping.tableName);
- } catch (AccumuloException e) {
- LOG.error(e.getMessage(), e);
- } catch (AccumuloSecurityException e) {
- LOG.error(e.getMessage(), e);
- } catch (TableNotFoundException e) {
+ } catch (AccumuloException | AccumuloSecurityException | TableNotFoundException e) {
LOG.error(e.getMessage(), e);
}
}
@@ -531,7 +517,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
switch (field.schema().getType()) {
case MAP: // first entry only. Next are handled above on the next loop
- currentMap = new DirtyMapWrapper<Utf8, Object>(new HashMap<Utf8, Object>());
+ currentMap = new DirtyMapWrapper<>(new HashMap<Utf8, Object>());
currentPos = field.pos();
currentFam = entry.getKey().getColumnFamily();
currentSchema = field.schema().getValueType();
@@ -540,7 +526,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
fromBytes(currentSchema, entry.getValue().get()));
break;
case ARRAY:
- currentArray = new DirtyListWrapper<Object>(new ArrayList<Object>());
+ currentArray = new DirtyListWrapper<>(new ArrayList<>());
currentPos = field.pos();
currentFam = entry.getKey().getColumnFamily();
currentSchema = field.schema().getElementType();
@@ -554,7 +540,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
.get(firstNotNullSchemaTypeIndex(field.schema()));
// map and array were coded without union index so need to be read the same way
if (effectiveSchema.getType() == Type.ARRAY) {
- currentArray = new DirtyListWrapper<Object>(new ArrayList<Object>());
+ currentArray = new DirtyListWrapper<>(new ArrayList<>());
currentPos = field.pos();
currentFam = entry.getKey().getColumnFamily();
currentSchema = field.schema().getElementType();
@@ -564,7 +550,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
break;
}
else if (effectiveSchema.getType() == Type.MAP) {
- currentMap = new DirtyMapWrapper<Utf8, Object>(new HashMap<Utf8, Object>());
+ currentMap = new DirtyMapWrapper<>(new HashMap<Utf8, Object>());
currentPos = field.pos();
currentFam = entry.getKey().getColumnFamily();
currentSchema = effectiveSchema.getValueType();
@@ -600,7 +586,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
* @return String The field name
*/
private String getFieldName(Entry<Key, Value> entry) {
- String fieldName = mapping.columnMap.get(new Pair<Text,Text>(entry.getKey().getColumnFamily(),
+ String fieldName = mapping.columnMap.get(new Pair<>(entry.getKey().getColumnFamily(),
entry.getKey().getColumnQualifier()));
if (fieldName == null) {
fieldName = mapping.columnMap.get(new Pair<Text,Text>(entry.getKey().getColumnFamily(), null));
@@ -693,7 +679,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
}
// continue like a regular top-level union
case RECORD:
- SpecificDatumWriter<Object> writer = new SpecificDatumWriter<Object>(field.schema());
+ SpecificDatumWriter<Object> writer = new SpecificDatumWriter<>(field.schema());
ByteArrayOutputStream os = new ByteArrayOutputStream();
org.apache.avro.io.BinaryEncoder encoder = EncoderFactory.get().binaryEncoder(os, null);
writer.write(o, encoder);
@@ -854,7 +840,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
public Result<K,T> execute(Query<K,T> query) {
try {
Scanner scanner = createScanner(query);
- return new AccumuloResult<K,T>(this, query, scanner);
+ return new AccumuloResult<>(this, query, scanner);
} catch (TableNotFoundException e) {
// TODO return empty result?
LOG.error(e.getMessage(), e);
@@ -864,7 +850,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
@Override
public Query<K,T> newQuery() {
- return new AccumuloQuery<K,T>(this);
+ return new AccumuloQuery<>(this);
}
Text pad(Text key, int bytes) {
@@ -887,7 +873,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
else
tl = TabletLocator.getInstance(conn.getInstance(), new Text(Tables.getTableId(conn.getInstance(), mapping.tableName)));
- Map<String,Map<KeyExtent,List<Range>>> binnedRanges = new HashMap<String,Map<KeyExtent,List<Range>>>();
+ Map<String,Map<KeyExtent,List<Range>>> binnedRanges = new HashMap<>();
tl.invalidateCache();
while (tl.binRanges(Collections.singletonList(createRange(query)), binnedRanges, credentials).size() > 0) {
@@ -900,7 +886,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
tl.invalidateCache();
}
- List<PartitionQuery<K,T>> ret = new ArrayList<PartitionQuery<K,T>>();
+ List<PartitionQuery<K,T>> ret = new ArrayList<>();
Text startRow = null;
Text endRow = null;
@@ -910,7 +896,7 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
endRow = new Text(toBytes(query.getEndKey()));
//hadoop expects hostnames, accumulo keeps track of IPs... so need to convert
- HashMap<String,String> hostNameCache = new HashMap<String,String>();
+ HashMap<String,String> hostNameCache = new HashMap<>();
for (Entry<String,Map<KeyExtent,List<Range>>> entry : binnedRanges.entrySet()) {
String ip = entry.getKey().split(":", 2)[0];
@@ -941,18 +927,14 @@ public class AccumuloStore<K,T extends PersistentBase> extends DataStoreBase<K,T
endKey = fromBytes(getKeyClass(), TextUtil.getBytes(endRow));
}
- PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<K,T>(query, startKey, endKey, location);
+ PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<>(query, startKey, endKey, location);
pqi.setConf(getConf());
ret.add(pqi);
}
}
return ret;
- } catch (TableNotFoundException e) {
- throw new IOException(e);
- } catch (AccumuloException e) {
- throw new IOException(e);
- } catch (AccumuloSecurityException e) {
+ } catch (TableNotFoundException | AccumuloException | AccumuloSecurityException e) {
throw new IOException(e);
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-accumulo/src/test/java/org/apache/gora/accumulo/util/SignedBinaryEncoderTest.java
----------------------------------------------------------------------
diff --git a/gora-accumulo/src/test/java/org/apache/gora/accumulo/util/SignedBinaryEncoderTest.java b/gora-accumulo/src/test/java/org/apache/gora/accumulo/util/SignedBinaryEncoderTest.java
index 16d54a7..0ae2c47 100644
--- a/gora-accumulo/src/test/java/org/apache/gora/accumulo/util/SignedBinaryEncoderTest.java
+++ b/gora-accumulo/src/test/java/org/apache/gora/accumulo/util/SignedBinaryEncoderTest.java
@@ -104,7 +104,7 @@ public class SignedBinaryEncoderTest {
@Test
public void testDouble() {
- ArrayList<Double> testData = new ArrayList<Double>();
+ ArrayList<Double> testData = new ArrayList<>();
testData.add(Double.NEGATIVE_INFINITY);
testData.add(Double.MIN_VALUE);
testData.add(Math.nextUp(Double.NEGATIVE_INFINITY));
@@ -135,7 +135,7 @@ public class SignedBinaryEncoderTest {
@Test
public void testFloat() {
- ArrayList<Float> testData = new ArrayList<Float>();
+ ArrayList<Float> testData = new ArrayList<>();
testData.add(Float.NEGATIVE_INFINITY);
testData.add(Float.MIN_VALUE);
testData.add(Math.nextUp(Float.NEGATIVE_INFINITY));
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResult.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResult.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResult.java
index 46dad15..dc99258 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResult.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResult.java
@@ -69,9 +69,9 @@ public class CassandraResult<K, T extends PersistentBase> extends ResultBase<K,
* @return
*/
private CassandraColumn getUnionTypeColumn(String pFieldName, Object[] pCassandraRow){
-
- for (int iCnt = 0; iCnt < pCassandraRow.length; iCnt++){
- CassandraColumn cColumn = (CassandraColumn)pCassandraRow[iCnt];
+
+ for (Object currentPCassandraRow : pCassandraRow) {
+ CassandraColumn cColumn = (CassandraColumn) currentPCassandraRow;
String columnName = StringSerializer.get().fromByteBuffer(cColumn.getName().duplicate());
if (pFieldName.equals(columnName))
return cColumn;
@@ -102,7 +102,7 @@ public class CassandraResult<K, T extends PersistentBase> extends ResultBase<K,
if (fieldName != null) {
// get field
- if (fieldName.indexOf(CassandraStore.UNION_COL_SUFIX) < 0) {
+ if (!fieldName.contains(CassandraStore.UNION_COL_SUFIX)) {
int pos = this.persistent.getSchema().getField(fieldName).pos();
Field field = fields.get(pos);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResultSet.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResultSet.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResultSet.java
index 5fc4e6c..c994860 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResultSet.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraResultSet.java
@@ -34,7 +34,7 @@ public class CassandraResultSet<K> extends ArrayList<CassandraRow<K>> {
/**
* Maps keys to indices in the list.
*/
- private HashMap<K, Integer> indexMap = new HashMap<K, Integer>();
+ private HashMap<K, Integer> indexMap = new HashMap<>();
public CassandraRow<K> getRow(K key) {
Integer integer = this.indexMap.get(key);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraSuperColumn.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraSuperColumn.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraSuperColumn.java
index b529316..84848bb 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraSuperColumn.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/query/CassandraSuperColumn.java
@@ -52,7 +52,7 @@ public class CassandraSuperColumn extends CassandraColumn {
switch (type) {
case ARRAY:
- List<Object> array = new ArrayList<Object>();
+ List<Object> array = new ArrayList<>();
for (HColumn<ByteBuffer, ByteBuffer> hColumn : this.hSuperColumn.getColumns()) {
Object memberValue = fromByteBuffer(fieldSchema.getElementType(), hColumn.getValue());
@@ -63,11 +63,11 @@ public class CassandraSuperColumn extends CassandraColumn {
break;
case MAP:
- Map<CharSequence, Object> map = new HashMap<CharSequence, Object>();
+ Map<CharSequence, Object> map = new HashMap<>();
for (HColumn<ByteBuffer, ByteBuffer> hColumn : this.hSuperColumn.getColumns()) {
CharSequence mapKey = CharSequenceSerializer.get().fromByteBuffer(hColumn.getName());
- if (mapKey.toString().indexOf(CassandraStore.UNION_COL_SUFIX) < 0) {
+ if (!mapKey.toString().contains(CassandraStore.UNION_COL_SUFIX)) {
Object memberValue = null;
// We need detect real type for UNION Fields
if (fieldSchema.getValueType().getType().equals(Type.UNION)){
@@ -170,9 +170,9 @@ public class CassandraSuperColumn extends CassandraColumn {
}
private HColumn<ByteBuffer, ByteBuffer> getUnionTypeColumn(String fieldName, Object[] hColumns) {
- for (int iCnt = 0; iCnt < hColumns.length; iCnt++){
+ for (Object currentHColumn : hColumns) {
@SuppressWarnings("unchecked")
- HColumn<ByteBuffer, ByteBuffer> hColumn = (HColumn<ByteBuffer, ByteBuffer>)hColumns[iCnt];
+ HColumn<ByteBuffer, ByteBuffer> hColumn = (HColumn<ByteBuffer, ByteBuffer>) currentHColumn;
String columnName = StringSerializer.get().fromByteBuffer(hColumn.getNameBytes().duplicate());
if (fieldName.equals(columnName))
return hColumn;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializerUtil.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializerUtil.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializerUtil.java
index a8f40d2..1fa6883 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializerUtil.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializerUtil.java
@@ -18,13 +18,13 @@ public class AvroSerializerUtil {
* Threadlocals maintaining reusable binary decoders and encoders.
*/
private static ThreadLocal<ByteArrayOutputStream> outputStream =
- new ThreadLocal<ByteArrayOutputStream>();
+ new ThreadLocal<>();
public static final ThreadLocal<BinaryEncoder> encoders =
- new ThreadLocal<BinaryEncoder>();
+ new ThreadLocal<>();
public static final ThreadLocal<BinaryDecoder> decoders =
- new ThreadLocal<BinaryDecoder>();
+ new ThreadLocal<>();
/**
* Create a {@link java.util.concurrent.ConcurrentHashMap} for the
@@ -36,10 +36,10 @@ public class AvroSerializerUtil {
* @see <a href="https://issues.apache.org/jira/browse/AVRO-650">AVRO-650</a>
*/
public static final ConcurrentHashMap<String, SpecificDatumWriter<?>> writerMap =
- new ConcurrentHashMap<String, SpecificDatumWriter<?>>();
+ new ConcurrentHashMap<>();
public static final ConcurrentHashMap<String, SpecificDatumReader<?>> readerMap =
- new ConcurrentHashMap<String, SpecificDatumReader<?>>();
+ new ConcurrentHashMap<>();
@SuppressWarnings({ "unchecked", "rawtypes" })
public static <T> byte[] serializer(T value, Schema schema) throws IOException{
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/ListSerializer.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/ListSerializer.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/ListSerializer.java
index 7530421..6422082 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/ListSerializer.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/ListSerializer.java
@@ -43,8 +43,8 @@ public class ListSerializer<T> extends AbstractSerializer<List<T>> {
public static final Logger LOG = LoggerFactory.getLogger(ListSerializer.class);
- private static Map<Type, ListSerializer> elementTypeToSerializerMap = new HashMap<Type, ListSerializer>();
- private static Map<Class, ListSerializer> fixedClassToSerializerMap = new HashMap<Class, ListSerializer>();
+ private static Map<Type, ListSerializer> elementTypeToSerializerMap = new HashMap<>();
+ private static Map<Class, ListSerializer> fixedClassToSerializerMap = new HashMap<>();
public static ListSerializer get(Type elementType) {
ListSerializer serializer = elementTypeToSerializerMap.get(elementType);
@@ -140,7 +140,7 @@ public class ListSerializer<T> extends AbstractSerializer<List<T>> {
private ByteBuffer toByteBufferWithVariableLengthElements(List<T> array) {
int n = array.size();
- List<byte[]> list = new ArrayList<byte[]>(n);
+ List<byte[]> list = new ArrayList<>(n);
n *= 4;
for (T element : array) {
byte[] bytes = BytesArraySerializer.get().fromByteBuffer(elementSerializer.toByteBuffer(element));
@@ -161,7 +161,7 @@ public class ListSerializer<T> extends AbstractSerializer<List<T>> {
if (byteBuffer == null) {
return null;
}
- ArrayList<T> array = new ArrayList<T>();
+ ArrayList<T> array = new ArrayList<>();
while (true) {
T element = null;
try {
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/MapSerializer.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/MapSerializer.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/MapSerializer.java
index 52849b8..2bdcea0 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/MapSerializer.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/MapSerializer.java
@@ -43,8 +43,8 @@ public class MapSerializer<T> extends AbstractSerializer<Map<CharSequence, T>> {
public static final Logger LOG = LoggerFactory.getLogger(MapSerializer.class);
- private static Map<Type, MapSerializer> valueTypeToSerializerMap = new HashMap<Type, MapSerializer>();
- private static Map<Class, MapSerializer> fixedClassToSerializerMap = new HashMap<Class, MapSerializer>();
+ private static Map<Type, MapSerializer> valueTypeToSerializerMap = new HashMap<>();
+ private static Map<Class, MapSerializer> fixedClassToSerializerMap = new HashMap<>();
public static MapSerializer get(Type valueType) {
MapSerializer serializer = valueTypeToSerializerMap.get(valueType);
@@ -131,7 +131,7 @@ public class MapSerializer<T> extends AbstractSerializer<Map<CharSequence, T>> {
private ByteBuffer toByteBufferWithFixedLengthElements(Map<CharSequence, T> map) {
int n = map.size();
- List<byte[]> list = new ArrayList<byte[]>(n);
+ List<byte[]> list = new ArrayList<>(n);
n *= 4;
for (CharSequence key : map.keySet()) {
T value = map.get(key);
@@ -157,7 +157,7 @@ public class MapSerializer<T> extends AbstractSerializer<Map<CharSequence, T>> {
private ByteBuffer toByteBufferWithVariableLengthElements(Map<CharSequence, T> map) {
int n = map.size();
- List<byte[]> list = new ArrayList<byte[]>(n);
+ List<byte[]> list = new ArrayList<>(n);
n *= 8;
for (CharSequence key : map.keySet()) {
T value = map.get(key);
@@ -182,7 +182,7 @@ public class MapSerializer<T> extends AbstractSerializer<Map<CharSequence, T>> {
if (byteBuffer == null) {
return null;
}
- Map<CharSequence, T> map = new HashMap<CharSequence, T>();
+ Map<CharSequence, T> map = new HashMap<>();
while (true) {
CharSequence key = null;
T value = null;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/SpecificFixedSerializer.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/SpecificFixedSerializer.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/SpecificFixedSerializer.java
index 2232c08..71f935a 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/SpecificFixedSerializer.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/serializers/SpecificFixedSerializer.java
@@ -47,7 +47,7 @@ public class SpecificFixedSerializer extends AbstractSerializer<SpecificFixed> {
return serializer;
}
- private static Map<Class, SpecificFixedSerializer> classToSerializerMap = new HashMap<Class, SpecificFixedSerializer>();
+ private static Map<Class, SpecificFixedSerializer> classToSerializerMap = new HashMap<>();
public static SpecificFixedSerializer get(Class clazz) {
SpecificFixedSerializer serializer = classToSerializerMap.get(clazz);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
index 4cca6f0..661bb21 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraClient.java
@@ -127,7 +127,7 @@ public class CassandraClient<K, T extends PersistentBase> {
String username = properties
.getProperty("gora.cassandrastore.username");
if (username != null) {
- accessMap = new HashMap<String, String>();
+ accessMap = new HashMap<>();
accessMap.put("username", username);
String password = properties
.getProperty("gora.cassandrastore.password");
@@ -240,7 +240,7 @@ public class CassandraClient<K, T extends PersistentBase> {
* @return Map<String, HConsistencyLevel> with the mapping between colFams and consistency level.
*/
private Map<String, HConsistencyLevel> getConsisLevelForColFams(List<ColumnFamilyDefinition> pColFams) {
- Map<String, HConsistencyLevel> clMap = new HashMap<String, HConsistencyLevel>();
+ Map<String, HConsistencyLevel> clMap = new HashMap<>();
// Get columnFamily consistency level.
String colFamConsisLvl = (colFamConsLvl != null && !colFamConsLvl.isEmpty())?colFamConsLvl:DEFAULT_HECTOR_CONSIS_LEVEL;
LOG.debug("ColumnFamily consistency level configured to '" + colFamConsisLvl + "'.");
@@ -554,7 +554,7 @@ public class CassandraClient<K, T extends PersistentBase> {
* corresponding column names required to get all the query fields.
*/
public Map<String, List<String>> getFamilyMap(Query<K, T> query) {
- Map<String, List<String>> map = new HashMap<String, List<String>>();
+ Map<String, List<String>> map = new HashMap<>();
Schema persistentSchema = query.getDataStore().newPersistent().getSchema();
for (String field: query.getFields()) {
String family = this.getMappingFamily(field);
@@ -563,7 +563,7 @@ public class CassandraClient<K, T extends PersistentBase> {
// check if the family value was already initialized
List<String> list = map.get(family);
if (list == null) {
- list = new ArrayList<String>();
+ list = new ArrayList<>();
map.put(family, list);
}
if (persistentSchema.getField(field).schema().getType() == Type.UNION)
@@ -593,7 +593,7 @@ public class CassandraClient<K, T extends PersistentBase> {
* names and values the query fields
*/
public Map<String, String> getReverseMap(Query<K, T> query) {
- Map<String, String> map = new HashMap<String, String>();
+ Map<String, String> map = new HashMap<>();
Schema persistentSchema = query.getDataStore().newPersistent().getSchema();
for (String field: query.getFields()) {
String family = this.getMappingFamily(field);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMapping.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMapping.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMapping.java
index e3b1243..a748bb4 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMapping.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMapping.java
@@ -64,28 +64,28 @@ public class CassandraMapping {
/**
* List of the super column families.
*/
- private List<String> superFamilies = new ArrayList<String>();
+ private List<String> superFamilies = new ArrayList<>();
/**
* Look up the column family associated to the Avro field.
*/
- private Map<String, String> familyMap = new HashMap<String, String>();
+ private Map<String, String> familyMap = new HashMap<>();
/**
* Look up the column associated to the Avro field.
*/
- private Map<String, String> columnMap = new HashMap<String, String>();
+ private Map<String, String> columnMap = new HashMap<>();
/**
* Helps storing attributes defined for each field.
*/
- private Map<String, String> columnAttrMap = new HashMap<String, String>();
+ private Map<String, String> columnAttrMap = new HashMap<>();
/**
* Look up the column family from its name.
*/
private Map<String, BasicColumnFamilyDefinition> columnFamilyDefinitions =
- new HashMap<String, BasicColumnFamilyDefinition>();
+ new HashMap<>();
/**
@@ -313,7 +313,7 @@ public class CassandraMapping {
}
public List<ColumnFamilyDefinition> getColumnFamilyDefinitions() {
- List<ColumnFamilyDefinition> list = new ArrayList<ColumnFamilyDefinition>();
+ List<ColumnFamilyDefinition> list = new ArrayList<>();
for (String key: this.columnFamilyDefinitions.keySet()) {
ColumnFamilyDefinition columnFamilyDefinition = this.columnFamilyDefinitions.get(key);
ThriftCfDef thriftCfDef = new ThriftCfDef(columnFamilyDefinition);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMappingManager.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMappingManager.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMappingManager.java
index 1e55178..18ea7c8 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMappingManager.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraMappingManager.java
@@ -56,15 +56,12 @@ public class CassandraMappingManager {
private Map<String, Element> mappingMap = null;
private CassandraMappingManager() {
- keyspaceMap = new HashMap<String, Element>();
- mappingMap = new HashMap<String, Element>();
+ keyspaceMap = new HashMap<>();
+ mappingMap = new HashMap<>();
try {
loadConfiguration();
}
- catch (JDOMException e) {
- LOG.error(e.toString());
- }
- catch (IOException e) {
+ catch (JDOMException | IOException e) {
LOG.error(e.toString());
}
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java
----------------------------------------------------------------------
diff --git a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java
index 10aea99..f13d91a 100644
--- a/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java
+++ b/gora-cassandra/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java
@@ -90,7 +90,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
public static String readOpConsLvl;
public static String writeOpConsLvl;
- private CassandraClient<K, T> cassandraClient = new CassandraClient<K, T>();
+ private CassandraClient<K, T> cassandraClient = new CassandraClient<>();
/**
* Fixed string with value "UnionIndex" used to generate an extra column based on
@@ -113,7 +113,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
private Map<K, T> buffer = Collections.synchronizedMap(new LinkedHashMap<K, T>());
public static final ThreadLocal<BinaryEncoder> encoders =
- new ThreadLocal<BinaryEncoder>();
+ new ThreadLocal<>();
/**
* Create a {@link java.util.concurrent.ConcurrentHashMap} for the
@@ -125,7 +125,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
* @see <a href="https://issues.apache.org/jira/browse/AVRO-650">AVRO-650</a>
*/
public static final ConcurrentHashMap<String, SpecificDatumWriter<?>> writerMap =
- new ConcurrentHashMap<String, SpecificDatumWriter<?>>();
+ new ConcurrentHashMap<>();
/** The default constructor for CassandraStore */
public CassandraStore() throws Exception {
@@ -196,14 +196,14 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
Map<String, List<String>> familyMap = this.cassandraClient.getFamilyMap(query);
Map<String, String> reverseMap = this.cassandraClient.getReverseMap(query);
- CassandraQuery<K, T> cassandraQuery = new CassandraQuery<K, T>();
+ CassandraQuery<K, T> cassandraQuery = new CassandraQuery<>();
cassandraQuery.setQuery(query);
cassandraQuery.setFamilyMap(familyMap);
- CassandraResult<K, T> cassandraResult = new CassandraResult<K, T>(this, query);
+ CassandraResult<K, T> cassandraResult = new CassandraResult<>(this, query);
cassandraResult.setReverseMap(reverseMap);
- CassandraResultSet<K> cassandraResultSet = new CassandraResultSet<K>();
+ CassandraResultSet<K> cassandraResultSet = new CassandraResultSet<>();
// We query Cassandra keyspace by families.
for (String family : familyMap.keySet()) {
@@ -239,7 +239,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
// find associated row in the resultset
CassandraRow<K> cassandraRow = cassandraResultSet.getRow(key);
if (cassandraRow == null) {
- cassandraRow = new CassandraRow<K>();
+ cassandraRow = new CassandraRow<>();
cassandraResultSet.putRow(key, cassandraRow);
cassandraRow.setKey(key);
}
@@ -269,7 +269,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
K key = superRow.getKey();
CassandraRow<K> cassandraRow = cassandraResultSet.getRow(key);
if (cassandraRow == null) {
- cassandraRow = new CassandraRow<K>();
+ cassandraRow = new CassandraRow<>();
cassandraResultSet.putRow(key, cassandraRow);
cassandraRow.setKey(key);
}
@@ -327,7 +327,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
@Override
public T get(K key, String[] fields) {
- CassandraQuery<K,T> query = new CassandraQuery<K,T>();
+ CassandraQuery<K,T> query = new CassandraQuery<>();
query.setDataStore(this);
query.setKeyRange(key, key);
@@ -352,8 +352,8 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
public List<PartitionQuery<K, T>> getPartitions(Query<K, T> query)
throws IOException {
// TODO GORA-298 Implement CassandraStore#getPartitions
- List<PartitionQuery<K,T>> partitions = new ArrayList<PartitionQuery<K,T>>();
- PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<K, T>(query);
+ List<PartitionQuery<K,T>> partitions = new ArrayList<>();
+ PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<>(query);
pqi.setConf(getConf());
partitions.add(pqi);
return partitions;
@@ -370,7 +370,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
@Override
public Query<K, T> newQuery() {
- Query<K,T> query = new CassandraQuery<K, T>(this);
+ Query<K,T> query = new CassandraQuery<>(this);
query.setFields(getFieldsToQuery(null));
return query;
}
@@ -530,7 +530,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
Schema valueSchema = schema.getValueType();
Type valueType = valueSchema.getType();
if (Type.UNION.equals(valueType)){
- Map<CharSequence,Object> valueMap = new HashMap<CharSequence, Object>();
+ Map<CharSequence,Object> valueMap = new HashMap<>();
for (CharSequence mapKey: map.keySet()) {
Object mapValue = map.get(mapKey);
int valueUnionIndex = getUnionSchema(mapValue, valueSchema);
@@ -625,9 +625,8 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
private int getUnionSchema(Object pValue, Schema pUnionSchema){
int unionSchemaPos = 0;
// String valueType = pValue.getClass().getSimpleName();
- Iterator<Schema> it = pUnionSchema.getTypes().iterator();
- while ( it.hasNext() ){
- Type schemaType = it.next().getType();
+ for (Schema currentSchema : pUnionSchema.getTypes()) {
+ Type schemaType = currentSchema.getType();
if (pValue instanceof CharSequence && schemaType.equals(Type.STRING))
return unionSchemaPos;
else if (pValue instanceof ByteBuffer && schemaType.equals(Type.BYTES))
@@ -648,7 +647,7 @@ public class CassandraStore<K, T extends PersistentBase> extends DataStoreBase<K
return unionSchemaPos;
else if (pValue instanceof Persistent && schemaType.equals(Type.RECORD))
return unionSchemaPos;
- unionSchemaPos ++;
+ unionSchemaPos++;
}
// if we weren't able to determine which data type it is, then we return the default
return DEFAULT_UNION_SCHEMA;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-compiler/src/main/java/org/apache/gora/compiler/GoraCompiler.java
----------------------------------------------------------------------
diff --git a/gora-compiler/src/main/java/org/apache/gora/compiler/GoraCompiler.java b/gora-compiler/src/main/java/org/apache/gora/compiler/GoraCompiler.java
index c1f5293..a3a4797 100644
--- a/gora-compiler/src/main/java/org/apache/gora/compiler/GoraCompiler.java
+++ b/gora-compiler/src/main/java/org/apache/gora/compiler/GoraCompiler.java
@@ -45,13 +45,13 @@ public class GoraCompiler extends SpecificCompiler {
public static final int FIRST_UNMANAGED_FIELD_INDEX = 1;
- private static final Set<String> GORA_RESERVED_NAMES = new HashSet<String>();
+ private static final Set<String> GORA_RESERVED_NAMES = new HashSet<>();
static {
GORA_RESERVED_NAMES.addAll(Arrays.asList(DIRTY_BYTES_FIELD_NAME));
}
- private static final Set<String> GORA_HIDDEN_FIELD_NAMES = new HashSet<String>();
+ private static final Set<String> GORA_HIDDEN_FIELD_NAMES = new HashSet<>();
static {
GORA_HIDDEN_FIELD_NAMES.add(DIRTY_BYTES_FIELD_NAME);
@@ -64,7 +64,7 @@ public class GoraCompiler extends SpecificCompiler {
for (File src : srcFiles) {
LOG.info("Compiling: {}", src.getAbsolutePath());
Schema originalSchema = parser.parse(src);
- Map<Schema,Schema> queue = new HashMap<Schema,Schema>();
+ //Map<Schema,Schema> queue = new HashMap<>();
//Schema newSchema = getSchemaWithDirtySupport(originalSchema, queue);
Schema newSchema = originalSchema;
GoraCompiler compiler = new GoraCompiler(newSchema);
@@ -222,10 +222,9 @@ public class GoraCompiler extends SpecificCompiler {
private static Schema getUnionSchemaWithDirtySupport(Schema originalSchema, Map<Schema,Schema> queue) throws IOException {
List<Schema> schemaTypes = originalSchema.getTypes();
- List<Schema> newTypeSchemas = new ArrayList<Schema>();
- for (int i = 0; i < schemaTypes.size(); i++) {
- Schema currentTypeSchema = schemaTypes.get(i);
- newTypeSchemas.add(getSchemaWithDirtySupport(currentTypeSchema,queue));
+ List<Schema> newTypeSchemas = new ArrayList<>();
+ for (Schema currentTypeSchema : schemaTypes) {
+ newTypeSchemas.add(getSchemaWithDirtySupport(currentTypeSchema, queue));
}
return Schema.createUnion(newTypeSchemas);
}
@@ -248,7 +247,7 @@ public class GoraCompiler extends SpecificCompiler {
queue.put(originalSchema, newSchema);
- List<Field> newFields = new ArrayList<Schema.Field>();
+ List<Field> newFields = new ArrayList<>();
byte[] defaultDirtyBytesValue = new byte[getNumberOfBytesNeededForDirtyBits(originalSchema)];
Arrays.fill(defaultDirtyBytesValue, (byte) 0);
JsonNode defaultDirtyJsonValue = JsonNodeFactory.instance
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-compiler/src/main/java/org/apache/gora/compiler/utils/LicenseHeaders.java
----------------------------------------------------------------------
diff --git a/gora-compiler/src/main/java/org/apache/gora/compiler/utils/LicenseHeaders.java b/gora-compiler/src/main/java/org/apache/gora/compiler/utils/LicenseHeaders.java
index 6428e36..1bba8a0 100644
--- a/gora-compiler/src/main/java/org/apache/gora/compiler/utils/LicenseHeaders.java
+++ b/gora-compiler/src/main/java/org/apache/gora/compiler/utils/LicenseHeaders.java
@@ -228,22 +228,13 @@ public class LicenseHeaders {
* Initializes relations between supported licenses and license text
*/
public void initializeRelations(){
- relatedLicenses = new HashMap<String, String>();
+ relatedLicenses = new HashMap<>();
try {
for (String licenseValue : supportedLicenses) {
String var = (String) this.getClass().getDeclaredField(licenseValue).get(licenseValue);
relatedLicenses.put(licenseValue,var);
}
- } catch (SecurityException e) {
- LOG.error(e.getMessage());
- throw new RuntimeException(e);
- } catch (NoSuchFieldException e) {
- LOG.error(e.getMessage());
- throw new RuntimeException(e);
- } catch (IllegalArgumentException e) {
- LOG.error(e.getMessage());
- throw new RuntimeException(e);
- } catch (IllegalAccessException e) {
+ } catch (SecurityException | NoSuchFieldException | IllegalArgumentException | IllegalAccessException e) {
LOG.error(e.getMessage());
throw new RuntimeException(e);
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/examples/java/org/apache/gora/examples/WebPageDataCreator.java
----------------------------------------------------------------------
diff --git a/gora-core/src/examples/java/org/apache/gora/examples/WebPageDataCreator.java b/gora-core/src/examples/java/org/apache/gora/examples/WebPageDataCreator.java
index cd933d5..38c13a9 100644
--- a/gora-core/src/examples/java/org/apache/gora/examples/WebPageDataCreator.java
+++ b/gora-core/src/examples/java/org/apache/gora/examples/WebPageDataCreator.java
@@ -55,7 +55,7 @@ public class WebPageDataCreator {
//"http://example.com",
};
- public static HashMap<String, Integer> URL_INDEXES = new HashMap<String, Integer>();
+ public static HashMap<String, Integer> URL_INDEXES = new HashMap<>();
static {
for(int i=0; i<URLS.length; i++) {
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/avro/store/AvroStore.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/avro/store/AvroStore.java b/gora-core/src/main/java/org/apache/gora/avro/store/AvroStore.java
index 817885d..1eb1efe 100644
--- a/gora-core/src/main/java/org/apache/gora/avro/store/AvroStore.java
+++ b/gora-core/src/main/java/org/apache/gora/avro/store/AvroStore.java
@@ -141,7 +141,7 @@ public class AvroStore<K, T extends PersistentBase>
*/
@Override
protected Result<K,T> executeQuery(Query<K,T> query) throws IOException {
- return new AvroResult<K,T>(this, (AvroQuery<K,T>)query,
+ return new AvroResult<>(this, (AvroQuery<K,T>)query,
getDatumReader(), getDecoder());
}
@@ -172,7 +172,7 @@ public class AvroStore<K, T extends PersistentBase>
@Override
public AvroQuery<K,T> newQuery() {
- return new AvroQuery<K,T>(this);
+ return new AvroQuery<>(this);
}
@Override
@@ -233,11 +233,11 @@ public class AvroStore<K, T extends PersistentBase>
}
protected DatumWriter<T> createDatumWriter() {
- return new SpecificDatumWriter<T>(schema);
+ return new SpecificDatumWriter<>(schema);
}
protected DatumReader<T> createDatumReader() {
- return new SpecificDatumReader<T>(schema);
+ return new SpecificDatumReader<>(schema);
}
@Override
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/avro/store/DataFileAvroStore.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/avro/store/DataFileAvroStore.java b/gora-core/src/main/java/org/apache/gora/avro/store/DataFileAvroStore.java
index 3d490b7..35c4cbf 100644
--- a/gora-core/src/main/java/org/apache/gora/avro/store/DataFileAvroStore.java
+++ b/gora-core/src/main/java/org/apache/gora/avro/store/DataFileAvroStore.java
@@ -65,7 +65,7 @@ public class DataFileAvroStore<K, T extends PersistentBase> extends AvroStore<K,
private DataFileWriter<T> getWriter() throws IOException {
if(writer == null) {
- writer = new DataFileWriter<T>(getDatumWriter());
+ writer = new DataFileWriter<>(getDatumWriter());
writer.create(schema, getOrCreateOutputStream());
}
return writer;
@@ -74,7 +74,7 @@ public class DataFileAvroStore<K, T extends PersistentBase> extends AvroStore<K,
@Override
protected Result<K, T> executeQuery(Query<K, T> query) {
try{
- return new DataFileAvroResult<K, T>(this, query
+ return new DataFileAvroResult<>(this, query
, createReader(createFsInput()));
} catch(IOException ex){
LOG.error(ex.getMessage(), ex);
@@ -87,7 +87,7 @@ public class DataFileAvroStore<K, T extends PersistentBase> extends AvroStore<K,
try{
FsInput fsInput = createFsInput();
DataFileReader<T> reader = createReader(fsInput);
- return new DataFileAvroResult<K, T>(this, query, reader, fsInput
+ return new DataFileAvroResult<>(this, query, reader, fsInput
, query.getStart(), query.getLength());
} catch(IOException ex){
LOG.error(ex.getMessage(), ex);
@@ -96,7 +96,7 @@ public class DataFileAvroStore<K, T extends PersistentBase> extends AvroStore<K,
}
private DataFileReader<T> createReader(FsInput fsInput) throws IOException {
- return new DataFileReader<T>(fsInput, getDatumReader());
+ return new DataFileReader<>(fsInput, getDatumReader());
}
private FsInput createFsInput() throws IOException {
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/filter/FilterList.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/filter/FilterList.java b/gora-core/src/main/java/org/apache/gora/filter/FilterList.java
index b0bca20..3700c89 100644
--- a/gora-core/src/main/java/org/apache/gora/filter/FilterList.java
+++ b/gora-core/src/main/java/org/apache/gora/filter/FilterList.java
@@ -38,7 +38,7 @@ public class FilterList<K, T extends PersistentBase> implements Filter<K, T> {
}
private Operator operator = Operator.MUST_PASS_ALL;
- private List<Filter<K, T>> filters = new ArrayList<Filter<K, T>>();
+ private List<Filter<K, T>> filters = new ArrayList<>();
public FilterList() {
}
@@ -74,7 +74,7 @@ public class FilterList<K, T extends PersistentBase> implements Filter<K, T> {
operator = Operator.values()[opByte];
int size = in.readInt();
if (size > 0) {
- filters = new ArrayList<Filter<K, T>>(size);
+ filters = new ArrayList<>(size);
try {
for (int i = 0; i < size; i++) {
@SuppressWarnings("unchecked")
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/filter/MapFieldValueFilter.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/filter/MapFieldValueFilter.java b/gora-core/src/main/java/org/apache/gora/filter/MapFieldValueFilter.java
index 40c7b41..f4c4383 100644
--- a/gora-core/src/main/java/org/apache/gora/filter/MapFieldValueFilter.java
+++ b/gora-core/src/main/java/org/apache/gora/filter/MapFieldValueFilter.java
@@ -42,7 +42,7 @@ public class MapFieldValueFilter<K, T extends PersistentBase> implements Filter<
protected String fieldName;
protected Utf8 mapKey;
protected FilterOp filterOp;
- protected List<Object> operands = new ArrayList<Object>();
+ protected List<Object> operands = new ArrayList<>();
protected boolean filterIfMissing = false;
private Configuration conf = new Configuration(); // just create empty conf,
@@ -54,8 +54,7 @@ public class MapFieldValueFilter<K, T extends PersistentBase> implements Filter<
Text.writeString(out, mapKey.toString());
WritableUtils.writeEnum(out, filterOp);
WritableUtils.writeVInt(out, operands.size());
- for (int i = 0; i < operands.size(); i++) {
- Object operand = operands.get(i);
+ for (Object operand : operands) {
if (operand instanceof String) {
throw new IllegalStateException("Use Utf8 instead of String for operands");
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/filter/SingleFieldValueFilter.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/filter/SingleFieldValueFilter.java b/gora-core/src/main/java/org/apache/gora/filter/SingleFieldValueFilter.java
index a000bc0..5b701a3 100644
--- a/gora-core/src/main/java/org/apache/gora/filter/SingleFieldValueFilter.java
+++ b/gora-core/src/main/java/org/apache/gora/filter/SingleFieldValueFilter.java
@@ -40,7 +40,7 @@ public class SingleFieldValueFilter<K, T extends PersistentBase> implements Filt
protected String fieldName;
protected FilterOp filterOp;
- protected List<Object> operands = new ArrayList<Object>();
+ protected List<Object> operands = new ArrayList<>();
protected boolean filterIfMissing = false;
private Configuration conf = new Configuration(); //just create empty conf,
@@ -50,13 +50,12 @@ public class SingleFieldValueFilter<K, T extends PersistentBase> implements Filt
Text.writeString(out, fieldName);
WritableUtils.writeEnum(out, filterOp);
WritableUtils.writeVInt(out, operands.size());
- for (int i = 0; i < operands.size(); i++) {
- Object operand = operands.get(i);
+ for (Object operand : operands) {
if (operand instanceof String) {
throw new IllegalStateException("Use Utf8 instead of String for operands");
}
if (operand instanceof Utf8) {
- operand=operand.toString();
+ operand = operand.toString();
}
if (operand instanceof Boolean) {
ObjectWritable.writeObject(out, operand, Boolean.TYPE, conf);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/mapreduce/GoraInputFormat.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/mapreduce/GoraInputFormat.java b/gora-core/src/main/java/org/apache/gora/mapreduce/GoraInputFormat.java
index 9249af8..320cfe7 100644
--- a/gora-core/src/main/java/org/apache/gora/mapreduce/GoraInputFormat.java
+++ b/gora-core/src/main/java/org/apache/gora/mapreduce/GoraInputFormat.java
@@ -84,7 +84,7 @@ public class GoraInputFormat<K, T extends PersistentBase>
((GoraInputSplit)split).getQuery();
setInputPath(partitionQuery, context);
- return new GoraRecordReader<K, T>(partitionQuery, context);
+ return new GoraRecordReader<>(partitionQuery, context);
}
@Override
@@ -92,7 +92,7 @@ public class GoraInputFormat<K, T extends PersistentBase>
InterruptedException {
List<PartitionQuery<K, T>> queries = dataStore.getPartitions(query);
- List<InputSplit> splits = new ArrayList<InputSplit>(queries.size());
+ List<InputSplit> splits = new ArrayList<>(queries.size());
for(PartitionQuery<K,T> query : queries) {
splits.add(new GoraInputSplit(context.getConfiguration(), query));
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentDeserializer.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentDeserializer.java b/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentDeserializer.java
index e331b4e..d592872 100644
--- a/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentDeserializer.java
+++ b/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentDeserializer.java
@@ -45,7 +45,7 @@ public class PersistentDeserializer
this.reuseObjects = reuseObjects;
try {
Schema schema = AvroUtils.getSchema(persistentClass);
- datumReader = new SpecificDatumReader<Persistent>(schema);
+ datumReader = new SpecificDatumReader<>(schema);
} catch (Exception ex) {
throw new RuntimeException(ex);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentSerializer.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentSerializer.java b/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentSerializer.java
index 96ed10b..4b1a646 100644
--- a/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentSerializer.java
+++ b/gora-core/src/main/java/org/apache/gora/mapreduce/PersistentSerializer.java
@@ -36,7 +36,7 @@ public class PersistentSerializer implements Serializer<Persistent> {
private BinaryEncoder encoder;
public PersistentSerializer() {
- this.datumWriter = new SpecificDatumWriter<Persistent>();
+ this.datumWriter = new SpecificDatumWriter<>();
}
@Override
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/memory/store/MemStore.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/memory/store/MemStore.java b/gora-core/src/main/java/org/apache/gora/memory/store/MemStore.java
index 444c0ba..162485c 100644
--- a/gora-core/src/main/java/org/apache/gora/memory/store/MemStore.java
+++ b/gora-core/src/main/java/org/apache/gora/memory/store/MemStore.java
@@ -136,7 +136,7 @@ public class MemStore<K, T extends PersistentBase> extends DataStoreBase<K, T> {
ConcurrentNavigableMap<K,T> submap = map.subMap(startKey, true, endKey, true);
- return new MemResult<K,T>(this, query, submap);
+ return new MemResult<>(this, query, submap);
}
@SuppressWarnings("unchecked")
@@ -162,8 +162,8 @@ public class MemStore<K, T extends PersistentBase> extends DataStoreBase<K, T> {
return obj;
}
T newObj = AvroUtils.deepClonePersistent(obj);
- for(int i = 0; i<otherFields.size(); i++) {
- int index = otherFields.get(i).pos();
+ for (Field otherField : otherFields) {
+ int index = otherField.pos();
newObj.put(index, obj.get(index));
}
return newObj;
@@ -171,7 +171,7 @@ public class MemStore<K, T extends PersistentBase> extends DataStoreBase<K, T> {
@Override
public Query<K, T> newQuery() {
- return new MemQuery<K, T>(this);
+ return new MemQuery<>(this);
}
@SuppressWarnings("unchecked")
@@ -185,8 +185,8 @@ public class MemStore<K, T extends PersistentBase> extends DataStoreBase<K, T> {
* Returns a single partition containing the original query
*/
public List<PartitionQuery<K, T>> getPartitions(Query<K, T> query){
- List<PartitionQuery<K, T>> list = new ArrayList<PartitionQuery<K,T>>();
- PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<K, T>(query);
+ List<PartitionQuery<K, T>> list = new ArrayList<>();
+ PartitionQueryImpl<K, T> pqi = new PartitionQueryImpl<>(query);
pqi.setConf(getConf());
list.add(pqi);
return list;
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyCollectionWrapper.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyCollectionWrapper.java b/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyCollectionWrapper.java
index 87fc00c..d9b85f5 100644
--- a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyCollectionWrapper.java
+++ b/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyCollectionWrapper.java
@@ -65,7 +65,7 @@ public class DirtyCollectionWrapper<T> implements Dirtyable,
@Override
public Iterator<T> iterator() {
- return new DirtyIteratorWrapper<T>(delegate.iterator(), dirtyFlag);
+ return new DirtyIteratorWrapper<>(delegate.iterator(), dirtyFlag);
}
@Override
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyListWrapper.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyListWrapper.java b/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyListWrapper.java
index ecc8715..3b09310 100644
--- a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyListWrapper.java
+++ b/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyListWrapper.java
@@ -73,19 +73,19 @@ public class DirtyListWrapper<T> extends DirtyCollectionWrapper<T> implements
@Override
public ListIterator<T> listIterator() {
- return new DirtyListIterator<T>(getDelegate().listIterator(),
+ return new DirtyListIterator<>(getDelegate().listIterator(),
getDirtyFlag());
}
@Override
public ListIterator<T> listIterator(int index) {
- return new DirtyListIterator<T>(getDelegate().listIterator(index),
+ return new DirtyListIterator<>(getDelegate().listIterator(index),
getDirtyFlag());
}
@Override
public List<T> subList(int fromIndex, int toIndex) {
- return new DirtyListWrapper<T>(getDelegate().subList(fromIndex, toIndex),
+ return new DirtyListWrapper<>(getDelegate().subList(fromIndex, toIndex),
getDirtyFlag());
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyMapWrapper.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyMapWrapper.java b/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyMapWrapper.java
index 44adfdc..74e320d 100644
--- a/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyMapWrapper.java
+++ b/gora-core/src/main/java/org/apache/gora/persistency/impl/DirtyMapWrapper.java
@@ -164,7 +164,7 @@ public class DirtyMapWrapper<K, V> implements Map<K, V>, Dirtyable {
@Override
public Collection<V> values() {
- return new DirtyCollectionWrapper<V>(delegate.values(), dirtyFlag);
+ return new DirtyCollectionWrapper<>(delegate.values(), dirtyFlag);
}
@Override
@@ -175,7 +175,7 @@ public class DirtyMapWrapper<K, V> implements Map<K, V>, Dirtyable {
new Function<Entry<K, V>, DirtyEntryWrapper<K, V>>() {
@Override
public DirtyEntryWrapper<K, V> apply(java.util.Map.Entry<K, V> input) {
- return new DirtyEntryWrapper<K, V>(input, dirtyFlag);
+ return new DirtyEntryWrapper<>(input, dirtyFlag);
}
});
return new DirtySetWrapper(dirtyEntrySet, dirtyFlag);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/BeanFactoryWSImpl.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/BeanFactoryWSImpl.java b/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/BeanFactoryWSImpl.java
index ff6e1c3..ccb8971 100644
--- a/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/BeanFactoryWSImpl.java
+++ b/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/BeanFactoryWSImpl.java
@@ -111,10 +111,7 @@ public class BeanFactoryWSImpl<K, T extends Persistent> implements BeanFactory<K
public T newPersistent() {
try {
return persistentClass.newInstance();
- } catch (InstantiationException e) {
- LOG.error(e.getMessage());
- throw new RuntimeException(e);
- } catch (IllegalAccessException e) {
+ } catch (InstantiationException | IllegalAccessException e) {
LOG.error(e.getMessage());
throw new RuntimeException(e);
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/PersistentWSBase.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/PersistentWSBase.java b/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/PersistentWSBase.java
index 58cf566..fd17e94 100644
--- a/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/PersistentWSBase.java
+++ b/gora-core/src/main/java/org/apache/gora/persistency/ws/impl/PersistentWSBase.java
@@ -34,13 +34,13 @@ public abstract class PersistentWSBase implements Persistent {
* Maps keys to their own classes
*/
protected static Map<Class<?>, Map<String, Integer>> FIELD_MAP =
- new HashMap<Class<?>, Map<String,Integer>>();
+ new HashMap<>();
/**
* Maps fields to their own classes
*/
protected static Map<Class<?>, String[]> FIELDS =
- new HashMap<Class<?>, String[]>();
+ new HashMap<>();
/** Subclasses should call this function for all the persistable fields
@@ -51,7 +51,7 @@ public abstract class PersistentWSBase implements Persistent {
protected static void registerFields(Class<?> clazz, String... fields) {
FIELDS.put(clazz, fields);
int fieldsLength = fields == null ? 0 :fields.length;
- HashMap<String, Integer> map = new HashMap<String, Integer>(fieldsLength);
+ HashMap<String, Integer> map = new HashMap<>(fieldsLength);
for(int i=0; i < fieldsLength; i++) {
map.put(fields[i], i);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/store/impl/DataStoreBase.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/store/impl/DataStoreBase.java b/gora-core/src/main/java/org/apache/gora/store/impl/DataStoreBase.java
index 5f73104..3b18532 100644
--- a/gora-core/src/main/java/org/apache/gora/store/impl/DataStoreBase.java
+++ b/gora-core/src/main/java/org/apache/gora/store/impl/DataStoreBase.java
@@ -88,7 +88,7 @@ public abstract class DataStoreBase<K, T extends PersistentBase>
setKeyClass(keyClass);
setPersistentClass(persistentClass);
if (this.beanFactory == null) {
- this.beanFactory = new BeanFactoryImpl<K, T>(keyClass, persistentClass);
+ this.beanFactory = new BeanFactoryImpl<>(keyClass, persistentClass);
}
schema = this.beanFactory.getCachedPersistent().getSchema();
fieldMap = AvroUtils.getFieldMap(schema);
@@ -96,8 +96,8 @@ public abstract class DataStoreBase<K, T extends PersistentBase>
autoCreateSchema = DataStoreFactory.getAutoCreateSchema(properties, this);
this.properties = properties;
- datumReader = new SpecificDatumReader<T>(schema);
- datumWriter = new SpecificDatumWriter<T>(schema);
+ datumReader = new SpecificDatumReader<>(schema);
+ datumWriter = new SpecificDatumWriter<>(schema);
}
@Override
@@ -171,7 +171,7 @@ public abstract class DataStoreBase<K, T extends PersistentBase>
protected String[] getFields() {
List<Field> schemaFields = beanFactory.getCachedPersistent().getSchema().getFields();
- List<Field> list = new ArrayList<Field>();
+ List<Field> list = new ArrayList<>();
for (Field field : schemaFields) {
if (!Persistent.DIRTY_BYTES_FIELD_NAME.equalsIgnoreCase(field.name())) {
list.add(field);
@@ -211,10 +211,8 @@ public abstract class DataStoreBase<K, T extends PersistentBase>
Class<T> persistentClass = (Class<T>)ClassLoadingUtils.loadClass(Text.readString(in));
Properties props = WritableUtils.readProperties(in);
initialize(keyClass, persistentClass, props);
- } catch (ClassNotFoundException ex) {
+ } catch (ClassNotFoundException | IOException ex) {
LOG.error(ex.getMessage(), ex);
- } catch (IOException e) {
- LOG.error(e.getMessage(), e);
}
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java b/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java
index de14f4a..c559243 100644
--- a/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java
+++ b/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java
@@ -163,10 +163,10 @@ public InputStream getInputStream() {
List<PartitionQuery<K, T>> queries = null;
try{
splits = GoraMapReduceUtils.getSplits(getConf(), inputPath);
- queries = new ArrayList<PartitionQuery<K,T>>(splits.size());
+ queries = new ArrayList<>(splits.size());
for(InputSplit split : splits) {
- queries.add(new FileSplitPartitionQuery<K, T>(query, (FileSplit) split));
+ queries.add(new FileSplitPartitionQuery<>(query, (FileSplit) split));
}
}catch(IOException ex){
LOG.error(ex.getMessage(), ex);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/util/AvroUtils.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/util/AvroUtils.java b/gora-core/src/main/java/org/apache/gora/util/AvroUtils.java
index 3f51995..86ab4a3 100644
--- a/gora-core/src/main/java/org/apache/gora/util/AvroUtils.java
+++ b/gora-core/src/main/java/org/apache/gora/util/AvroUtils.java
@@ -45,7 +45,7 @@ public class AvroUtils {
*/
public static Map<String, Field> getFieldMap(Schema schema) {
List<Field> fields = schema.getFields();
- HashMap<String, Field> fieldMap = new HashMap<String, Field>(fields.size());
+ HashMap<String, Field> fieldMap = new HashMap<>(fields.size());
for (Field field : fields) {
fieldMap.put(field.name(), field);
}
@@ -103,7 +103,7 @@ public class AvroUtils {
public static <T extends Persistent> T deepClonePersistent(T persistent) {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
BinaryEncoder enc = EncoderFactory.get().binaryEncoder(bos, null);
- SpecificDatumWriter<Persistent> writer = new SpecificDatumWriter<Persistent>(
+ SpecificDatumWriter<Persistent> writer = new SpecificDatumWriter<>(
persistent.getSchema());
try {
writer.write(persistent, enc);
@@ -117,7 +117,7 @@ public class AvroUtils {
byte[] value = bos.toByteArray();
Decoder dec = DecoderFactory.get().binaryDecoder(value, null);
@SuppressWarnings("unchecked")
- SpecificDatumReader<T> reader = new SpecificDatumReader<T>(
+ SpecificDatumReader<T> reader = new SpecificDatumReader<>(
(Class<T>) persistent.getClass());
try {
return reader.read(null, dec);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/util/IOUtils.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/util/IOUtils.java b/gora-core/src/main/java/org/apache/gora/util/IOUtils.java
index eb39cec..bc60360 100644
--- a/gora-core/src/main/java/org/apache/gora/util/IOUtils.java
+++ b/gora-core/src/main/java/org/apache/gora/util/IOUtils.java
@@ -106,8 +106,7 @@ public class IOUtils {
SerializationFactory serializationFactory = new SerializationFactory(getOrCreateConf(conf));
Serializer<T> serializer = serializationFactory.getSerializer(objClass);
- ByteBufferOutputStream os = new ByteBufferOutputStream();
- try {
+ try (ByteBufferOutputStream os = new ByteBufferOutputStream()) {
serializer.open(os);
serializer.serialize(obj);
@@ -126,8 +125,6 @@ public class IOUtils {
}finally {
if(serializer != null)
serializer.close();
- if(os != null)
- os.close();
}
}
@@ -219,11 +216,10 @@ public class IOUtils {
int length = WritableUtils.readVInt(in);
byte[] arr = new byte[length];
in.readFully(arr);
- List<ByteBuffer> list = new ArrayList<ByteBuffer>();
+ List<ByteBuffer> list = new ArrayList<>();
list.add(ByteBuffer.wrap(arr));
- ByteBufferInputStream is = new ByteBufferInputStream(list);
- try {
+ try (ByteBufferInputStream is = new ByteBufferInputStream(list)) {
deserializer.open(is);
T newObj = deserializer.deserialize(obj);
return newObj;
@@ -231,8 +227,6 @@ public class IOUtils {
}finally {
if(deserializer != null)
deserializer.close();
- if(is != null)
- is.close();
}
}
@@ -519,7 +513,7 @@ public class IOUtils {
* Reads until the end of the input stream, and returns the contents as a byte[]
*/
public static byte[] readFully(InputStream in) throws IOException {
- List<ByteBuffer> buffers = new ArrayList<ByteBuffer>(4);
+ List<ByteBuffer> buffers = new ArrayList<>(4);
while(true) {
ByteBuffer buffer = ByteBuffer.allocate(BUFFER_SIZE);
int count = in.read(buffer.array(), 0, BUFFER_SIZE);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/util/NodeWalker.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/util/NodeWalker.java b/gora-core/src/main/java/org/apache/gora/util/NodeWalker.java
index 9a586c0..216e658 100644
--- a/gora-core/src/main/java/org/apache/gora/util/NodeWalker.java
+++ b/gora-core/src/main/java/org/apache/gora/util/NodeWalker.java
@@ -46,7 +46,7 @@ public class NodeWalker {
*/
public NodeWalker(Node rootNode) {
- nodes = new Stack<Node>();
+ nodes = new Stack<>();
nodes.add(rootNode);
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/main/java/org/apache/gora/util/StringUtils.java
----------------------------------------------------------------------
diff --git a/gora-core/src/main/java/org/apache/gora/util/StringUtils.java b/gora-core/src/main/java/org/apache/gora/util/StringUtils.java
index 75c03cd..9a38d8b 100644
--- a/gora-core/src/main/java/org/apache/gora/util/StringUtils.java
+++ b/gora-core/src/main/java/org/apache/gora/util/StringUtils.java
@@ -34,7 +34,7 @@ public class StringUtils {
* Joins the two given arrays, removing dup elements.
*/
public static String[] joinStringArrays(String[] arr1, String... arr2) {
- HashSet<String> set = new HashSet<String>();
+ HashSet<String> set = new HashSet<>();
Collections.addAll(set, arr1);
Collections.addAll(set, arr2);
@@ -83,7 +83,7 @@ public class StringUtils {
public static LinkedHashSet<Set<String>> powerset(String[] set) {
//create the empty power set
- LinkedHashSet<Set<String>> power = new LinkedHashSet<Set<String>>();
+ LinkedHashSet<Set<String>> power = new LinkedHashSet<>();
//get the number of elements in the set
int elements = set.length;
@@ -98,7 +98,7 @@ public class StringUtils {
String binary = intToBinary(i, elements);
//create a new set
- LinkedHashSet<String> innerSet = new LinkedHashSet<String>();
+ LinkedHashSet<String> innerSet = new LinkedHashSet<>();
//convert each digit in the current binary number to the corresponding element
//in the given set
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/GoraTestDriver.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/GoraTestDriver.java b/gora-core/src/test/java/org/apache/gora/GoraTestDriver.java
index 817d57b..02006d9 100644
--- a/gora-core/src/test/java/org/apache/gora/GoraTestDriver.java
+++ b/gora-core/src/test/java/org/apache/gora/GoraTestDriver.java
@@ -48,7 +48,7 @@ public class GoraTestDriver {
@SuppressWarnings({ "rawtypes", "unchecked" })
protected GoraTestDriver(Class<? extends DataStore> dataStoreClass) {
this.dataStoreClass = (Class<? extends DataStore<?, ?>>) dataStoreClass;
- this.dataStores = new HashSet<DataStore>();
+ this.dataStores = new HashSet<>();
}
/** Should be called once before the tests are started, probably in the
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java b/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java
index e3f02bf..2f0aee5 100644
--- a/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java
+++ b/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java
@@ -40,7 +40,7 @@ public class TestDataFileAvroStoreMapReduce extends DataStoreMapReduceTestBase {
@Override
protected DataStore<String, WebPage> createWebPageDataStore()
throws IOException {
- DataFileAvroStore<String,WebPage> webPageStore = new DataFileAvroStore<String, WebPage>();
+ DataFileAvroStore<String,WebPage> webPageStore = new DataFileAvroStore<>();
webPageStore.initialize(String.class, WebPage.class, DataStoreFactory.createProps());
webPageStore.setOutputPath(WEBPAGE_OUTPUT);
webPageStore.setInputPath(WEBPAGE_OUTPUT);
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/avro/store/TestAvroStore.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/avro/store/TestAvroStore.java b/gora-core/src/test/java/org/apache/gora/avro/store/TestAvroStore.java
index 6baf504..d870b68 100644
--- a/gora-core/src/test/java/org/apache/gora/avro/store/TestAvroStore.java
+++ b/gora-core/src/test/java/org/apache/gora/avro/store/TestAvroStore.java
@@ -61,7 +61,7 @@ public class TestAvroStore {
employeeStore.setOutputPath(EMPLOYEE_OUTPUT);
employeeStore.setInputPath(EMPLOYEE_OUTPUT);
- webPageStore = new AvroStore<String, WebPage>();
+ webPageStore = new AvroStore<>();
webPageStore.initialize(String.class, WebPage.class, DataStoreFactory.createProps());
webPageStore.setOutputPath(WEBPAGE_OUTPUT);
webPageStore.setInputPath(WEBPAGE_OUTPUT);
@@ -74,7 +74,7 @@ public class TestAvroStore {
}
protected AvroStore<String, WebPage> createWebPageDataStore() {
- return new AvroStore<String, WebPage>();
+ return new AvroStore<>();
}
@After
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/avro/store/TestDataFileAvroStore.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/avro/store/TestDataFileAvroStore.java b/gora-core/src/test/java/org/apache/gora/avro/store/TestDataFileAvroStore.java
index 0d7d485..88c9c4b 100644
--- a/gora-core/src/test/java/org/apache/gora/avro/store/TestDataFileAvroStore.java
+++ b/gora-core/src/test/java/org/apache/gora/avro/store/TestDataFileAvroStore.java
@@ -30,12 +30,12 @@ public class TestDataFileAvroStore extends TestAvroStore {
@Override
protected AvroStore<String, Employee> createEmployeeDataStore() {
- return new DataFileAvroStore<String, Employee>();
+ return new DataFileAvroStore<>();
}
@Override
protected AvroStore<String, WebPage> createWebPageDataStore() {
- return new DataFileAvroStore<String, WebPage>();
+ return new DataFileAvroStore<>();
}
//import all tests from super class
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/examples/TestWebPageDataCreator.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/examples/TestWebPageDataCreator.java b/gora-core/src/test/java/org/apache/gora/examples/TestWebPageDataCreator.java
index 68fbfb1..8825dd7 100644
--- a/gora-core/src/test/java/org/apache/gora/examples/TestWebPageDataCreator.java
+++ b/gora-core/src/test/java/org/apache/gora/examples/TestWebPageDataCreator.java
@@ -13,7 +13,7 @@ public class TestWebPageDataCreator {
@Test
public void testCreatesData() throws IOException{
- MemStore<String, WebPage> dataStore = new MemStore<String, WebPage>();
+ MemStore<String, WebPage> dataStore = new MemStore<>();
WebPageDataCreator.createWebPageData(dataStore);
}
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/filter/TestMapFieldValueFilter.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/filter/TestMapFieldValueFilter.java b/gora-core/src/test/java/org/apache/gora/filter/TestMapFieldValueFilter.java
index b53207a..bd8abfa 100644
--- a/gora-core/src/test/java/org/apache/gora/filter/TestMapFieldValueFilter.java
+++ b/gora-core/src/test/java/org/apache/gora/filter/TestMapFieldValueFilter.java
@@ -31,7 +31,7 @@ public class TestMapFieldValueFilter {
@Test
public void testSerialization() throws IOException {
- MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<String, WebPage>();
+ MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<>();
//set filter field name as metadata
filter.setFieldName(WebPage.Field.METADATA.toString());
filter.setMapKey(new Utf8("fetchTime"));
@@ -39,7 +39,7 @@ public class TestMapFieldValueFilter {
filter.setFilterIfMissing(true);
filter.getOperands().add(new Utf8("http://example.org"));
byte[] byteArray = WritableUtils.toByteArray(filter);
- MapFieldValueFilter<String, WebPage> filter2 = new MapFieldValueFilter<String, WebPage>();
+ MapFieldValueFilter<String, WebPage> filter2 = new MapFieldValueFilter<>();
filter2.readFields(new DataInputStream(new ByteArrayInputStream(byteArray)));
assertEquals(filter.getFieldName(), filter2.getFieldName());
assertEquals(filter.getMapKey(), filter2.getMapKey());
@@ -50,7 +50,7 @@ public class TestMapFieldValueFilter {
@Test
public void testFilterBasics() {
- MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<String, WebPage>();
+ MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<>();
//set filter field name as outlinks
filter.setFieldName(WebPage.Field.OUTLINKS.toString());
filter.setMapKey(new Utf8("example"));
@@ -72,7 +72,7 @@ public class TestMapFieldValueFilter {
@Test
public void testFilterEntryInMap() {
- MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<String, WebPage>();
+ MapFieldValueFilter<String, WebPage> filter = new MapFieldValueFilter<>();
//set filter field name as outlinks
filter.setFieldName(WebPage.Field.OUTLINKS.toString());
filter.setMapKey(new Utf8("foobar.whatever"));
http://git-wip-us.apache.org/repos/asf/gora/blob/f681764a/gora-core/src/test/java/org/apache/gora/filter/TestSingleFieldValueFilter.java
----------------------------------------------------------------------
diff --git a/gora-core/src/test/java/org/apache/gora/filter/TestSingleFieldValueFilter.java b/gora-core/src/test/java/org/apache/gora/filter/TestSingleFieldValueFilter.java
index 6390b0d..6eb9c3d 100644
--- a/gora-core/src/test/java/org/apache/gora/filter/TestSingleFieldValueFilter.java
+++ b/gora-core/src/test/java/org/apache/gora/filter/TestSingleFieldValueFilter.java
@@ -32,14 +32,14 @@ public class TestSingleFieldValueFilter {
@Test
public void testSerialization() throws IOException {
- SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<String, WebPage>();
+ SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<>();
//set filter field to url
filter.setFieldName(WebPage.Field.URL.toString());
filter.setFilterOp(FilterOp.EQUALS);
filter.setFilterIfMissing(true);
filter.getOperands().add(new Utf8("http://example.org"));
byte[] byteArray = WritableUtils.toByteArray(filter);
- SingleFieldValueFilter<String, WebPage> filter2 = new SingleFieldValueFilter<String, WebPage>();
+ SingleFieldValueFilter<String, WebPage> filter2 = new SingleFieldValueFilter<>();
filter2.readFields(new DataInputStream(new ByteArrayInputStream(byteArray)));
assertEquals(filter.getFieldName(), filter2.getFieldName());
assertEquals(filter.getFilterOp(), filter2.getFilterOp());
@@ -49,7 +49,7 @@ public class TestSingleFieldValueFilter {
@Test
public void testFilterBasics() {
- SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<String, WebPage>();
+ SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<>();
//set filter field to url
filter.setFieldName(WebPage.Field.URL.toString());
filter.setFilterOp(FilterOp.EQUALS);
@@ -71,7 +71,7 @@ public class TestSingleFieldValueFilter {
@Test
public void testFilterInequals() {
- SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<String, WebPage>();
+ SingleFieldValueFilter<String, WebPage> filter = new SingleFieldValueFilter<>();
//set filter field to url
filter.setFieldName(WebPage.Field.URL.toString());
filter.setFilterOp(FilterOp.NOT_EQUALS);
[3/3] gora git commit: GORA-436 Improve Source Code as Java 7
Compatible this closes #41
Posted by le...@apache.org.
GORA-436 Improve Source Code as Java 7 Compatible this closes #41
Project: http://git-wip-us.apache.org/repos/asf/gora/repo
Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/e201926a
Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/e201926a
Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/e201926a
Branch: refs/heads/master
Commit: e201926a3cbfe16d6636f86d184f991f8a0c8d17
Parents: f681764
Author: Lewis John McGibbney <le...@jpl.nasa.gov>
Authored: Sat Sep 5 12:06:59 2015 -0400
Committer: Lewis John McGibbney <le...@jpl.nasa.gov>
Committed: Sat Sep 5 12:06:59 2015 -0400
----------------------------------------------------------------------
CHANGES.txt | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/gora/blob/e201926a/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 603adb2..17b6cba 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -4,6 +4,8 @@
Current Development
+* GORA-436 Improve Source Code as Java 7 Compatible (Furkan KAMACI via lewismc)
+
* GORA-435 Clean Up Code and Fix Potential Bugs (Furkan KAMACI via lewismc)
* GORA-433 Non-Final Public Static Fields Should Be Final (Furkan KAMACI via lewismc)