| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| input_reader.py | 17 2. split_input is called to split inputs based on map_job.JobConfig.
73 def split_input(cls, job_config): member in class:InputReader
88 raise NotImplementedError("split_input() not implemented in %s" % cls)
|
| sample_input_reader.py | 69 def split_input(cls, job_config): member in class:SampleInputReader
|
| model_datastore_input_reader.py | 40 def split_input(cls, job_config): member in class:ModelDatastoreInputReader
47 return super(ModelDatastoreInputReader, cls).split_input(job_config)
|
| abstract_datastore_input_reader.py | 47 This is internal constructor. Use split_input to create readers instead.
90 def split_input(cls, job_config): member in class:AbstractDatastoreInputReader
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| input_readers.py | 118 * They are created by using the split_input method to generate a set of
170 def split_input(cls, mapper_spec): member in class:InputReader
183 raise NotImplementedError("split_input() not implemented in %s" % cls)
277 This is internal constructor. Use split_input to create readers instead.
334 def split_input(cls, mapper_spec): member in class:AbstractDatastoreInputReader
716 def split_input(cls, mapper_spec): member in class:DatastoreInputReader
722 return super(DatastoreInputReader, cls).split_input(mapper_spec)
1134 def split_input(cls, mapper_spec): member in class:_OldAbstractDatastoreInputReader
1398 def split_input(cls, mapper_spec): member in class:BlobstoreLineInputReader
1566 def split_input(cls, mapper_spec, _reader=blobstore.BlobReader): member in class:BlobstoreZipInputReader
1688 def split_input(cls, mapper_spec, _reader=blobstore.BlobReader): member in class:BlobstoreZipLineInputReader
1872 def split_input(cls, mapper_spec): member in class:RandomStringInputReader
1990 def split_input(cls, mapper_spec): member in class:NamespaceInputReader
2151 def split_input(cls, mapper_spec): member in class:LogInputReader
2408 def split_input(cls, mapper_spec): member in class:_GoogleCloudStorageInputReader
[all...] |
| shuffler.py | 386 def split_input(cls, mapper_spec): member in class:_MergingReader
|
| handlers.py | [all...] |
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/ |
| _gcs.py | 215 def split_input(cls, job_config): member in class:GCSInputReader
|
