### Question:
DynamicFilterService { @VisibleForTesting static Set<DynamicFilterId> getSourceStageInnerLazyDynamicFilters(PlanFragment plan) { if (!plan.getPartitioning().equals(SOURCE_DISTRIBUTION)) { return ImmutableSet.of(); } PlanNode planNode = plan.getRoot(); Set<DynamicFilterId> innerStageDynamicFilters = intersection(getProducedDynamicFilters(planNode), getConsumedDynamicFilters(planNode)); Set<DynamicFilterId> replicatedDynamicFilters = getReplicatedDynamicFilters(planNode); return ImmutableSet.copyOf(intersection(innerStageDynamicFilters, replicatedDynamicFilters)); } @Inject  DynamicFilterService(DynamicFilterConfig dynamicFilterConfig); @VisibleForTesting  DynamicFilterService(ExecutorService executor); @PreDestroy void stop(); void registerQuery(SqlQueryExecution sqlQueryExecution, SubPlan fragmentedPlan); @VisibleForTesting void registerQuery(
            QueryId queryId,
            Set<DynamicFilterId> dynamicFilters,
            Set<DynamicFilterId> lazyDynamicFilters,
            Set<DynamicFilterId> replicatedDynamicFilters); DynamicFiltersStats getDynamicFilteringStats(QueryId queryId, Session session); void removeQuery(QueryId queryId); boolean isCollectingTaskNeeded(QueryId queryId, PlanFragment plan); void unblockStageDynamicFilters(QueryId queryId, PlanFragment plan); DynamicFilter createDynamicFilter(QueryId queryId, List<DynamicFilters.Descriptor> dynamicFilterDescriptors, Map<Symbol, ColumnHandle> columnHandles); void addTaskDynamicFilters(TaskId taskId, Map<DynamicFilterId, Domain> newDynamicFilters); void stageCannotScheduleMoreTasks(StageId stageId, int numberOfTasks);  }### Answer:
@Test public void testSourceStageInnerLazyDynamicFilters() { DynamicFilterId dynamicFilterId = new DynamicFilterId("filterId"); assertEquals(getSourceStageInnerLazyDynamicFilters(createPlan(dynamicFilterId, SOURCE_DISTRIBUTION, REPLICATE)), ImmutableSet.of(dynamicFilterId)); assertEquals(getSourceStageInnerLazyDynamicFilters(createPlan(dynamicFilterId, FIXED_HASH_DISTRIBUTION, REPLICATE)), ImmutableSet.of()); assertEquals(getSourceStageInnerLazyDynamicFilters(createPlan(dynamicFilterId, SOURCE_DISTRIBUTION, REPARTITION)), ImmutableSet.of()); }