private static Set<PlanNodeType> getOptionsByPrefix(final PartialPath prefix) {
    return OPTION_PLAN_MAP.keySet().stream()
        .filter(path -> path.overlapWithFullPathPrefix(prefix))
        .map(OPTION_PLAN_MAP::get)
        .flatMap(Collection::stream)
        .collect(Collectors.toSet());
  }
{@link SchemaRegionListeningFilter} is to classify the {@link PlanNode}s to help {@link
SchemaRegionListeningQueue} and pipe to collect.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/SchemaRegionListeningFilter.java