Searched defs:shard_id (Results 1 – 3 of 3) sorted by relevance
742 shard_id, argument1046 shard_id = property(get_shard_id) variable in ShardState1067 def get_key_by_shard_id(cls, shard_id): argument1079 def get_by_shard_id(cls, shard_id): argument
905 def get_task_name(shard_id, slice_id, retry=0): argument
337 def get_shard_iterator(self, stream_name, shard_id, shard_iterator_type, argument