Home
last modified time | relevance | path

Searched refs:mapperClass (Results 1 – 25 of 27) sorted by relevance

12

/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/lib/
H A DTaggedInputSplit.java45 private Class<? extends Mapper> mapperClass; field in TaggedInputSplit
63 Class<? extends Mapper> mapperClass) { in TaggedInputSplit() argument
68 this.mapperClass = mapperClass; in TaggedInputSplit()
95 return mapperClass; in getMapperClass()
113 mapperClass = (Class<? extends Mapper>) readClass(in); in readFields()
129 Text.writeString(out, mapperClass.getName()); in write()
H A DDelegatingInputFormat.java79 Class<? extends Mapper> mapperClass = mapperMap.get(path); in getSplits() local
80 if (!mapperPaths.containsKey(mapperClass)) { in getSplits()
81 mapperPaths.put(mapperClass, new LinkedList<Path>()); in getSplits()
84 mapperPaths.get(mapperClass).add(path); in getSplits()
92 Class<? extends Mapper> mapperClass = mapEntry.getKey(); in getSplits() local
94 if (mapperClass == null) { in getSplits()
95 mapperClass = conf.getMapperClass(); in getSplits()
106 mapperClass)); in getSplits()
H A DMultipleInputs.java67 Class<? extends Mapper> mapperClass) { in addInputPath() argument
71 String mapperMapping = path.toString() + ";" + mapperClass.getName(); in addInputPath()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/lib/
H A DTaggedInputSplit.java46 private Class<? extends Mapper> mapperClass; field in TaggedInputSplit
64 Class<? extends Mapper> mapperClass) { in TaggedInputSplit() argument
69 this.mapperClass = mapperClass; in TaggedInputSplit()
96 return mapperClass; in getMapperClass()
114 mapperClass = (Class<? extends Mapper>) readClass(in); in readFields()
130 Text.writeString(out, mapperClass.getName()); in write()
H A DDelegatingInputFormat.java83 Class<? extends Mapper> mapperClass = mapperMap.get(path); in getSplits() local
84 if (!mapperPaths.containsKey(mapperClass)) { in getSplits()
85 mapperPaths.put(mapperClass, new LinkedList<Path>()); in getSplits()
88 mapperPaths.get(mapperClass).add(path); in getSplits()
96 Class<? extends Mapper> mapperClass = mapEntry.getKey(); in getSplits() local
98 if (mapperClass == null) { in getSplits()
99 mapperClass = conf.getMapperClass(); in getSplits()
110 mapperClass)); in getSplits()
H A DMultipleInputs.java71 Class<? extends Mapper> mapperClass) { in addInputPath() argument
75 String mapperMapping = path.toString() + ";" + mapperClass.getName(); in addInputPath()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/lib/input/
H A DDelegatingInputFormat.java87 Class<? extends Mapper> mapperClass = mapperMap.get(path); in getSplits() local
88 if (!mapperPaths.containsKey(mapperClass)) { in getSplits()
89 mapperPaths.put(mapperClass, new LinkedList<Path>()); in getSplits()
92 mapperPaths.get(mapperClass).add(path); in getSplits()
100 Class<? extends Mapper> mapperClass = mapEntry.getKey(); in getSplits() local
102 if (mapperClass == null) { in getSplits()
104 mapperClass = job.getMapperClass(); in getSplits()
118 mapperClass)); in getSplits()
H A DTaggedInputSplit.java53 private Class<? extends Mapper> mapperClass; field in TaggedInputSplit
72 Class<? extends Mapper> mapperClass) { in TaggedInputSplit() argument
77 this.mapperClass = mapperClass; in TaggedInputSplit()
106 return mapperClass; in getMapperClass()
121 mapperClass = (Class<? extends Mapper<?, ?, ?, ?>>) readClass(in); in readFields()
143 Text.writeString(out, mapperClass.getName()); in write()
H A DMultipleInputs.java80 Class<? extends Mapper> mapperClass) { in addInputPath() argument
84 String mapperMapping = path.toString() + ";" + mapperClass.getName(); in addInputPath()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/input/
H A DDelegatingInputFormat.java87 Class<? extends Mapper> mapperClass = mapperMap.get(path); in getSplits() local
88 if (!mapperPaths.containsKey(mapperClass)) { in getSplits()
89 mapperPaths.put(mapperClass, new LinkedList<Path>()); in getSplits()
92 mapperPaths.get(mapperClass).add(path); in getSplits()
100 Class<? extends Mapper> mapperClass = mapEntry.getKey(); in getSplits() local
102 if (mapperClass == null) { in getSplits()
104 mapperClass = job.getMapperClass(); in getSplits()
118 mapperClass)); in getSplits()
H A DTaggedInputSplit.java54 private Class<? extends Mapper> mapperClass; field in TaggedInputSplit
73 Class<? extends Mapper> mapperClass) { in TaggedInputSplit() argument
78 this.mapperClass = mapperClass; in TaggedInputSplit()
107 return mapperClass; in getMapperClass()
122 mapperClass = (Class<? extends Mapper<?, ?, ?, ?>>) readClass(in); in readFields()
144 Text.writeString(out, mapperClass.getName()); in write()
H A DMultipleInputs.java80 Class<? extends Mapper> mapperClass) { in addInputPath() argument
84 String mapperMapping = path.toString() + ";" + mapperClass.getName(); in addInputPath()
/dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/user/
H A DMappedUserProvider.java65 final String mapperClass = JiveGlobals.getProperty( PROPERTY_MAPPER_CLASSNAME ); in MappedUserProvider() local
66 if ( mapperClass == null ) in MappedUserProvider()
73 final Class c = ClassUtils.forName( mapperClass ); in MappedUserProvider()
78 …alStateException( "Unable to create new instance of UserProviderMapper class: " + mapperClass, e ); in MappedUserProvider()
/dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/auth/
H A DMappedAuthProvider.java61 final String mapperClass = JiveGlobals.getProperty( PROPERTY_MAPPER_CLASSNAME ); in MappedAuthProvider() local
62 if ( mapperClass == null ) in MappedAuthProvider()
69 final Class c = ClassUtils.forName( mapperClass ); in MappedAuthProvider()
74 …alStateException( "Unable to create new instance of AuthProviderMapper class: " + mapperClass, e ); in MappedAuthProvider()
/dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/user/property/
H A DMappedUserPropertyProvider.java68 final String mapperClass = JiveGlobals.getProperty( PROPERTY_MAPPER_CLASSNAME ); in MappedUserPropertyProvider() local
69 if ( mapperClass == null ) in MappedUserPropertyProvider()
76 final Class c = ClassUtils.forName( mapperClass ); in MappedUserPropertyProvider()
81 …xception( "Unable to create new instance of UserPropertyProviderMapper class: " + mapperClass, e ); in MappedUserPropertyProvider()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/eclipse-plugin/src/java/org/apache/hadoop/eclipse/launch/
H A DLocalMapReduceLaunchTabGroup.java78 private Text mapperClass; field in LocalMapReduceLaunchTabGroup.MapReduceLaunchTab
98 mapperClass = new Text(panel, SWT.SINGLE | SWT.BORDER); in createControl()
99 createRow(parent, panel, mapperClass); in createControl()
154 mapperClass.setText(configuration.getAttribute( in initializeFrom()
169 mapperClass.getText()); in performApply()
/dports/audio/ampache/ampache-php74-5.0.0/src/Module/User/Activity/TypeHandler/
H A DActivityTypeHandlerMapper.php56 $mapperClass = static::MAP[$object_type] ?? GenericActivityTypeHandler::class;
58 return new $mapperClass(
/dports/www/bolt/bolt-2.2.24/vendor/miljar/php-exif/lib/PHPExif/Adapter/
H A DAdapterAbstract.php45 protected $mapperClass = ''; variable in PHPExif\\Adapter\\AdapterAbstract
81 $mapper = new $this->mapperClass;
H A DExiftool.php50 protected $mapperClass = '\\PHPExif\\Mapper\\Exiftool'; variable in PHPExif\\Adapter\\Exiftool
H A DNative.php66 protected $mapperClass = '\\PHPExif\\Mapper\\Native'; variable in PHPExif\\Adapter\\Native
/dports/www/owncloud/owncloud/lib/private/Files/Mount/
H A DObjectHomeMountProvider.php122 $mapperClass = $config['arguments']['mapper-class'];
123 $mapper = new $mapperClass($user);
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/
H A DImportTsv.java473 Class mapperClass = in createSubmittableJob() local
480 job.setJarByClass(mapperClass); in createSubmittableJob()
483 job.setMapperClass(mapperClass); in createSubmittableJob()
537 if (mapperClass.equals(TsvImporterTextMapper.class)) { in createSubmittableJob()
553 if (mapperClass.equals(TsvImporterTextMapper.class)) { in createSubmittableJob()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/fs/
H A DTestDFSIO.java242 Class<? extends Mapper<Text, LongWritable, Text, Text>> mapperClass, in runIOTest() argument
250 job.setMapperClass(mapperClass); in runIOTest()
H A DDFSCIOTest.java280 private static void runIOTest( Class<? extends Mapper> mapperClass, in runIOTest() argument
288 job.setMapperClass(mapperClass); in runIOTest()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/
H A DDFSCIOTest.java279 private static void runIOTest( Class<? extends Mapper> mapperClass, in runIOTest() argument
287 job.setMapperClass(mapperClass); in runIOTest()

12