Searched refs:split_input (Results 1 - 8 of 8) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
H A Dinput_reader.py17 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)
H A Dmodel_datastore_input_reader.py40 def split_input(cls, job_config): member in class:ModelDatastoreInputReader
47 return super(ModelDatastoreInputReader, cls).split_input(job_config)
H A Dsample_input_reader.py69 def split_input(cls, job_config): member in class:SampleInputReader
H A Dabstract_datastore_input_reader.py47 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/
H A Dinput_readers.py118 * 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)
1065 """Return input reader objects. Helper for split_input."""
1134 def split_input(cls, mapper_spec): member in class:_OldAbstractDatastoreInputReader
1398 def split_input(cl 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...]
H A Dshuffler.py386 def split_input(cls, mapper_spec): member in class:_MergingReader
H A Dhandlers.py1459 readers = input_reader_class.split_input(split_param)
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
H A D_gcs.py215 def split_input(cls, job_config): member in class:GCSInputReader

Completed in 80 milliseconds