public static boolean shouldSchemaRegionBeListened(
      final int consensusGroupId, final PipeParameters parameters) throws IllegalPathException {
    final boolean isTableModel =
        PathUtils.isTableModelDatabase(
            SchemaEngine.getInstance()
                .getSchemaRegion(new SchemaRegionId(consensusGroupId))
                .getDatabaseFullPath());
    return (TreePattern.isTreeModelDataAllowToBeCaptured(parameters) && !isTableModel
            || TablePattern.isTableModelDataAllowToBeCaptured(parameters) && isTableModel)
        && !parseListeningPlanTypeSet(parameters).isEmpty();
  }
{@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