Skip to content

Commit fba3388

Browse files
Select sharding functor.
1 parent 95c6111 commit fba3388

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

src/mapper.cc

+7
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,13 @@ void FuzzMapper::select_task_sources(const MapperContext ctx, const Task &task,
197197
random_sources(rng, input.source_instances, output.chosen_ranking);
198198
}
199199

200+
void FuzzMapper::select_sharding_functor(const MapperContext ctx, const Task &task,
201+
const SelectShardingFunctorInput &input,
202+
SelectShardingFunctorOutput &output) {
203+
// TODO: customize the sharding functor
204+
output.chosen_functor = 0;
205+
}
206+
200207
void FuzzMapper::map_inline(const MapperContext ctx, const InlineMapping &inline_op,
201208
const MapInlineInput &input, MapInlineOutput &output) {
202209
RngChannel &rng = map_inline_channel;

src/mapper.h

+3
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,9 @@ class FuzzMapper : public NullMapper {
5050
void select_task_sources(const MapperContext ctx, const Task &task,
5151
const SelectTaskSrcInput &input,
5252
SelectTaskSrcOutput &output) override;
53+
void select_sharding_functor(const MapperContext ctx, const Task &task,
54+
const SelectShardingFunctorInput &input,
55+
SelectShardingFunctorOutput &output) override;
5356

5457
public: // Inline mapping calls
5558
void map_inline(const MapperContext ctx, const InlineMapping &inline_op,

0 commit comments

Comments
 (0)