HomeSort by relevance Sort by last modified time
    Searched defs:Shard (Results 1 - 9 of 9) sorted by null

  /external/tensorflow/tensorflow/core/util/
work_sharder.cc 23 void Shard(int max_parallelism, thread::ThreadPool* workers, int64 total,
39 // We shard [0, total) into "num_shards" shards.
42 // If total * cost_per_unit is small, it is not worth shard too
50 // Each shard contains up to "block_size" units. [0, total) is sharded
53 // The 1st shard is done by the caller thread and the other shards
54 // are dispatched to the worker threads. The last shard may be smaller than
67 work(start, limit); // Compute the shard.
68 counter.DecrementCount(); // The shard is done.
72 // Inline execute the 1st shard.
  /art/compiler/utils/
dedupe_set-inl.h 55 class DedupeSet<InKey, StoreKey, Alloc, HashType, HashFunc, kShard>::Shard {
57 Shard(const Alloc& alloc, const std::string& lock_name)
64 ~Shard() {
217 shards_[i].reset(new Shard(alloc, oss.str()));
240 for (HashType shard = 0; shard < kShard; ++shard) {
241 shards_[shard]->UpdateStats(self, &stats);
  /external/autotest/server/cros/ap_configurators/
pyauto_utils.py 168 def Shard(ilist, shard_index, num_shards):
169 """Shard a given list and return the group at index |shard_index|.
174 num_shards: shard count
178 if shard_index == num_shards - 1: # Exhaust the remainder in the last shard.
  /external/protobuf/java/core/src/test/java/com/google/protobuf/
IsValidUtf8TestUtil.java 157 static final class Shard {
164 public Shard(long index, long start, long lim, long expected) {
206 static final List<Shard> FOUR_BYTE_SHARDS =
210 private static List<Shard> generateFourByteShards(int numShards, long[] expected) {
212 List<Shard> shards = new ArrayList<Shard>(numShards);
217 shards.add(new Shard(i, increment * i, increment * (i + 1), expected[i]));
  /external/tensorflow/tensorflow/core/kernels/
record_yielder.cc 71 struct RecordYielder::Shard {
72 int index; // Shard index.
73 std::vector<string> filenames; // File names given to this shard.
74 Notification done; // Notified when this shard is done.
75 Status status; // Shard status.
132 // Shards files and use one thread to go through each shard.
134 std::vector<Shard> shards(N);
136 Shard* shard = &shards[i]; local
137 shard->index = i
    [all...]
  /external/tensorflow/tensorflow/contrib/factorization/kernels/
wals_solver_ops.cc 144 typedef std::pair<int64, int64> Shard;
145 std::vector<Shard> shards;
189 // Lambda encapsulating the per-shard computation.
190 auto work = [&](const Shard& shard) {
212 CHECK_GE(shard.first, 0);
213 CHECK_LE(shard.second, perm.size());
214 CHECK_LE(shard.first, shard.second);
215 const int64 input_index = get_input_index(perm[shard.first])
    [all...]
  /external/autotest/frontend/afe/
models.py 217 class Shard(dbmodels.Model, model_logic.ModelExtensions):
454 # shard, just delete any existing user records that don't match
495 'shard'])
500 assert link == 'shard', 'Link %s should not be deserialized' % link
501 self.shard = Shard.deserialize(data)
517 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in class:Host
635 def assign_to_shard(cls, shard, known_ids):
636 """Assigns hosts to a shard
1541 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in class:Job
    [all...]
  /prebuilts/tools/common/m2/repository/com/amazonaws/aws-java-sdk-kinesis/1.11.18/
aws-java-sdk-kinesis-1.11.18.jar 
  /prebuilts/tools/common/m2/repository/com/amazonaws/aws-java-sdk-dynamodb/1.11.18/
aws-java-sdk-dynamodb-1.11.18.jar 

Completed in 186 milliseconds