API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jan 7th, 2019
117
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
JSON 80.01 KB | None | 0 0
raw download clone embed print report
  1. {
  2.     "nodes": [
  3.  
  4.     {
  5.         "id": 20,
  6.         "type": "source",
  7.         "pact": "Data Source",
  8.         "contents": "at getGraphCollection(CSVDataSource.java:79) (org.apache.flink.api.java.io.TextInputFormat)",
  9.         "parallelism": "4",
  10.         "global_properties": [
  11.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  12.             { "name": "Partitioning Order", "value": "(none)" },
  13.             { "name": "Uniqueness", "value": "not unique" }
  14.         ],
  15.         "local_properties": [
  16.             { "name": "Order", "value": "(none)" },
  17.             { "name": "Grouping", "value": "not grouped" },
  18.             { "name": "Uniqueness", "value": "not unique" }
  19.         ],
  20.         "estimates": [
  21.             { "name": "Est. Output Size", "value": "4.45 M" },
  22.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  23.         "costs": [
  24.             { "name": "Network", "value": "0.0" },
  25.             { "name": "Disk I/O", "value": "4.45 M" },
  26.             { "name": "CPU", "value": "0.0" },
  27.             { "name": "Cumulative Network", "value": "0.0" },
  28.             { "name": "Cumulative Disk I/O", "value": "4.45 M" },
  29.             { "name": "Cumulative CPU", "value": "0.0" }
  30.         ],
  31.         "compiler_hints": [
  32.             { "name": "Output Size (bytes)", "value": "(none)" },
  33.             { "name": "Output Cardinality", "value": "(none)" },
  34.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  35.             { "name": "Filter Factor", "value": "(none)" }      ]
  36.     },
  37.     {
  38.         "id": 23,
  39.         "type": "source",
  40.         "pact": "Data Source",
  41.         "contents": "at fromFile(MetaData.java:69) (org.apache.flink.api.java.io.TextInputFormat)",
  42.         "parallelism": "4",
  43.         "global_properties": [
  44.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  45.             { "name": "Partitioning Order", "value": "(none)" },
  46.             { "name": "Uniqueness", "value": "not unique" }
  47.         ],
  48.         "local_properties": [
  49.             { "name": "Order", "value": "(none)" },
  50.             { "name": "Grouping", "value": "not grouped" },
  51.             { "name": "Uniqueness", "value": "not unique" }
  52.         ],
  53.         "estimates": [
  54.             { "name": "Est. Output Size", "value": "732.00" },
  55.             { "name": "Est. Cardinality", "value": "26.00" }        ],
  56.         "costs": [
  57.             { "name": "Network", "value": "0.0" },
  58.             { "name": "Disk I/O", "value": "732.00" },
  59.             { "name": "CPU", "value": "0.0" },
  60.             { "name": "Cumulative Network", "value": "0.0" },
  61.             { "name": "Cumulative Disk I/O", "value": "732.00" },
  62.             { "name": "Cumulative CPU", "value": "0.0" }
  63.         ],
  64.         "compiler_hints": [
  65.             { "name": "Output Size (bytes)", "value": "(none)" },
  66.             { "name": "Output Cardinality", "value": "(none)" },
  67.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  68.             { "name": "Filter Factor", "value": "(none)" }      ]
  69.     },
  70.     {
  71.         "id": 22,
  72.         "type": "pact",
  73.         "pact": "Map",
  74.         "contents": "Map at fromFile(MetaData.java:70)",
  75.         "parallelism": "4",
  76.         "predecessors": [
  77.             {"id": 23, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  78.         ],
  79.         "driver_strategy": "Map",
  80.         "global_properties": [
  81.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  82.             { "name": "Partitioning Order", "value": "(none)" },
  83.             { "name": "Uniqueness", "value": "not unique" }
  84.         ],
  85.         "local_properties": [
  86.             { "name": "Order", "value": "(none)" },
  87.             { "name": "Grouping", "value": "not grouped" },
  88.             { "name": "Uniqueness", "value": "not unique" }
  89.         ],
  90.         "estimates": [
  91.             { "name": "Est. Output Size", "value": "(unknown)" },
  92.             { "name": "Est. Cardinality", "value": "26.00" }        ],
  93.         "costs": [
  94.             { "name": "Network", "value": "0.0" },
  95.             { "name": "Disk I/O", "value": "0.0" },
  96.             { "name": "CPU", "value": "0.0" },
  97.             { "name": "Cumulative Network", "value": "0.0" },
  98.             { "name": "Cumulative Disk I/O", "value": "732.00" },
  99.             { "name": "Cumulative CPU", "value": "0.0" }
  100.         ],
  101.         "compiler_hints": [
  102.             { "name": "Output Size (bytes)", "value": "(none)" },
  103.             { "name": "Output Cardinality", "value": "(none)" },
  104.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  105.             { "name": "Filter Factor", "value": "(none)" }      ]
  106.     },
  107.     {
  108.         "id": 21,
  109.         "type": "pact",
  110.         "pact": "Map",
  111.         "contents": "Map at fromFile(MetaData.java:71)",
  112.         "parallelism": "4",
  113.         "predecessors": [
  114.             {"id": 22, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  115.         ],
  116.         "driver_strategy": "Map",
  117.         "global_properties": [
  118.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  119.             { "name": "Partitioning Order", "value": "(none)" },
  120.             { "name": "Uniqueness", "value": "not unique" }
  121.         ],
  122.         "local_properties": [
  123.             { "name": "Order", "value": "(none)" },
  124.             { "name": "Grouping", "value": "not grouped" },
  125.             { "name": "Uniqueness", "value": "not unique" }
  126.         ],
  127.         "estimates": [
  128.             { "name": "Est. Output Size", "value": "(unknown)" },
  129.             { "name": "Est. Cardinality", "value": "26.00" }        ],
  130.         "costs": [
  131.             { "name": "Network", "value": "0.0" },
  132.             { "name": "Disk I/O", "value": "0.0" },
  133.             { "name": "CPU", "value": "0.0" },
  134.             { "name": "Cumulative Network", "value": "0.0" },
  135.             { "name": "Cumulative Disk I/O", "value": "732.00" },
  136.             { "name": "Cumulative CPU", "value": "0.0" }
  137.         ],
  138.         "compiler_hints": [
  139.             { "name": "Output Size (bytes)", "value": "(none)" },
  140.             { "name": "Output Cardinality", "value": "(none)" },
  141.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  142.             { "name": "Filter Factor", "value": "(none)" }      ]
  143.     },
  144.     {
  145.         "id": 19,
  146.         "type": "pact",
  147.         "pact": "Map",
  148.         "contents": "Map at getGraphCollection(CSVDataSource.java:80)",
  149.         "parallelism": "4",
  150.         "predecessors": [
  151.             {"id": 20, "side": "first", "ship_strategy": "Forward", "exchange_mode": "PIPELINED"},
  152.             {"id": 21, "side": "second", "ship_strategy": "Broadcast", "exchange_mode": "BATCH"}
  153.         ],
  154.         "driver_strategy": "Map",
  155.         "global_properties": [
  156.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  157.             { "name": "Partitioning Order", "value": "(none)" },
  158.             { "name": "Uniqueness", "value": "not unique" }
  159.         ],
  160.         "local_properties": [
  161.             { "name": "Order", "value": "(none)" },
  162.             { "name": "Grouping", "value": "not grouped" },
  163.             { "name": "Uniqueness", "value": "not unique" }
  164.         ],
  165.         "estimates": [
  166.             { "name": "Est. Output Size", "value": "(unknown)" },
  167.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  168.         "costs": [
  169.             { "name": "Network", "value": "0.0" },
  170.             { "name": "Disk I/O", "value": "0.0" },
  171.             { "name": "CPU", "value": "0.0" },
  172.             { "name": "Cumulative Network", "value": "0.0" },
  173.             { "name": "Cumulative Disk I/O", "value": "4.45 M" },
  174.             { "name": "Cumulative CPU", "value": "0.0" }
  175.         ],
  176.         "compiler_hints": [
  177.             { "name": "Output Size (bytes)", "value": "(none)" },
  178.             { "name": "Output Cardinality", "value": "(none)" },
  179.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  180.             { "name": "Filter Factor", "value": "(none)" }      ]
  181.     },
  182.     {
  183.         "id": 18,
  184.         "type": "pact",
  185.         "pact": "Map",
  186.         "contents": "Map at fromDataSets(GVEGraphLayoutFactory.java:60)",
  187.         "parallelism": "4",
  188.         "predecessors": [
  189.             {"id": 19, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  190.         ],
  191.         "driver_strategy": "Map",
  192.         "global_properties": [
  193.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  194.             { "name": "Partitioning Order", "value": "(none)" },
  195.             { "name": "Uniqueness", "value": "not unique" }
  196.         ],
  197.         "local_properties": [
  198.             { "name": "Order", "value": "(none)" },
  199.             { "name": "Grouping", "value": "not grouped" },
  200.             { "name": "Uniqueness", "value": "not unique" }
  201.         ],
  202.         "estimates": [
  203.             { "name": "Est. Output Size", "value": "(unknown)" },
  204.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  205.         "costs": [
  206.             { "name": "Network", "value": "0.0" },
  207.             { "name": "Disk I/O", "value": "0.0" },
  208.             { "name": "CPU", "value": "0.0" },
  209.             { "name": "Cumulative Network", "value": "0.0" },
  210.             { "name": "Cumulative Disk I/O", "value": "4.45 M" },
  211.             { "name": "Cumulative CPU", "value": "0.0" }
  212.         ],
  213.         "compiler_hints": [
  214.             { "name": "Output Size (bytes)", "value": "(none)" },
  215.             { "name": "Output Cardinality", "value": "(none)" },
  216.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  217.             { "name": "Filter Factor", "value": "(none)" }      ]
  218.     },
  219.     {
  220.         "id": 17,
  221.         "type": "pact",
  222.         "pact": "Map",
  223.         "contents": "Map at transformGraphProperties(CAPFQuery.java:207)",
  224.         "parallelism": "4",
  225.         "predecessors": [
  226.             {"id": 18, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  227.         ],
  228.         "driver_strategy": "Map",
  229.         "global_properties": [
  230.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  231.             { "name": "Partitioning Order", "value": "(none)" },
  232.             { "name": "Uniqueness", "value": "not unique" }
  233.         ],
  234.         "local_properties": [
  235.             { "name": "Order", "value": "(none)" },
  236.             { "name": "Grouping", "value": "not grouped" },
  237.             { "name": "Uniqueness", "value": "not unique" }
  238.         ],
  239.         "estimates": [
  240.             { "name": "Est. Output Size", "value": "(unknown)" },
  241.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  242.         "costs": [
  243.             { "name": "Network", "value": "0.0" },
  244.             { "name": "Disk I/O", "value": "0.0" },
  245.             { "name": "CPU", "value": "0.0" },
  246.             { "name": "Cumulative Network", "value": "0.0" },
  247.             { "name": "Cumulative Disk I/O", "value": "4.45 M" },
  248.             { "name": "Cumulative CPU", "value": "0.0" }
  249.         ],
  250.         "compiler_hints": [
  251.             { "name": "Output Size (bytes)", "value": "(none)" },
  252.             { "name": "Output Cardinality", "value": "(none)" },
  253.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  254.             { "name": "Filter Factor", "value": "(none)" }      ]
  255.     },
  256.     {
  257.         "id": 16,
  258.         "type": "pact",
  259.         "pact": "Map",
  260.         "contents": "Map at fromDataSets(GVEGraphLayoutFactory.java:60)",
  261.         "parallelism": "4",
  262.         "predecessors": [
  263.             {"id": 17, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  264.         ],
  265.         "driver_strategy": "Map",
  266.         "global_properties": [
  267.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  268.             { "name": "Partitioning Order", "value": "(none)" },
  269.             { "name": "Uniqueness", "value": "not unique" }
  270.         ],
  271.         "local_properties": [
  272.             { "name": "Order", "value": "(none)" },
  273.             { "name": "Grouping", "value": "not grouped" },
  274.             { "name": "Uniqueness", "value": "not unique" }
  275.         ],
  276.         "estimates": [
  277.             { "name": "Est. Output Size", "value": "(unknown)" },
  278.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  279.         "costs": [
  280.             { "name": "Network", "value": "0.0" },
  281.             { "name": "Disk I/O", "value": "0.0" },
  282.             { "name": "CPU", "value": "0.0" },
  283.             { "name": "Cumulative Network", "value": "0.0" },
  284.             { "name": "Cumulative Disk I/O", "value": "4.45 M" },
  285.             { "name": "Cumulative CPU", "value": "0.0" }
  286.         ],
  287.         "compiler_hints": [
  288.             { "name": "Output Size (bytes)", "value": "(none)" },
  289.             { "name": "Output Cardinality", "value": "(none)" },
  290.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  291.             { "name": "Filter Factor", "value": "(none)" }      ]
  292.     },
  293.     {
  294.         "id": 15,
  295.         "type": "pact",
  296.         "pact": "Map",
  297.         "contents": "Map at createNodeTables(CAPFQuery.java:261)",
  298.         "parallelism": "4",
  299.         "predecessors": [
  300.             {"id": 16, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  301.         ],
  302.         "driver_strategy": "Map",
  303.         "global_properties": [
  304.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  305.             { "name": "Partitioning Order", "value": "(none)" },
  306.             { "name": "Uniqueness", "value": "not unique" }
  307.         ],
  308.         "local_properties": [
  309.             { "name": "Order", "value": "(none)" },
  310.             { "name": "Grouping", "value": "not grouped" },
  311.             { "name": "Uniqueness", "value": "not unique" }
  312.         ],
  313.         "estimates": [
  314.             { "name": "Est. Output Size", "value": "(unknown)" },
  315.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  316.         "costs": [
  317.             { "name": "Network", "value": "0.0" },
  318.             { "name": "Disk I/O", "value": "0.0" },
  319.             { "name": "CPU", "value": "0.0" },
  320.             { "name": "Cumulative Network", "value": "0.0" },
  321.             { "name": "Cumulative Disk I/O", "value": "2.23 M" },
  322.             { "name": "Cumulative CPU", "value": "0.0" }
  323.         ],
  324.         "compiler_hints": [
  325.             { "name": "Output Size (bytes)", "value": "(none)" },
  326.             { "name": "Output Cardinality", "value": "(none)" },
  327.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  328.             { "name": "Filter Factor", "value": "(none)" }      ]
  329.     },
  330.     {
  331.         "id": 14,
  332.         "type": "pact",
  333.         "pact": "Filter",
  334.         "contents": "Filter at createNodeTables(CAPFQuery.java:292)",
  335.         "parallelism": "4",
  336.         "predecessors": [
  337.             {"id": 15, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  338.         ],
  339.         "driver_strategy": "FlatMap",
  340.         "global_properties": [
  341.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  342.             { "name": "Partitioning Order", "value": "(none)" },
  343.             { "name": "Uniqueness", "value": "not unique" }
  344.         ],
  345.         "local_properties": [
  346.             { "name": "Order", "value": "(none)" },
  347.             { "name": "Grouping", "value": "not grouped" },
  348.             { "name": "Uniqueness", "value": "not unique" }
  349.         ],
  350.         "estimates": [
  351.             { "name": "Est. Output Size", "value": "0.0" },
  352.             { "name": "Est. Cardinality", "value": "17.68 K" }      ],
  353.         "costs": [
  354.             { "name": "Network", "value": "0.0" },
  355.             { "name": "Disk I/O", "value": "0.0" },
  356.             { "name": "CPU", "value": "0.0" },
  357.             { "name": "Cumulative Network", "value": "0.0" },
  358.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  359.             { "name": "Cumulative CPU", "value": "0.0" }
  360.         ],
  361.         "compiler_hints": [
  362.             { "name": "Output Size (bytes)", "value": "(none)" },
  363.             { "name": "Output Cardinality", "value": "(none)" },
  364.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  365.             { "name": "Filter Factor", "value": "(none)" }      ]
  366.     },
  367.     {
  368.         "id": 13,
  369.         "type": "pact",
  370.         "pact": "Map",
  371.         "contents": "Map at createNodeTables(CAPFQuery.java:297)",
  372.         "parallelism": "4",
  373.         "predecessors": [
  374.             {"id": 14, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  375.         ],
  376.         "driver_strategy": "Map",
  377.         "global_properties": [
  378.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  379.             { "name": "Partitioning Order", "value": "(none)" },
  380.             { "name": "Uniqueness", "value": "not unique" }
  381.         ],
  382.         "local_properties": [
  383.             { "name": "Order", "value": "(none)" },
  384.             { "name": "Grouping", "value": "not grouped" },
  385.             { "name": "Uniqueness", "value": "not unique" }
  386.         ],
  387.         "estimates": [
  388.             { "name": "Est. Output Size", "value": "(unknown)" },
  389.             { "name": "Est. Cardinality", "value": "17.68 K" }      ],
  390.         "costs": [
  391.             { "name": "Network", "value": "0.0" },
  392.             { "name": "Disk I/O", "value": "0.0" },
  393.             { "name": "CPU", "value": "0.0" },
  394.             { "name": "Cumulative Network", "value": "0.0" },
  395.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  396.             { "name": "Cumulative CPU", "value": "0.0" }
  397.         ],
  398.         "compiler_hints": [
  399.             { "name": "Output Size (bytes)", "value": "(none)" },
  400.             { "name": "Output Cardinality", "value": "(none)" },
  401.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  402.             { "name": "Filter Factor", "value": "(none)" }      ]
  403.     },
  404.     {
  405.         "id": 12,
  406.         "type": "pact",
  407.         "pact": "FlatMap",
  408.         "contents": "select: (f0 AS __NODE__post__session_tmp1)",
  409.         "parallelism": "4",
  410.         "predecessors": [
  411.             {"id": 13, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  412.         ],
  413.         "driver_strategy": "FlatMap",
  414.         "global_properties": [
  415.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  416.             { "name": "Partitioning Order", "value": "(none)" },
  417.             { "name": "Uniqueness", "value": "not unique" }
  418.         ],
  419.         "local_properties": [
  420.             { "name": "Order", "value": "(none)" },
  421.             { "name": "Grouping", "value": "not grouped" },
  422.             { "name": "Uniqueness", "value": "not unique" }
  423.         ],
  424.         "estimates": [
  425.             { "name": "Est. Output Size", "value": "(unknown)" },
  426.             { "name": "Est. Cardinality", "value": "88.38 K" }      ],
  427.         "costs": [
  428.             { "name": "Network", "value": "0.0" },
  429.             { "name": "Disk I/O", "value": "0.0" },
  430.             { "name": "CPU", "value": "0.0" },
  431.             { "name": "Cumulative Network", "value": "0.0" },
  432.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  433.             { "name": "Cumulative CPU", "value": "0.0" }
  434.         ],
  435.         "compiler_hints": [
  436.             { "name": "Output Size (bytes)", "value": "(none)" },
  437.             { "name": "Output Cardinality", "value": "(none)" },
  438.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  439.             { "name": "Filter Factor", "value": "(none)" }      ]
  440.     },
  441.     {
  442.         "id": 35,
  443.         "type": "source",
  444.         "pact": "Data Source",
  445.         "contents": "at getGraphCollection(CSVDataSource.java:84) (org.apache.flink.api.java.io.TextInputFormat)",
  446.         "parallelism": "4",
  447.         "global_properties": [
  448.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  449.             { "name": "Partitioning Order", "value": "(none)" },
  450.             { "name": "Uniqueness", "value": "not unique" }
  451.         ],
  452.         "local_properties": [
  453.             { "name": "Order", "value": "(none)" },
  454.             { "name": "Grouping", "value": "not grouped" },
  455.             { "name": "Uniqueness", "value": "not unique" }
  456.         ],
  457.         "estimates": [
  458.             { "name": "Est. Output Size", "value": "7.57 M" },
  459.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  460.         "costs": [
  461.             { "name": "Network", "value": "0.0" },
  462.             { "name": "Disk I/O", "value": "7.57 M" },
  463.             { "name": "CPU", "value": "0.0" },
  464.             { "name": "Cumulative Network", "value": "0.0" },
  465.             { "name": "Cumulative Disk I/O", "value": "7.57 M" },
  466.             { "name": "Cumulative CPU", "value": "0.0" }
  467.         ],
  468.         "compiler_hints": [
  469.             { "name": "Output Size (bytes)", "value": "(none)" },
  470.             { "name": "Output Cardinality", "value": "(none)" },
  471.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  472.             { "name": "Filter Factor", "value": "(none)" }      ]
  473.     },
  474.     {
  475.         "id": 34,
  476.         "type": "pact",
  477.         "pact": "Map",
  478.         "contents": "Map at getGraphCollection(CSVDataSource.java:85)",
  479.         "parallelism": "4",
  480.         "predecessors": [
  481.             {"id": 35, "side": "first", "ship_strategy": "Forward", "exchange_mode": "PIPELINED"},
  482.             {"id": 21, "side": "second", "ship_strategy": "Broadcast", "exchange_mode": "BATCH"}
  483.         ],
  484.         "driver_strategy": "Map",
  485.         "global_properties": [
  486.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  487.             { "name": "Partitioning Order", "value": "(none)" },
  488.             { "name": "Uniqueness", "value": "not unique" }
  489.         ],
  490.         "local_properties": [
  491.             { "name": "Order", "value": "(none)" },
  492.             { "name": "Grouping", "value": "not grouped" },
  493.             { "name": "Uniqueness", "value": "not unique" }
  494.         ],
  495.         "estimates": [
  496.             { "name": "Est. Output Size", "value": "(unknown)" },
  497.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  498.         "costs": [
  499.             { "name": "Network", "value": "0.0" },
  500.             { "name": "Disk I/O", "value": "0.0" },
  501.             { "name": "CPU", "value": "0.0" },
  502.             { "name": "Cumulative Network", "value": "0.0" },
  503.             { "name": "Cumulative Disk I/O", "value": "7.57 M" },
  504.             { "name": "Cumulative CPU", "value": "0.0" }
  505.         ],
  506.         "compiler_hints": [
  507.             { "name": "Output Size (bytes)", "value": "(none)" },
  508.             { "name": "Output Cardinality", "value": "(none)" },
  509.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  510.             { "name": "Filter Factor", "value": "(none)" }      ]
  511.     },
  512.     {
  513.         "id": 33,
  514.         "type": "pact",
  515.         "pact": "Map",
  516.         "contents": "Map at fromDataSets(GVEGraphLayoutFactory.java:63)",
  517.         "parallelism": "4",
  518.         "predecessors": [
  519.             {"id": 34, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  520.         ],
  521.         "driver_strategy": "Map",
  522.         "global_properties": [
  523.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  524.             { "name": "Partitioning Order", "value": "(none)" },
  525.             { "name": "Uniqueness", "value": "not unique" }
  526.         ],
  527.         "local_properties": [
  528.             { "name": "Order", "value": "(none)" },
  529.             { "name": "Grouping", "value": "not grouped" },
  530.             { "name": "Uniqueness", "value": "not unique" }
  531.         ],
  532.         "estimates": [
  533.             { "name": "Est. Output Size", "value": "(unknown)" },
  534.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  535.         "costs": [
  536.             { "name": "Network", "value": "0.0" },
  537.             { "name": "Disk I/O", "value": "0.0" },
  538.             { "name": "CPU", "value": "0.0" },
  539.             { "name": "Cumulative Network", "value": "0.0" },
  540.             { "name": "Cumulative Disk I/O", "value": "7.57 M" },
  541.             { "name": "Cumulative CPU", "value": "0.0" }
  542.         ],
  543.         "compiler_hints": [
  544.             { "name": "Output Size (bytes)", "value": "(none)" },
  545.             { "name": "Output Cardinality", "value": "(none)" },
  546.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  547.             { "name": "Filter Factor", "value": "(none)" }      ]
  548.     },
  549.     {
  550.         "id": 32,
  551.         "type": "pact",
  552.         "pact": "Map",
  553.         "contents": "Map at transformGraphProperties(CAPFQuery.java:209)",
  554.         "parallelism": "4",
  555.         "predecessors": [
  556.             {"id": 33, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  557.         ],
  558.         "driver_strategy": "Map",
  559.         "global_properties": [
  560.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  561.             { "name": "Partitioning Order", "value": "(none)" },
  562.             { "name": "Uniqueness", "value": "not unique" }
  563.         ],
  564.         "local_properties": [
  565.             { "name": "Order", "value": "(none)" },
  566.             { "name": "Grouping", "value": "not grouped" },
  567.             { "name": "Uniqueness", "value": "not unique" }
  568.         ],
  569.         "estimates": [
  570.             { "name": "Est. Output Size", "value": "(unknown)" },
  571.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  572.         "costs": [
  573.             { "name": "Network", "value": "0.0" },
  574.             { "name": "Disk I/O", "value": "0.0" },
  575.             { "name": "CPU", "value": "0.0" },
  576.             { "name": "Cumulative Network", "value": "0.0" },
  577.             { "name": "Cumulative Disk I/O", "value": "7.57 M" },
  578.             { "name": "Cumulative CPU", "value": "0.0" }
  579.         ],
  580.         "compiler_hints": [
  581.             { "name": "Output Size (bytes)", "value": "(none)" },
  582.             { "name": "Output Cardinality", "value": "(none)" },
  583.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  584.             { "name": "Filter Factor", "value": "(none)" }      ]
  585.     },
  586.     {
  587.         "id": 31,
  588.         "type": "pact",
  589.         "pact": "Map",
  590.         "contents": "Map at fromDataSets(GVEGraphLayoutFactory.java:63)",
  591.         "parallelism": "4",
  592.         "predecessors": [
  593.             {"id": 32, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  594.         ],
  595.         "driver_strategy": "Map",
  596.         "global_properties": [
  597.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  598.             { "name": "Partitioning Order", "value": "(none)" },
  599.             { "name": "Uniqueness", "value": "not unique" }
  600.         ],
  601.         "local_properties": [
  602.             { "name": "Order", "value": "(none)" },
  603.             { "name": "Grouping", "value": "not grouped" },
  604.             { "name": "Uniqueness", "value": "not unique" }
  605.         ],
  606.         "estimates": [
  607.             { "name": "Est. Output Size", "value": "(unknown)" },
  608.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  609.         "costs": [
  610.             { "name": "Network", "value": "0.0" },
  611.             { "name": "Disk I/O", "value": "0.0" },
  612.             { "name": "CPU", "value": "0.0" },
  613.             { "name": "Cumulative Network", "value": "0.0" },
  614.             { "name": "Cumulative Disk I/O", "value": "7.57 M" },
  615.             { "name": "Cumulative CPU", "value": "0.0" }
  616.         ],
  617.         "compiler_hints": [
  618.             { "name": "Output Size (bytes)", "value": "(none)" },
  619.             { "name": "Output Cardinality", "value": "(none)" },
  620.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  621.             { "name": "Filter Factor", "value": "(none)" }      ]
  622.     },
  623.     {
  624.         "id": 39,
  625.         "type": "pact",
  626.         "pact": "Map",
  627.         "contents": "Map at count(Count.java:43)",
  628.         "parallelism": "4",
  629.         "predecessors": [
  630.             {"id": 16, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  631.         ],
  632.         "driver_strategy": "Map",
  633.         "global_properties": [
  634.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  635.             { "name": "Partitioning Order", "value": "(none)" },
  636.             { "name": "Uniqueness", "value": "not unique" }
  637.         ],
  638.         "local_properties": [
  639.             { "name": "Order", "value": "(none)" },
  640.             { "name": "Grouping", "value": "not grouped" },
  641.             { "name": "Uniqueness", "value": "not unique" }
  642.         ],
  643.         "estimates": [
  644.             { "name": "Est. Output Size", "value": "(unknown)" },
  645.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  646.         "costs": [
  647.             { "name": "Network", "value": "0.0" },
  648.             { "name": "Disk I/O", "value": "0.0" },
  649.             { "name": "CPU", "value": "0.0" },
  650.             { "name": "Cumulative Network", "value": "0.0" },
  651.             { "name": "Cumulative Disk I/O", "value": "2.23 M" },
  652.             { "name": "Cumulative CPU", "value": "0.0" }
  653.         ],
  654.         "compiler_hints": [
  655.             { "name": "Output Size (bytes)", "value": "(none)" },
  656.             { "name": "Output Cardinality", "value": "(none)" },
  657.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  658.             { "name": "Filter Factor", "value": "(none)" }      ]
  659.     },
  660.     {
  661.         "id": 40,
  662.         "type": "source",
  663.         "pact": "Data Source",
  664.         "contents": "at count(Count.java:44) (org.apache.flink.api.java.io.CollectionInputFormat)",
  665.         "parallelism": "1",
  666.         "global_properties": [
  667.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  668.             { "name": "Partitioning Order", "value": "(none)" },
  669.             { "name": "Uniqueness", "value": "not unique" }
  670.         ],
  671.         "local_properties": [
  672.             { "name": "Order", "value": "(none)" },
  673.             { "name": "Grouping", "value": "not grouped" },
  674.             { "name": "Uniqueness", "value": "not unique" }
  675.         ],
  676.         "estimates": [
  677.             { "name": "Est. Output Size", "value": "(unknown)" },
  678.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  679.         "costs": [
  680.             { "name": "Network", "value": "0.0" },
  681.             { "name": "Disk I/O", "value": "0.0" },
  682.             { "name": "CPU", "value": "0.0" },
  683.             { "name": "Cumulative Network", "value": "0.0" },
  684.             { "name": "Cumulative Disk I/O", "value": "0.0" },
  685.             { "name": "Cumulative CPU", "value": "0.0" }
  686.         ],
  687.         "compiler_hints": [
  688.             { "name": "Output Size (bytes)", "value": "(none)" },
  689.             { "name": "Output Cardinality", "value": "(none)" },
  690.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  691.             { "name": "Filter Factor", "value": "(none)" }      ]
  692.     },
  693.     {
  694.         "id": 38,
  695.         "type": "pact",
  696.         "pact": "Union",
  697.         "contents": "",
  698.         "parallelism": "1",
  699.         "predecessors": [
  700.             {"id": 39, "side": "first", "ship_strategy": "Redistribute", "exchange_mode": "PIPELINED"},
  701.             {"id": 40, "side": "second", "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  702.         ],
  703.         "global_properties": [
  704.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  705.             { "name": "Partitioning Order", "value": "(none)" },
  706.             { "name": "Uniqueness", "value": "not unique" }
  707.         ],
  708.         "local_properties": [
  709.             { "name": "Order", "value": "(none)" },
  710.             { "name": "Grouping", "value": "not grouped" },
  711.             { "name": "Uniqueness", "value": "not unique" }
  712.         ],
  713.         "estimates": [
  714.             { "name": "Est. Output Size", "value": "(unknown)" },
  715.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  716.         "costs": [
  717.             { "name": "Network", "value": "0.0" },
  718.             { "name": "Disk I/O", "value": "0.0" },
  719.             { "name": "CPU", "value": "0.0" },
  720.             { "name": "Cumulative Network", "value": "(unknown)" },
  721.             { "name": "Cumulative Disk I/O", "value": "2.23 M" },
  722.             { "name": "Cumulative CPU", "value": "0.0" }
  723.         ],
  724.         "compiler_hints": [
  725.             { "name": "Output Size (bytes)", "value": "(none)" },
  726.             { "name": "Output Cardinality", "value": "(none)" },
  727.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  728.             { "name": "Filter Factor", "value": "(none)" }      ]
  729.     },
  730.     {
  731.         "id": 37,
  732.         "type": "pact",
  733.         "pact": "GroupReduce",
  734.         "contents": "SUM(0), at sum(DataSet.java:351",
  735.         "parallelism": "1",
  736.         "predecessors": [
  737.             {"id": 38, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  738.         ],
  739.         "driver_strategy": "Group Reduce All",
  740.         "global_properties": [
  741.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  742.             { "name": "Partitioning Order", "value": "(none)" },
  743.             { "name": "Uniqueness", "value": "not unique" }
  744.         ],
  745.         "local_properties": [
  746.             { "name": "Order", "value": "(none)" },
  747.             { "name": "Grouping", "value": "not grouped" },
  748.             { "name": "Uniqueness", "value": "not unique" }
  749.         ],
  750.         "estimates": [
  751.             { "name": "Est. Output Size", "value": "(unknown)" },
  752.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  753.         "costs": [
  754.             { "name": "Network", "value": "0.0" },
  755.             { "name": "Disk I/O", "value": "0.0" },
  756.             { "name": "CPU", "value": "0.0" },
  757.             { "name": "Cumulative Network", "value": "(unknown)" },
  758.             { "name": "Cumulative Disk I/O", "value": "2.23 M" },
  759.             { "name": "Cumulative CPU", "value": "0.0" }
  760.         ],
  761.         "compiler_hints": [
  762.             { "name": "Output Size (bytes)", "value": "(none)" },
  763.             { "name": "Output Cardinality", "value": "(none)" },
  764.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  765.             { "name": "Filter Factor", "value": "(none)" }      ]
  766.     },
  767.     {
  768.         "id": 36,
  769.         "type": "pact",
  770.         "pact": "Map",
  771.         "contents": "Map at count(Count.java:46)",
  772.         "parallelism": "4",
  773.         "predecessors": [
  774.             {"id": 37, "ship_strategy": "Redistribute", "exchange_mode": "PIPELINED"}
  775.         ],
  776.         "driver_strategy": "Map",
  777.         "global_properties": [
  778.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  779.             { "name": "Partitioning Order", "value": "(none)" },
  780.             { "name": "Uniqueness", "value": "not unique" }
  781.         ],
  782.         "local_properties": [
  783.             { "name": "Order", "value": "(none)" },
  784.             { "name": "Grouping", "value": "not grouped" },
  785.             { "name": "Uniqueness", "value": "not unique" }
  786.         ],
  787.         "estimates": [
  788.             { "name": "Est. Output Size", "value": "(unknown)" },
  789.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  790.         "costs": [
  791.             { "name": "Network", "value": "(unknown)" },
  792.             { "name": "Disk I/O", "value": "0.0" },
  793.             { "name": "CPU", "value": "0.0" },
  794.             { "name": "Cumulative Network", "value": "(unknown)" },
  795.             { "name": "Cumulative Disk I/O", "value": "2.23 M" },
  796.             { "name": "Cumulative CPU", "value": "0.0" }
  797.         ],
  798.         "compiler_hints": [
  799.             { "name": "Output Size (bytes)", "value": "(none)" },
  800.             { "name": "Output Cardinality", "value": "(none)" },
  801.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  802.             { "name": "Filter Factor", "value": "(none)" }      ]
  803.     },
  804.     {
  805.         "id": 30,
  806.         "type": "pact",
  807.         "pact": "Map",
  808.         "contents": "Map at createRelationshipTables(CAPFQuery.java:336)",
  809.         "parallelism": "4",
  810.         "predecessors": [
  811.             {"id": 31, "side": "first", "ship_strategy": "Forward", "exchange_mode": "PIPELINED"},
  812.             {"id": 36, "side": "second", "ship_strategy": "Broadcast", "exchange_mode": "PIPELINED"}
  813.         ],
  814.         "driver_strategy": "Map",
  815.         "global_properties": [
  816.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  817.             { "name": "Partitioning Order", "value": "(none)" },
  818.             { "name": "Uniqueness", "value": "not unique" }
  819.         ],
  820.         "local_properties": [
  821.             { "name": "Order", "value": "(none)" },
  822.             { "name": "Grouping", "value": "not grouped" },
  823.             { "name": "Uniqueness", "value": "not unique" }
  824.         ],
  825.         "estimates": [
  826.             { "name": "Est. Output Size", "value": "(unknown)" },
  827.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  828.         "costs": [
  829.             { "name": "Network", "value": "0.0" },
  830.             { "name": "Disk I/O", "value": "0.0" },
  831.             { "name": "CPU", "value": "0.0" },
  832.             { "name": "Cumulative Network", "value": "(unknown)" },
  833.             { "name": "Cumulative Disk I/O", "value": "12.02 M" },
  834.             { "name": "Cumulative CPU", "value": "0.0" }
  835.         ],
  836.         "compiler_hints": [
  837.             { "name": "Output Size (bytes)", "value": "(none)" },
  838.             { "name": "Output Cardinality", "value": "(none)" },
  839.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  840.             { "name": "Filter Factor", "value": "(none)" }      ]
  841.     },
  842.     {
  843.         "id": 29,
  844.         "type": "pact",
  845.         "pact": "Map",
  846.         "contents": "Map at createRelationshipTables(CAPFQuery.java:341)",
  847.         "parallelism": "4",
  848.         "predecessors": [
  849.             {"id": 30, "ship_strategy": "Hash Partition on [5]", "exchange_mode": "PIPELINED"}
  850.         ],
  851.         "driver_strategy": "Map",
  852.         "global_properties": [
  853.             { "name": "Partitioning", "value": "HASH_PARTITIONED" },
  854.             { "name": "Partitioned on", "value": "[1]" },
  855.             { "name": "Partitioning Order", "value": "(none)" },
  856.             { "name": "Uniqueness", "value": "not unique" }
  857.         ],
  858.         "local_properties": [
  859.             { "name": "Order", "value": "(none)" },
  860.             { "name": "Grouping", "value": "not grouped" },
  861.             { "name": "Uniqueness", "value": "not unique" }
  862.         ],
  863.         "estimates": [
  864.             { "name": "Est. Output Size", "value": "(unknown)" },
  865.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  866.         "costs": [
  867.             { "name": "Network", "value": "(unknown)" },
  868.             { "name": "Disk I/O", "value": "0.0" },
  869.             { "name": "CPU", "value": "0.0" },
  870.             { "name": "Cumulative Network", "value": "(unknown)" },
  871.             { "name": "Cumulative Disk I/O", "value": "12.02 M" },
  872.             { "name": "Cumulative CPU", "value": "0.0" }
  873.         ],
  874.         "compiler_hints": [
  875.             { "name": "Output Size (bytes)", "value": "(none)" },
  876.             { "name": "Output Cardinality", "value": "(none)" },
  877.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  878.             { "name": "Filter Factor", "value": "(none)" }      ]
  879.     },
  880.     {
  881.         "id": 41,
  882.         "type": "pact",
  883.         "pact": "Map",
  884.         "contents": "Key Extractor",
  885.         "parallelism": "4",
  886.         "predecessors": [
  887.             {"id": 15, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  888.         ],
  889.         "driver_strategy": "Map",
  890.         "global_properties": [
  891.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  892.             { "name": "Partitioning Order", "value": "(none)" },
  893.             { "name": "Uniqueness", "value": "not unique" }
  894.         ],
  895.         "local_properties": [
  896.             { "name": "Order", "value": "(none)" },
  897.             { "name": "Grouping", "value": "not grouped" },
  898.             { "name": "Uniqueness", "value": "not unique" }
  899.         ],
  900.         "estimates": [
  901.             { "name": "Est. Output Size", "value": "(unknown)" },
  902.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  903.         "costs": [
  904.             { "name": "Network", "value": "0.0" },
  905.             { "name": "Disk I/O", "value": "0.0" },
  906.             { "name": "CPU", "value": "0.0" },
  907.             { "name": "Cumulative Network", "value": "0.0" },
  908.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  909.             { "name": "Cumulative CPU", "value": "0.0" }
  910.         ],
  911.         "compiler_hints": [
  912.             { "name": "Output Size (bytes)", "value": "(none)" },
  913.             { "name": "Output Cardinality", "value": "(none)" },
  914.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  915.             { "name": "Filter Factor", "value": "(none)" }      ]
  916.     },
  917.     {
  918.         "id": 28,
  919.         "type": "pact",
  920.         "pact": "Join",
  921.         "contents": "Join at createRelationshipTables(CAPFQuery.java:343)",
  922.         "parallelism": "4",
  923.         "predecessors": [
  924.             {"id": 29, "side": "first", "ship_strategy": "Forward", "exchange_mode": "PIPELINED"},
  925.             {"id": 41, "side": "second", "ship_strategy": "Hash Partition on [0]", "exchange_mode": "PIPELINED"}
  926.         ],
  927.         "driver_strategy": "Hybrid Hash (build: Key Extractor (id: 41))",
  928.         "global_properties": [
  929.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  930.             { "name": "Partitioning Order", "value": "(none)" },
  931.             { "name": "Uniqueness", "value": "not unique" }
  932.         ],
  933.         "local_properties": [
  934.             { "name": "Order", "value": "(none)" },
  935.             { "name": "Grouping", "value": "not grouped" },
  936.             { "name": "Uniqueness", "value": "not unique" }
  937.         ],
  938.         "estimates": [
  939.             { "name": "Est. Output Size", "value": "(unknown)" },
  940.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  941.         "costs": [
  942.             { "name": "Network", "value": "(unknown)" },
  943.             { "name": "Disk I/O", "value": "(unknown)" },
  944.             { "name": "CPU", "value": "(unknown)" },
  945.             { "name": "Cumulative Network", "value": "(unknown)" },
  946.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  947.             { "name": "Cumulative CPU", "value": "(unknown)" }
  948.         ],
  949.         "compiler_hints": [
  950.             { "name": "Output Size (bytes)", "value": "(none)" },
  951.             { "name": "Output Cardinality", "value": "(none)" },
  952.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  953.             { "name": "Filter Factor", "value": "(none)" }      ]
  954.     },
  955.     {
  956.         "id": 42,
  957.         "type": "pact",
  958.         "pact": "Map",
  959.         "contents": "Key Extractor",
  960.         "parallelism": "4",
  961.         "predecessors": [
  962.             {"id": 15, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  963.         ],
  964.         "driver_strategy": "Map",
  965.         "global_properties": [
  966.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  967.             { "name": "Partitioning Order", "value": "(none)" },
  968.             { "name": "Uniqueness", "value": "not unique" }
  969.         ],
  970.         "local_properties": [
  971.             { "name": "Order", "value": "(none)" },
  972.             { "name": "Grouping", "value": "not grouped" },
  973.             { "name": "Uniqueness", "value": "not unique" }
  974.         ],
  975.         "estimates": [
  976.             { "name": "Est. Output Size", "value": "(unknown)" },
  977.             { "name": "Est. Cardinality", "value": "35.35 K" }      ],
  978.         "costs": [
  979.             { "name": "Network", "value": "0.0" },
  980.             { "name": "Disk I/O", "value": "0.0" },
  981.             { "name": "CPU", "value": "0.0" },
  982.             { "name": "Cumulative Network", "value": "0.0" },
  983.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  984.             { "name": "Cumulative CPU", "value": "0.0" }
  985.         ],
  986.         "compiler_hints": [
  987.             { "name": "Output Size (bytes)", "value": "(none)" },
  988.             { "name": "Output Cardinality", "value": "(none)" },
  989.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  990.             { "name": "Filter Factor", "value": "(none)" }      ]
  991.     },
  992.     {
  993.         "id": 27,
  994.         "type": "pact",
  995.         "pact": "Join",
  996.         "contents": "Join at createRelationshipTables(CAPFQuery.java:345)",
  997.         "parallelism": "4",
  998.         "predecessors": [
  999.             {"id": 28, "side": "first", "ship_strategy": "Hash Partition on [2]", "exchange_mode": "PIPELINED"},
  1000.             {"id": 42, "side": "second", "ship_strategy": "Hash Partition on [0]", "exchange_mode": "PIPELINED"}
  1001.         ],
  1002.         "driver_strategy": "Hybrid Hash (build: Key Extractor (id: 42))",
  1003.         "global_properties": [
  1004.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1005.             { "name": "Partitioning Order", "value": "(none)" },
  1006.             { "name": "Uniqueness", "value": "not unique" }
  1007.         ],
  1008.         "local_properties": [
  1009.             { "name": "Order", "value": "(none)" },
  1010.             { "name": "Grouping", "value": "not grouped" },
  1011.             { "name": "Uniqueness", "value": "not unique" }
  1012.         ],
  1013.         "estimates": [
  1014.             { "name": "Est. Output Size", "value": "(unknown)" },
  1015.             { "name": "Est. Cardinality", "value": "66.89 K" }      ],
  1016.         "costs": [
  1017.             { "name": "Network", "value": "(unknown)" },
  1018.             { "name": "Disk I/O", "value": "(unknown)" },
  1019.             { "name": "CPU", "value": "(unknown)" },
  1020.             { "name": "Cumulative Network", "value": "(unknown)" },
  1021.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1022.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1023.         ],
  1024.         "compiler_hints": [
  1025.             { "name": "Output Size (bytes)", "value": "(none)" },
  1026.             { "name": "Output Cardinality", "value": "(none)" },
  1027.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1028.             { "name": "Filter Factor", "value": "(none)" }      ]
  1029.     },
  1030.     {
  1031.         "id": 26,
  1032.         "type": "pact",
  1033.         "pact": "Filter",
  1034.         "contents": "Filter at createRelationshipTables(CAPFQuery.java:376)",
  1035.         "parallelism": "4",
  1036.         "predecessors": [
  1037.             {"id": 27, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  1038.         ],
  1039.         "driver_strategy": "FlatMap",
  1040.         "global_properties": [
  1041.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1042.             { "name": "Partitioning Order", "value": "(none)" },
  1043.             { "name": "Uniqueness", "value": "not unique" }
  1044.         ],
  1045.         "local_properties": [
  1046.             { "name": "Order", "value": "(none)" },
  1047.             { "name": "Grouping", "value": "not grouped" },
  1048.             { "name": "Uniqueness", "value": "not unique" }
  1049.         ],
  1050.         "estimates": [
  1051.             { "name": "Est. Output Size", "value": "0.0" },
  1052.             { "name": "Est. Cardinality", "value": "33.44 K" }      ],
  1053.         "costs": [
  1054.             { "name": "Network", "value": "0.0" },
  1055.             { "name": "Disk I/O", "value": "0.0" },
  1056.             { "name": "CPU", "value": "0.0" },
  1057.             { "name": "Cumulative Network", "value": "(unknown)" },
  1058.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1059.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1060.         ],
  1061.         "compiler_hints": [
  1062.             { "name": "Output Size (bytes)", "value": "(none)" },
  1063.             { "name": "Output Cardinality", "value": "(none)" },
  1064.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1065.             { "name": "Filter Factor", "value": "(none)" }      ]
  1066.     },
  1067.     {
  1068.         "id": 25,
  1069.         "type": "pact",
  1070.         "pact": "Map",
  1071.         "contents": "Map at createRelationshipTables(CAPFQuery.java:381)",
  1072.         "parallelism": "4",
  1073.         "predecessors": [
  1074.             {"id": 26, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1075.         ],
  1076.         "driver_strategy": "Map",
  1077.         "global_properties": [
  1078.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1079.             { "name": "Partitioning Order", "value": "(none)" },
  1080.             { "name": "Uniqueness", "value": "not unique" }
  1081.         ],
  1082.         "local_properties": [
  1083.             { "name": "Order", "value": "(none)" },
  1084.             { "name": "Grouping", "value": "not grouped" },
  1085.             { "name": "Uniqueness", "value": "not unique" }
  1086.         ],
  1087.         "estimates": [
  1088.             { "name": "Est. Output Size", "value": "(unknown)" },
  1089.             { "name": "Est. Cardinality", "value": "33.44 K" }      ],
  1090.         "costs": [
  1091.             { "name": "Network", "value": "0.0" },
  1092.             { "name": "Disk I/O", "value": "0.0" },
  1093.             { "name": "CPU", "value": "0.0" },
  1094.             { "name": "Cumulative Network", "value": "(unknown)" },
  1095.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1096.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1097.         ],
  1098.         "compiler_hints": [
  1099.             { "name": "Output Size (bytes)", "value": "(none)" },
  1100.             { "name": "Output Cardinality", "value": "(none)" },
  1101.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1102.             { "name": "Filter Factor", "value": "(none)" }      ]
  1103.     },
  1104.     {
  1105.         "id": 24,
  1106.         "type": "pact",
  1107.         "pact": "FlatMap",
  1108.         "contents": "select: (f0 AS edge_id, f1 AS start_node, f2 AS end_node)",
  1109.         "parallelism": "4",
  1110.         "predecessors": [
  1111.             {"id": 25, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  1112.         ],
  1113.         "driver_strategy": "FlatMap",
  1114.         "global_properties": [
  1115.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1116.             { "name": "Partitioning Order", "value": "(none)" },
  1117.             { "name": "Uniqueness", "value": "not unique" }
  1118.         ],
  1119.         "local_properties": [
  1120.             { "name": "Order", "value": "(none)" },
  1121.             { "name": "Grouping", "value": "not grouped" },
  1122.             { "name": "Uniqueness", "value": "not unique" }
  1123.         ],
  1124.         "estimates": [
  1125.             { "name": "Est. Output Size", "value": "(unknown)" },
  1126.             { "name": "Est. Cardinality", "value": "167.21 K" }     ],
  1127.         "costs": [
  1128.             { "name": "Network", "value": "0.0" },
  1129.             { "name": "Disk I/O", "value": "0.0" },
  1130.             { "name": "CPU", "value": "0.0" },
  1131.             { "name": "Cumulative Network", "value": "(unknown)" },
  1132.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1133.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1134.         ],
  1135.         "compiler_hints": [
  1136.             { "name": "Output Size (bytes)", "value": "(none)" },
  1137.             { "name": "Output Cardinality", "value": "(none)" },
  1138.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1139.             { "name": "Filter Factor", "value": "(none)" }      ]
  1140.     },
  1141.     {
  1142.         "id": 11,
  1143.         "type": "pact",
  1144.         "pact": "Join",
  1145.         "contents": "where: (=(__NODE__post__session_tmp1, start_node)), join: (__NODE__post__session_tmp1, edge_id, start_node, end_node)",
  1146.         "parallelism": "4",
  1147.         "predecessors": [
  1148.             {"id": 12, "side": "first", "ship_strategy": "Hash Partition on [0]", "exchange_mode": "PIPELINED"},
  1149.             {"id": 24, "side": "second", "ship_strategy": "Hash Partition on [1]", "exchange_mode": "PIPELINED"}
  1150.         ],
  1151.         "driver_strategy": "Hybrid Hash (build: select: (f0 AS edge_id, f1 AS start_node, f2 AS end_node) (id: 24))",
  1152.         "global_properties": [
  1153.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1154.             { "name": "Partitioning Order", "value": "(none)" },
  1155.             { "name": "Uniqueness", "value": "not unique" }
  1156.         ],
  1157.         "local_properties": [
  1158.             { "name": "Order", "value": "(none)" },
  1159.             { "name": "Grouping", "value": "not grouped" },
  1160.             { "name": "Uniqueness", "value": "not unique" }
  1161.         ],
  1162.         "estimates": [
  1163.             { "name": "Est. Output Size", "value": "(unknown)" },
  1164.             { "name": "Est. Cardinality", "value": "167.21 K" }     ],
  1165.         "costs": [
  1166.             { "name": "Network", "value": "(unknown)" },
  1167.             { "name": "Disk I/O", "value": "(unknown)" },
  1168.             { "name": "CPU", "value": "(unknown)" },
  1169.             { "name": "Cumulative Network", "value": "(unknown)" },
  1170.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1171.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1172.         ],
  1173.         "compiler_hints": [
  1174.             { "name": "Output Size (bytes)", "value": "(none)" },
  1175.             { "name": "Output Cardinality", "value": "(none)" },
  1176.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1177.             { "name": "Filter Factor", "value": "(none)" }      ]
  1178.     },
  1179.     {
  1180.         "id": 10,
  1181.         "type": "pact",
  1182.         "pact": "FlatMap",
  1183.         "contents": "select: (__NODE__post__session_tmp1, __RELATIONSHIP__hasCreator__session_tmp1, target___RELATIONSHIP__hasCreator__session_tmp1___NODE)",
  1184.         "parallelism": "4",
  1185.         "predecessors": [
  1186.             {"id": 11, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1187.         ],
  1188.         "driver_strategy": "FlatMap",
  1189.         "global_properties": [
  1190.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1191.             { "name": "Partitioning Order", "value": "(none)" },
  1192.             { "name": "Uniqueness", "value": "not unique" }
  1193.         ],
  1194.         "local_properties": [
  1195.             { "name": "Order", "value": "(none)" },
  1196.             { "name": "Grouping", "value": "not grouped" },
  1197.             { "name": "Uniqueness", "value": "not unique" }
  1198.         ],
  1199.         "estimates": [
  1200.             { "name": "Est. Output Size", "value": "(unknown)" },
  1201.             { "name": "Est. Cardinality", "value": "836.05 K" }     ],
  1202.         "costs": [
  1203.             { "name": "Network", "value": "0.0" },
  1204.             { "name": "Disk I/O", "value": "0.0" },
  1205.             { "name": "CPU", "value": "0.0" },
  1206.             { "name": "Cumulative Network", "value": "(unknown)" },
  1207.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1208.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1209.         ],
  1210.         "compiler_hints": [
  1211.             { "name": "Output Size (bytes)", "value": "(none)" },
  1212.             { "name": "Output Cardinality", "value": "(none)" },
  1213.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1214.             { "name": "Filter Factor", "value": "(none)" }      ]
  1215.     },
  1216.     {
  1217.         "id": 49,
  1218.         "type": "pact",
  1219.         "pact": "Filter",
  1220.         "contents": "Filter at createNodeTables(CAPFQuery.java:292)",
  1221.         "parallelism": "4",
  1222.         "predecessors": [
  1223.             {"id": 15, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  1224.         ],
  1225.         "driver_strategy": "FlatMap",
  1226.         "global_properties": [
  1227.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1228.             { "name": "Partitioning Order", "value": "(none)" },
  1229.             { "name": "Uniqueness", "value": "not unique" }
  1230.         ],
  1231.         "local_properties": [
  1232.             { "name": "Order", "value": "(none)" },
  1233.             { "name": "Grouping", "value": "not grouped" },
  1234.             { "name": "Uniqueness", "value": "not unique" }
  1235.         ],
  1236.         "estimates": [
  1237.             { "name": "Est. Output Size", "value": "0.0" },
  1238.             { "name": "Est. Cardinality", "value": "17.68 K" }      ],
  1239.         "costs": [
  1240.             { "name": "Network", "value": "0.0" },
  1241.             { "name": "Disk I/O", "value": "0.0" },
  1242.             { "name": "CPU", "value": "0.0" },
  1243.             { "name": "Cumulative Network", "value": "0.0" },
  1244.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  1245.             { "name": "Cumulative CPU", "value": "0.0" }
  1246.         ],
  1247.         "compiler_hints": [
  1248.             { "name": "Output Size (bytes)", "value": "(none)" },
  1249.             { "name": "Output Cardinality", "value": "(none)" },
  1250.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1251.             { "name": "Filter Factor", "value": "(none)" }      ]
  1252.     },
  1253.     {
  1254.         "id": 48,
  1255.         "type": "pact",
  1256.         "pact": "Map",
  1257.         "contents": "Map at createNodeTables(CAPFQuery.java:297)",
  1258.         "parallelism": "4",
  1259.         "predecessors": [
  1260.             {"id": 49, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1261.         ],
  1262.         "driver_strategy": "Map",
  1263.         "global_properties": [
  1264.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1265.             { "name": "Partitioning Order", "value": "(none)" },
  1266.             { "name": "Uniqueness", "value": "not unique" }
  1267.         ],
  1268.         "local_properties": [
  1269.             { "name": "Order", "value": "(none)" },
  1270.             { "name": "Grouping", "value": "not grouped" },
  1271.             { "name": "Uniqueness", "value": "not unique" }
  1272.         ],
  1273.         "estimates": [
  1274.             { "name": "Est. Output Size", "value": "(unknown)" },
  1275.             { "name": "Est. Cardinality", "value": "17.68 K" }      ],
  1276.         "costs": [
  1277.             { "name": "Network", "value": "0.0" },
  1278.             { "name": "Disk I/O", "value": "0.0" },
  1279.             { "name": "CPU", "value": "0.0" },
  1280.             { "name": "Cumulative Network", "value": "0.0" },
  1281.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  1282.             { "name": "Cumulative CPU", "value": "0.0" }
  1283.         ],
  1284.         "compiler_hints": [
  1285.             { "name": "Output Size (bytes)", "value": "(none)" },
  1286.             { "name": "Output Cardinality", "value": "(none)" },
  1287.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1288.             { "name": "Filter Factor", "value": "(none)" }      ]
  1289.     },
  1290.     {
  1291.         "id": 47,
  1292.         "type": "pact",
  1293.         "pact": "FlatMap",
  1294.         "contents": "select: (f0 AS node_id)",
  1295.         "parallelism": "4",
  1296.         "predecessors": [
  1297.             {"id": 48, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1298.         ],
  1299.         "driver_strategy": "FlatMap",
  1300.         "global_properties": [
  1301.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1302.             { "name": "Partitioning Order", "value": "(none)" },
  1303.             { "name": "Uniqueness", "value": "not unique" }
  1304.         ],
  1305.         "local_properties": [
  1306.             { "name": "Order", "value": "(none)" },
  1307.             { "name": "Grouping", "value": "not grouped" },
  1308.             { "name": "Uniqueness", "value": "not unique" }
  1309.         ],
  1310.         "estimates": [
  1311.             { "name": "Est. Output Size", "value": "(unknown)" },
  1312.             { "name": "Est. Cardinality", "value": "88.38 K" }      ],
  1313.         "costs": [
  1314.             { "name": "Network", "value": "0.0" },
  1315.             { "name": "Disk I/O", "value": "0.0" },
  1316.             { "name": "CPU", "value": "0.0" },
  1317.             { "name": "Cumulative Network", "value": "0.0" },
  1318.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  1319.             { "name": "Cumulative CPU", "value": "0.0" }
  1320.         ],
  1321.         "compiler_hints": [
  1322.             { "name": "Output Size (bytes)", "value": "(none)" },
  1323.             { "name": "Output Cardinality", "value": "(none)" },
  1324.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1325.             { "name": "Filter Factor", "value": "(none)" }      ]
  1326.     },
  1327.     {
  1328.         "id": 50,
  1329.         "type": "pact",
  1330.         "pact": "FlatMap",
  1331.         "contents": "select: (f0 AS edge_id, f1 AS start_node, f2 AS end_node)",
  1332.         "parallelism": "4",
  1333.         "predecessors": [
  1334.             {"id": 25, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  1335.         ],
  1336.         "driver_strategy": "FlatMap",
  1337.         "global_properties": [
  1338.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1339.             { "name": "Partitioning Order", "value": "(none)" },
  1340.             { "name": "Uniqueness", "value": "not unique" }
  1341.         ],
  1342.         "local_properties": [
  1343.             { "name": "Order", "value": "(none)" },
  1344.             { "name": "Grouping", "value": "not grouped" },
  1345.             { "name": "Uniqueness", "value": "not unique" }
  1346.         ],
  1347.         "estimates": [
  1348.             { "name": "Est. Output Size", "value": "(unknown)" },
  1349.             { "name": "Est. Cardinality", "value": "167.21 K" }     ],
  1350.         "costs": [
  1351.             { "name": "Network", "value": "0.0" },
  1352.             { "name": "Disk I/O", "value": "0.0" },
  1353.             { "name": "CPU", "value": "0.0" },
  1354.             { "name": "Cumulative Network", "value": "(unknown)" },
  1355.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1356.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1357.         ],
  1358.         "compiler_hints": [
  1359.             { "name": "Output Size (bytes)", "value": "(none)" },
  1360.             { "name": "Output Cardinality", "value": "(none)" },
  1361.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1362.             { "name": "Filter Factor", "value": "(none)" }      ]
  1363.     },
  1364.     {
  1365.         "id": 46,
  1366.         "type": "pact",
  1367.         "pact": "Join",
  1368.         "contents": "where: (=(node_id, start_node)), join: (node_id, edge_id, start_node, end_node)",
  1369.         "parallelism": "4",
  1370.         "predecessors": [
  1371.             {"id": 47, "side": "first", "ship_strategy": "Hash Partition on [0]", "exchange_mode": "PIPELINED"},
  1372.             {"id": 50, "side": "second", "ship_strategy": "Hash Partition on [1]", "exchange_mode": "PIPELINED"}
  1373.         ],
  1374.         "driver_strategy": "Hybrid Hash (build: select: (f0 AS edge_id, f1 AS start_node, f2 AS end_node) (id: 50))",
  1375.         "global_properties": [
  1376.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1377.             { "name": "Partitioning Order", "value": "(none)" },
  1378.             { "name": "Uniqueness", "value": "not unique" }
  1379.         ],
  1380.         "local_properties": [
  1381.             { "name": "Order", "value": "(none)" },
  1382.             { "name": "Grouping", "value": "not grouped" },
  1383.             { "name": "Uniqueness", "value": "not unique" }
  1384.         ],
  1385.         "estimates": [
  1386.             { "name": "Est. Output Size", "value": "(unknown)" },
  1387.             { "name": "Est. Cardinality", "value": "167.21 K" }     ],
  1388.         "costs": [
  1389.             { "name": "Network", "value": "(unknown)" },
  1390.             { "name": "Disk I/O", "value": "(unknown)" },
  1391.             { "name": "CPU", "value": "(unknown)" },
  1392.             { "name": "Cumulative Network", "value": "(unknown)" },
  1393.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1394.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1395.         ],
  1396.         "compiler_hints": [
  1397.             { "name": "Output Size (bytes)", "value": "(none)" },
  1398.             { "name": "Output Cardinality", "value": "(none)" },
  1399.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1400.             { "name": "Filter Factor", "value": "(none)" }      ]
  1401.     },
  1402.     {
  1403.         "id": 45,
  1404.         "type": "pact",
  1405.         "pact": "FlatMap",
  1406.         "contents": "select: (node_id AS __NODE__comment__session_tmp1, edge_id AS __RELATIONSHIP__hasCreator__session_tmp1, end_node AS target___RELATIONSHIP__hasCreator__session_tmp1___NODE)",
  1407.         "parallelism": "4",
  1408.         "predecessors": [
  1409.             {"id": 46, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1410.         ],
  1411.         "driver_strategy": "FlatMap",
  1412.         "global_properties": [
  1413.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1414.             { "name": "Partitioning Order", "value": "(none)" },
  1415.             { "name": "Uniqueness", "value": "not unique" }
  1416.         ],
  1417.         "local_properties": [
  1418.             { "name": "Order", "value": "(none)" },
  1419.             { "name": "Grouping", "value": "not grouped" },
  1420.             { "name": "Uniqueness", "value": "not unique" }
  1421.         ],
  1422.         "estimates": [
  1423.             { "name": "Est. Output Size", "value": "(unknown)" },
  1424.             { "name": "Est. Cardinality", "value": "836.05 K" }     ],
  1425.         "costs": [
  1426.             { "name": "Network", "value": "0.0" },
  1427.             { "name": "Disk I/O", "value": "0.0" },
  1428.             { "name": "CPU", "value": "0.0" },
  1429.             { "name": "Cumulative Network", "value": "(unknown)" },
  1430.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1431.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1432.         ],
  1433.         "compiler_hints": [
  1434.             { "name": "Output Size (bytes)", "value": "(none)" },
  1435.             { "name": "Output Cardinality", "value": "(none)" },
  1436.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1437.             { "name": "Filter Factor", "value": "(none)" }      ]
  1438.     },
  1439.     {
  1440.         "id": 53,
  1441.         "type": "pact",
  1442.         "pact": "Filter",
  1443.         "contents": "Filter at createNodeTables(CAPFQuery.java:292)",
  1444.         "parallelism": "4",
  1445.         "predecessors": [
  1446.             {"id": 15, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  1447.         ],
  1448.         "driver_strategy": "FlatMap",
  1449.         "global_properties": [
  1450.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1451.             { "name": "Partitioning Order", "value": "(none)" },
  1452.             { "name": "Uniqueness", "value": "not unique" }
  1453.         ],
  1454.         "local_properties": [
  1455.             { "name": "Order", "value": "(none)" },
  1456.             { "name": "Grouping", "value": "not grouped" },
  1457.             { "name": "Uniqueness", "value": "not unique" }
  1458.         ],
  1459.         "estimates": [
  1460.             { "name": "Est. Output Size", "value": "0.0" },
  1461.             { "name": "Est. Cardinality", "value": "17.68 K" }      ],
  1462.         "costs": [
  1463.             { "name": "Network", "value": "0.0" },
  1464.             { "name": "Disk I/O", "value": "0.0" },
  1465.             { "name": "CPU", "value": "0.0" },
  1466.             { "name": "Cumulative Network", "value": "0.0" },
  1467.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  1468.             { "name": "Cumulative CPU", "value": "0.0" }
  1469.         ],
  1470.         "compiler_hints": [
  1471.             { "name": "Output Size (bytes)", "value": "(none)" },
  1472.             { "name": "Output Cardinality", "value": "(none)" },
  1473.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1474.             { "name": "Filter Factor", "value": "(none)" }      ]
  1475.     },
  1476.     {
  1477.         "id": 52,
  1478.         "type": "pact",
  1479.         "pact": "Map",
  1480.         "contents": "Map at createNodeTables(CAPFQuery.java:297)",
  1481.         "parallelism": "4",
  1482.         "predecessors": [
  1483.             {"id": 53, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1484.         ],
  1485.         "driver_strategy": "Map",
  1486.         "global_properties": [
  1487.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1488.             { "name": "Partitioning Order", "value": "(none)" },
  1489.             { "name": "Uniqueness", "value": "not unique" }
  1490.         ],
  1491.         "local_properties": [
  1492.             { "name": "Order", "value": "(none)" },
  1493.             { "name": "Grouping", "value": "not grouped" },
  1494.             { "name": "Uniqueness", "value": "not unique" }
  1495.         ],
  1496.         "estimates": [
  1497.             { "name": "Est. Output Size", "value": "(unknown)" },
  1498.             { "name": "Est. Cardinality", "value": "17.68 K" }      ],
  1499.         "costs": [
  1500.             { "name": "Network", "value": "0.0" },
  1501.             { "name": "Disk I/O", "value": "0.0" },
  1502.             { "name": "CPU", "value": "0.0" },
  1503.             { "name": "Cumulative Network", "value": "0.0" },
  1504.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  1505.             { "name": "Cumulative CPU", "value": "0.0" }
  1506.         ],
  1507.         "compiler_hints": [
  1508.             { "name": "Output Size (bytes)", "value": "(none)" },
  1509.             { "name": "Output Cardinality", "value": "(none)" },
  1510.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1511.             { "name": "Filter Factor", "value": "(none)" }      ]
  1512.     },
  1513.     {
  1514.         "id": 51,
  1515.         "type": "pact",
  1516.         "pact": "FlatMap",
  1517.         "contents": "where: (=(f1, _UTF-16LE'Joseph')), select: (f0 AS __NODE__person__session_tmp1)",
  1518.         "parallelism": "4",
  1519.         "predecessors": [
  1520.             {"id": 52, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1521.         ],
  1522.         "driver_strategy": "FlatMap",
  1523.         "global_properties": [
  1524.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1525.             { "name": "Partitioning Order", "value": "(none)" },
  1526.             { "name": "Uniqueness", "value": "not unique" }
  1527.         ],
  1528.         "local_properties": [
  1529.             { "name": "Order", "value": "(none)" },
  1530.             { "name": "Grouping", "value": "not grouped" },
  1531.             { "name": "Uniqueness", "value": "not unique" }
  1532.         ],
  1533.         "estimates": [
  1534.             { "name": "Est. Output Size", "value": "(unknown)" },
  1535.             { "name": "Est. Cardinality", "value": "88.38 K" }      ],
  1536.         "costs": [
  1537.             { "name": "Network", "value": "0.0" },
  1538.             { "name": "Disk I/O", "value": "0.0" },
  1539.             { "name": "CPU", "value": "0.0" },
  1540.             { "name": "Cumulative Network", "value": "0.0" },
  1541.             { "name": "Cumulative Disk I/O", "value": "370.95 K" },
  1542.             { "name": "Cumulative CPU", "value": "0.0" }
  1543.         ],
  1544.         "compiler_hints": [
  1545.             { "name": "Output Size (bytes)", "value": "(none)" },
  1546.             { "name": "Output Cardinality", "value": "(none)" },
  1547.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1548.             { "name": "Filter Factor", "value": "(none)" }      ]
  1549.     },
  1550.     {
  1551.         "id": 44,
  1552.         "type": "pact",
  1553.         "pact": "Join",
  1554.         "contents": "where: (=(target___RELATIONSHIP__hasCreator__session_tmp1___NODE, __NODE__person__session_tmp1)), join: (__NODE__comment__session_tmp1, __RELATIONSHIP__hasCreator__session_tmp1, target___RELATIONSHIP__hasCreator__session_tmp1___NODE, __NODE__person__session_tmp1)",
  1555.         "parallelism": "4",
  1556.         "predecessors": [
  1557.             {"id": 45, "side": "first", "ship_strategy": "Hash Partition on [2]", "exchange_mode": "PIPELINED"},
  1558.             {"id": 51, "side": "second", "ship_strategy": "Hash Partition on [0]", "exchange_mode": "PIPELINED"}
  1559.         ],
  1560.         "driver_strategy": "Hybrid Hash (build: where: (=(f1, _UTF-16LE'Joseph')), select: (f0 AS __NODE__person__session_tmp1) (id: 51))",
  1561.         "global_properties": [
  1562.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1563.             { "name": "Partitioning Order", "value": "(none)" },
  1564.             { "name": "Uniqueness", "value": "not unique" }
  1565.         ],
  1566.         "local_properties": [
  1567.             { "name": "Order", "value": "(none)" },
  1568.             { "name": "Grouping", "value": "not grouped" },
  1569.             { "name": "Uniqueness", "value": "not unique" }
  1570.         ],
  1571.         "estimates": [
  1572.             { "name": "Est. Output Size", "value": "(unknown)" },
  1573.             { "name": "Est. Cardinality", "value": "836.05 K" }     ],
  1574.         "costs": [
  1575.             { "name": "Network", "value": "(unknown)" },
  1576.             { "name": "Disk I/O", "value": "(unknown)" },
  1577.             { "name": "CPU", "value": "(unknown)" },
  1578.             { "name": "Cumulative Network", "value": "(unknown)" },
  1579.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1580.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1581.         ],
  1582.         "compiler_hints": [
  1583.             { "name": "Output Size (bytes)", "value": "(none)" },
  1584.             { "name": "Output Cardinality", "value": "(none)" },
  1585.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1586.             { "name": "Filter Factor", "value": "(none)" }      ]
  1587.     },
  1588.     {
  1589.         "id": 43,
  1590.         "type": "pact",
  1591.         "pact": "FlatMap",
  1592.         "contents": "select: (__NODE__comment__session_tmp1, __RELATIONSHIP__hasCreator__session_tmp1 AS UNNAMED17__RELATIONSHIP__hasCreator_, __NODE__person__session_tmp1)",
  1593.         "parallelism": "4",
  1594.         "predecessors": [
  1595.             {"id": 44, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1596.         ],
  1597.         "driver_strategy": "FlatMap",
  1598.         "global_properties": [
  1599.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1600.             { "name": "Partitioning Order", "value": "(none)" },
  1601.             { "name": "Uniqueness", "value": "not unique" }
  1602.         ],
  1603.         "local_properties": [
  1604.             { "name": "Order", "value": "(none)" },
  1605.             { "name": "Grouping", "value": "not grouped" },
  1606.             { "name": "Uniqueness", "value": "not unique" }
  1607.         ],
  1608.         "estimates": [
  1609.             { "name": "Est. Output Size", "value": "(unknown)" },
  1610.             { "name": "Est. Cardinality", "value": "4.18 M" }       ],
  1611.         "costs": [
  1612.             { "name": "Network", "value": "0.0" },
  1613.             { "name": "Disk I/O", "value": "0.0" },
  1614.             { "name": "CPU", "value": "0.0" },
  1615.             { "name": "Cumulative Network", "value": "(unknown)" },
  1616.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1617.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1618.         ],
  1619.         "compiler_hints": [
  1620.             { "name": "Output Size (bytes)", "value": "(none)" },
  1621.             { "name": "Output Cardinality", "value": "(none)" },
  1622.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1623.             { "name": "Filter Factor", "value": "(none)" }      ]
  1624.     },
  1625.     {
  1626.         "id": 9,
  1627.         "type": "pact",
  1628.         "pact": "Join",
  1629.         "contents": "where: (AND(=(target___RELATIONSHIP__hasCreator__session_tmp1___NODE, __NODE__person__session_tmp1), <>(UNNAMED17__RELATIONSHIP__hasCreator_, __RELATIONSHIP__hasCreator__session_tmp1))), join: (__NODE__post__session_tmp1, __RELATIONSHIP__hasCreator__session_tmp1, target___RELATIONSHIP__hasCreator__session_tmp1___NODE, __NODE__comment__session_tmp1, UNNAMED17__RELATIONSHIP__hasCreator_, __NODE__person__session_tmp1)",
  1630.         "parallelism": "4",
  1631.         "predecessors": [
  1632.             {"id": 10, "side": "first", "ship_strategy": "Hash Partition on [2]", "exchange_mode": "PIPELINED"},
  1633.             {"id": 43, "side": "second", "ship_strategy": "Hash Partition on [2]", "exchange_mode": "PIPELINED"}
  1634.         ],
  1635.         "driver_strategy": "Hybrid Hash (build: select: (__NODE__comment__session_tmp1, __RELATIONSHIP__hasCreator__session_tmp1 AS UNNAMED17__RELATIONSHIP__hasCreator_, __NODE__person__session_tmp1) (id: 43))",
  1636.         "global_properties": [
  1637.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1638.             { "name": "Partitioning Order", "value": "(none)" },
  1639.             { "name": "Uniqueness", "value": "not unique" }
  1640.         ],
  1641.         "local_properties": [
  1642.             { "name": "Order", "value": "(none)" },
  1643.             { "name": "Grouping", "value": "not grouped" },
  1644.             { "name": "Uniqueness", "value": "not unique" }
  1645.         ],
  1646.         "estimates": [
  1647.             { "name": "Est. Output Size", "value": "(unknown)" },
  1648.             { "name": "Est. Cardinality", "value": "4.18 M" }       ],
  1649.         "costs": [
  1650.             { "name": "Network", "value": "(unknown)" },
  1651.             { "name": "Disk I/O", "value": "(unknown)" },
  1652.             { "name": "CPU", "value": "(unknown)" },
  1653.             { "name": "Cumulative Network", "value": "(unknown)" },
  1654.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1655.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1656.         ],
  1657.         "compiler_hints": [
  1658.             { "name": "Output Size (bytes)", "value": "(none)" },
  1659.             { "name": "Output Cardinality", "value": "(none)" },
  1660.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1661.             { "name": "Filter Factor", "value": "(none)" }      ]
  1662.     },
  1663.     {
  1664.         "id": 8,
  1665.         "type": "pact",
  1666.         "pact": "FlatMap",
  1667.         "contents": "select: (__NODE__post__session_tmp1, __NODE__comment__session_tmp1, __NODE__person__session_tmp1)",
  1668.         "parallelism": "4",
  1669.         "predecessors": [
  1670.             {"id": 9, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1671.         ],
  1672.         "driver_strategy": "FlatMap",
  1673.         "global_properties": [
  1674.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1675.             { "name": "Partitioning Order", "value": "(none)" },
  1676.             { "name": "Uniqueness", "value": "not unique" }
  1677.         ],
  1678.         "local_properties": [
  1679.             { "name": "Order", "value": "(none)" },
  1680.             { "name": "Grouping", "value": "not grouped" },
  1681.             { "name": "Uniqueness", "value": "not unique" }
  1682.         ],
  1683.         "estimates": [
  1684.             { "name": "Est. Output Size", "value": "(unknown)" },
  1685.             { "name": "Est. Cardinality", "value": "20.90 M" }      ],
  1686.         "costs": [
  1687.             { "name": "Network", "value": "0.0" },
  1688.             { "name": "Disk I/O", "value": "0.0" },
  1689.             { "name": "CPU", "value": "0.0" },
  1690.             { "name": "Cumulative Network", "value": "(unknown)" },
  1691.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1692.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1693.         ],
  1694.         "compiler_hints": [
  1695.             { "name": "Output Size (bytes)", "value": "(none)" },
  1696.             { "name": "Output Cardinality", "value": "(none)" },
  1697.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1698.             { "name": "Filter Factor", "value": "(none)" }      ]
  1699.     },
  1700.     {
  1701.         "id": 56,
  1702.         "type": "pact",
  1703.         "pact": "Filter",
  1704.         "contents": "Filter at createRelationshipTables(CAPFQuery.java:376)",
  1705.         "parallelism": "4",
  1706.         "predecessors": [
  1707.             {"id": 27, "ship_strategy": "Forward", "exchange_mode": "BATCH"}
  1708.         ],
  1709.         "driver_strategy": "FlatMap",
  1710.         "global_properties": [
  1711.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1712.             { "name": "Partitioning Order", "value": "(none)" },
  1713.             { "name": "Uniqueness", "value": "not unique" }
  1714.         ],
  1715.         "local_properties": [
  1716.             { "name": "Order", "value": "(none)" },
  1717.             { "name": "Grouping", "value": "not grouped" },
  1718.             { "name": "Uniqueness", "value": "not unique" }
  1719.         ],
  1720.         "estimates": [
  1721.             { "name": "Est. Output Size", "value": "0.0" },
  1722.             { "name": "Est. Cardinality", "value": "33.44 K" }      ],
  1723.         "costs": [
  1724.             { "name": "Network", "value": "0.0" },
  1725.             { "name": "Disk I/O", "value": "0.0" },
  1726.             { "name": "CPU", "value": "0.0" },
  1727.             { "name": "Cumulative Network", "value": "(unknown)" },
  1728.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1729.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1730.         ],
  1731.         "compiler_hints": [
  1732.             { "name": "Output Size (bytes)", "value": "(none)" },
  1733.             { "name": "Output Cardinality", "value": "(none)" },
  1734.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1735.             { "name": "Filter Factor", "value": "(none)" }      ]
  1736.     },
  1737.     {
  1738.         "id": 55,
  1739.         "type": "pact",
  1740.         "pact": "Map",
  1741.         "contents": "Map at createRelationshipTables(CAPFQuery.java:381)",
  1742.         "parallelism": "4",
  1743.         "predecessors": [
  1744.             {"id": 56, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1745.         ],
  1746.         "driver_strategy": "Map",
  1747.         "global_properties": [
  1748.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1749.             { "name": "Partitioning Order", "value": "(none)" },
  1750.             { "name": "Uniqueness", "value": "not unique" }
  1751.         ],
  1752.         "local_properties": [
  1753.             { "name": "Order", "value": "(none)" },
  1754.             { "name": "Grouping", "value": "not grouped" },
  1755.             { "name": "Uniqueness", "value": "not unique" }
  1756.         ],
  1757.         "estimates": [
  1758.             { "name": "Est. Output Size", "value": "(unknown)" },
  1759.             { "name": "Est. Cardinality", "value": "33.44 K" }      ],
  1760.         "costs": [
  1761.             { "name": "Network", "value": "0.0" },
  1762.             { "name": "Disk I/O", "value": "0.0" },
  1763.             { "name": "CPU", "value": "0.0" },
  1764.             { "name": "Cumulative Network", "value": "(unknown)" },
  1765.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1766.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1767.         ],
  1768.         "compiler_hints": [
  1769.             { "name": "Output Size (bytes)", "value": "(none)" },
  1770.             { "name": "Output Cardinality", "value": "(none)" },
  1771.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1772.             { "name": "Filter Factor", "value": "(none)" }      ]
  1773.     },
  1774.     {
  1775.         "id": 54,
  1776.         "type": "pact",
  1777.         "pact": "FlatMap",
  1778.         "contents": "select: (f1 AS source___RELATIONSHIP__replyOf__session_tmp1___NODE, f2 AS target___RELATIONSHIP__replyOf__session_tmp1___NODE)",
  1779.         "parallelism": "4",
  1780.         "predecessors": [
  1781.             {"id": 55, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1782.         ],
  1783.         "driver_strategy": "FlatMap",
  1784.         "global_properties": [
  1785.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1786.             { "name": "Partitioning Order", "value": "(none)" },
  1787.             { "name": "Uniqueness", "value": "not unique" }
  1788.         ],
  1789.         "local_properties": [
  1790.             { "name": "Order", "value": "(none)" },
  1791.             { "name": "Grouping", "value": "not grouped" },
  1792.             { "name": "Uniqueness", "value": "not unique" }
  1793.         ],
  1794.         "estimates": [
  1795.             { "name": "Est. Output Size", "value": "(unknown)" },
  1796.             { "name": "Est. Cardinality", "value": "167.21 K" }     ],
  1797.         "costs": [
  1798.             { "name": "Network", "value": "0.0" },
  1799.             { "name": "Disk I/O", "value": "0.0" },
  1800.             { "name": "CPU", "value": "0.0" },
  1801.             { "name": "Cumulative Network", "value": "(unknown)" },
  1802.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1803.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1804.         ],
  1805.         "compiler_hints": [
  1806.             { "name": "Output Size (bytes)", "value": "(none)" },
  1807.             { "name": "Output Cardinality", "value": "(none)" },
  1808.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1809.             { "name": "Filter Factor", "value": "(none)" }      ]
  1810.     },
  1811.     {
  1812.         "id": 7,
  1813.         "type": "pact",
  1814.         "pact": "Join",
  1815.         "contents": "where: (AND(=(__NODE__comment__session_tmp1, source___RELATIONSHIP__replyOf__session_tmp1___NODE), =(__NODE__post__session_tmp1, target___RELATIONSHIP__replyOf__session_tmp1___NODE))), join: (__NODE__post__session_tmp1, __NODE__comment__session_tmp1, __NODE__person__session_tmp1, source___RELATIONSHIP__replyOf__session_tmp1___NODE, target___RELATIONSHIP__replyOf__session_tmp1___NODE)",
  1816.         "parallelism": "4",
  1817.         "predecessors": [
  1818.             {"id": 8, "side": "first", "ship_strategy": "Hash Partition on [1, 0]", "exchange_mode": "PIPELINED"},
  1819.             {"id": 54, "side": "second", "ship_strategy": "Hash Partition on [0, 1]", "exchange_mode": "PIPELINED"}
  1820.         ],
  1821.         "driver_strategy": "Hybrid Hash (build: select: (f1 AS source___RELATIONSHIP__replyOf__session_tmp1___NODE, f2 AS target___RELATIONSHIP__replyOf__session_tmp1___NODE) (id: 54))",
  1822.         "global_properties": [
  1823.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1824.             { "name": "Partitioning Order", "value": "(none)" },
  1825.             { "name": "Uniqueness", "value": "not unique" }
  1826.         ],
  1827.         "local_properties": [
  1828.             { "name": "Order", "value": "(none)" },
  1829.             { "name": "Grouping", "value": "not grouped" },
  1830.             { "name": "Uniqueness", "value": "not unique" }
  1831.         ],
  1832.         "estimates": [
  1833.             { "name": "Est. Output Size", "value": "(unknown)" },
  1834.             { "name": "Est. Cardinality", "value": "20.90 M" }      ],
  1835.         "costs": [
  1836.             { "name": "Network", "value": "(unknown)" },
  1837.             { "name": "Disk I/O", "value": "(unknown)" },
  1838.             { "name": "CPU", "value": "(unknown)" },
  1839.             { "name": "Cumulative Network", "value": "(unknown)" },
  1840.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1841.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1842.         ],
  1843.         "compiler_hints": [
  1844.             { "name": "Output Size (bytes)", "value": "(none)" },
  1845.             { "name": "Output Cardinality", "value": "(none)" },
  1846.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1847.             { "name": "Filter Factor", "value": "(none)" }      ]
  1848.     },
  1849.     {
  1850.         "id": 6,
  1851.         "type": "pact",
  1852.         "pact": "FlatMap",
  1853.         "contents": "select: (__NODE__comment__session_tmp1, __NODE__post__session_tmp1, __NODE__person__session_tmp1)",
  1854.         "parallelism": "4",
  1855.         "predecessors": [
  1856.             {"id": 7, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1857.         ],
  1858.         "driver_strategy": "FlatMap",
  1859.         "global_properties": [
  1860.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1861.             { "name": "Partitioning Order", "value": "(none)" },
  1862.             { "name": "Uniqueness", "value": "not unique" }
  1863.         ],
  1864.         "local_properties": [
  1865.             { "name": "Order", "value": "(none)" },
  1866.             { "name": "Grouping", "value": "not grouped" },
  1867.             { "name": "Uniqueness", "value": "not unique" }
  1868.         ],
  1869.         "estimates": [
  1870.             { "name": "Est. Output Size", "value": "(unknown)" },
  1871.             { "name": "Est. Cardinality", "value": "104.51 M" }     ],
  1872.         "costs": [
  1873.             { "name": "Network", "value": "0.0" },
  1874.             { "name": "Disk I/O", "value": "0.0" },
  1875.             { "name": "CPU", "value": "0.0" },
  1876.             { "name": "Cumulative Network", "value": "(unknown)" },
  1877.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1878.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1879.         ],
  1880.         "compiler_hints": [
  1881.             { "name": "Output Size (bytes)", "value": "(none)" },
  1882.             { "name": "Output Cardinality", "value": "(none)" },
  1883.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1884.             { "name": "Filter Factor", "value": "(none)" }      ]
  1885.     },
  1886.     {
  1887.         "id": 5,
  1888.         "type": "pact",
  1889.         "pact": "Map",
  1890.         "contents": "Map at getGraphs(CAPFQueryResult.java:180)",
  1891.         "parallelism": "4",
  1892.         "predecessors": [
  1893.             {"id": 6, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1894.         ],
  1895.         "driver_strategy": "Map",
  1896.         "global_properties": [
  1897.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1898.             { "name": "Partitioning Order", "value": "(none)" },
  1899.             { "name": "Uniqueness", "value": "not unique" }
  1900.         ],
  1901.         "local_properties": [
  1902.             { "name": "Order", "value": "(none)" },
  1903.             { "name": "Grouping", "value": "not grouped" },
  1904.             { "name": "Uniqueness", "value": "not unique" }
  1905.         ],
  1906.         "estimates": [
  1907.             { "name": "Est. Output Size", "value": "(unknown)" },
  1908.             { "name": "Est. Cardinality", "value": "104.51 M" }     ],
  1909.         "costs": [
  1910.             { "name": "Network", "value": "0.0" },
  1911.             { "name": "Disk I/O", "value": "0.0" },
  1912.             { "name": "CPU", "value": "0.0" },
  1913.             { "name": "Cumulative Network", "value": "(unknown)" },
  1914.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1915.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1916.         ],
  1917.         "compiler_hints": [
  1918.             { "name": "Output Size (bytes)", "value": "(none)" },
  1919.             { "name": "Output Cardinality", "value": "(none)" },
  1920.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1921.             { "name": "Filter Factor", "value": "(none)" }      ]
  1922.     },
  1923.     {
  1924.         "id": 4,
  1925.         "type": "pact",
  1926.         "pact": "FlatMap",
  1927.         "contents": "FlatMap at getGraphs(CAPFQueryResult.java:194)",
  1928.         "parallelism": "4",
  1929.         "predecessors": [
  1930.             {"id": 5, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  1931.         ],
  1932.         "driver_strategy": "FlatMap",
  1933.         "global_properties": [
  1934.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  1935.             { "name": "Partitioning Order", "value": "(none)" },
  1936.             { "name": "Uniqueness", "value": "not unique" }
  1937.         ],
  1938.         "local_properties": [
  1939.             { "name": "Order", "value": "(none)" },
  1940.             { "name": "Grouping", "value": "not grouped" },
  1941.             { "name": "Uniqueness", "value": "not unique" }
  1942.         ],
  1943.         "estimates": [
  1944.             { "name": "Est. Output Size", "value": "(unknown)" },
  1945.             { "name": "Est. Cardinality", "value": "522.53 M" }     ],
  1946.         "costs": [
  1947.             { "name": "Network", "value": "0.0" },
  1948.             { "name": "Disk I/O", "value": "0.0" },
  1949.             { "name": "CPU", "value": "0.0" },
  1950.             { "name": "Cumulative Network", "value": "(unknown)" },
  1951.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1952.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1953.         ],
  1954.         "compiler_hints": [
  1955.             { "name": "Output Size (bytes)", "value": "(none)" },
  1956.             { "name": "Output Cardinality", "value": "(none)" },
  1957.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1958.             { "name": "Filter Factor", "value": "(none)" }      ]
  1959.     },
  1960.     {
  1961.         "id": 3,
  1962.         "type": "pact",
  1963.         "pact": "GroupReduce",
  1964.         "contents": "GroupReduce at getGraphs(CAPFQueryResult.java:196)",
  1965.         "parallelism": "4",
  1966.         "predecessors": [
  1967.             {"id": 4, "ship_strategy": "Hash Partition on [0]", "local_strategy": "Sort on [0:ASC]", "exchange_mode": "PIPELINED"}
  1968.         ],
  1969.         "driver_strategy": "Sorted Group Reduce",
  1970.         "global_properties": [
  1971.             { "name": "Partitioning", "value": "HASH_PARTITIONED" },
  1972.             { "name": "Partitioned on", "value": "[0]" },
  1973.             { "name": "Partitioning Order", "value": "(none)" },
  1974.             { "name": "Uniqueness", "value": "not unique" }
  1975.         ],
  1976.         "local_properties": [
  1977.             { "name": "Order", "value": "[0:ASC]" },
  1978.             { "name": "Grouped on", "value": "[0]" },
  1979.             { "name": "Uniqueness", "value": "not unique" }
  1980.         ],
  1981.         "estimates": [
  1982.             { "name": "Est. Output Size", "value": "(unknown)" },
  1983.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  1984.         "costs": [
  1985.             { "name": "Network", "value": "(unknown)" },
  1986.             { "name": "Disk I/O", "value": "(unknown)" },
  1987.             { "name": "CPU", "value": "(unknown)" },
  1988.             { "name": "Cumulative Network", "value": "(unknown)" },
  1989.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  1990.             { "name": "Cumulative CPU", "value": "(unknown)" }
  1991.         ],
  1992.         "compiler_hints": [
  1993.             { "name": "Output Size (bytes)", "value": "(none)" },
  1994.             { "name": "Output Cardinality", "value": "(none)" },
  1995.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  1996.             { "name": "Filter Factor", "value": "(none)" }      ]
  1997.     },
  1998.     {
  1999.         "id": 2,
  2000.         "type": "pact",
  2001.         "pact": "Join",
  2002.         "contents": "Join at getGraphs(CAPFQueryResult.java:203)",
  2003.         "parallelism": "4",
  2004.         "predecessors": [
  2005.             {"id": 3, "side": "first", "ship_strategy": "Forward", "exchange_mode": "PIPELINED"},
  2006.             {"id": 15, "side": "second", "ship_strategy": "Hash Partition on [0]", "exchange_mode": "BATCH"}
  2007.         ],
  2008.         "driver_strategy": "Hybrid Hash (build: GroupReduce at getGraphs(CAPFQueryResult.java:196) (id: 3))",
  2009.         "global_properties": [
  2010.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  2011.             { "name": "Partitioning Order", "value": "(none)" },
  2012.             { "name": "Uniqueness", "value": "not unique" }
  2013.         ],
  2014.         "local_properties": [
  2015.             { "name": "Order", "value": "(none)" },
  2016.             { "name": "Grouping", "value": "not grouped" },
  2017.             { "name": "Uniqueness", "value": "not unique" }
  2018.         ],
  2019.         "estimates": [
  2020.             { "name": "Est. Output Size", "value": "(unknown)" },
  2021.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  2022.         "costs": [
  2023.             { "name": "Network", "value": "(unknown)" },
  2024.             { "name": "Disk I/O", "value": "(unknown)" },
  2025.             { "name": "CPU", "value": "(unknown)" },
  2026.             { "name": "Cumulative Network", "value": "(unknown)" },
  2027.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  2028.             { "name": "Cumulative CPU", "value": "(unknown)" }
  2029.         ],
  2030.         "compiler_hints": [
  2031.             { "name": "Output Size (bytes)", "value": "(none)" },
  2032.             { "name": "Output Cardinality", "value": "(none)" },
  2033.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  2034.             { "name": "Filter Factor", "value": "(none)" }      ]
  2035.     },
  2036.     {
  2037.         "id": 1,
  2038.         "type": "pact",
  2039.         "pact": "Map",
  2040.         "contents": "Map at getGraphs(CAPFQueryResult.java:212)",
  2041.         "parallelism": "4",
  2042.         "predecessors": [
  2043.             {"id": 2, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  2044.         ],
  2045.         "driver_strategy": "Map",
  2046.         "global_properties": [
  2047.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  2048.             { "name": "Partitioning Order", "value": "(none)" },
  2049.             { "name": "Uniqueness", "value": "not unique" }
  2050.         ],
  2051.         "local_properties": [
  2052.             { "name": "Order", "value": "(none)" },
  2053.             { "name": "Grouping", "value": "not grouped" },
  2054.             { "name": "Uniqueness", "value": "not unique" }
  2055.         ],
  2056.         "estimates": [
  2057.             { "name": "Est. Output Size", "value": "(unknown)" },
  2058.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  2059.         "costs": [
  2060.             { "name": "Network", "value": "0.0" },
  2061.             { "name": "Disk I/O", "value": "0.0" },
  2062.             { "name": "CPU", "value": "0.0" },
  2063.             { "name": "Cumulative Network", "value": "(unknown)" },
  2064.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  2065.             { "name": "Cumulative CPU", "value": "(unknown)" }
  2066.         ],
  2067.         "compiler_hints": [
  2068.             { "name": "Output Size (bytes)", "value": "(none)" },
  2069.             { "name": "Output Cardinality", "value": "(none)" },
  2070.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  2071.             { "name": "Filter Factor", "value": "(none)" }      ]
  2072.     },
  2073.     {
  2074.         "id": 0,
  2075.         "type": "sink",
  2076.         "pact": "Data Sink",
  2077.         "contents": "org.apache.flink.api.java.io.LocalCollectionOutputFormat@75bbc7ab",
  2078.         "parallelism": "4",
  2079.         "predecessors": [
  2080.             {"id": 1, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
  2081.         ],
  2082.         "global_properties": [
  2083.             { "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
  2084.             { "name": "Partitioning Order", "value": "(none)" },
  2085.             { "name": "Uniqueness", "value": "not unique" }
  2086.         ],
  2087.         "local_properties": [
  2088.             { "name": "Order", "value": "(none)" },
  2089.             { "name": "Grouping", "value": "not grouped" },
  2090.             { "name": "Uniqueness", "value": "not unique" }
  2091.         ],
  2092.         "estimates": [
  2093.             { "name": "Est. Output Size", "value": "(unknown)" },
  2094.             { "name": "Est. Cardinality", "value": "(unknown)" }        ],
  2095.         "costs": [
  2096.             { "name": "Network", "value": "0.0" },
  2097.             { "name": "Disk I/O", "value": "0.0" },
  2098.             { "name": "CPU", "value": "0.0" },
  2099.             { "name": "Cumulative Network", "value": "(unknown)" },
  2100.             { "name": "Cumulative Disk I/O", "value": "(unknown)" },
  2101.             { "name": "Cumulative CPU", "value": "(unknown)" }
  2102.         ],
  2103.         "compiler_hints": [
  2104.             { "name": "Output Size (bytes)", "value": "(none)" },
  2105.             { "name": "Output Cardinality", "value": "(none)" },
  2106.             { "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
  2107.             { "name": "Filter Factor", "value": "(none)" }      ]
  2108.     }
  2109.     ]
  2110. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!