Examples of MongoRecordReader

Examples of com.mongodb.hadoop.mapred.input.MongoRecordReader

41
42
43
44
45
46
47
        if (!(split instanceof MongoInputSplit))
            throw new IllegalStateException("Creation of a new RecordReader requires a MongoInputSplit instance.");

        final MongoInputSplit mis = (MongoInputSplit) split;

        return new MongoRecordReader(mis);
    }
View Full Code Here

Examples of com.mongodb.hadoop.mapred.input.MongoRecordReader

51
52
53
54
55
56
57
        // split is of type 'MongoHiveInputSplit'
        MongoHiveInputSplit mhis = (MongoHiveInputSplit) split;

        // return MongoRecordReader. Delegate is of type 'MongoInputSplit'
        return new MongoRecordReader((MongoInputSplit) mhis.getDelegate());
    }
View Full Code Here

Examples of com.mongodb.hadoop.mapred.input.MongoRecordReader

45
46
47
48
49
50
51
            throw new IllegalStateException("Creation of a new RecordReader requires a MongoInputSplit instance.");
        }

        final MongoInputSplit mis = (MongoInputSplit) split;

        return new MongoRecordReader(mis);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.