static boolean shouldPlanBeListened(final PlanNode node) {
    try {
      return node.getType() == PlanNodeType.PIPE_ENRICHED_WRITE
          || node.getType() == PlanNodeType.PIPE_ENRICHED_NON_WRITE
          || OPTION_PLAN_MAP.values().stream().anyMatch(types -> types.contains(node.getType()))
              && (node.getType() != PlanNodeType.CREATE_OR_UPDATE_TABLE_DEVICE
                  || !((CreateOrUpdateTableDeviceNode) node).getAttributeNameList().isEmpty());
    } catch (final Exception e) {
      // Some plan nodes may not contain "getType()" implementation
      return false;
    }
  }
{@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