Function View

src/environmentd/src/http/static/js/memory.jsx:243–674

(props)

}

function View(props) {
  const [stats, setStats] = useState(null);
  const [operators, setOperators] = useState(null);
  const [channels, setChannels] = useState(null);
  const [view, setView] = useState(null);
  const [graph, setGraph] = useState(null);
  const [dot, setDot] = useState(null);
  const [loading, setLoading] = useState(true);
  const [error, setError] = useState(false);

  useEffect(() => {
    setLoading(true);
    setError(false);
    setGraph(null);

    const load = async () => {
      // Use mz_dataflow_operator_parents for hierarchy - much cleaner than computing from addresses.
      // The query computes:
      // 1. All operators in the dataflow with their parent_id
      // 2. Which operators are scopes (have children)
      // 3. Memory and elapsed time stats
      // 4. All addresses (operators + channels) for edge lookups
      const {
        results: [_set_cluster, _set_replica, stats_table, operators_table, addresses_table, channels_table],
      } = await query(`
        SET cluster = ${formatNameForQuery(props.clusterName)};
        SET cluster_replica = ${formatNameForQuery(props.replicaName)};

        -- Dataflow stats
        SELECT
          name, batches, records, size
        FROM
          mz_introspection.mz_records_per_dataflow
        WHERE
          id = ${props.dataflowId};

        -- All operators with parent relationships, scope detection, and stats
        WITH dataflow_operators AS (
            SELECT
                o.id,
                o.name,
                p.parent_id,
                a.address
            FROM mz_introspection.mz_dataflow_operators o
            LEFT JOIN mz_introspection.mz_dataflow_operator_parents p ON o.id = p.id
            JOIN mz_introspection.mz_dataflow_addresses a ON o.id = a.id
            WHERE a.address[1] = ${props.dataflowId}
        ),
        scope_ids AS (
            SELECT DISTINCT parent_id as id FROM dataflow_operators WHERE parent_id IS NOT NULL
        )
        SELECT
            o.id,
            o.name,
            o.parent_id,
            o.address,
            CASE WHEN s.id IS NOT NULL THEN true ELSE false END as is_scope,
            r.records,