Author: lewismc
Date: Sat Jan 12 16:33:43 2013
New Revision: 1432469
URL: http://svn.apache.org/viewvc?rev=1432469&view=rev
Log:
NUTCH-1274 Fix [cast] javac warnings
Modified:
nutch/trunk/CHANGES.txt
nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDatum.java
nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReader.java
nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java
nutch/trunk/src/java/org/apache/nutch/crawl/Generator.java
nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java
nutch/trunk/src/java/org/apache/nutch/indexer/solr/SolrMappingReader.java
nutch/trunk/src/java/org/apache/nutch/parse/ParseOutputFormat.java
nutch/trunk/src/java/org/apache/nutch/parse/ParseSegment.java
nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkDumper.java
nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkRank.java
nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/Loops.java
nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/WebGraph.java
nutch/trunk/src/java/org/apache/nutch/segment/ContentAsTextInputFormat.java
nutch/trunk/src/java/org/apache/nutch/segment/SegmentMerger.java
nutch/trunk/src/java/org/apache/nutch/segment/SegmentReader.java
nutch/trunk/src/java/org/apache/nutch/tools/FreeGenerator.java
nutch/trunk/src/java/org/apache/nutch/tools/arc/ArcRecordReader.java
nutch/trunk/src/test/org/apache/nutch/parse/TestParserFactory.java
Modified: nutch/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/nutch/trunk/CHANGES.txt?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/CHANGES.txt (original)
+++ nutch/trunk/CHANGES.txt Sat Jan 12 16:33:43 2013
@@ -2,6 +2,8 @@ Nutch Change Log
(trunk): Current Development
+* NUTCH-1274 Fix [cast] javac warnings (Tejas Patil via lewismc)
+
* NUTCH-1494 RSS feed plugin seems broken (Sourajit Basak, Tejas Patil and
lewismc)
* NUTCH-1127 JUnit test for urlfilter-validator (Tejas Patil via lewismc)
Modified: nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDatum.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDatum.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDatum.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDatum.java Sat Jan 12
16:33:43 2013
@@ -457,7 +457,7 @@ public class CrawlDatum implements Writa
int res = 0;
if (signature != null) {
for (int i = 0; i < signature.length / 4; i += 4) {
- res ^= (int)(signature[i] << 24 + signature[i+1] << 16 +
+ res ^= (signature[i] << 24 + signature[i+1] << 16 +
signature[i+2] << 8 + signature[i+3]);
}
}
Modified: nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReader.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReader.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReader.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReader.java Sat Jan 12
16:33:43 2013
@@ -175,10 +175,10 @@ public class CrawlDbReader implements Cl
public void reduce(Text key, Iterator<LongWritable> values,
OutputCollector<Text, LongWritable> output, Reporter reporter)
throws IOException {
val.set(0L);
- String k = ((Text)key).toString();
+ String k = key.toString();
if (!k.equals("s")) {
while (values.hasNext()) {
- LongWritable cnt = (LongWritable)values.next();
+ LongWritable cnt = values.next();
val.set(val.get() + cnt.get());
}
output.collect(key, val);
@@ -187,7 +187,7 @@ public class CrawlDbReader implements Cl
long min = Long.MAX_VALUE;
long max = Long.MIN_VALUE;
while (values.hasNext()) {
- LongWritable cnt = (LongWritable)values.next();
+ LongWritable cnt = values.next();
if (cnt.get() < min) min = cnt.get();
if (cnt.get() > max) max = cnt.get();
total += cnt.get();
@@ -205,40 +205,40 @@ public class CrawlDbReader implements Cl
public void reduce(Text key, Iterator<LongWritable> values,
OutputCollector<Text, LongWritable> output, Reporter reporter)
throws IOException {
- String k = ((Text) key).toString();
+ String k = key.toString();
if (k.equals("T")) {
// sum all values for this key
long sum = 0;
while (values.hasNext()) {
- sum += ((LongWritable) values.next()).get();
+ sum += values.next().get();
}
// output sum
output.collect(key, new LongWritable(sum));
} else if (k.startsWith("status") || k.startsWith("retry")) {
LongWritable cnt = new LongWritable();
while (values.hasNext()) {
- LongWritable val = (LongWritable)values.next();
+ LongWritable val = values.next();
cnt.set(cnt.get() + val.get());
}
output.collect(key, cnt);
} else if (k.equals("scx")) {
LongWritable cnt = new LongWritable(Long.MIN_VALUE);
while (values.hasNext()) {
- LongWritable val = (LongWritable)values.next();
+ LongWritable val = values.next();
if (cnt.get() < val.get()) cnt.set(val.get());
}
output.collect(key, cnt);
} else if (k.equals("scn")) {
LongWritable cnt = new LongWritable(Long.MAX_VALUE);
while (values.hasNext()) {
- LongWritable val = (LongWritable)values.next();
+ LongWritable val = values.next();
if (cnt.get() > val.get()) cnt.set(val.get());
}
output.collect(key, cnt);
} else if (k.equals("sct")) {
LongWritable cnt = new LongWritable();
while (values.hasNext()) {
- LongWritable val = (LongWritable)values.next();
+ LongWritable val = values.next();
cnt.set(cnt.get() + val.get());
}
output.collect(key, cnt);
@@ -356,9 +356,9 @@ public class CrawlDbReader implements Cl
String k = entry.getKey();
LongWritable val = entry.getValue();
if (k.equals("scn")) {
- LOG.info("min score:\t" + (float) (val.get() / 1000.0f));
+ LOG.info("min score:\t" + (val.get() / 1000.0f));
} else if (k.equals("scx")) {
- LOG.info("max score:\t" + (float) (val.get() / 1000.0f));
+ LOG.info("max score:\t" + (val.get() / 1000.0f));
} else if (k.equals("sct")) {
LOG.info("avg score:\t" + (float) ((((double)val.get()) /
totalCnt.get()) / 1000.0));
} else if (k.startsWith("status")) {
Modified: nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/crawl/CrawlDbReducer.java Sat Jan 12
16:33:43 2013
@@ -75,7 +75,7 @@ public class CrawlDbReducer implements R
org.apache.hadoop.io.MapWritable metaFromParse = null;
while (values.hasNext()) {
- CrawlDatum datum = (CrawlDatum)values.next();
+ CrawlDatum datum = values.next();
if (!multiple && values.hasNext()) multiple = true;
if (CrawlDatum.hasDbStatus(datum)) {
if (!oldSet) {
@@ -184,10 +184,10 @@ public class CrawlDbReducer implements R
if (oldSet) { // if old exists
result.set(old); // use it
} else {
- result = schedule.initializeSchedule((Text)key, result);
+ result = schedule.initializeSchedule(key, result);
result.setStatus(CrawlDatum.STATUS_DB_UNFETCHED);
try {
- scfilters.initialScore((Text)key, result);
+ scfilters.initialScore(key, result);
} catch (ScoringFilterException e) {
if (LOG.isWarnEnabled()) {
LOG.warn("Cannot filter init score for url " + key +
@@ -216,7 +216,7 @@ public class CrawlDbReducer implements R
}
}
// set the schedule
- result = schedule.setFetchSchedule((Text)key, result, prevFetchTime,
+ result = schedule.setFetchSchedule(key, result, prevFetchTime,
prevModifiedTime, fetch.getFetchTime(), fetch.getModifiedTime(),
modified);
// set the result status and signature
if (modified == FetchSchedule.STATUS_NOTMODIFIED) {
@@ -254,7 +254,7 @@ public class CrawlDbReducer implements R
// NOTMODIFIED state, when the old fetched copy was already removed with
// old segments.
if (maxInterval < result.getFetchInterval())
- result = schedule.forceRefetch((Text)key, result, false);
+ result = schedule.forceRefetch(key, result, false);
break;
case CrawlDatum.STATUS_SIGNATURE:
if (LOG.isWarnEnabled()) {
@@ -265,7 +265,7 @@ public class CrawlDbReducer implements R
if (oldSet) {
result.setSignature(old.getSignature()); // use old signature
}
- result = schedule.setPageRetrySchedule((Text)key, result, prevFetchTime,
+ result = schedule.setPageRetrySchedule(key, result, prevFetchTime,
prevModifiedTime, fetch.getFetchTime());
if (result.getRetriesSinceFetch() < retryMax) {
result.setStatus(CrawlDatum.STATUS_DB_UNFETCHED);
@@ -278,7 +278,7 @@ public class CrawlDbReducer implements R
if (oldSet)
result.setSignature(old.getSignature()); // use old signature
result.setStatus(CrawlDatum.STATUS_DB_GONE);
- result = schedule.setPageGoneSchedule((Text)key, result, prevFetchTime,
+ result = schedule.setPageGoneSchedule(key, result, prevFetchTime,
prevModifiedTime, fetch.getFetchTime());
break;
@@ -287,7 +287,7 @@ public class CrawlDbReducer implements R
}
try {
- scfilters.updateDbScore((Text)key, oldSet ? old : null, result,
linkList);
+ scfilters.updateDbScore(key, oldSet ? old : null, result, linkList);
} catch (Exception e) {
if (LOG.isWarnEnabled()) {
LOG.warn("Couldn't update score, key=" + key + ": " + e);
Modified: nutch/trunk/src/java/org/apache/nutch/crawl/Generator.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/crawl/Generator.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/crawl/Generator.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/crawl/Generator.java Sat Jan 12
16:33:43 2013
@@ -201,7 +201,7 @@ public class Generator extends Configure
}
float sort = 1.0f;
try {
- sort = scfilters.generatorSortValue((Text) key, crawlDatum, sort);
+ sort = scfilters.generatorSortValue(key, crawlDatum, sort);
} catch (ScoringFilterException sfe) {
if (LOG.isWarnEnabled()) {
LOG.warn("Couldn't filter generatorSortValue for " + key + ": " +
sfe);
@@ -222,7 +222,7 @@ public class Generator extends Configure
// record generation time
crawlDatum.getMetaData().put(Nutch.WRITABLE_GENERATE_TIME_KEY, genTime);
entry.datum = crawlDatum;
- entry.url = (Text) key;
+ entry.url = key;
output.collect(sortValue, entry); // invert for sort by score
}
@@ -345,7 +345,7 @@ public class Generator extends Configure
public void map(FloatWritable key, SelectorEntry value,
OutputCollector<Text,SelectorEntry> output, Reporter reporter) throws
IOException {
- SelectorEntry entry = (SelectorEntry) value;
+ SelectorEntry entry = value;
output.collect(entry.url, entry);
}
}
Modified: nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java Sat Jan 12
16:33:43 2013
@@ -1079,7 +1079,7 @@ public class Fetcher extends Configured
}
// Overwrite the outlinks in ParseData with the normalized and
filtered set
- parseData.setOutlinks((Outlink[])outlinkList.toArray(new
Outlink[outlinkList.size()]));
+ parseData.setOutlinks(outlinkList.toArray(new
Outlink[outlinkList.size()]));
output.collect(url, new NutchWritable(
new ParseImpl(new ParseText(parse.getText()),
Modified:
nutch/trunk/src/java/org/apache/nutch/indexer/solr/SolrMappingReader.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/indexer/solr/SolrMappingReader.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/indexer/solr/SolrMappingReader.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/indexer/solr/SolrMappingReader.java
Sat Jan 12 16:33:43 2013
@@ -122,21 +122,21 @@ public class SolrMappingReader {
public String hasCopy(String key) {
if (copyMap.containsKey(key)) {
- key = (String) copyMap.get(key);
+ key = copyMap.get(key);
}
return key;
}
public String mapKey(String key) throws IOException {
if(keyMap.containsKey(key)) {
- key = (String) keyMap.get(key);
+ key = keyMap.get(key);
}
return key;
}
public String mapCopyKey(String key) throws IOException {
if(copyMap.containsKey(key)) {
- key = (String) copyMap.get(key);
+ key = copyMap.get(key);
}
return key;
}
Modified: nutch/trunk/src/java/org/apache/nutch/parse/ParseOutputFormat.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/parse/ParseOutputFormat.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/parse/ParseOutputFormat.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/parse/ParseOutputFormat.java Sat Jan
12 16:33:43 2013
@@ -251,7 +251,7 @@ public class ParseOutputFormat implement
try {
// compute score contributions and adjustment to the original score
- adjust = scfilters.distributeScoreToOutlinks((Text)key, parseData,
+ adjust = scfilters.distributeScoreToOutlinks(key, parseData,
targets, null, links.length);
} catch (ScoringFilterException e) {
LOG.warn("Cannot distribute score from " + key + ": " +
e.getMessage());
Modified: nutch/trunk/src/java/org/apache/nutch/parse/ParseSegment.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/parse/ParseSegment.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/parse/ParseSegment.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/parse/ParseSegment.java Sat Jan 12
16:33:43 2013
@@ -180,7 +180,7 @@ public class ParseSegment extends Config
public void reduce(Text key, Iterator<Writable> values,
OutputCollector<Text, Writable> output, Reporter reporter)
throws IOException {
- output.collect(key, (Writable)values.next()); // collect first value
+ output.collect(key, values.next()); // collect first value
}
public void parse(Path segment) throws IOException {
Modified: nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkDumper.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkDumper.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkDumper.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkDumper.java Sat
Jan 12 16:33:43 2013
@@ -265,7 +265,7 @@ public class LinkDumper
node = (Node)obj;
}
else if (obj instanceof LinkDatum) {
- outlinks.add((LinkDatum)WritableUtils.clone((LinkDatum)obj, conf));
+ outlinks.add(WritableUtils.clone((LinkDatum)obj, conf));
}
else if (obj instanceof LoopSet) {
loops = (LoopSet)obj;
@@ -323,7 +323,7 @@ public class LinkDumper
while (values.hasNext()) {
LinkNode cur = values.next();
if (numNodes < maxInlinks) {
- nodeList.add((LinkNode)WritableUtils.clone(cur, conf));
+ nodeList.add(WritableUtils.clone(cur, conf));
numNodes++;
}
else {
Modified: nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkRank.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkRank.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkRank.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/LinkRank.java Sat
Jan 12 16:33:43 2013
@@ -338,7 +338,7 @@ public class LinkRank
throws IOException {
String url = key.toString();
- Node outNode = (Node)WritableUtils.clone(node, conf);
+ Node outNode = WritableUtils.clone(node, conf);
outNode.setInlinkScore(initialScore);
output.collect(new Text(url), outNode);
@@ -397,7 +397,7 @@ public class LinkRank
node = (Node)obj;
}
else if (obj instanceof LinkDatum) {
- outlinks.add((LinkDatum)WritableUtils.clone((LinkDatum)obj, conf));
+ outlinks.add(WritableUtils.clone((LinkDatum)obj, conf));
}
else if (obj instanceof LoopSet) {
loops = (LoopSet)obj;
@@ -555,7 +555,7 @@ public class LinkRank
+ numInlinks + " iteration: " + itNum);
// store the score in a temporary NodeDb
- Node outNode = (Node)WritableUtils.clone(node, conf);
+ Node outNode = WritableUtils.clone(node, conf);
outNode.setInlinkScore(linkRankScore);
output.collect(key, outNode);
}
Modified: nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/Loops.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/Loops.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/Loops.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/Loops.java Sat Jan
12 16:33:43 2013
@@ -348,7 +348,7 @@ public class Loops
ObjectWritable next = values.next();
Object value = next.get();
if (value instanceof Route) {
- routeList.add((Route)WritableUtils.clone((Route)value, conf));
+ routeList.add(WritableUtils.clone((Route)value, conf));
}
else if (value instanceof Text) {
String outlinkUrl = ((Text)value).toString();
Modified: nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/WebGraph.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/WebGraph.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/WebGraph.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/scoring/webgraph/WebGraph.java Sat
Jan 12 16:33:43 2013
@@ -345,7 +345,7 @@ public class WebGraph
if (mostRecent == 0L || mostRecent < timestamp) {
mostRecent = timestamp;
}
- outlinkList.add((LinkDatum)WritableUtils.clone(next, conf));
+ outlinkList.add(WritableUtils.clone(next, conf));
reporter.incrCounter("WebGraph.outlinks", "added links", 1);
}
else if (value instanceof BooleanWritable) {
Modified:
nutch/trunk/src/java/org/apache/nutch/segment/ContentAsTextInputFormat.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/segment/ContentAsTextInputFormat.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/segment/ContentAsTextInputFormat.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/segment/ContentAsTextInputFormat.java
Sat Jan 12 16:33:43 2013
@@ -49,8 +49,8 @@ public class ContentAsTextInputFormat
throws IOException {
sequenceFileRecordReader = new SequenceFileRecordReader<Text, Content>(
conf, split);
- innerKey = (Text)sequenceFileRecordReader.createKey();
- innerValue = (Content)sequenceFileRecordReader.createValue();
+ innerKey = sequenceFileRecordReader.createKey();
+ innerValue = sequenceFileRecordReader.createValue();
}
public Text createKey() {
Modified: nutch/trunk/src/java/org/apache/nutch/segment/SegmentMerger.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/segment/SegmentMerger.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/segment/SegmentMerger.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/segment/SegmentMerger.java Sat Jan 12
16:33:43 2013
@@ -213,7 +213,7 @@ public class SegmentMerger extends Confi
public void write(Text key, MetaWrapper wrapper) throws IOException {
// unwrap
SegmentPart sp =
SegmentPart.parse(wrapper.getMeta(SEGMENT_PART_KEY));
- Writable o = (Writable)wrapper.get();
+ Writable o = wrapper.get();
String slice = wrapper.getMeta(SEGMENT_SLICE_KEY);
if (o instanceof CrawlDatum) {
if (sp.partName.equals(CrawlDatum.GENERATE_DIR_NAME)) {
Modified: nutch/trunk/src/java/org/apache/nutch/segment/SegmentReader.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/segment/SegmentReader.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/segment/SegmentReader.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/segment/SegmentReader.java Sat Jan 12
16:33:43 2013
@@ -237,7 +237,7 @@ public class SegmentReader extends Confi
writer = new PrintWriter(new BufferedWriter(new
OutputStreamWriter(fs.create(dumpFile))));
try {
for (int i = 0; i < files.length; i++) {
- Path partFile = (Path) files[i];
+ Path partFile = files[i];
try {
currentRecordNumber = append(fs, job, partFile, writer,
currentRecordNumber);
} catch (IOException exception) {
Modified: nutch/trunk/src/java/org/apache/nutch/tools/FreeGenerator.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/tools/FreeGenerator.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/tools/FreeGenerator.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/tools/FreeGenerator.java Sat Jan 12
16:33:43 2013
@@ -124,7 +124,7 @@ public class FreeGenerator extends Confi
// pick unique urls from values - discard the reduce key due to hash
collisions
HashMap<Text, CrawlDatum> unique = new HashMap<Text, CrawlDatum>();
while (values.hasNext()) {
- Generator.SelectorEntry entry = (Generator.SelectorEntry)values.next();
+ Generator.SelectorEntry entry = values.next();
unique.put(entry.url, entry.datum);
}
// output unique urls
Modified: nutch/trunk/src/java/org/apache/nutch/tools/arc/ArcRecordReader.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/tools/arc/ArcRecordReader.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/tools/arc/ArcRecordReader.java
(original)
+++ nutch/trunk/src/java/org/apache/nutch/tools/arc/ArcRecordReader.java Sat
Jan 12 16:33:43 2013
@@ -122,14 +122,14 @@ public class ArcRecordReader
* Creates a new instance of the <code>Text</code> object for the key.
*/
public Text createKey() {
- return (Text)ReflectionUtils.newInstance(Text.class, conf);
+ return ReflectionUtils.newInstance(Text.class, conf);
}
/**
* Creates a new instance of the <code>BytesWritable</code> object for the
key
*/
public BytesWritable createValue() {
- return (BytesWritable)ReflectionUtils.newInstance(BytesWritable.class,
conf);
+ return ReflectionUtils.newInstance(BytesWritable.class, conf);
}
/**
@@ -264,9 +264,9 @@ public class ArcRecordReader
System.arraycopy(content, eol + 1, raw, 0, raw.length);
// populate key and values with the header and raw content.
- Text keyText = (Text)key;
+ Text keyText = key;
keyText.set(header);
- BytesWritable valueBytes = (BytesWritable)value;
+ BytesWritable valueBytes = value;
valueBytes.set(raw, 0, raw.length);
// TODO: It would be best to start at the end of the gzip read but
Modified: nutch/trunk/src/test/org/apache/nutch/parse/TestParserFactory.java
URL:
http://svn.apache.org/viewvc/nutch/trunk/src/test/org/apache/nutch/parse/TestParserFactory.java?rev=1432469&r1=1432468&r2=1432469&view=diff
==============================================================================
--- nutch/trunk/src/test/org/apache/nutch/parse/TestParserFactory.java
(original)
+++ nutch/trunk/src/test/org/apache/nutch/parse/TestParserFactory.java Sat Jan
12 16:33:43 2013
@@ -49,11 +49,11 @@ public class TestParserFactory extends T
/** Unit test for <code>getExtensions(String)</code> method. */
public void testGetExtensions() throws Exception {
- Extension ext = (Extension)parserFactory.getExtensions("text/html").get(0);
+ Extension ext = parserFactory.getExtensions("text/html").get(0);
assertEquals("parse-tika", ext.getDescriptor().getPluginId());
- ext = (Extension) parserFactory.getExtensions("text/html;
charset=ISO-8859-1").get(0);
+ ext = parserFactory.getExtensions("text/html; charset=ISO-8859-1").get(0);
assertEquals("parse-tika", ext.getDescriptor().getPluginId());
- ext = (Extension)parserFactory.getExtensions("foo/bar").get(0);
+ ext = parserFactory.getExtensions("foo/bar").get(0);
assertEquals("parse-tika", ext.getDescriptor().getPluginId());
}
