hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1420023 - /hama/trunk/core/src/main/java/org/apache/hama/pipes/PipesNonJavaInputFormat.java
Date Tue, 11 Dec 2012 07:53:20 GMT
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);
   }
 



Mime
View raw message