Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

moved logging to debug

  • Loading branch information...
commit 11fa49443bcd5752299a21537d25a4099c57b745 1 parent f84e098
@rgnitz rgnitz authored
Showing with 5 additions and 3 deletions.
  1. +5 −3 src/main/com/mongodb/hadoop/MongoInputFormat.java
View
8 src/main/com/mongodb/hadoop/MongoInputFormat.java
@@ -44,7 +44,7 @@
public class MongoInputFormat extends InputFormat<Object, BSONObject> {
-
+ @Override
public RecordReader<Object, BSONObject> createRecordReader( InputSplit split, TaskAttemptContext context ){
if ( !( split instanceof MongoInputSplit ) )
throw new IllegalStateException( "Creation of a new RecordReader requires a MongoInputSplit instance." );
@@ -54,13 +54,14 @@
return new com.mongodb.hadoop.input.MongoRecordReader( mis );
}
+ @Override
public List<InputSplit> getSplits( JobContext context ){
final Configuration hadoopConfiguration = context.getConfiguration();
final MongoConfig conf = new MongoConfig( hadoopConfiguration );
return getSplits( hadoopConfiguration, conf );
}
- //public because called by the other MongoInputFormat
+ // public because called by the other MongoInputFormat
public List<InputSplit> getSplits( Configuration hadoopConfiguration, MongoConfig conf ){
if ( conf.getLimit() > 0 || conf.getSkip() > 0 ){
@@ -305,7 +306,8 @@ else if ( useShards )
}
}
- private static MongoURI getNewURI( MongoURI originalUri, String newServerUri, Boolean slaveok ){
+ private static MongoURI getNewURI( MongoURI originalUri, String newServerUri, Boolean slaveok ) {
+
String originalUriString = originalUri.toString();
originalUriString = originalUriString.substring( MongoURI.MONGODB_PREFIX.length() );
Please sign in to comment.
Something went wrong with that request. Please try again.