Author: edwardyoon
Date: Tue Dec 11 07:53:20 2012
New Revision: 1420023
URL: http://svn.apache.org/viewvc?rev=1420023&view=rev
Log:
replace deprecated method to alternative.
Modified:
hama/trunk/core/src/main/java/org/apache/hama/pipes/PipesNonJavaInputFormat.java
Modified:
hama/trunk/core/src/main/java/org/apache/hama/pipes/PipesNonJavaInputFormat.java
URL:
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/pipes/PipesNonJavaInputFormat.java?rev=1420023&r1=1420022&r2=1420023&view=diff
==============================================================================
---
hama/trunk/core/src/main/java/org/apache/hama/pipes/PipesNonJavaInputFormat.java
(original)
+++
hama/trunk/core/src/main/java/org/apache/hama/pipes/PipesNonJavaInputFormat.java
Tue Dec 11 07:53:20 2012
@@ -47,15 +47,15 @@ public class PipesNonJavaInputFormat imp
@Override
public RecordReader<FloatWritable, NullWritable> getRecordReader(
InputSplit genericSplit, BSPJob job) throws IOException {
- return new PipesDummyRecordReader(job.getConf(), genericSplit);
+ return new PipesDummyRecordReader(job.getConfiguration(), genericSplit);
}
@Override
public InputSplit[] getSplits(BSPJob job, int numSplits) throws IOException {
// Delegate the generation of input splits to the 'original' InputFormat
return ReflectionUtils.newInstance(
- job.getConf().getClass("hama.pipes.user.inputformat",
- TextInputFormat.class, InputFormat.class), job.getConf())
+ job.getConfiguration().getClass("hama.pipes.user.inputformat",
+ TextInputFormat.class, InputFormat.class), job.getConfiguration())
.getSplits(job, numSplits);
}