explain.depesz.com

PostgreSQL's explain analyze made readable

Result: yJf1

Settings
# exclusive inclusive rows x rows loops node
1. 0.000 17,360.060 ↓ 0.0 0 1

Insert on "state.q"."util.in_progress" (cost=648,538.34..648,538.38 rows=1 width=72) (actual time=17,360.059..17,360.060 rows=0 loops=1)

  • Functions: 2,334
  • Options: Inlining true, Optimization true, Expressions true, Deforming true
  • Timing: Generation 224.301 ms, Inlining 57.377 ms, Optimization 10159.898 ms, Emission 6939.374 ms, Total 17380.950 ms
2.          

CTE dequeued_rows

3. 0.000 3.105 ↓ 5.0 100 1

Delete on "state.qp"."organizations.6" (cost=12.84..25.05 rows=20 width=6) (actual time=2.177..3.105 rows=100 loops=1)

  • Output: "organizations.6.secondary_1".uuid, "organizations.6.secondary_1".partition, "organizations.6.secondary_1"."exists", "organizations.6.secondary_1".deleted, "organizations.6.secondary_1".properties, "organizations.6.secondary_1".is_primary_dirty, "organizations.6.secondary_1".dirty_field_ids, "organizations.6.secondary_1".dirty_rel_ids, "organizations.6.secondary_1"."counter.apptopia_total_apps", "organizations.6.secondary_1"."counter.investor_prediction_num_investors", "organizations.6.secondary_1"."counter.num_acquisitions", "organizations.6.secondary_1"."counter.num_alumni", "organizations.6.secondary_1"."counter.num_articles", "organizations.6.secondary_1"."counter.num_current_advisor_positions", "organizations.6.secondary_1"."counter.num_current_positions", "organizations.6.secondary_1"."counter.num_diversity_spotlight_investments", "organizations.6.secondary_1"."counter.num_event_appearances", "organizations.6.secondary_1"."counter.num_exits", "organizations.6.secondary_1"."counter.num_exits_ipo", "organizations.6.secondary_1"."counter.num_founder_alumni", "organizations.6.secondary_1"."counter.num_founders", "organizations.6.secondary_1"."counter.num_funding_rounds", "organizations.6.secondary_1"."counter.num_funds", "organizations.6.secondary_1"."counter.num_investments", "organizations.6.secondary_1"."counter.num_investments_funding_rounds", "organizations.6.secondary_1"."counter.num_investors", "organizations.6.secondary_1"."counter.num_lead_investments", "organizations.6.secondary_1"."counter.num_lead_investors", "organizations.6.secondary_1"."counter.num_parent_organizations", "organizations.6.secondary_1"."counter.num_past_positions", "organizations.6.secondary_1"."counter.num_portfolio_organizations", "organizations.6.secondary_1"."counter.num_relationships", "organizations.6.secondary_1"."counter.num_sub_organizations", "organizations.6.secondary_1"."counter.num_was_acquired", "organizations.6.secondary_1"."counter.num_went_public", "organizations.6.secondary_1"."counter.siftery_num_product_creates", "organizations.6.secondary_1".updated_at
  • Delete on "state.qp"."organizations.6.secondary" "organizations.6.secondary_1
  • Delete on "state.qp"."organizations.6.primary" "organizations.6.primary_1
4.          

Initplan (for Delete)

5. 0.360 1.890 ↓ 1.2 288 1

Limit (cost=0.20..12.84 rows=237 width=16) (actual time=0.039..1.890 rows=288 loops=1)

  • Output: primary_uuids_1.uuid
6.          

CTE primary_uuids

7. 0.003 0.019 ↓ 0.0 0 1

Limit (cost=0.00..0.20 rows=1 width=16) (actual time=0.018..0.019 rows=0 loops=1)

  • Output: "organizations.6.primary".uuid
8. 0.016 0.016 ↓ 0.0 0 1

Seq Scan on "state.qp"."organizations.6.primary" (cost=0.00..0.20 rows=1 width=16) (actual time=0.015..0.016 rows=0 loops=1)

  • Output: "organizations.6.primary".uuid
9. 0.382 1.530 ↓ 1.2 288 1

Append (cost=0.00..12.64 rows=237 width=16) (actual time=0.035..1.530 rows=288 loops=1)

10. 0.021 0.021 ↓ 0.0 0 1

CTE Scan on primary_uuids primary_uuids_1 (cost=0.00..0.02 rows=1 width=16) (actual time=0.020..0.021 rows=0 loops=1)

  • Output: primary_uuids_1.uuid
11. 0.372 1.127 ↓ 1.2 288 1

Limit (cost=0.02..9.08 rows=236 width=16) (actual time=0.012..1.127 rows=288 loops=1)

  • Output: "organizations.6.secondary".uuid
12.          

Initplan (for Limit)

13. 0.002 0.002 ↓ 0.0 0 1

CTE Scan on primary_uuids (cost=0.00..0.02 rows=1 width=0) (actual time=0.001..0.002 rows=0 loops=1)

14. 0.366 0.753 ↓ 1.2 288 1

Result (cost=0.00..9.06 rows=236 width=16) (actual time=0.009..0.753 rows=288 loops=1)

  • Output: "organizations.6.secondary".uuid
  • One-Time Filter: (NOT $1)
15. 0.387 0.387 ↓ 1.2 288 1

Seq Scan on "state.qp"."organizations.6.secondary" (cost=0.00..9.06 rows=236 width=16) (actual time=0.003..0.387 rows=288 loops=1)

  • Output: "organizations.6.secondary".uuid, "organizations.6.secondary".partition, "organizations.6.secondary"."exists", "organizations.6.secondary".deleted, "organizations.6.secondary".properties, "organizations.6.secondary".is_primary_dirty, "organizations.6.secondary".dirty_field_ids, "organizations.6.secondary".dirty_rel_ids, "organizations.6.secondary"."counter.apptopia_total_apps", "organizations.6.secondary"."counter.investor_prediction_num_investors", "organizations.6.secondary"."counter.num_acquisitions", "organizations.6.secondary"."counter.num_alumni", "organizations.6.secondary"."counter.num_articles", "organizations.6.secondary"."counter.num_current_advisor_positions", "organizations.6.secondary"."counter.num_current_positions", "organizations.6.secondary"."counter.num_diversity_spotlight_investments", "organizations.6.secondary"."counter.num_event_appearances", "organizations.6.secondary"."counter.num_exits", "organizations.6.secondary"."counter.num_exits_ipo", "organizations.6.secondary"."counter.num_founder_alumni", "organizations.6.secondary"."counter.num_founders", "organizations.6.secondary"."counter.num_funding_rounds", "organizations.6.secondary"."counter.num_funds", "organizations.6.secondary"."counter.num_investments", "organizations.6.secondary"."counter.num_investments_funding_rounds", "organizations.6.secondary"."counter.num_investors", "organizations.6.secondary"."counter.num_lead_investments", "organizations.6.secondary"."counter.num_lead_investors", "organizations.6.secondary"."counter.num_parent_organizations", "organizations.6.secondary"."counter.num_past_positions", "organizations.6.secondary"."counter.num_portfolio_organizations", "organizations.6.secondary"."counter.num_relationships", "organizations.6.secondary"."counter.num_sub_organizations", "organizations.6.secondary"."counter.num_was_acquired", "organizations.6.secondary"."counter.num_went_public", "organizations.6.secondary"."counter.siftery_num_product_creates", "organizations.6.secondary".updated_at
16. 2.648 2.648 ↓ 15.2 288 1

Seq Scan on "state.qp"."organizations.6.secondary" "organizations.6.secondary_1" (cost=0.00..12.01 rows=19 width=6) (actual time=2.144..2.648 rows=288 loops=1)

  • Output: "organizations.6.secondary_1".ctid
  • Filter: ("organizations.6.secondary_1".uuid = ANY ($2))
17. 0.005 0.005 ↓ 0.0 0 1

Seq Scan on "state.qp"."organizations.6.primary" "organizations.6.primary_1" (cost=0.00..0.20 rows=1 width=6) (actual time=0.004..0.005 rows=0 loops=1)

  • Output: "organizations.6.primary_1".ctid
  • Filter: ("organizations.6.primary_1".uuid = ANY ($2))
18.          

CTE merged_properties

19. 3.550 11.831 ↓ 2.5 50 1

Nested Loop Left Join (cost=1.25..127.08 rows=20 width=160) (actual time=4.055..11.831 rows=50 loops=1)

  • Output: dequeued_rows.uuid, COALESCE(state."exists", false), (COALESCE(state."exists", false) OR (any_true_agg(dequeued_rows."exists"))), state.deleted, (any_true_agg(dequeued_rows.deleted)), COALESCE(state.properties, '{}'::jsonb), CASE WHEN (((sum(dequeued_rows."counter.apptopia_total_apps")) IS NOT NULL) OR ((sum(dequeued_rows."counter.investor_prediction_num_investors")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_acquisitions")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_alumni")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_articles")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_current_advisor_positions")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_current_positions")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_diversity_spotlight_investments")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_event_appearances")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_exits")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_exits_ipo")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_founder_alumni")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_founders")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_funding_rounds")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_funds")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_investments")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_investments_funding_rounds")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_investors")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_lead_investments")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_lead_investors")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_parent_organizations")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_past_positions")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_portfolio_organizations")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_relationships")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_sub_organizations")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_was_acquired")) IS NOT NULL) OR ((sum(dequeued_rows."counter.num_went_public")) IS NOT NULL) OR ((sum(dequeued_rows."counter.siftery_num_product_creates")) IS NOT NULL)) THEN (COALESCE((state.properties || (merge_jsonb_agg(dequeued_rows.properties ORDER BY dequeued_rows.updated_at))), ((merge_jsonb_agg(dequeued_rows.properties ORDER BY dequeued_rows.updated_at)) || jsonb_build_object('uuid', dequeued_rows.uuid)), state.properties, '{}'::jsonb) || jsonb_build_object('apptopia_total_apps', COALESCE(to_jsonb(((sum(dequeued_rows."counter.apptopia_total_apps")) + ((state.properties ->> 'apptopia_total_apps'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.apptopia_total_apps"))), (state.properties -> 'apptopia_total_apps'::text)), 'investor_prediction_num_investors', COALESCE(to_jsonb(((sum(dequeued_rows."counter.investor_prediction_num_investors")) + ((state.properties ->> 'investor_prediction_num_investors'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.investor_prediction_num_investors"))), (state.properties -> 'investor_prediction_num_investors'::text)), 'num_acquisitions', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_acquisitions")) + ((state.properties ->> 'num_acquisitions'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_acquisitions"))), (state.properties -> 'num_acquisitions'::text)), 'num_alumni', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_alumni")) + ((state.properties ->> 'num_alumni'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_alumni"))), (state.properties -> 'num_alumni'::text)), 'num_articles', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_articles")) + ((state.properties ->> 'num_articles'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_articles"))), (state.properties -> 'num_articles'::text)), 'num_current_advisor_positions', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_current_advisor_positions")) + ((state.properties ->> 'num_current_advisor_positions'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_current_advisor_positions"))), (state.properties -> 'num_current_advisor_positions'::text)), 'num_current_positions', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_current_positions")) + ((state.properties ->> 'num_current_positions'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_current_positions"))), (state.properties -> 'num_current_positions'::text)), 'num_diversity_spotlight_investments', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_diversity_spotlight_investments")) + ((state.properties ->> 'num_diversity_spotlight_investments'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_diversity_spotlight_investments"))), (state.properties -> 'num_diversity_spotlight_investments'::text)), 'num_event_appearances', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_event_appearances")) + ((state.properties ->> 'num_event_appearances'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_event_appearances"))), (state.properties -> 'num_event_appearances'::text)), 'num_exits', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_exits")) + ((state.properties ->> 'num_exits'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_exits"))), (state.properties -> 'num_exits'::text)), 'num_exits_ipo', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_exits_ipo")) + ((state.properties ->> 'num_exits_ipo'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_exits_ipo"))), (state.properties -> 'num_exits_ipo'::text)), 'num_founder_alumni', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_founder_alumni")) + ((state.properties ->> 'num_founder_alumni'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_founder_alumni"))), (state.properties -> 'num_founder_alumni'::text)), 'num_founders', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_founders")) + ((state.properties ->> 'num_founders'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_founders"))), (state.properties -> 'num_founders'::text)), 'num_funding_rounds', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_funding_rounds")) + ((state.properties ->> 'num_funding_rounds'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_funding_rounds"))), (state.properties -> 'num_funding_rounds'::text)), 'num_funds', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_funds")) + ((state.properties ->> 'num_funds'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_funds"))), (state.properties -> 'num_funds'::text)), 'num_investments', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_investments")) + ((state.properties ->> 'num_investments'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_investments"))), (state.properties -> 'num_investments'::text)), 'num_investments_funding_rounds', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_investments_funding_rounds")) + ((state.properties ->> 'num_investments_funding_rounds'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_investments_funding_rounds"))), (state.properties -> 'num_investments_funding_rounds'::text)), 'num_investors', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_investors")) + ((state.properties ->> 'num_investors'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_investors"))), (state.properties -> 'num_investors'::text)), 'num_lead_investments', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_lead_investments")) + ((state.properties ->> 'num_lead_investments'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_lead_investments"))), (state.properties -> 'num_lead_investments'::text)), 'num_lead_investors', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_lead_investors")) + ((state.properties ->> 'num_lead_investors'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_lead_investors"))), (state.properties -> 'num_lead_investors'::text)), 'num_parent_organizations', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_parent_organizations")) + ((state.properties ->> 'num_parent_organizations'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_parent_organizations"))), (state.properties -> 'num_parent_organizations'::text)), 'num_past_positions', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_past_positions")) + ((state.properties ->> 'num_past_positions'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_past_positions"))), (state.properties -> 'num_past_positions'::text)), 'num_portfolio_organizations', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_portfolio_organizations")) + ((state.properties ->> 'num_portfolio_organizations'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_portfolio_organizations"))), (state.properties -> 'num_portfolio_organizations'::text)), 'num_relationships', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_relationships")) + ((state.properties ->> 'num_relationships'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_relationships"))), (state.properties -> 'num_relationships'::text)), 'num_sub_organizations', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_sub_organizations")) + ((state.properties ->> 'num_sub_organizations'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_sub_organizations"))), (state.properties -> 'num_sub_organizations'::text)), 'num_was_acquired', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_was_acquired")) + ((state.properties ->> 'num_was_acquired'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_was_acquired"))), (state.properties -> 'num_was_acquired'::text)), 'num_went_public', COALESCE(to_jsonb(((sum(dequeued_rows."counter.num_went_public")) + ((state.properties ->> 'num_went_public'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.num_went_public"))), (state.properties -> 'num_went_public'::text)), 'siftery_num_product_creates', COALESCE(to_jsonb(((sum(dequeued_rows."counter.siftery_num_product_creates")) + ((state.properties ->> 'siftery_num_product_creates'::text))::integer)), to_jsonb((sum(dequeued_rows."counter.siftery_num_product_creates"))), (state.properties -> 'siftery_num_product_creates'::text)))) ELSE COALESCE((state.properties || (merge_jsonb_agg(dequeued_rows.properties ORDER BY dequeued_rows.updated_at))), ((merge_jsonb_agg(dequeued_rows.properties ORDER BY dequeued_rows.updated_at)) || jsonb_build_object('uuid', dequeued_rows.uuid)), state.properties, '{}'::jsonb) END, (COALESCE(state.change_count, 0) + 1), GREATEST((max(dequeued_rows.updated_at)), state.updated_at), (array_unique(array_agg_mult(dequeued_rows.dirty_field_ids))), (array_unique(array_agg_mult(dequeued_rows.dirty_rel_ids)))
  • Inner Unique: true
  • Filter: ((NOT state.deleted) OR (state.deleted IS NULL))
20. 3.214 6.831 ↓ 2.5 50 1

GroupAggregate (cost=0.83..27.68 rows=20 width=346) (actual time=3.873..6.831 rows=50 loops=1)

  • Output: dequeued_rows.uuid, merge_jsonb_agg(dequeued_rows.properties ORDER BY dequeued_rows.updated_at), any_true_agg(dequeued_rows."exists"), any_true_agg(dequeued_rows.deleted), array_unique(array_agg_mult(dequeued_rows.dirty_field_ids)), array_unique(array_agg_mult(dequeued_rows.dirty_rel_ids)), sum(dequeued_rows."counter.apptopia_total_apps"), sum(dequeued_rows."counter.investor_prediction_num_investors"), sum(dequeued_rows."counter.num_acquisitions"), sum(dequeued_rows."counter.num_alumni"), sum(dequeued_rows."counter.num_articles"), sum(dequeued_rows."counter.num_current_advisor_positions"), sum(dequeued_rows."counter.num_current_positions"), sum(dequeued_rows."counter.num_diversity_spotlight_investments"), sum(dequeued_rows."counter.num_event_appearances"), sum(dequeued_rows."counter.num_exits"), sum(dequeued_rows."counter.num_exits_ipo"), sum(dequeued_rows."counter.num_founder_alumni"), sum(dequeued_rows."counter.num_founders"), sum(dequeued_rows."counter.num_funding_rounds"), sum(dequeued_rows."counter.num_funds"), sum(dequeued_rows."counter.num_investments"), sum(dequeued_rows."counter.num_investments_funding_rounds"), sum(dequeued_rows."counter.num_investors"), sum(dequeued_rows."counter.num_lead_investments"), sum(dequeued_rows."counter.num_lead_investors"), sum(dequeued_rows."counter.num_parent_organizations"), sum(dequeued_rows."counter.num_past_positions"), sum(dequeued_rows."counter.num_portfolio_organizations"), sum(dequeued_rows."counter.num_relationships"), sum(dequeued_rows."counter.num_sub_organizations"), sum(dequeued_rows."counter.num_was_acquired"), sum(dequeued_rows."counter.num_went_public"), sum(dequeued_rows."counter.siftery_num_product_creates"), max(dequeued_rows.updated_at)
  • Group Key: dequeued_rows.uuid
21. 0.316 3.617 ↓ 5.0 100 1

Sort (cost=0.83..0.88 rows=20 width=234) (actual time=3.525..3.617 rows=100 loops=1)

  • Output: dequeued_rows.uuid, dequeued_rows.properties, dequeued_rows.updated_at, dequeued_rows."exists", dequeued_rows.deleted, dequeued_rows.dirty_field_ids, dequeued_rows.dirty_rel_ids, dequeued_rows."counter.apptopia_total_apps", dequeued_rows."counter.investor_prediction_num_investors", dequeued_rows."counter.num_acquisitions", dequeued_rows."counter.num_alumni", dequeued_rows."counter.num_articles", dequeued_rows."counter.num_current_advisor_positions", dequeued_rows."counter.num_current_positions", dequeued_rows."counter.num_diversity_spotlight_investments", dequeued_rows."counter.num_event_appearances", dequeued_rows."counter.num_exits", dequeued_rows."counter.num_exits_ipo", dequeued_rows."counter.num_founder_alumni", dequeued_rows."counter.num_founders", dequeued_rows."counter.num_funding_rounds", dequeued_rows."counter.num_funds", dequeued_rows."counter.num_investments", dequeued_rows."counter.num_investments_funding_rounds", dequeued_rows."counter.num_investors", dequeued_rows."counter.num_lead_investments", dequeued_rows."counter.num_lead_investors", dequeued_rows."counter.num_parent_organizations", dequeued_rows."counter.num_past_positions", dequeued_rows."counter.num_portfolio_organizations", dequeued_rows."counter.num_relationships", dequeued_rows."counter.num_sub_organizations", dequeued_rows."counter.num_was_acquired", dequeued_rows."counter.num_went_public", dequeued_rows."counter.siftery_num_product_creates
  • Sort Key: dequeued_rows.uuid
  • Sort Method: quicksort Memory: 76kB
22. 3.301 3.301 ↓ 5.0 100 1

CTE Scan on dequeued_rows (cost=0.00..0.40 rows=20 width=234) (actual time=2.184..3.301 rows=100 loops=1)

  • Output: dequeued_rows.uuid, dequeued_rows.properties, dequeued_rows.updated_at, dequeued_rows."exists", dequeued_rows.deleted, dequeued_rows.dirty_field_ids, dequeued_rows.dirty_rel_ids, dequeued_rows."counter.apptopia_total_apps", dequeued_rows."counter.investor_prediction_num_investors", dequeued_rows."counter.num_acquisitions", dequeued_rows."counter.num_alumni", dequeued_rows."counter.num_articles", dequeued_rows."counter.num_current_advisor_positions", dequeued_rows."counter.num_current_positions", dequeued_rows."counter.num_diversity_spotlight_investments", dequeued_rows."counter.num_event_appearances", dequeued_rows."counter.num_exits", dequeued_rows."counter.num_exits_ipo", dequeued_rows."counter.num_founder_alumni", dequeued_rows."counter.num_founders", dequeued_rows."counter.num_funding_rounds", dequeued_rows."counter.num_funds", dequeued_rows."counter.num_investments", dequeued_rows."counter.num_investments_funding_rounds", dequeued_rows."counter.num_investors", dequeued_rows."counter.num_lead_investments", dequeued_rows."counter.num_lead_investors", dequeued_rows."counter.num_parent_organizations", dequeued_rows."counter.num_past_positions", dequeued_rows."counter.num_portfolio_organizations", dequeued_rows."counter.num_relationships", dequeued_rows."counter.num_sub_organizations", dequeued_rows."counter.num_was_acquired", dequeued_rows."counter.num_went_public", dequeued_rows."counter.siftery_num_product_creates
23. 1.450 1.450 ↑ 1.0 1 50

Index Scan using "idx.organizations.uuid.6" on "state.p"."organizations.6" state (cost=0.42..4.44 rows=1 width=407) (actual time=0.029..0.029 rows=1 loops=50)

  • Output: state.uuid, state.partition, state."exists", state.deleted, state.properties, state.change_count, state.updated_at
  • Index Cond: (state.uuid = dequeued_rows.uuid)
24.          

CTE merged_properties_diff

25. 13.730 157.180 ↓ 2.5 50 1

CTE Scan on merged_properties (cost=0.00..70.95 rows=20 width=191) (actual time=6.620..157.180 rows=50 loops=1)

  • Output: merged_properties.uuid, merged_properties.old_exists, merged_properties.new_exists, merged_properties.new_deleted, merged_properties.old_properties, jsonb_strip_nulls(merged_properties.new_properties), (SubPlan 6), merged_properties.change_count, merged_properties.dirty_field_ids, merged_properties.dirty_rel_ids, merged_properties.updated_at
  • Filter: ((merged_properties.old_exists <> merged_properties.new_exists) OR (merged_properties.old_deleted <> merged_properties.new_deleted) OR (array_length((SubPlan 7), 1) > 0) OR (array_length(merged_properties.dirty_field_ids, 1) > 0) OR (array_length(merged_properties.dirty_rel_ids, 1) > 0))
26.          

SubPlan (for CTE Scan)

27. 70.400 70.400 ↑ 25.0 4 50

Function Scan on pg_catalog.jsonb_object_keys (cost=0.25..1.75 rows=100 width=4) (actual time=1.405..1.408 rows=4 loops=50)

  • Output: (jsonb_object_keys.jsonb_object_keys)::"state.q"."organization.field_ids
  • Function Call: jsonb_object_keys(jsonb_minus(merged_properties.new_properties, merged_properties.old_properties))
28. 73.050 73.050 ↑ 25.0 4 50

Function Scan on pg_catalog.jsonb_object_keys jsonb_object_keys_1 (cost=0.25..1.75 rows=100 width=4) (actual time=1.457..1.461 rows=4 loops=50)

  • Output: (jsonb_object_keys_1.jsonb_object_keys)::"state.q"."organization.field_ids
  • Function Call: jsonb_object_keys(jsonb_minus(merged_properties.new_properties, merged_properties.old_properties))
29.          

CTE mutated_rows

30. 14.059 172.130 ↓ 2.5 50 1

Insert on "state.p"."organizations.6" state_1 (cost=0.00..0.45 rows=20 width=66) (actual time=7.122..172.130 rows=50 loops=1)

  • Output: true
  • Conflict Resolution: UPDATE
  • Conflict Arbiter Indexes: idx.organizations.uuid.6
  • Tuples Inserted: 0
  • Conflicting Tuples: 50
31. 158.071 158.071 ↓ 2.5 50 1

CTE Scan on merged_properties_diff (cost=0.00..0.45 rows=20 width=66) (actual time=6.644..158.071 rows=50 loops=1)

  • Output: merged_properties_diff.uuid, 6, merged_properties_diff.new_exists, merged_properties_diff.new_deleted, merged_properties_diff.new_properties, merged_properties_diff.change_count, merged_properties_diff.updated_at
  • Filter: (merged_properties_diff.new_deleted OR (merged_properties_diff.new_properties <> merged_properties_diff.old_properties))
32.          

CTE field_aliases.organization

33. 0.003 0.075 ↓ 0.0 0 1

Insert on "state.qp"."organizations.6" "organizations.6_1" (cost=0.00..0.98 rows=2 width=239) (actual time=0.073..0.075 rows=0 loops=1)

  • Output: "organizations.6_1".partition
34. 0.001 0.072 ↓ 0.0 0 1

Result (cost=0.00..0.98 rows=2 width=239) (actual time=0.072..0.072 rows=0 loops=1)

  • Output: "*SELECT* 1".uuid, "*SELECT* 1"."?column?", false, false, "*SELECT* 1".jsonb_build_object, "*SELECT* 1".bool, NULL::"state.q"."organization.field_ids"[], NULL::rel_id[], NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, now()
35. 0.003 0.071 ↓ 0.0 0 1

Append (cost=0.00..0.95 rows=2 width=53) (actual time=0.070..0.071 rows=0 loops=1)

36. 0.002 0.037 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1 (cost=0.00..0.48 rows=1 width=53) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: "*SELECT* 1".uuid, "*SELECT* 1"."?column?", "*SELECT* 1".jsonb_build_object, "*SELECT* 1".bool
37. 0.035 0.035 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_1 (cost=0.00..0.47 rows=1 width=53) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_1.uuid, 6, true, jsonb_build_object('identifier', jsonb_build_object('permalink', (merged_properties_diff_1.new_properties -> 'permalink'::text), 'image_id', (merged_properties_diff_1.new_properties -> 'image_id'::text), 'uuid', (merged_properties_diff_1.new_properties -> 'uuid'::text), 'entity_def_id', (merged_properties_diff_1.new_properties -> 'entity_def_id'::text), 'value', (merged_properties_diff_1.new_properties -> 'name'::text)))
  • Filter: (merged_properties_diff_1.changed_field_ids && '{permalink,image_id,uuid,entity_def_id,name}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
38. 0.001 0.031 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2 (cost=0.00..0.46 rows=1 width=53) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: "*SELECT* 2".uuid, "*SELECT* 2"."?column?", "*SELECT* 2".jsonb_build_object, "*SELECT* 2".bool
39. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_2 (cost=0.00..0.45 rows=1 width=53) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_2.uuid, 6, true, jsonb_build_object('title', (merged_properties_diff_2.new_properties -> 'name'::text))
  • Filter: (merged_properties_diff_2.changed_field_ids && '{name}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
40.          

CTE featured_order.employees_featured_order.job

41. 0.003 0.052 ↓ 0.0 0 1

Insert on "state.q".jobs (cost=2.09..91.37 rows=1 width=131) (actual time=0.050..0.052 rows=0 loops=1)

  • Output: jobs.partition
42.          

CTE extracted_featured_properties

43. 0.035 0.035 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_3 (cost=0.00..1.11 rows=1 width=80) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_3.uuid, (jsonb_array_elements_text(merged_properties_diff_3.old_properties, 'employees_featured_order'::text))::uuid[], (jsonb_array_elements_text(merged_properties_diff_3.new_properties, 'employees_featured_order'::text))::uuid[]
  • Filter: ((merged_properties_diff_3.changed_field_ids && '{employees_featured_order}'::"state.q"."organization.field_ids"[]) OR (merged_properties_diff_3.dirty_rel_ids && '{has_position}'::rel_id[]))
  • Rows Removed by Filter: 50
44. 0.001 0.049 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.98..90.26 rows=1 width=131) (actual time=0.049..0.049 rows=0 loops=1)

  • Output: (unnest(extracted_featured_properties_1."new.employees_featured_order")), rel.target_partition, false, false, jsonb_build_object('employee_featured_order', (ord.new_position - 1)), true, NULL::"state.q"."job.field_ids"[], NULL::rel_id[], NULL::integer, now()
  • Join Filter: ((unnest(extracted_featured_properties_1."new.employees_featured_order")) = ord.target)
45. 0.002 0.048 ↓ 0.0 0 1

Nested Loop (cost=0.98..89.91 rows=1 width=20) (actual time=0.047..0.048 rows=0 loops=1)

  • Output: (unnest(extracted_featured_properties_1."new.employees_featured_order")), rel.target_partition
  • Inner Unique: true
46. 0.002 0.046 ↓ 0.0 0 1

HashAggregate (cost=0.55..0.75 rows=20 width=32) (actual time=0.046..0.046 rows=0 loops=1)

  • Output: extracted_featured_properties_1.uuid, (unnest(extracted_featured_properties_1."new.employees_featured_order"))
  • Group Key: extracted_featured_properties_1.uuid, (unnest(extracted_featured_properties_1."new.employees_featured_order"))
47. 0.002 0.044 ↓ 0.0 0 1

Append (cost=0.00..0.45 rows=20 width=32) (actual time=0.043..0.044 rows=0 loops=1)

48. 0.002 0.039 ↓ 0.0 0 1

ProjectSet (cost=0.00..0.08 rows=10 width=32) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: extracted_featured_properties_1.uuid, unnest(extracted_featured_properties_1."new.employees_featured_order")
49. 0.037 0.037 ↓ 0.0 0 1

CTE Scan on extracted_featured_properties extracted_featured_properties_1 (cost=0.00..0.02 rows=1 width=48) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: extracted_featured_properties_1.uuid, extracted_featured_properties_1."old.employees_featured_order", extracted_featured_properties_1."new.employees_featured_order
50. 0.001 0.003 ↓ 0.0 0 1

ProjectSet (cost=0.00..0.08 rows=10 width=32) (actual time=0.003..0.003 rows=0 loops=1)

  • Output: extracted_featured_properties_2.uuid, unnest(extracted_featured_properties_2."old.employees_featured_order")
51. 0.002 0.002 ↓ 0.0 0 1

CTE Scan on extracted_featured_properties extracted_featured_properties_2 (cost=0.00..0.02 rows=1 width=48) (actual time=0.001..0.002 rows=0 loops=1)

  • Output: extracted_featured_properties_2.uuid, extracted_featured_properties_2."old.employees_featured_order", extracted_featured_properties_2."new.employees_featured_order
52. 0.000 0.000 ↓ 0.0 0

Index Scan using "rel.has_position.target_source" on public."rel.has_position" rel (cost=0.43..4.45 rows=1 width=36) (never executed)

  • Output: rel.source_partition, rel.source_entity_def_id, rel.source, rel.target_partition, rel.target_entity_def_id, rel.target
  • Index Cond: ((rel.target = (unnest(extracted_featured_properties_1."new.employees_featured_order"))) AND (rel.source = extracted_featured_properties_1.uuid))
53. 0.000 0.000 ↓ 0.0 0

Nested Loop (cost=0.00..0.22 rows=10 width=24) (never executed)

  • Output: ord.new_position, ord.target
54. 0.000 0.000 ↓ 0.0 0

CTE Scan on extracted_featured_properties (cost=0.00..0.02 rows=1 width=32) (never executed)

  • Output: extracted_featured_properties.uuid, extracted_featured_properties."old.employees_featured_order", extracted_featured_properties."new.employees_featured_order
55. 0.000 0.000 ↓ 0.0 0

Function Scan on pg_catalog.unnest ord (cost=0.00..0.10 rows=10 width=24) (never executed)

  • Output: ord.target, ord.new_position
  • Function Call: unnest(extracted_featured_properties."new.employees_featured_order")
56.          

CTE featured_order.advisors_featured_order.job

57. 0.002 0.051 ↓ 0.0 0 1

Insert on "state.q".jobs jobs_1 (cost=2.09..91.37 rows=1 width=131) (actual time=0.050..0.051 rows=0 loops=1)

  • Output: jobs_1.partition
58.          

CTE extracted_featured_properties

59. 0.035 0.035 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_4 (cost=0.00..1.11 rows=1 width=80) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_4.uuid, (jsonb_array_elements_text(merged_properties_diff_4.old_properties, 'advisors_featured_order'::text))::uuid[], (jsonb_array_elements_text(merged_properties_diff_4.new_properties, 'advisors_featured_order'::text))::uuid[]
  • Filter: ((merged_properties_diff_4.changed_field_ids && '{advisors_featured_order}'::"state.q"."organization.field_ids"[]) OR (merged_properties_diff_4.dirty_rel_ids && '{has_position}'::rel_id[]))
  • Rows Removed by Filter: 50
60. 0.002 0.049 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.98..90.26 rows=1 width=131) (actual time=0.048..0.049 rows=0 loops=1)

  • Output: (unnest(extracted_featured_properties_4."new.advisors_featured_order")), rel_1.target_partition, false, false, jsonb_build_object('advisor_featured_order', (ord_1.new_position - 1)), true, NULL::"state.q"."job.field_ids"[], NULL::rel_id[], NULL::integer, now()
  • Join Filter: ((unnest(extracted_featured_properties_4."new.advisors_featured_order")) = ord_1.target)
61. 0.002 0.047 ↓ 0.0 0 1

Nested Loop (cost=0.98..89.91 rows=1 width=20) (actual time=0.046..0.047 rows=0 loops=1)

  • Output: (unnest(extracted_featured_properties_4."new.advisors_featured_order")), rel_1.target_partition
  • Inner Unique: true
62. 0.002 0.045 ↓ 0.0 0 1

HashAggregate (cost=0.55..0.75 rows=20 width=32) (actual time=0.045..0.045 rows=0 loops=1)

  • Output: extracted_featured_properties_4.uuid, (unnest(extracted_featured_properties_4."new.advisors_featured_order"))
  • Group Key: extracted_featured_properties_4.uuid, (unnest(extracted_featured_properties_4."new.advisors_featured_order"))
63. 0.002 0.043 ↓ 0.0 0 1

Append (cost=0.00..0.45 rows=20 width=32) (actual time=0.043..0.043 rows=0 loops=1)

64. 0.001 0.038 ↓ 0.0 0 1

ProjectSet (cost=0.00..0.08 rows=10 width=32) (actual time=0.038..0.038 rows=0 loops=1)

  • Output: extracted_featured_properties_4.uuid, unnest(extracted_featured_properties_4."new.advisors_featured_order")
65. 0.037 0.037 ↓ 0.0 0 1

CTE Scan on extracted_featured_properties extracted_featured_properties_4 (cost=0.00..0.02 rows=1 width=48) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: extracted_featured_properties_4.uuid, extracted_featured_properties_4."old.advisors_featured_order", extracted_featured_properties_4."new.advisors_featured_order
66. 0.002 0.003 ↓ 0.0 0 1

ProjectSet (cost=0.00..0.08 rows=10 width=32) (actual time=0.002..0.003 rows=0 loops=1)

  • Output: extracted_featured_properties_5.uuid, unnest(extracted_featured_properties_5."old.advisors_featured_order")
67. 0.001 0.001 ↓ 0.0 0 1

CTE Scan on extracted_featured_properties extracted_featured_properties_5 (cost=0.00..0.02 rows=1 width=48) (actual time=0.001..0.001 rows=0 loops=1)

  • Output: extracted_featured_properties_5.uuid, extracted_featured_properties_5."old.advisors_featured_order", extracted_featured_properties_5."new.advisors_featured_order
68. 0.000 0.000 ↓ 0.0 0

Index Scan using "rel.has_position.target_source" on public."rel.has_position" rel_1 (cost=0.43..4.45 rows=1 width=36) (never executed)

  • Output: rel_1.source_partition, rel_1.source_entity_def_id, rel_1.source, rel_1.target_partition, rel_1.target_entity_def_id, rel_1.target
  • Index Cond: ((rel_1.target = (unnest(extracted_featured_properties_4."new.advisors_featured_order"))) AND (rel_1.source = extracted_featured_properties_4.uuid))
69. 0.000 0.000 ↓ 0.0 0

Nested Loop (cost=0.00..0.22 rows=10 width=24) (never executed)

  • Output: ord_1.new_position, ord_1.target
70. 0.000 0.000 ↓ 0.0 0

CTE Scan on extracted_featured_properties extracted_featured_properties_3 (cost=0.00..0.02 rows=1 width=32) (never executed)

  • Output: extracted_featured_properties_3.uuid, extracted_featured_properties_3."old.advisors_featured_order", extracted_featured_properties_3."new.advisors_featured_order
71. 0.000 0.000 ↓ 0.0 0

Function Scan on pg_catalog.unnest ord_1 (cost=0.00..0.10 rows=10 width=24) (never executed)

  • Output: ord_1.target, ord_1.new_position
  • Function Call: unnest(extracted_featured_properties_3."new.advisors_featured_order")
72.          

CTE sinister.dequeued.195d7065.has_investor_diversity_spot

73. 0.002 0.017 ↓ 0.0 0 1

Delete on "state.qp"."organizations.sinister.has_investor_diversity_spot.source.6" (cost=0.00..11.60 rows=1,060 width=6) (actual time=0.016..0.017 rows=0 loops=1)

  • Output: "organizations.sinister.has_investor_diversity_spot.source.6".source_partition, "organizations.sinister.has_investor_diversity_spot.source.6".source_entity_def_id, "organizations.sinister.has_investor_diversity_spot.source.6".source, "organizations.sinister.has_investor_diversity_spot.source.6".target_partition, "organizations.sinister.has_investor_diversity_spot.source.6".target_entity_def_id, "organizations.sinister.has_investor_diversity_spot.source.6".target, "organizations.sinister.has_investor_diversity_spot.source.6".deleted
74. 0.015 0.015 ↓ 0.0 0 1

Seq Scan on "state.qp"."organizations.sinister.has_investor_diversity_spot.source.6" (cost=0.00..11.60 rows=1,060 width=6) (actual time=0.014..0.015 rows=0 loops=1)

  • Output: "organizations.sinister.has_investor_diversity_spot.source.6".ctid
75.          

CTE dexter.dequeued.195d7065.has_investor_diversity_spot

76. 0.002 0.011 ↓ 0.0 0 1

Delete on "state.qp"."organizations.dexter.has_investor_diversity_spot.source.6" (cost=0.00..11.60 rows=1,060 width=6) (actual time=0.010..0.011 rows=0 loops=1)

  • Output: "organizations.dexter.has_investor_diversity_spot.source.6".source_partition, "organizations.dexter.has_investor_diversity_spot.source.6".source_entity_def_id, "organizations.dexter.has_investor_diversity_spot.source.6".source, "organizations.dexter.has_investor_diversity_spot.source.6".target_partition, "organizations.dexter.has_investor_diversity_spot.source.6".target_entity_def_id, "organizations.dexter.has_investor_diversity_spot.source.6".target, "organizations.dexter.has_investor_diversity_spot.source.6".deleted
77. 0.009 0.009 ↓ 0.0 0 1

Seq Scan on "state.qp"."organizations.dexter.has_investor_diversity_spot.source.6" (cost=0.00..11.60 rows=1,060 width=6) (actual time=0.008..0.009 rows=0 loops=1)

  • Output: "organizations.dexter.has_investor_diversity_spot.source.6".ctid
78.          

CTE jump_rel.enqueued.195d7065.has_investor_diversity_spot

79. 0.003 0.116 ↓ 0.0 0 1

Insert on "state.q"."rel.has_investor_diversity_spot" (cost=76.09..642,074.89 rows=10,040 width=61) (actual time=0.115..0.116 rows=0 loops=1)

  • Output: "rel.has_investor_diversity_spot".source_partition
80. 0.001 0.113 ↓ 0.0 0 1

Result (cost=76.09..642,074.89 rows=10,040 width=61) (actual time=0.113..0.113 rows=0 loops=1)

  • Output: sinister.target_partition, sinister.target_entity_def_id, sinister.target, dexter.target_partition, dexter.target_entity_def_id, dexter.target, (false), nextval('"state.q"."rel.has_investor_diversity_spot_serial_id_seq"'::regclass), now()
81. 0.003 0.112 ↓ 0.0 0 1

Append (cost=76.09..641,874.09 rows=10,040 width=49) (actual time=0.111..0.112 rows=0 loops=1)

82. 0.006 0.027 ↓ 0.0 0 1

HashAggregate (cost=76.09..84.17 rows=808 width=49) (actual time=0.026..0.027 rows=0 loops=1)

  • Output: sinister.target_partition, sinister.target_entity_def_id, sinister.target, dexter.target_partition, dexter.target_entity_def_id, dexter.target, (false)
  • Group Key: sinister.target_partition, sinister.target_entity_def_id, sinister.target, dexter.target_partition, dexter.target_entity_def_id, dexter.target, false
83. 0.002 0.021 ↓ 0.0 0 1

Hash Join (cost=27.37..61.95 rows=808 width=49) (actual time=0.020..0.021 rows=0 loops=1)

  • Output: sinister.target_partition, sinister.target_entity_def_id, sinister.target, dexter.target_partition, dexter.target_entity_def_id, dexter.target, false
  • Hash Cond: (sinister.source = dexter.source)
84. 0.019 0.019 ↓ 0.0 0 1

CTE Scan on "sinister.dequeued.195d7065.has_investor_diversity_spot" sinister (cost=0.00..21.20 rows=530 width=40) (actual time=0.018..0.019 rows=0 loops=1)

  • Output: sinister.source_partition, sinister.source_entity_def_id, sinister.source, sinister.target_partition, sinister.target_entity_def_id, sinister.target, sinister.deleted
  • Filter: (NOT sinister.deleted)
85. 0.000 0.000 ↓ 0.0 0

Hash (cost=14.94..14.94 rows=994 width=40) (never executed)

  • Output: dexter.target_partition, dexter.target_entity_def_id, dexter.target, dexter.source
86. 0.000 0.000 ↓ 0.0 0

Seq Scan on public."rel.has_diversity_spotlight" dexter (cost=0.00..14.94 rows=994 width=40) (never executed)

  • Output: dexter.target_partition, dexter.target_entity_def_id, dexter.target, dexter.source
87. 0.020 0.034 ↓ 0.0 0 1

HashAggregate (cost=5,795.75..5,825.74 rows=2,999 width=49) (actual time=0.034..0.034 rows=0 loops=1)

  • Output: sinister_1.target_partition, sinister_1.target_entity_def_id, sinister_1.target, dexter_1.target_partition, dexter_1.target_entity_def_id, dexter_1.target, (false)
  • Group Key: sinister_1.target_partition, sinister_1.target_entity_def_id, sinister_1.target, dexter_1.target_partition, dexter_1.target_entity_def_id, dexter_1.target, false
88. 0.001 0.014 ↓ 0.0 0 1

Nested Loop (cost=0.42..5,743.26 rows=2,999 width=49) (actual time=0.014..0.014 rows=0 loops=1)

  • Output: sinister_1.target_partition, sinister_1.target_entity_def_id, sinister_1.target, dexter_1.target_partition, dexter_1.target_entity_def_id, dexter_1.target, false
89. 0.013 0.013 ↓ 0.0 0 1

CTE Scan on "dexter.dequeued.195d7065.has_investor_diversity_spot" dexter_1 (cost=0.00..21.20 rows=530 width=40) (actual time=0.012..0.013 rows=0 loops=1)

  • Output: dexter_1.source_partition, dexter_1.source_entity_def_id, dexter_1.source, dexter_1.target_partition, dexter_1.target_entity_def_id, dexter_1.target, dexter_1.deleted
  • Filter: (NOT dexter_1.deleted)
90. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_investor" on public."rel.has_investor" sinister_1 (cost=0.42..10.74 rows=6 width=40) (never executed)

  • Output: sinister_1.source_partition, sinister_1.source_entity_def_id, sinister_1.source, sinister_1.target_partition, sinister_1.target_entity_def_id, sinister_1.target
  • Index Cond: (sinister_1.source = dexter_1.source)
91. 0.012 0.031 ↓ 0.0 0 1

Hash Join (cost=27.82..51,528.98 rows=502 width=49) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: pub.source_partition, pub.source_entity_def_id, pub.source, pub.target_partition, pub.target_entity_def_id, pub.target, true
  • Hash Cond: (pub.source = sinister_2.target)
  • Join Filter: (SubPlan 17)
92. 0.015 0.015 ↑ 4,325.0 1 1

Seq Scan on public."rel.has_investor_diversity_spot" pub (cost=0.00..52.75 rows=4,325 width=48) (actual time=0.015..0.015 rows=1 loops=1)

  • Output: pub.source_partition, pub.source_entity_def_id, pub.source, pub.target_partition, pub.target_entity_def_id, pub.target
93. 0.002 0.004 ↓ 0.0 0 1

Hash (cost=21.20..21.20 rows=530 width=32) (actual time=0.004..0.004 rows=0 loops=1)

  • Output: sinister_2.target, sinister_2.source
  • Buckets: 1,024 Batches: 1 Memory Usage: 8kB
94. 0.002 0.002 ↓ 0.0 0 1

CTE Scan on "sinister.dequeued.195d7065.has_investor_diversity_spot" sinister_2 (cost=0.00..21.20 rows=530 width=32) (actual time=0.001..0.002 rows=0 loops=1)

  • Output: sinister_2.target, sinister_2.source
  • Filter: sinister_2.deleted
95.          

SubPlan (for Hash Join)

96. 0.000 0.000 ↓ 0.0 0

Aggregate (cost=50.92..50.94 rows=1 width=1) (never executed)

  • Output: (count(*) = 0)
97. 0.000 0.000 ↓ 0.0 0

Hash Join (cost=43.74..50.92 rows=1 width=0) (never executed)

  • Inner Unique: true
  • Hash Cond: (inner_dexter.source = inner_sinister.source)
98. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_diversity_spotlight" inner_dexter (cost=5.24..12.10 rows=124 width=16) (never executed)

  • Output: inner_dexter.source_partition, inner_dexter.source_entity_def_id, inner_dexter.source, inner_dexter.target_partition, inner_dexter.target_entity_def_id, inner_dexter.target
  • Recheck Cond: (inner_dexter.target = pub.target)
  • Filter: (inner_dexter.source <> pub.target)
99. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "rel.has_diversity_spotlight.target_source" (cost=0.00..5.21 rows=124 width=0) (never executed)

  • Index Cond: (inner_dexter.target = pub.target)
100. 0.000 0.000 ↓ 0.0 0

Hash (cost=38.26..38.26 rows=19 width=16) (never executed)

  • Output: inner_sinister.source
101. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_investor" inner_sinister (cost=2.57..38.26 rows=19 width=16) (never executed)

  • Output: inner_sinister.source
  • Recheck Cond: (inner_sinister.target = sinister_2.target)
  • Filter: (inner_sinister.source <> sinister_2.source)
102. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "rel.has_investor.target_source" (cost=0.00..2.56 rows=19 width=0) (never executed)

  • Index Cond: (inner_sinister.target = sinister_2.target)
103. 0.008 0.017 ↓ 0.0 0 1

Hash Join (cost=27.82..584,284.61 rows=5,731 width=49) (actual time=0.016..0.017 rows=0 loops=1)

  • Output: pub_1.source_partition, pub_1.source_entity_def_id, pub_1.source, pub_1.target_partition, pub_1.target_entity_def_id, pub_1.target, true
  • Hash Cond: (pub_1.target = dexter_2.target)
  • Join Filter: (SubPlan 18)
104. 0.006 0.006 ↑ 4,325.0 1 1

Seq Scan on public."rel.has_investor_diversity_spot" pub_1 (cost=0.00..52.75 rows=4,325 width=48) (actual time=0.006..0.006 rows=1 loops=1)

  • Output: pub_1.source_partition, pub_1.source_entity_def_id, pub_1.source, pub_1.target_partition, pub_1.target_entity_def_id, pub_1.target
105. 0.001 0.003 ↓ 0.0 0 1

Hash (cost=21.20..21.20 rows=530 width=32) (actual time=0.003..0.003 rows=0 loops=1)

  • Output: dexter_2.target, dexter_2.source
  • Buckets: 1,024 Batches: 1 Memory Usage: 8kB
106. 0.002 0.002 ↓ 0.0 0 1

CTE Scan on "dexter.dequeued.195d7065.has_investor_diversity_spot" dexter_2 (cost=0.00..21.20 rows=530 width=32) (actual time=0.001..0.002 rows=0 loops=1)

  • Output: dexter_2.target, dexter_2.source
  • Filter: dexter_2.deleted
107.          

SubPlan (for Hash Join)

108. 0.000 0.000 ↓ 0.0 0

Aggregate (cost=50.92..50.94 rows=1 width=1) (never executed)

  • Output: (count(*) = 0)
109. 0.000 0.000 ↓ 0.0 0

Hash Join (cost=43.74..50.92 rows=1 width=0) (never executed)

  • Inner Unique: true
  • Hash Cond: (inner_dexter_1.source = inner_sinister_1.source)
110. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_diversity_spotlight" inner_dexter_1 (cost=5.24..12.10 rows=124 width=16) (never executed)

  • Output: inner_dexter_1.source_partition, inner_dexter_1.source_entity_def_id, inner_dexter_1.source, inner_dexter_1.target_partition, inner_dexter_1.target_entity_def_id, inner_dexter_1.target
  • Recheck Cond: (inner_dexter_1.target = dexter_2.target)
  • Filter: (inner_dexter_1.source <> dexter_2.source)
111. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "rel.has_diversity_spotlight.target_source" (cost=0.00..5.21 rows=124 width=0) (never executed)

  • Index Cond: (inner_dexter_1.target = dexter_2.target)
112. 0.000 0.000 ↓ 0.0 0

Hash (cost=38.26..38.26 rows=19 width=16) (never executed)

  • Output: inner_sinister_1.source
113. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_investor" inner_sinister_1 (cost=2.57..38.26 rows=19 width=16) (never executed)

  • Output: inner_sinister_1.source
  • Recheck Cond: (inner_sinister_1.target = pub_1.source)
  • Filter: (inner_sinister_1.source <> pub_1.source)
114. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "rel.has_investor.target_source" (cost=0.00..2.56 rows=19 width=0) (never executed)

  • Index Cond: (inner_sinister_1.target = pub_1.source)
115.          

CTE sink_enqueue.elastic.organization

116. 15.531 15.877 ↓ 5.6 50 1

Insert on "elastic.qp"."organizations.6" "organizations.6_2" (cost=0.00..2.77 rows=9 width=61) (actual time=15.292..15.877 rows=50 loops=1)

  • Output: "organizations.6_2".partition
117. 0.065 0.346 ↓ 5.6 50 1

Append (cost=0.00..2.77 rows=9 width=61) (actual time=0.014..0.346 rows=50 loops=1)

118. 0.255 0.255 ↓ 8.3 50 1

CTE Scan on merged_properties_diff merged_properties_diff_5 (cost=0.00..0.46 rows=6 width=61) (actual time=0.012..0.255 rows=50 loops=1)

  • Output: merged_properties_diff_5.uuid, 6, (merged_properties_diff_5.changed_field_ids && '{num_past_positions,last_funding_at,school_method,num_founder_alumni,num_investments_funding_rounds,founder_identifiers,num_exits_ipo,valuation_date,num_lead_investments,extended_description,ipo_amount_raised,funding_total,program_application_deadline,num_parent_organizations,acquisition_price,demo_days,short_description,facebook,revenue_range,num_current_positions,ipo_share_price,school_type,investor_stage,hub_tags,num_relationships,num_diversity_spotlight_investments,num_articles,linkedin,phone_number,stock_symbol,acquisition_announced_on,admin_notes,last_funding_type,location_group_identifiers,exited_on,founded_on,hubs,acquisition_status,num_lead_investors,funds_total,website,program_duration,went_public_on,last_equity_funding_type,diversity_spotlights,aliases,investor_identifiers,closed_on,num_enrollments,override_layout_id,image_url,contact_email,email_domains,funding_stage,permalink,owner_identifier,num_funding_rounds,num_employees_enum,listed_stock_symbol,num_alumni,last_equity_funding_total,num_portfolio_organizations,company_type,acquisition_identifier,num_was_acquired,equity_funding_total,title,legal_name,num_founders,num_investors,is_locked,ipo_status,advisors_featured_order,acquisition_terms,investor_type,valuation,stock_link,ipo_valuation,num_investments,category_groups,school_program,permalink_aliases,num_went_public,website_url,acquirer_identifier,identifier,operating_status,image_id,employees_featured_order,categories,location_identifiers,layout_id,name,num_funds,num_current_advisor_positions,acquisition_type,num_event_appearances,stock_exchange_symbol,num_exits,twitter,num_acquisitions,delisted_on,description,program_type,status,num_sub_organizations,last_funding_total}'::"state.q"."organization.field_ids"[]), merged_properties_diff_5.changed_field_ids, merged_properties_diff_5.updated_at
  • Filter: (merged_properties_diff_5.old_exists AND (merged_properties_diff_5.changed_field_ids && '{aberdeen_last_updated,aberdeen_site_communications_spend,aberdeen_site_it_spend,aberdeen_site_other_hardware_spend,aberdeen_site_other_it_spend,aberdeen_site_pc_spend,aberdeen_site_server_spend,aberdeen_site_services_spend,aberdeen_site_software_spend,aberdeen_site_storage_spend,acquirer_identifier,acquisition_announced_on,acquisition_identifier,acquisition_price,acquisition_status,acquisition_terms,acquisition_type,admin_notes,advisors_featured_order,aliases,apptopia_last_updated,apptopia_total_apps,apptopia_total_downloads,apptopia_total_downloads_mom_pct,bombora_last_updated,builtwith_num_technologies_not_used,builtwith_num_technologies_used,builtwith_technologies_used_mom_pct,builtwith_updated_at,categories,category_groups,closed_on,company_type,contact_email,created_at,delisted_on,demo_days,description,diversity_spotlights,email_domains,employees_featured_order,entity_def_id,equity_funding_total,exited_on,extended_description,facebook,facet_ids,founded_on,founder_identifiers,funding_stage,funding_total,funds_total,hub_tags,hubs,identifier,image_id,image_url,investor_identifiers,investor_prediction_num_investors,investor_prediction_target_round,investor_stage,investor_type,ipo_amount_raised,ipo_share_price,ipo_status,ipo_valuation,ipqwery_ip_score,ipqwery_last_updated,ipqwery_num_both_total,ipqwery_num_patent_granted,ipqwery_num_patent_pending,ipqwery_num_patent_total,ipqwery_num_trademark_pending,ipqwery_num_trademark_registered,ipqwery_num_trademark_total,ipqwery_popular_patent_category,ipqwery_popular_patent_class,ipqwery_popular_trademark_class,is_locked,last_equity_funding_total,last_equity_funding_type,last_funding_at,last_funding_total,last_funding_type,last_key_employee_change_date,last_layoff_date,layout_id,legal_name,linkedin,listed_stock_symbol,location_group_identifiers,location_identifiers,name,num_acquisitions,num_alumni,num_articles,num_current_advisor_positions,num_current_positions,num_diversity_spotlight_investments,num_employees_enum,num_enrollments,num_event_appearances,num_exits,num_exits_ipo,num_founder_alumni,num_founders,num_funding_rounds,num_funds,num_investments,num_investments_funding_rounds,num_investors,num_lead_investments,num_lead_investors,num_parent_organizations,num_past_positions,num_portfolio_organizations,num_relationships,num_sub_organizations,num_was_acquired,num_went_public,operating_status,override_layout_id,owner_identifier,permalink,permalink_aliases,phone_number,privco_funding_round_title,privco_growth_percentile,privco_last_updated,privco_valuation,privco_valuation_range,privco_valuation_timestamp,program_application_deadline,program_duration,program_type,rank,rank_delta_d30,rank_delta_d7,rank_delta_d90,rank_org,rank_org_company,rank_org_school,rank_principal,rank_principal_investor,revenue_range,school_method,school_program,school_type,short_description,siftery_last_updated,siftery_num_product_creates,siftery_num_product_mom_pct,siftery_num_products,similarweb_bounce_rate,similarweb_bounce_rate_mom_pct,similarweb_global_rank,similarweb_global_rank_mom,similarweb_global_rank_mom_pct,similarweb_last_updated,similarweb_visit_duration,similarweb_visit_duration_mom_pct,similarweb_visit_pageview_mom_pct,similarweb_visit_pageviews,similarweb_visits_latest_6_months_avg,similarweb_visits_latest_month,similarweb_visits_mom_pct,status,stock_exchange_symbol,stock_link,stock_symbol,title,twitter,updated_at,uuid,valuation,valuation_date,website,website_url,went_public_on}'::"state.q"."organization.field_ids"[]))
119. 0.026 0.026 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_6 (cost=0.00..2.17 rows=3 width=61) (actual time=0.025..0.026 rows=0 loops=1)

  • Output: merged_properties_diff_6.uuid, 6, (merged_properties_diff_6.changed_field_ids && '{num_past_positions,last_funding_at,school_method,num_founder_alumni,num_investments_funding_rounds,founder_identifiers,num_exits_ipo,valuation_date,num_lead_investments,extended_description,ipo_amount_raised,funding_total,program_application_deadline,num_parent_organizations,acquisition_price,demo_days,short_description,facebook,revenue_range,num_current_positions,ipo_share_price,school_type,investor_stage,hub_tags,num_relationships,num_diversity_spotlight_investments,num_articles,linkedin,phone_number,stock_symbol,acquisition_announced_on,admin_notes,last_funding_type,location_group_identifiers,exited_on,founded_on,hubs,acquisition_status,num_lead_investors,funds_total,website,program_duration,went_public_on,last_equity_funding_type,diversity_spotlights,aliases,investor_identifiers,closed_on,num_enrollments,override_layout_id,image_url,contact_email,email_domains,funding_stage,permalink,owner_identifier,num_funding_rounds,num_employees_enum,listed_stock_symbol,num_alumni,last_equity_funding_total,num_portfolio_organizations,company_type,acquisition_identifier,num_was_acquired,equity_funding_total,title,legal_name,num_founders,num_investors,is_locked,ipo_status,advisors_featured_order,acquisition_terms,investor_type,valuation,stock_link,ipo_valuation,num_investments,category_groups,school_program,permalink_aliases,num_went_public,website_url,acquirer_identifier,identifier,operating_status,image_id,employees_featured_order,categories,location_identifiers,layout_id,name,num_funds,num_current_advisor_positions,acquisition_type,num_event_appearances,stock_exchange_symbol,num_exits,twitter,num_acquisitions,delisted_on,description,program_type,status,num_sub_organizations,last_funding_total}'::"state.q"."organization.field_ids"[]), ((SubPlan 20))::"state.q"."organization.field_ids"[], merged_properties_diff_6.updated_at
  • Filter: ((NOT merged_properties_diff_6.old_exists) AND merged_properties_diff_6.new_exists AND (merged_properties_diff_6.changed_field_ids && '{aberdeen_last_updated,aberdeen_site_communications_spend,aberdeen_site_it_spend,aberdeen_site_other_hardware_spend,aberdeen_site_other_it_spend,aberdeen_site_pc_spend,aberdeen_site_server_spend,aberdeen_site_services_spend,aberdeen_site_software_spend,aberdeen_site_storage_spend,acquirer_identifier,acquisition_announced_on,acquisition_identifier,acquisition_price,acquisition_status,acquisition_terms,acquisition_type,admin_notes,advisors_featured_order,aliases,apptopia_last_updated,apptopia_total_apps,apptopia_total_downloads,apptopia_total_downloads_mom_pct,bombora_last_updated,builtwith_num_technologies_not_used,builtwith_num_technologies_used,builtwith_technologies_used_mom_pct,builtwith_updated_at,categories,category_groups,closed_on,company_type,contact_email,created_at,delisted_on,demo_days,description,diversity_spotlights,email_domains,employees_featured_order,entity_def_id,equity_funding_total,exited_on,extended_description,facebook,facet_ids,founded_on,founder_identifiers,funding_stage,funding_total,funds_total,hub_tags,hubs,identifier,image_id,image_url,investor_identifiers,investor_prediction_num_investors,investor_prediction_target_round,investor_stage,investor_type,ipo_amount_raised,ipo_share_price,ipo_status,ipo_valuation,ipqwery_ip_score,ipqwery_last_updated,ipqwery_num_both_total,ipqwery_num_patent_granted,ipqwery_num_patent_pending,ipqwery_num_patent_total,ipqwery_num_trademark_pending,ipqwery_num_trademark_registered,ipqwery_num_trademark_total,ipqwery_popular_patent_category,ipqwery_popular_patent_class,ipqwery_popular_trademark_class,is_locked,last_equity_funding_total,last_equity_funding_type,last_funding_at,last_funding_total,last_funding_type,last_key_employee_change_date,last_layoff_date,layout_id,legal_name,linkedin,listed_stock_symbol,location_group_identifiers,location_identifiers,name,num_acquisitions,num_alumni,num_articles,num_current_advisor_positions,num_current_positions,num_diversity_spotlight_investments,num_employees_enum,num_enrollments,num_event_appearances,num_exits,num_exits_ipo,num_founder_alumni,num_founders,num_funding_rounds,num_funds,num_investments,num_investments_funding_rounds,num_investors,num_lead_investments,num_lead_investors,num_parent_organizations,num_past_positions,num_portfolio_organizations,num_relationships,num_sub_organizations,num_was_acquired,num_went_public,operating_status,override_layout_id,owner_identifier,permalink,permalink_aliases,phone_number,privco_funding_round_title,privco_growth_percentile,privco_last_updated,privco_valuation,privco_valuation_range,privco_valuation_timestamp,program_application_deadline,program_duration,program_type,rank,rank_delta_d30,rank_delta_d7,rank_delta_d90,rank_org,rank_org_company,rank_org_school,rank_principal,rank_principal_investor,revenue_range,school_method,school_program,school_type,short_description,siftery_last_updated,siftery_num_product_creates,siftery_num_product_mom_pct,siftery_num_products,similarweb_bounce_rate,similarweb_bounce_rate_mom_pct,similarweb_global_rank,similarweb_global_rank_mom,similarweb_global_rank_mom_pct,similarweb_last_updated,similarweb_visit_duration,similarweb_visit_duration_mom_pct,similarweb_visit_pageview_mom_pct,similarweb_visit_pageviews,similarweb_visits_latest_6_months_avg,similarweb_visits_latest_month,similarweb_visits_mom_pct,status,stock_exchange_symbol,stock_link,stock_symbol,title,twitter,updated_at,uuid,valuation,valuation_date,website,website_url,went_public_on}'::"state.q"."organization.field_ids"[]))
  • Rows Removed by Filter: 50
120.          

SubPlan (for CTE Scan)

121. 0.000 0.000 ↓ 0.0 0

ProjectSet (cost=0.00..0.52 rows=100 width=32) (never executed)

  • Output: jsonb_object_keys(merged_properties_diff_6.new_properties)
122. 0.000 0.000 ↓ 0.0 0

Result (cost=0.00..0.01 rows=1 width=0) (never executed)

123.          

CTE sink_enqueue.timeseries.organization

124. 15.237 15.480 ↓ 10.0 50 1

Insert on "timeseries.qp"."organizations.6" "organizations.6_3" (cost=0.00..2.13 rows=5 width=61) (actual time=14.954..15.480 rows=50 loops=1)

  • Output: "organizations.6_3".partition
125. 0.065 0.243 ↓ 10.0 50 1

Append (cost=0.00..2.13 rows=5 width=61) (actual time=0.009..0.243 rows=50 loops=1)

126. 0.151 0.151 ↓ 16.7 50 1

CTE Scan on merged_properties_diff merged_properties_diff_7 (cost=0.00..0.46 rows=3 width=61) (actual time=0.008..0.151 rows=50 loops=1)

  • Output: merged_properties_diff_7.uuid, 6, (merged_properties_diff_7.changed_field_ids && '{num_past_positions,num_founder_alumni,num_investments_funding_rounds,num_exits_ipo,num_lead_investments,funding_total,num_current_positions,num_relationships,num_diversity_spotlight_investments,num_articles,num_lead_investors,funds_total,num_funding_rounds,num_alumni,num_portfolio_organizations,equity_funding_total,num_investors,num_investments,num_funds,num_current_advisor_positions,num_event_appearances,num_exits,num_acquisitions,num_sub_organizations,last_funding_total}'::"state.q"."organization.field_ids"[]), merged_properties_diff_7.changed_field_ids, merged_properties_diff_7.updated_at
  • Filter: (merged_properties_diff_7.old_exists AND (merged_properties_diff_7.changed_field_ids && '{aberdeen_last_updated,aberdeen_site_communications_spend,aberdeen_site_it_spend,aberdeen_site_other_hardware_spend,aberdeen_site_other_it_spend,aberdeen_site_pc_spend,aberdeen_site_server_spend,aberdeen_site_services_spend,aberdeen_site_software_spend,aberdeen_site_storage_spend,apptopia_last_updated,apptopia_total_apps,apptopia_total_downloads,apptopia_total_downloads_mom_pct,apptopia_total_downloads_yoy_pct,builtwith_num_technologies_not_used,builtwith_num_technologies_used,builtwith_technologies_used_mom_pct,builtwith_updated_at,equity_funding_total,funding_total,funds_total,ipqwery_ip_score,ipqwery_last_updated,ipqwery_num_both_total,ipqwery_num_patent_granted,ipqwery_num_patent_pending,ipqwery_num_patent_total,ipqwery_num_trademark_pending,ipqwery_num_trademark_registered,ipqwery_num_trademark_total,last_funding_total,num_acquisitions,num_alumni,num_articles,num_current_advisor_positions,num_current_positions,num_diversity_spotlight_investments,num_event_appearances,num_exits,num_exits_ipo,num_founder_alumni,num_funding_rounds,num_funds,num_investments,num_investments_funding_rounds,num_investors,num_lead_investments,num_lead_investors,num_past_positions,num_portfolio_organizations,num_relationships,num_sub_organizations,privco_last_updated,privco_valuation_range,rank,rank_delta_d30,rank_delta_d7,rank_delta_d90,rank_org,rank_org_company,rank_org_school,rank_principal,rank_principal_investor,siftery_last_updated,siftery_num_product_creates,siftery_num_product_mom_pct,siftery_num_products,similarweb_bounce_rate,similarweb_bounce_rate_mom_pct,similarweb_global_rank,similarweb_global_rank_mom,similarweb_global_rank_mom_pct,similarweb_visit_duration,similarweb_visit_duration_mom_pct,similarweb_visit_pageview_mom_pct,similarweb_visit_pageviews,similarweb_visits_latest_6_months_avg,similarweb_visits_latest_month,similarweb_visits_mom_pct,similarweb_visits_yoy_pct,updated_at}'::"state.q"."organization.field_ids"[]))
127. 0.027 0.027 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_8 (cost=0.00..1.60 rows=2 width=61) (actual time=0.026..0.027 rows=0 loops=1)

  • Output: merged_properties_diff_8.uuid, 6, (merged_properties_diff_8.changed_field_ids && '{num_past_positions,num_founder_alumni,num_investments_funding_rounds,num_exits_ipo,num_lead_investments,funding_total,num_current_positions,num_relationships,num_diversity_spotlight_investments,num_articles,num_lead_investors,funds_total,num_funding_rounds,num_alumni,num_portfolio_organizations,equity_funding_total,num_investors,num_investments,num_funds,num_current_advisor_positions,num_event_appearances,num_exits,num_acquisitions,num_sub_organizations,last_funding_total}'::"state.q"."organization.field_ids"[]), ((SubPlan 22))::"state.q"."organization.field_ids"[], merged_properties_diff_8.updated_at
  • Filter: ((NOT merged_properties_diff_8.old_exists) AND merged_properties_diff_8.new_exists AND (merged_properties_diff_8.changed_field_ids && '{aberdeen_last_updated,aberdeen_site_communications_spend,aberdeen_site_it_spend,aberdeen_site_other_hardware_spend,aberdeen_site_other_it_spend,aberdeen_site_pc_spend,aberdeen_site_server_spend,aberdeen_site_services_spend,aberdeen_site_software_spend,aberdeen_site_storage_spend,apptopia_last_updated,apptopia_total_apps,apptopia_total_downloads,apptopia_total_downloads_mom_pct,apptopia_total_downloads_yoy_pct,builtwith_num_technologies_not_used,builtwith_num_technologies_used,builtwith_technologies_used_mom_pct,builtwith_updated_at,equity_funding_total,funding_total,funds_total,ipqwery_ip_score,ipqwery_last_updated,ipqwery_num_both_total,ipqwery_num_patent_granted,ipqwery_num_patent_pending,ipqwery_num_patent_total,ipqwery_num_trademark_pending,ipqwery_num_trademark_registered,ipqwery_num_trademark_total,last_funding_total,num_acquisitions,num_alumni,num_articles,num_current_advisor_positions,num_current_positions,num_diversity_spotlight_investments,num_event_appearances,num_exits,num_exits_ipo,num_founder_alumni,num_funding_rounds,num_funds,num_investments,num_investments_funding_rounds,num_investors,num_lead_investments,num_lead_investors,num_past_positions,num_portfolio_organizations,num_relationships,num_sub_organizations,privco_last_updated,privco_valuation_range,rank,rank_delta_d30,rank_delta_d7,rank_delta_d90,rank_org,rank_org_company,rank_org_school,rank_principal,rank_principal_investor,siftery_last_updated,siftery_num_product_creates,siftery_num_product_mom_pct,siftery_num_products,similarweb_bounce_rate,similarweb_bounce_rate_mom_pct,similarweb_global_rank,similarweb_global_rank_mom,similarweb_global_rank_mom_pct,similarweb_visit_duration,similarweb_visit_duration_mom_pct,similarweb_visit_pageview_mom_pct,similarweb_visit_pageviews,similarweb_visits_latest_6_months_avg,similarweb_visits_latest_month,similarweb_visits_mom_pct,similarweb_visits_yoy_pct,updated_at}'::"state.q"."organization.field_ids"[]))
  • Rows Removed by Filter: 50
128.          

SubPlan (for CTE Scan)

129. 0.000 0.000 ↓ 0.0 0

ProjectSet (cost=0.00..0.52 rows=100 width=32) (never executed)

  • Output: jsonb_object_keys(merged_properties_diff_8.new_properties)
130. 0.000 0.000 ↓ 0.0 0

Result (cost=0.00..0.01 rows=1 width=0) (never executed)

131.          

CTE sink_enqueue.algolia.organization

132. 14.923 15.130 ↓ 25.0 50 1

Insert on "algolia.qp"."organizations.6" "organizations.6_4" (cost=0.00..1.51 rows=2 width=61) (actual time=14.647..15.130 rows=50 loops=1)

  • Output: "organizations.6_4".partition
133. 0.066 0.207 ↓ 25.0 50 1

Append (cost=0.00..1.51 rows=2 width=61) (actual time=0.009..0.207 rows=50 loops=1)

134. 0.113 0.113 ↓ 50.0 50 1

CTE Scan on merged_properties_diff merged_properties_diff_9 (cost=0.00..0.45 rows=1 width=61) (actual time=0.007..0.113 rows=50 loops=1)

  • Output: merged_properties_diff_9.uuid, 6, (merged_properties_diff_9.changed_field_ids && '{aliases,identifier,num_relationships,short_description}'::"state.q"."organization.field_ids"[]), merged_properties_diff_9.changed_field_ids, merged_properties_diff_9.updated_at
  • Filter: (merged_properties_diff_9.old_exists AND (merged_properties_diff_9.changed_field_ids && '{aliases,created_at,entity_def_id,facet_ids,identifier,num_relationships,rank,short_description,updated_at,uuid}'::"state.q"."organization.field_ids"[]))
135. 0.028 0.028 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_10 (cost=0.00..1.02 rows=1 width=61) (actual time=0.027..0.028 rows=0 loops=1)

  • Output: merged_properties_diff_10.uuid, 6, (merged_properties_diff_10.changed_field_ids && '{aliases,identifier,num_relationships,short_description}'::"state.q"."organization.field_ids"[]), ((SubPlan 24))::"state.q"."organization.field_ids"[], merged_properties_diff_10.updated_at
  • Filter: ((NOT merged_properties_diff_10.old_exists) AND merged_properties_diff_10.new_exists AND (merged_properties_diff_10.changed_field_ids && '{aliases,created_at,entity_def_id,facet_ids,identifier,num_relationships,rank,short_description,updated_at,uuid}'::"state.q"."organization.field_ids"[]))
  • Rows Removed by Filter: 50
136.          

SubPlan (for CTE Scan)

137. 0.000 0.000 ↓ 0.0 0

ProjectSet (cost=0.00..0.52 rows=100 width=32) (never executed)

  • Output: jsonb_object_keys(merged_properties_diff_10.new_properties)
138. 0.000 0.000 ↓ 0.0 0

Result (cost=0.00..0.01 rows=1 width=0) (never executed)

139.          

CTE sink_enqueue.pg_sink.organization

140. 14.812 15.142 ↓ 5.6 50 1

Insert on "postgres.qp"."organizations.6" "organizations.6_5" (cost=0.00..2.77 rows=9 width=61) (actual time=14.616..15.142 rows=50 loops=1)

  • Output: "organizations.6_5".partition
141. 0.065 0.330 ↓ 5.6 50 1

Append (cost=0.00..2.77 rows=9 width=61) (actual time=0.012..0.330 rows=50 loops=1)

142. 0.239 0.239 ↓ 8.3 50 1

CTE Scan on merged_properties_diff merged_properties_diff_11 (cost=0.00..0.46 rows=6 width=61) (actual time=0.010..0.239 rows=50 loops=1)

  • Output: merged_properties_diff_11.uuid, 6, (merged_properties_diff_11.changed_field_ids && '{num_past_positions,last_funding_at,school_method,num_founder_alumni,num_investments_funding_rounds,founder_identifiers,num_exits_ipo,valuation_date,num_lead_investments,extended_description,ipo_amount_raised,funding_total,program_application_deadline,num_parent_organizations,acquisition_price,demo_days,short_description,facebook,revenue_range,num_current_positions,ipo_share_price,school_type,investor_stage,hub_tags,num_relationships,num_diversity_spotlight_investments,num_articles,linkedin,phone_number,stock_symbol,acquisition_announced_on,admin_notes,last_funding_type,location_group_identifiers,exited_on,founded_on,hubs,acquisition_status,num_lead_investors,funds_total,website,program_duration,went_public_on,last_equity_funding_type,diversity_spotlights,aliases,investor_identifiers,closed_on,num_enrollments,override_layout_id,image_url,contact_email,email_domains,funding_stage,permalink,owner_identifier,num_funding_rounds,num_employees_enum,listed_stock_symbol,num_alumni,last_equity_funding_total,num_portfolio_organizations,company_type,acquisition_identifier,num_was_acquired,equity_funding_total,legal_name,num_founders,num_investors,is_locked,ipo_status,advisors_featured_order,acquisition_terms,investor_type,valuation,stock_link,ipo_valuation,num_investments,category_groups,school_program,permalink_aliases,num_went_public,website_url,acquirer_identifier,identifier,operating_status,image_id,employees_featured_order,categories,location_identifiers,layout_id,name,num_funds,num_current_advisor_positions,acquisition_type,num_event_appearances,stock_exchange_symbol,num_exits,twitter,num_acquisitions,delisted_on,description,program_type,status,num_sub_organizations,last_funding_total}'::"state.q"."organization.field_ids"[]), merged_properties_diff_11.changed_field_ids, merged_properties_diff_11.updated_at
  • Filter: (merged_properties_diff_11.old_exists AND (merged_properties_diff_11.changed_field_ids && '{aberdeen_last_updated,aberdeen_site_communications_spend,aberdeen_site_it_spend,aberdeen_site_other_hardware_spend,aberdeen_site_other_it_spend,aberdeen_site_pc_spend,aberdeen_site_server_spend,aberdeen_site_services_spend,aberdeen_site_software_spend,aberdeen_site_storage_spend,acquirer_identifier,acquisition_announced_on,acquisition_identifier,acquisition_price,acquisition_status,acquisition_terms,acquisition_type,admin_notes,advisors_featured_order,aliases,apptopia_last_updated,apptopia_total_apps,apptopia_total_downloads,apptopia_total_downloads_mom_pct,bombora_last_updated,builtwith_num_technologies_not_used,builtwith_num_technologies_used,builtwith_technologies_used_mom_pct,builtwith_updated_at,categories,category_groups,closed_on,company_type,contact_email,created_at,delisted_on,demo_days,description,diversity_spotlights,email_domains,employees_featured_order,entity_def_id,equity_funding_total,exited_on,extended_description,facebook,facet_ids,founded_on,founder_identifiers,funding_stage,funding_total,funds_total,hub_tags,hubs,identifier,image_id,image_url,investor_identifiers,investor_prediction_num_investors,investor_prediction_target_round,investor_stage,investor_type,ipo_amount_raised,ipo_share_price,ipo_status,ipo_valuation,ipqwery_ip_score,ipqwery_last_updated,ipqwery_num_both_total,ipqwery_num_patent_granted,ipqwery_num_patent_pending,ipqwery_num_patent_total,ipqwery_num_trademark_pending,ipqwery_num_trademark_registered,ipqwery_num_trademark_total,ipqwery_popular_patent_category,ipqwery_popular_patent_class,ipqwery_popular_trademark_class,is_locked,last_equity_funding_total,last_equity_funding_type,last_funding_at,last_funding_total,last_funding_type,last_key_employee_change_date,last_layoff_date,layout_id,legal_name,linkedin,listed_stock_symbol,location_group_identifiers,location_identifiers,name,num_acquisitions,num_alumni,num_articles,num_current_advisor_positions,num_current_positions,num_diversity_spotlight_investments,num_employees_enum,num_enrollments,num_event_appearances,num_exits,num_exits_ipo,num_founder_alumni,num_founders,num_funding_rounds,num_funds,num_investments,num_investments_funding_rounds,num_investors,num_lead_investments,num_lead_investors,num_parent_organizations,num_past_positions,num_portfolio_organizations,num_relationships,num_sub_organizations,num_was_acquired,num_went_public,operating_status,override_layout_id,owner_identifier,permalink,permalink_aliases,phone_number,privco_funding_round_title,privco_growth_percentile,privco_last_updated,privco_valuation,privco_valuation_range,privco_valuation_timestamp,program_application_deadline,program_duration,program_type,rank,rank_delta_d30,rank_delta_d7,rank_delta_d90,rank_org,rank_org_company,rank_org_school,rank_principal,rank_principal_investor,revenue_range,school_method,school_program,school_type,short_description,siftery_last_updated,siftery_num_product_creates,siftery_num_product_mom_pct,siftery_num_products,similarweb_bounce_rate,similarweb_bounce_rate_mom_pct,similarweb_global_rank,similarweb_global_rank_mom,similarweb_global_rank_mom_pct,similarweb_last_updated,similarweb_visit_duration,similarweb_visit_duration_mom_pct,similarweb_visit_pageview_mom_pct,similarweb_visit_pageviews,similarweb_visits_latest_6_months_avg,similarweb_visits_latest_month,similarweb_visits_mom_pct,status,stock_exchange_symbol,stock_link,stock_symbol,twitter,updated_at,uuid,valuation,valuation_date,website,website_url,went_public_on}'::"state.q"."organization.field_ids"[]))
143. 0.026 0.026 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_12 (cost=0.00..2.17 rows=3 width=61) (actual time=0.025..0.026 rows=0 loops=1)

  • Output: merged_properties_diff_12.uuid, 6, (merged_properties_diff_12.changed_field_ids && '{num_past_positions,last_funding_at,school_method,num_founder_alumni,num_investments_funding_rounds,founder_identifiers,num_exits_ipo,valuation_date,num_lead_investments,extended_description,ipo_amount_raised,funding_total,program_application_deadline,num_parent_organizations,acquisition_price,demo_days,short_description,facebook,revenue_range,num_current_positions,ipo_share_price,school_type,investor_stage,hub_tags,num_relationships,num_diversity_spotlight_investments,num_articles,linkedin,phone_number,stock_symbol,acquisition_announced_on,admin_notes,last_funding_type,location_group_identifiers,exited_on,founded_on,hubs,acquisition_status,num_lead_investors,funds_total,website,program_duration,went_public_on,last_equity_funding_type,diversity_spotlights,aliases,investor_identifiers,closed_on,num_enrollments,override_layout_id,image_url,contact_email,email_domains,funding_stage,permalink,owner_identifier,num_funding_rounds,num_employees_enum,listed_stock_symbol,num_alumni,last_equity_funding_total,num_portfolio_organizations,company_type,acquisition_identifier,num_was_acquired,equity_funding_total,legal_name,num_founders,num_investors,is_locked,ipo_status,advisors_featured_order,acquisition_terms,investor_type,valuation,stock_link,ipo_valuation,num_investments,category_groups,school_program,permalink_aliases,num_went_public,website_url,acquirer_identifier,identifier,operating_status,image_id,employees_featured_order,categories,location_identifiers,layout_id,name,num_funds,num_current_advisor_positions,acquisition_type,num_event_appearances,stock_exchange_symbol,num_exits,twitter,num_acquisitions,delisted_on,description,program_type,status,num_sub_organizations,last_funding_total}'::"state.q"."organization.field_ids"[]), ((SubPlan 26))::"state.q"."organization.field_ids"[], merged_properties_diff_12.updated_at
  • Filter: ((NOT merged_properties_diff_12.old_exists) AND merged_properties_diff_12.new_exists AND (merged_properties_diff_12.changed_field_ids && '{aberdeen_last_updated,aberdeen_site_communications_spend,aberdeen_site_it_spend,aberdeen_site_other_hardware_spend,aberdeen_site_other_it_spend,aberdeen_site_pc_spend,aberdeen_site_server_spend,aberdeen_site_services_spend,aberdeen_site_software_spend,aberdeen_site_storage_spend,acquirer_identifier,acquisition_announced_on,acquisition_identifier,acquisition_price,acquisition_status,acquisition_terms,acquisition_type,admin_notes,advisors_featured_order,aliases,apptopia_last_updated,apptopia_total_apps,apptopia_total_downloads,apptopia_total_downloads_mom_pct,bombora_last_updated,builtwith_num_technologies_not_used,builtwith_num_technologies_used,builtwith_technologies_used_mom_pct,builtwith_updated_at,categories,category_groups,closed_on,company_type,contact_email,created_at,delisted_on,demo_days,description,diversity_spotlights,email_domains,employees_featured_order,entity_def_id,equity_funding_total,exited_on,extended_description,facebook,facet_ids,founded_on,founder_identifiers,funding_stage,funding_total,funds_total,hub_tags,hubs,identifier,image_id,image_url,investor_identifiers,investor_prediction_num_investors,investor_prediction_target_round,investor_stage,investor_type,ipo_amount_raised,ipo_share_price,ipo_status,ipo_valuation,ipqwery_ip_score,ipqwery_last_updated,ipqwery_num_both_total,ipqwery_num_patent_granted,ipqwery_num_patent_pending,ipqwery_num_patent_total,ipqwery_num_trademark_pending,ipqwery_num_trademark_registered,ipqwery_num_trademark_total,ipqwery_popular_patent_category,ipqwery_popular_patent_class,ipqwery_popular_trademark_class,is_locked,last_equity_funding_total,last_equity_funding_type,last_funding_at,last_funding_total,last_funding_type,last_key_employee_change_date,last_layoff_date,layout_id,legal_name,linkedin,listed_stock_symbol,location_group_identifiers,location_identifiers,name,num_acquisitions,num_alumni,num_articles,num_current_advisor_positions,num_current_positions,num_diversity_spotlight_investments,num_employees_enum,num_enrollments,num_event_appearances,num_exits,num_exits_ipo,num_founder_alumni,num_founders,num_funding_rounds,num_funds,num_investments,num_investments_funding_rounds,num_investors,num_lead_investments,num_lead_investors,num_parent_organizations,num_past_positions,num_portfolio_organizations,num_relationships,num_sub_organizations,num_was_acquired,num_went_public,operating_status,override_layout_id,owner_identifier,permalink,permalink_aliases,phone_number,privco_funding_round_title,privco_growth_percentile,privco_last_updated,privco_valuation,privco_valuation_range,privco_valuation_timestamp,program_application_deadline,program_duration,program_type,rank,rank_delta_d30,rank_delta_d7,rank_delta_d90,rank_org,rank_org_company,rank_org_school,rank_principal,rank_principal_investor,revenue_range,school_method,school_program,school_type,short_description,siftery_last_updated,siftery_num_product_creates,siftery_num_product_mom_pct,siftery_num_products,similarweb_bounce_rate,similarweb_bounce_rate_mom_pct,similarweb_global_rank,similarweb_global_rank_mom,similarweb_global_rank_mom_pct,similarweb_last_updated,similarweb_visit_duration,similarweb_visit_duration_mom_pct,similarweb_visit_pageview_mom_pct,similarweb_visit_pageviews,similarweb_visits_latest_6_months_avg,similarweb_visits_latest_month,similarweb_visits_mom_pct,status,stock_exchange_symbol,stock_link,stock_symbol,twitter,updated_at,uuid,valuation,valuation_date,website,website_url,went_public_on}'::"state.q"."organization.field_ids"[]))
  • Rows Removed by Filter: 50
144.          

SubPlan (for CTE Scan)

145. 0.000 0.000 ↓ 0.0 0

ProjectSet (cost=0.00..0.52 rows=100 width=32) (never executed)

  • Output: jsonb_object_keys(merged_properties_diff_12.new_properties)
146. 0.000 0.000 ↓ 0.0 0

Result (cost=0.00..0.01 rows=1 width=0) (never executed)

147.          

CTE dirty_field_enqueue.acquisition

148. 0.002 0.213 ↓ 0.0 0 1

Insert on "state.q".acquisitions (cost=39.86..43.56 rows=13 width=131) (actual time=0.212..0.213 rows=0 loops=1)

  • Output: acquisitions.partition
149. 0.002 0.211 ↓ 0.0 0 1

Subquery Scan on *SELECT* (cost=39.86..43.56 rows=13 width=131) (actual time=0.210..0.211 rows=0 loops=1)

  • Output: "*SELECT*".uuid, "*SELECT*".partition, false, false, NULL::jsonb, "*SELECT*".bool, "*SELECT*".array_unique, NULL::rel_id[], NULL::integer, now()
150. 0.002 0.209 ↓ 0.0 0 1

GroupAggregate (cost=39.86..43.37 rows=13 width=53) (actual time=0.209..0.209 rows=0 loops=1)

  • Output: "*SELECT* 1_1".target, "*SELECT* 1_1".target_partition, true, array_unique(array_agg_mult("*SELECT* 1_1"."array"))
  • Group Key: "*SELECT* 1_1".target, "*SELECT* 1_1".target_partition
151. 0.004 0.207 ↓ 0.0 0 1

Sort (cost=39.86..39.89 rows=13 width=52) (actual time=0.207..0.207 rows=0 loops=1)

  • Output: "*SELECT* 1_1".target, "*SELECT* 1_1".target_partition, "*SELECT* 1_1"."array
  • Sort Key: "*SELECT* 1_1".target, "*SELECT* 1_1".target_partition
  • Sort Method: quicksort Memory: 25kB
152. 0.002 0.203 ↓ 0.0 0 1

Append (cost=0.87..39.62 rows=13 width=52) (actual time=0.203..0.203 rows=0 loops=1)

153. 0.002 0.037 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_1 (cost=0.87..4.92 rows=1 width=52) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: "*SELECT* 1_1".target, "*SELECT* 1_1".target_partition, "*SELECT* 1_1"."array
154. 0.001 0.035 ↓ 0.0 0 1

Nested Loop (cost=0.87..4.91 rows=1 width=56) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.was_acquired".target_partition, "rel.was_acquired".target, '{is_last}'::"state.q"."acquisition.field_ids"[]
155. 0.002 0.034 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_13.uuid
  • Group Key: merged_properties_diff_13.uuid
156. 0.032 0.032 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_13 (cost=0.00..0.45 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_13.uuid, merged_properties_diff_13.old_exists, merged_properties_diff_13.new_exists, merged_properties_diff_13.new_deleted, merged_properties_diff_13.old_properties, merged_properties_diff_13.new_properties, merged_properties_diff_13.changed_field_ids, merged_properties_diff_13.change_count, merged_properties_diff_13.dirty_field_ids, merged_properties_diff_13.dirty_rel_ids, merged_properties_diff_13.updated_at
  • Filter: (merged_properties_diff_13.changed_field_ids && '{last_acquired_by_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
157. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.was_acquired" on public."rel.was_acquired" (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: "rel.was_acquired".source_partition, "rel.was_acquired".source_entity_def_id, "rel.was_acquired".source, "rel.was_acquired".target_partition, "rel.was_acquired".target_entity_def_id, "rel.was_acquired".target
  • Index Cond: ("rel.was_acquired".source = merged_properties_diff_13.uuid)
158. 0.002 0.039 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_1 (cost=2.91..12.40 rows=5 width=52) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "*SELECT* 2_1".target, "*SELECT* 2_1".target_partition, "*SELECT* 2_1"."array
159. 0.001 0.037 ↓ 0.0 0 1

Nested Loop (cost=2.91..12.35 rows=5 width=56) (actual time=0.037..0.037 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_acquired".target_partition, "rel.has_acquired".target, '{acquirer_identifier}'::"state.q"."acquisition.field_ids"[]
160. 0.002 0.036 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: merged_properties_diff_14.uuid
  • Group Key: merged_properties_diff_14.uuid
161. 0.034 0.034 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_14 (cost=0.00..0.45 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_14.uuid, merged_properties_diff_14.old_exists, merged_properties_diff_14.new_exists, merged_properties_diff_14.new_deleted, merged_properties_diff_14.old_properties, merged_properties_diff_14.new_properties, merged_properties_diff_14.changed_field_ids, merged_properties_diff_14.change_count, merged_properties_diff_14.dirty_field_ids, merged_properties_diff_14.dirty_rel_ids, merged_properties_diff_14.updated_at
  • Filter: (merged_properties_diff_14.changed_field_ids && '{name,permalink,image_id,uuid,entity_def_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
162. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_acquired" (cost=2.46..11.84 rows=5 width=36) (never executed)

  • Output: "rel.has_acquired".source_partition, "rel.has_acquired".source_entity_def_id, "rel.has_acquired".source, "rel.has_acquired".target_partition, "rel.has_acquired".target_entity_def_id, "rel.has_acquired".target
  • Recheck Cond: ("rel.has_acquired".source = merged_properties_diff_14.uuid)
163. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_acquired" (cost=0.00..2.46 rows=5 width=0) (never executed)

  • Index Cond: ("rel.has_acquired".source = merged_properties_diff_14.uuid)
164. 0.002 0.044 ↓ 0.0 0 1

Subquery Scan on *SELECT* 3 (cost=0.87..4.92 rows=1 width=52) (actual time=0.043..0.044 rows=0 loops=1)

  • Output: "*SELECT* 3".target, "*SELECT* 3".target_partition, "*SELECT* 3"."array
165. 0.001 0.042 ↓ 0.0 0 1

Nested Loop (cost=0.87..4.91 rows=1 width=56) (actual time=0.042..0.042 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.was_acquired_1".target_partition, "rel.was_acquired_1".target, '{acquiree_funding_stage,image_id,acquiree_categories,acquiree_last_funding_type,acquiree_num_funding_rounds,acquiree_funding_total,acquiree_locations,acquiree_revenue_range,acquiree_short_description,acquiree_website}'::"state.q"."acquisition.field_ids"[]
166. 0.002 0.041 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: merged_properties_diff_15.uuid
  • Group Key: merged_properties_diff_15.uuid
167. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_15 (cost=0.00..0.45 rows=1 width=16) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: merged_properties_diff_15.uuid, merged_properties_diff_15.old_exists, merged_properties_diff_15.new_exists, merged_properties_diff_15.new_deleted, merged_properties_diff_15.old_properties, merged_properties_diff_15.new_properties, merged_properties_diff_15.changed_field_ids, merged_properties_diff_15.change_count, merged_properties_diff_15.dirty_field_ids, merged_properties_diff_15.dirty_rel_ids, merged_properties_diff_15.updated_at
  • Filter: (merged_properties_diff_15.changed_field_ids && '{website,image_id,short_description,revenue_range,funding_total,num_funding_rounds,last_funding_type,categories,location_identifiers,funding_stage}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
168. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.was_acquired" on public."rel.was_acquired" "rel.was_acquired_1" (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: "rel.was_acquired_1".source_partition, "rel.was_acquired_1".source_entity_def_id, "rel.was_acquired_1".source, "rel.was_acquired_1".target_partition, "rel.was_acquired_1".target_entity_def_id, "rel.was_acquired_1".target
  • Index Cond: ("rel.was_acquired_1".source = merged_properties_diff_15.uuid)
169. 0.002 0.039 ↓ 0.0 0 1

Subquery Scan on *SELECT* 4 (cost=0.87..4.92 rows=1 width=52) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "*SELECT* 4".target, "*SELECT* 4".target_partition, "*SELECT* 4"."array
170. 0.001 0.037 ↓ 0.0 0 1

Nested Loop (cost=0.87..4.91 rows=1 width=56) (actual time=0.037..0.037 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.was_acquired_2".target_partition, "rel.was_acquired_2".target, '{acquiree_identifier}'::"state.q"."acquisition.field_ids"[]
171. 0.002 0.036 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: merged_properties_diff_16.uuid
  • Group Key: merged_properties_diff_16.uuid
172. 0.034 0.034 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_16 (cost=0.00..0.45 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_16.uuid, merged_properties_diff_16.old_exists, merged_properties_diff_16.new_exists, merged_properties_diff_16.new_deleted, merged_properties_diff_16.old_properties, merged_properties_diff_16.new_properties, merged_properties_diff_16.changed_field_ids, merged_properties_diff_16.change_count, merged_properties_diff_16.dirty_field_ids, merged_properties_diff_16.dirty_rel_ids, merged_properties_diff_16.updated_at
  • Filter: (merged_properties_diff_16.changed_field_ids && '{name,permalink,image_id,uuid,entity_def_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
173. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.was_acquired" on public."rel.was_acquired" "rel.was_acquired_2" (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: "rel.was_acquired_2".source_partition, "rel.was_acquired_2".source_entity_def_id, "rel.was_acquired_2".source, "rel.was_acquired_2".target_partition, "rel.was_acquired_2".target_entity_def_id, "rel.was_acquired_2".target
  • Index Cond: ("rel.was_acquired_2".source = merged_properties_diff_16.uuid)
174. 0.001 0.042 ↓ 0.0 0 1

Subquery Scan on *SELECT* 5 (cost=2.91..12.40 rows=5 width=52) (actual time=0.042..0.042 rows=0 loops=1)

  • Output: "*SELECT* 5".target, "*SELECT* 5".target_partition, "*SELECT* 5"."array
175. 0.002 0.041 ↓ 0.0 0 1

Nested Loop (cost=2.91..12.35 rows=5 width=56) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_acquired_1".target_partition, "rel.has_acquired_1".target, '{acquirer_num_funding_rounds,acquirer_locations,acquirer_website,acquirer_funding_stage,acquirer_revenue_range,acquirer_funding_total,acquirer_categories,acquirer_short_description}'::"state.q"."acquisition.field_ids"[]
176. 0.002 0.039 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: merged_properties_diff_17.uuid
  • Group Key: merged_properties_diff_17.uuid
177. 0.037 0.037 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_17 (cost=0.00..0.45 rows=1 width=16) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: merged_properties_diff_17.uuid, merged_properties_diff_17.old_exists, merged_properties_diff_17.new_exists, merged_properties_diff_17.new_deleted, merged_properties_diff_17.old_properties, merged_properties_diff_17.new_properties, merged_properties_diff_17.changed_field_ids, merged_properties_diff_17.change_count, merged_properties_diff_17.dirty_field_ids, merged_properties_diff_17.dirty_rel_ids, merged_properties_diff_17.updated_at
  • Filter: (merged_properties_diff_17.changed_field_ids && '{website,short_description,revenue_range,funding_total,num_funding_rounds,categories,location_identifiers,funding_stage}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
178. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_acquired" "rel.has_acquired_1" (cost=2.46..11.84 rows=5 width=36) (never executed)

  • Output: "rel.has_acquired_1".source_partition, "rel.has_acquired_1".source_entity_def_id, "rel.has_acquired_1".source, "rel.has_acquired_1".target_partition, "rel.has_acquired_1".target_entity_def_id, "rel.has_acquired_1".target
  • Recheck Cond: ("rel.has_acquired_1".source = merged_properties_diff_17.uuid)
179. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_acquired" (cost=0.00..2.46 rows=5 width=0) (never executed)

  • Index Cond: ("rel.has_acquired_1".source = merged_properties_diff_17.uuid)
180.          

CTE dirty_field_enqueue.organization

181. 0.003 0.042 ↓ 0.0 0 1

Insert on "state.q".organizations (cost=3.02..39.15 rows=19 width=239) (actual time=0.040..0.042 rows=0 loops=1)

  • Output: organizations.partition
182. 0.002 0.039 ↓ 0.0 0 1

Subquery Scan on *SELECT*_1 (cost=3.02..39.15 rows=19 width=239) (actual time=0.039..0.039 rows=0 loops=1)

  • Output: "*SELECT*_1".uuid, "*SELECT*_1".partition, false, false, NULL::jsonb, "*SELECT*_1".bool, "*SELECT*_1".dirty_field_ids, NULL::rel_id[], NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, now()
183. 0.001 0.037 ↓ 0.0 0 1

Nested Loop (cost=3.02..38.87 rows=19 width=53) (actual time=0.037..0.037 rows=0 loops=1)

  • Output: "rel.has_investor".source, "rel.has_investor".source_partition, true, '{investor_identifiers}'::"state.q"."organization.field_ids"[]
184. 0.002 0.036 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: merged_properties_diff_18.uuid
  • Group Key: merged_properties_diff_18.uuid
185. 0.034 0.034 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_18 (cost=0.00..0.45 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_18.uuid, merged_properties_diff_18.old_exists, merged_properties_diff_18.new_exists, merged_properties_diff_18.new_deleted, merged_properties_diff_18.old_properties, merged_properties_diff_18.new_properties, merged_properties_diff_18.changed_field_ids, merged_properties_diff_18.change_count, merged_properties_diff_18.dirty_field_ids, merged_properties_diff_18.dirty_rel_ids, merged_properties_diff_18.updated_at
  • Filter: (merged_properties_diff_18.changed_field_ids && '{name,permalink,image_id,uuid,entity_def_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
186. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_investor" (cost=2.57..38.22 rows=19 width=36) (never executed)

  • Output: "rel.has_investor".source_partition, "rel.has_investor".source_entity_def_id, "rel.has_investor".source, "rel.has_investor".target_partition, "rel.has_investor".target_entity_def_id, "rel.has_investor".target
  • Recheck Cond: ("rel.has_investor".target = merged_properties_diff_18.uuid)
187. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "rel.has_investor.target_source" (cost=0.00..2.56 rows=19 width=0) (never executed)

  • Index Cond: ("rel.has_investor".target = merged_properties_diff_18.uuid)
188.          

CTE dirty_field_enqueue.press_reference

189. 0.002 0.038 ↓ 0.0 0 1

Insert on "state.q".press_references (cost=43.81..2,636.11 rows=1,393 width=126) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: press_references.partition
190. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_2 (cost=43.81..2,636.11 rows=1,393 width=126) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT*_2".uuid, "*SELECT*_2".partition, false, false, NULL::jsonb, "*SELECT*_2".dirty_field_ids, NULL::rel_id[], now()
191. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=43.81..2,615.22 rows=1,393 width=52) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: "rel.has_mention".target, "rel.has_mention".target_partition, '{activity_entities}'::"state.q"."press_reference.field_ids"[]
192. 0.001 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_19.uuid
  • Group Key: merged_properties_diff_19.uuid
193. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_19 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_19.uuid, merged_properties_diff_19.old_exists, merged_properties_diff_19.new_exists, merged_properties_diff_19.new_deleted, merged_properties_diff_19.old_properties, merged_properties_diff_19.new_properties, merged_properties_diff_19.changed_field_ids, merged_properties_diff_19.change_count, merged_properties_diff_19.dirty_field_ids, merged_properties_diff_19.dirty_rel_ids, merged_properties_diff_19.updated_at
  • Filter: (merged_properties_diff_19.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
194. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_mention" (cost=43.36..2,600.82 rows=1,393 width=36) (never executed)

  • Output: "rel.has_mention".source_partition, "rel.has_mention".source_entity_def_id, "rel.has_mention".source, "rel.has_mention".target_partition, "rel.has_mention".target_entity_def_id, "rel.has_mention".target
  • Recheck Cond: ("rel.has_mention".source = merged_properties_diff_19.uuid)
195. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_mention" (cost=0.00..43.01 rows=1,393 width=0) (never executed)

  • Index Cond: ("rel.has_mention".source = merged_properties_diff_19.uuid)
196.          

CTE dirty_field_enqueue.funding_round

197. 0.002 0.274 ↓ 0.0 0 1

Insert on "state.q".funding_rounds (cost=118.66..132.68 rows=51 width=139) (actual time=0.273..0.274 rows=0 loops=1)

  • Output: funding_rounds.partition
198. 0.002 0.272 ↓ 0.0 0 1

Subquery Scan on *SELECT*_3 (cost=118.66..132.68 rows=51 width=139) (actual time=0.271..0.272 rows=0 loops=1)

  • Output: "*SELECT*_3".uuid, "*SELECT*_3".partition, false, false, NULL::jsonb, "*SELECT*_3".bool, "*SELECT*_3".array_unique, NULL::rel_id[], NULL::integer, NULL::integer, NULL::integer, now()
199. 0.003 0.270 ↓ 0.0 0 1

HashAggregate (cost=118.66..131.92 rows=51 width=53) (actual time=0.269..0.270 rows=0 loops=1)

  • Output: "*SELECT* 1_2".target, "*SELECT* 1_2".target_partition, true, array_unique(array_agg_mult("*SELECT* 1_2"."array"))
  • Group Key: "*SELECT* 1_2".target, "*SELECT* 1_2".target_partition
200. 0.002 0.267 ↓ 0.0 0 1

Append (cost=2.90..118.28 rows=51 width=52) (actual time=0.267..0.267 rows=0 loops=1)

201. 0.002 0.048 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_2 (cost=2.90..8.83 rows=3 width=52) (actual time=0.047..0.048 rows=0 loops=1)

  • Output: "*SELECT* 1_2".target, "*SELECT* 1_2".target_partition, "*SELECT* 1_2"."array
202. 0.001 0.046 ↓ 0.0 0 1

Nested Loop (cost=2.90..8.80 rows=3 width=56) (actual time=0.046..0.046 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_funding_round".target_partition, "rel.has_funding_round".target, '{funded_organization_diversity_spotlights,funded_organization_revenue_range,image_id,funded_organization_funding_stage,funded_organization_categories,funded_organization_location,funded_organization_funding_total,funded_organization_location_groups,funded_organization_website,funded_organization_num_funding_rounds,funded_organization_description}'::"state.q"."funding_round.field_ids"[]
203. 0.002 0.045 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.044..0.045 rows=0 loops=1)

  • Output: merged_properties_diff_20.uuid
  • Group Key: merged_properties_diff_20.uuid
204. 0.043 0.043 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_20 (cost=0.00..0.45 rows=1 width=16) (actual time=0.042..0.043 rows=0 loops=1)

  • Output: merged_properties_diff_20.uuid, merged_properties_diff_20.old_exists, merged_properties_diff_20.new_exists, merged_properties_diff_20.new_deleted, merged_properties_diff_20.old_properties, merged_properties_diff_20.new_properties, merged_properties_diff_20.changed_field_ids, merged_properties_diff_20.change_count, merged_properties_diff_20.dirty_field_ids, merged_properties_diff_20.dirty_rel_ids, merged_properties_diff_20.updated_at
  • Filter: (merged_properties_diff_20.changed_field_ids && '{location_group_identifiers,website,diversity_spotlights,image_id,short_description,revenue_range,funding_total,num_funding_rounds,categories,location_identifiers,funding_stage}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
205. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_funding_round" (cost=2.45..8.31 rows=3 width=36) (never executed)

  • Output: "rel.has_funding_round".source_partition, "rel.has_funding_round".source_entity_def_id, "rel.has_funding_round".source, "rel.has_funding_round".target_partition, "rel.has_funding_round".target_entity_def_id, "rel.has_funding_round".target
  • Recheck Cond: ("rel.has_funding_round".source = merged_properties_diff_20.uuid)
206. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_funding_round" (cost=0.00..2.44 rows=3 width=0) (never executed)

  • Index Cond: ("rel.has_funding_round".source = merged_properties_diff_20.uuid)
207. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_2 (cost=2.90..8.83 rows=3 width=52) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT* 2_2".target, "*SELECT* 2_2".target_partition, "*SELECT* 2_2"."array
208. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=2.90..8.80 rows=3 width=56) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_funding_round_1".target_partition, "rel.has_funding_round_1".target, '{is_last_post_money}'::"state.q"."funding_round.field_ids"[]
209. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_21.uuid
  • Group Key: merged_properties_diff_21.uuid
210. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_21 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_21.uuid, merged_properties_diff_21.old_exists, merged_properties_diff_21.new_exists, merged_properties_diff_21.new_deleted, merged_properties_diff_21.old_properties, merged_properties_diff_21.new_properties, merged_properties_diff_21.changed_field_ids, merged_properties_diff_21.change_count, merged_properties_diff_21.dirty_field_ids, merged_properties_diff_21.dirty_rel_ids, merged_properties_diff_21.updated_at
  • Filter: (merged_properties_diff_21.changed_field_ids && '{last_post_money_funding_round_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
211. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_funding_round" "rel.has_funding_round_1" (cost=2.45..8.31 rows=3 width=36) (never executed)

  • Output: "rel.has_funding_round_1".source_partition, "rel.has_funding_round_1".source_entity_def_id, "rel.has_funding_round_1".source, "rel.has_funding_round_1".target_partition, "rel.has_funding_round_1".target_entity_def_id, "rel.has_funding_round_1".target
  • Recheck Cond: ("rel.has_funding_round_1".source = merged_properties_diff_21.uuid)
212. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_funding_round" (cost=0.00..2.44 rows=3 width=0) (never executed)

  • Index Cond: ("rel.has_funding_round_1".source = merged_properties_diff_21.uuid)
213. 0.001 0.034 ↓ 0.0 0 1

Subquery Scan on *SELECT* 3_1 (cost=2.90..8.83 rows=3 width=52) (actual time=0.034..0.034 rows=0 loops=1)

  • Output: "*SELECT* 3_1".target, "*SELECT* 3_1".target_partition, "*SELECT* 3_1"."array
214. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.90..8.80 rows=3 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_funding_round_2".target_partition, "rel.has_funding_round_2".target, '{is_last}'::"state.q"."funding_round.field_ids"[]
215. 0.002 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_22.uuid
  • Group Key: merged_properties_diff_22.uuid
216. 0.029 0.029 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_22 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.029 rows=0 loops=1)

  • Output: merged_properties_diff_22.uuid, merged_properties_diff_22.old_exists, merged_properties_diff_22.new_exists, merged_properties_diff_22.new_deleted, merged_properties_diff_22.old_properties, merged_properties_diff_22.new_properties, merged_properties_diff_22.changed_field_ids, merged_properties_diff_22.change_count, merged_properties_diff_22.dirty_field_ids, merged_properties_diff_22.dirty_rel_ids, merged_properties_diff_22.updated_at
  • Filter: (merged_properties_diff_22.changed_field_ids && '{last_funding_round_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
217. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_funding_round" "rel.has_funding_round_2" (cost=2.45..8.31 rows=3 width=36) (never executed)

  • Output: "rel.has_funding_round_2".source_partition, "rel.has_funding_round_2".source_entity_def_id, "rel.has_funding_round_2".source, "rel.has_funding_round_2".target_partition, "rel.has_funding_round_2".target_entity_def_id, "rel.has_funding_round_2".target
  • Recheck Cond: ("rel.has_funding_round_2".source = merged_properties_diff_22.uuid)
218. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_funding_round" (cost=0.00..2.44 rows=3 width=0) (never executed)

  • Index Cond: ("rel.has_funding_round_2".source = merged_properties_diff_22.uuid)
219. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 4_1 (cost=2.94..19.83 rows=9 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 4_1".target, "*SELECT* 4_1".target_partition, "*SELECT* 4_1"."array
220. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.94..19.74 rows=9 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.lead_participated_in".target_partition, "rel.lead_participated_in".target, '{lead_investor_identifiers}'::"state.q"."funding_round.field_ids"[]
221. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_23.uuid
  • Group Key: merged_properties_diff_23.uuid
222. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_23 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_23.uuid, merged_properties_diff_23.old_exists, merged_properties_diff_23.new_exists, merged_properties_diff_23.new_deleted, merged_properties_diff_23.old_properties, merged_properties_diff_23.new_properties, merged_properties_diff_23.changed_field_ids, merged_properties_diff_23.change_count, merged_properties_diff_23.dirty_field_ids, merged_properties_diff_23.dirty_rel_ids, merged_properties_diff_23.updated_at
  • Filter: (merged_properties_diff_23.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
223. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.lead_participated_in" (cost=2.49..19.19 rows=9 width=36) (never executed)

  • Output: "rel.lead_participated_in".source_partition, "rel.lead_participated_in".source_entity_def_id, "rel.lead_participated_in".source, "rel.lead_participated_in".target_partition, "rel.lead_participated_in".target_entity_def_id, "rel.lead_participated_in".target
  • Recheck Cond: ("rel.lead_participated_in".source = merged_properties_diff_23.uuid)
224. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.lead_participated_in" (cost=0.00..2.48 rows=9 width=0) (never executed)

  • Index Cond: ("rel.lead_participated_in".source = merged_properties_diff_23.uuid)
225. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 5_1 (cost=2.90..8.82 rows=3 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 5_1".target, "*SELECT* 5_1".target_partition, "*SELECT* 5_1"."array
226. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.90..8.79 rows=3 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_equity_funding_round".target_partition, "rel.has_equity_funding_round".target, '{is_last_equity}'::"state.q"."funding_round.field_ids"[]
227. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_24.uuid
  • Group Key: merged_properties_diff_24.uuid
228. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_24 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_24.uuid, merged_properties_diff_24.old_exists, merged_properties_diff_24.new_exists, merged_properties_diff_24.new_deleted, merged_properties_diff_24.old_properties, merged_properties_diff_24.new_properties, merged_properties_diff_24.changed_field_ids, merged_properties_diff_24.change_count, merged_properties_diff_24.dirty_field_ids, merged_properties_diff_24.dirty_rel_ids, merged_properties_diff_24.updated_at
  • Filter: (merged_properties_diff_24.changed_field_ids && '{last_equity_funding_round_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
229. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_equity_funding_round" (cost=2.45..8.29 rows=3 width=36) (never executed)

  • Output: "rel.has_equity_funding_round".source_partition, "rel.has_equity_funding_round".source_entity_def_id, "rel.has_equity_funding_round".source, "rel.has_equity_funding_round".target_partition, "rel.has_equity_funding_round".target_entity_def_id, "rel.has_equity_funding_round".target
  • Recheck Cond: ("rel.has_equity_funding_round".source = merged_properties_diff_24.uuid)
230. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_equity_funding_round" (cost=0.00..2.44 rows=3 width=0) (never executed)

  • Index Cond: ("rel.has_equity_funding_round".source = merged_properties_diff_24.uuid)
231. 0.002 0.038 ↓ 0.0 0 1

Subquery Scan on *SELECT* 6 (cost=2.90..8.83 rows=3 width=52) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: "*SELECT* 6".target, "*SELECT* 6".target_partition, "*SELECT* 6"."array
232. 0.001 0.036 ↓ 0.0 0 1

Nested Loop (cost=2.90..8.80 rows=3 width=56) (actual time=0.036..0.036 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_funding_round_3".target_partition, "rel.has_funding_round_3".target, '{funded_organization_identifier}'::"state.q"."funding_round.field_ids"[]
233. 0.002 0.035 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_25.uuid
  • Group Key: merged_properties_diff_25.uuid
234. 0.033 0.033 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_25 (cost=0.00..0.45 rows=1 width=16) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_25.uuid, merged_properties_diff_25.old_exists, merged_properties_diff_25.new_exists, merged_properties_diff_25.new_deleted, merged_properties_diff_25.old_properties, merged_properties_diff_25.new_properties, merged_properties_diff_25.changed_field_ids, merged_properties_diff_25.change_count, merged_properties_diff_25.dirty_field_ids, merged_properties_diff_25.dirty_rel_ids, merged_properties_diff_25.updated_at
  • Filter: (merged_properties_diff_25.changed_field_ids && '{name,permalink,image_id,uuid,entity_def_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
235. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_funding_round" "rel.has_funding_round_3" (cost=2.45..8.31 rows=3 width=36) (never executed)

  • Output: "rel.has_funding_round_3".source_partition, "rel.has_funding_round_3".source_entity_def_id, "rel.has_funding_round_3".source, "rel.has_funding_round_3".target_partition, "rel.has_funding_round_3".target_entity_def_id, "rel.has_funding_round_3".target
  • Recheck Cond: ("rel.has_funding_round_3".source = merged_properties_diff_25.uuid)
236. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_funding_round" (cost=0.00..2.44 rows=3 width=0) (never executed)

  • Index Cond: ("rel.has_funding_round_3".source = merged_properties_diff_25.uuid)
237. 0.002 0.039 ↓ 0.0 0 1

Subquery Scan on *SELECT* 7 (cost=3.08..54.06 rows=27 width=52) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "*SELECT* 7".target, "*SELECT* 7".target_partition, "*SELECT* 7"."array
238. 0.002 0.037 ↓ 0.0 0 1

Nested Loop (cost=3.08..53.79 rows=27 width=56) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.participated_in".target_partition, "rel.participated_in".target, '{investor_identifiers}'::"state.q"."funding_round.field_ids"[]
239. 0.001 0.035 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_26.uuid
  • Group Key: merged_properties_diff_26.uuid
240. 0.034 0.034 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_26 (cost=0.00..0.45 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_26.uuid, merged_properties_diff_26.old_exists, merged_properties_diff_26.new_exists, merged_properties_diff_26.new_deleted, merged_properties_diff_26.old_properties, merged_properties_diff_26.new_properties, merged_properties_diff_26.changed_field_ids, merged_properties_diff_26.change_count, merged_properties_diff_26.dirty_field_ids, merged_properties_diff_26.dirty_rel_ids, merged_properties_diff_26.updated_at
  • Filter: (merged_properties_diff_26.changed_field_ids && '{name,permalink,image_id,uuid,entity_def_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
241. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.participated_in" (cost=2.63..53.06 rows=27 width=36) (never executed)

  • Output: "rel.participated_in".source_partition, "rel.participated_in".source_entity_def_id, "rel.participated_in".source, "rel.participated_in".target_partition, "rel.participated_in".target_entity_def_id, "rel.participated_in".target
  • Recheck Cond: ("rel.participated_in".source = merged_properties_diff_26.uuid)
242. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.participated_in" (cost=0.00..2.62 rows=27 width=0) (never executed)

  • Index Cond: ("rel.participated_in".source = merged_properties_diff_26.uuid)
243.          

CTE dirty_field_enqueue.investor_prediction

244. 0.002 0.038 ↓ 0.0 0 1

Insert on "state.q".investor_predictions (cost=3.09..48.95 rows=28 width=126) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: investor_predictions.partition
245. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_4 (cost=3.09..48.95 rows=28 width=126) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT*_4".uuid, "*SELECT*_4".partition, false, false, NULL::jsonb, "*SELECT*_4".dirty_field_ids, NULL::rel_id[], now()
246. 0.001 0.034 ↓ 0.0 0 1

Nested Loop (cost=3.09..48.53 rows=28 width=52) (actual time=0.034..0.034 rows=0 loops=1)

  • Output: "rel.has_predicted_investee".target, "rel.has_predicted_investee".target_partition, '{num_investments,investor_identifier}'::"state.q"."investor_prediction.field_ids"[]
247. 0.002 0.033 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_27.uuid
  • Group Key: merged_properties_diff_27.uuid
248. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_27 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_27.uuid, merged_properties_diff_27.old_exists, merged_properties_diff_27.new_exists, merged_properties_diff_27.new_deleted, merged_properties_diff_27.old_properties, merged_properties_diff_27.new_properties, merged_properties_diff_27.changed_field_ids, merged_properties_diff_27.change_count, merged_properties_diff_27.dirty_field_ids, merged_properties_diff_27.dirty_rel_ids, merged_properties_diff_27.updated_at
  • Filter: (merged_properties_diff_27.changed_field_ids && '{num_investments,identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
249. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_predicted_investee" (cost=2.63..47.79 rows=28 width=36) (never executed)

  • Output: "rel.has_predicted_investee".source_partition, "rel.has_predicted_investee".source_entity_def_id, "rel.has_predicted_investee".source, "rel.has_predicted_investee".target_partition, "rel.has_predicted_investee".target_entity_def_id, "rel.has_predicted_investee".target
  • Recheck Cond: ("rel.has_predicted_investee".source = merged_properties_diff_27.uuid)
250. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_predicted_investee" (cost=0.00..2.63 rows=28 width=0) (never executed)

  • Index Cond: ("rel.has_predicted_investee".source = merged_properties_diff_27.uuid)
251.          

CTE dirty_field_enqueue.degree

252. 0.003 0.039 ↓ 0.0 0 1

Insert on "state.q".degrees (cost=3.59..160.72 rows=92 width=126) (actual time=0.037..0.039 rows=0 loops=1)

  • Output: degrees.partition
253. 0.001 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_5 (cost=3.59..160.72 rows=92 width=126) (actual time=0.036..0.036 rows=0 loops=1)

  • Output: "*SELECT*_5".uuid, "*SELECT*_5".partition, false, false, NULL::jsonb, "*SELECT*_5".dirty_field_ids, NULL::rel_id[], now()
254. 0.002 0.035 ↓ 0.0 0 1

Nested Loop (cost=3.59..159.34 rows=92 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "rel.awarded_degree".target, "rel.awarded_degree".target_partition, '{school_identifier}'::"state.q"."degree.field_ids"[]
255. 0.002 0.033 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_28.uuid
  • Group Key: merged_properties_diff_28.uuid
256. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_28 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_28.uuid, merged_properties_diff_28.old_exists, merged_properties_diff_28.new_exists, merged_properties_diff_28.new_deleted, merged_properties_diff_28.old_properties, merged_properties_diff_28.new_properties, merged_properties_diff_28.changed_field_ids, merged_properties_diff_28.change_count, merged_properties_diff_28.dirty_field_ids, merged_properties_diff_28.dirty_rel_ids, merged_properties_diff_28.updated_at
  • Filter: (merged_properties_diff_28.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
257. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.awarded_degree" (cost=3.14..157.96 rows=92 width=36) (never executed)

  • Output: "rel.awarded_degree".source_partition, "rel.awarded_degree".source_entity_def_id, "rel.awarded_degree".source, "rel.awarded_degree".target_partition, "rel.awarded_degree".target_entity_def_id, "rel.awarded_degree".target
  • Recheck Cond: ("rel.awarded_degree".source = merged_properties_diff_28.uuid)
258. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.awarded_degree" (cost=0.00..3.11 rows=92 width=0) (never executed)

  • Index Cond: ("rel.awarded_degree".source = merged_properties_diff_28.uuid)
259.          

CTE dirty_field_enqueue.layoff

260. 0.003 0.038 ↓ 0.0 0 1

Insert on "state.q".layoffs (cost=2.64..6.03 rows=5 width=126) (actual time=0.036..0.038 rows=0 loops=1)

  • Output: layoffs.partition
261. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT*_6 (cost=2.64..6.03 rows=5 width=126) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT*_6".uuid, "*SELECT*_6".partition, false, false, NULL::jsonb, "*SELECT*_6".dirty_field_ids, NULL::rel_id[], now()
262. 0.001 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.64..5.96 rows=5 width=52) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: "rel.has_layoff".target, "rel.has_layoff".target_partition, '{organization_identifier}'::"state.q"."layoff.field_ids"[]
263. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_29.uuid
  • Group Key: merged_properties_diff_29.uuid
264. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_29 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_29.uuid, merged_properties_diff_29.old_exists, merged_properties_diff_29.new_exists, merged_properties_diff_29.new_deleted, merged_properties_diff_29.old_properties, merged_properties_diff_29.new_properties, merged_properties_diff_29.changed_field_ids, merged_properties_diff_29.change_count, merged_properties_diff_29.dirty_field_ids, merged_properties_diff_29.dirty_rel_ids, merged_properties_diff_29.updated_at
  • Filter: (merged_properties_diff_29.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
265. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_layoff" (cost=2.19..5.45 rows=5 width=36) (never executed)

  • Output: "rel.has_layoff".source_partition, "rel.has_layoff".source_entity_def_id, "rel.has_layoff".source, "rel.has_layoff".target_partition, "rel.has_layoff".target_entity_def_id, "rel.has_layoff".target
  • Recheck Cond: ("rel.has_layoff".source = merged_properties_diff_29.uuid)
266. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_layoff" (cost=0.00..2.19 rows=5 width=0) (never executed)

  • Index Cond: ("rel.has_layoff".source = merged_properties_diff_29.uuid)
267.          

CTE dirty_field_enqueue.job

268. 0.002 0.113 ↓ 0.0 0 1

Insert on "state.q".jobs jobs_2 (cost=110.00..124.03 rows=51 width=131) (actual time=0.112..0.113 rows=0 loops=1)

  • Output: jobs_2.partition
269. 0.002 0.111 ↓ 0.0 0 1

Subquery Scan on *SELECT*_7 (cost=110.00..124.03 rows=51 width=131) (actual time=0.110..0.111 rows=0 loops=1)

  • Output: "*SELECT*_7".uuid, "*SELECT*_7".partition, false, false, NULL::jsonb, "*SELECT*_7".bool, "*SELECT*_7".array_unique, NULL::rel_id[], NULL::integer, now()
270. 0.002 0.109 ↓ 0.0 0 1

HashAggregate (cost=110.00..123.26 rows=51 width=53) (actual time=0.108..0.109 rows=0 loops=1)

  • Output: "*SELECT* 1_3".target, "*SELECT* 1_3".target_partition, true, array_unique(array_agg_mult("*SELECT* 1_3"."array"))
  • Group Key: "*SELECT* 1_3".target, "*SELECT* 1_3".target_partition
271. 0.003 0.107 ↓ 0.0 0 1

Append (cost=3.01..109.62 rows=51 width=52) (actual time=0.106..0.107 rows=0 loops=1)

272. 0.001 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_3 (cost=3.01..36.45 rows=17 width=52) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: "*SELECT* 1_3".target, "*SELECT* 1_3".target_partition, "*SELECT* 1_3"."array
273. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=3.01..36.28 rows=17 width=56) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_position".target_partition, "rel.has_position".target, '{advisor_featured_order}'::"state.q"."job.field_ids"[]
274. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_30.uuid
  • Group Key: merged_properties_diff_30.uuid
275. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_30 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_30.uuid, merged_properties_diff_30.old_exists, merged_properties_diff_30.new_exists, merged_properties_diff_30.new_deleted, merged_properties_diff_30.old_properties, merged_properties_diff_30.new_properties, merged_properties_diff_30.changed_field_ids, merged_properties_diff_30.change_count, merged_properties_diff_30.dirty_field_ids, merged_properties_diff_30.dirty_rel_ids, merged_properties_diff_30.updated_at
  • Filter: (merged_properties_diff_30.changed_field_ids && '{advisors_featured_order}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
276. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_position" (cost=2.56..35.65 rows=17 width=36) (never executed)

  • Output: "rel.has_position".source_partition, "rel.has_position".source_entity_def_id, "rel.has_position".source, "rel.has_position".target_partition, "rel.has_position".target_entity_def_id, "rel.has_position".target
  • Recheck Cond: ("rel.has_position".source = merged_properties_diff_30.uuid)
277. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_position" (cost=0.00..2.56 rows=17 width=0) (never executed)

  • Index Cond: ("rel.has_position".source = merged_properties_diff_30.uuid)
278. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_3 (cost=3.01..36.45 rows=17 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 2_3".target, "*SELECT* 2_3".target_partition, "*SELECT* 2_3"."array
279. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=3.01..36.28 rows=17 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_position_1".target_partition, "rel.has_position_1".target, '{organization_identifier}'::"state.q"."job.field_ids"[]
280. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_31.uuid
  • Group Key: merged_properties_diff_31.uuid
281. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_31 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_31.uuid, merged_properties_diff_31.old_exists, merged_properties_diff_31.new_exists, merged_properties_diff_31.new_deleted, merged_properties_diff_31.old_properties, merged_properties_diff_31.new_properties, merged_properties_diff_31.changed_field_ids, merged_properties_diff_31.change_count, merged_properties_diff_31.dirty_field_ids, merged_properties_diff_31.dirty_rel_ids, merged_properties_diff_31.updated_at
  • Filter: (merged_properties_diff_31.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
282. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_position" "rel.has_position_1" (cost=2.56..35.65 rows=17 width=36) (never executed)

  • Output: "rel.has_position_1".source_partition, "rel.has_position_1".source_entity_def_id, "rel.has_position_1".source, "rel.has_position_1".target_partition, "rel.has_position_1".target_entity_def_id, "rel.has_position_1".target
  • Recheck Cond: ("rel.has_position_1".source = merged_properties_diff_31.uuid)
283. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_position" (cost=0.00..2.56 rows=17 width=0) (never executed)

  • Index Cond: ("rel.has_position_1".source = merged_properties_diff_31.uuid)
284. 0.001 0.034 ↓ 0.0 0 1

Subquery Scan on *SELECT* 3_2 (cost=3.01..36.45 rows=17 width=52) (actual time=0.034..0.034 rows=0 loops=1)

  • Output: "*SELECT* 3_2".target, "*SELECT* 3_2".target_partition, "*SELECT* 3_2"."array
285. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=3.01..36.28 rows=17 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_position_2".target_partition, "rel.has_position_2".target, '{employee_featured_order}'::"state.q"."job.field_ids"[]
286. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_32.uuid
  • Group Key: merged_properties_diff_32.uuid
287. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_32 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_32.uuid, merged_properties_diff_32.old_exists, merged_properties_diff_32.new_exists, merged_properties_diff_32.new_deleted, merged_properties_diff_32.old_properties, merged_properties_diff_32.new_properties, merged_properties_diff_32.changed_field_ids, merged_properties_diff_32.change_count, merged_properties_diff_32.dirty_field_ids, merged_properties_diff_32.dirty_rel_ids, merged_properties_diff_32.updated_at
  • Filter: (merged_properties_diff_32.changed_field_ids && '{employees_featured_order}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
288. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_position" "rel.has_position_2" (cost=2.56..35.65 rows=17 width=36) (never executed)

  • Output: "rel.has_position_2".source_partition, "rel.has_position_2".source_entity_def_id, "rel.has_position_2".source, "rel.has_position_2".target_partition, "rel.has_position_2".target_entity_def_id, "rel.has_position_2".target
  • Recheck Cond: ("rel.has_position_2".source = merged_properties_diff_32.uuid)
289. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_position" (cost=0.00..2.56 rows=17 width=0) (never executed)

  • Index Cond: ("rel.has_position_2".source = merged_properties_diff_32.uuid)
290.          

CTE dirty_field_enqueue.key_employee_change

291. 0.003 0.038 ↓ 0.0 0 1

Insert on "state.q".key_employee_changes (cost=0.73..4.78 rows=1 width=126) (actual time=0.036..0.038 rows=0 loops=1)

  • Output: key_employee_changes.partition
292. 0.001 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT*_8 (cost=0.73..4.78 rows=1 width=126) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: "*SELECT*_8".uuid, "*SELECT*_8".partition, false, false, NULL::jsonb, "*SELECT*_8".dirty_field_ids, NULL::rel_id[], now()
293. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=0.73..4.77 rows=1 width=52) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: "rel.has_key_employee_change".target, "rel.has_key_employee_change".target_partition, '{organization_identifier}'::"state.q"."key_employee_change.field_ids"[]
294. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_33.uuid
  • Group Key: merged_properties_diff_33.uuid
295. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_33 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_33.uuid, merged_properties_diff_33.old_exists, merged_properties_diff_33.new_exists, merged_properties_diff_33.new_deleted, merged_properties_diff_33.old_properties, merged_properties_diff_33.new_properties, merged_properties_diff_33.changed_field_ids, merged_properties_diff_33.change_count, merged_properties_diff_33.dirty_field_ids, merged_properties_diff_33.dirty_rel_ids, merged_properties_diff_33.updated_at
  • Filter: (merged_properties_diff_33.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
296. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_key_employee_change" on public."rel.has_key_employee_change" (cost=0.28..4.30 rows=1 width=36) (never executed)

  • Output: "rel.has_key_employee_change".source_partition, "rel.has_key_employee_change".source_entity_def_id, "rel.has_key_employee_change".source, "rel.has_key_employee_change".target_partition, "rel.has_key_employee_change".target_entity_def_id, "rel.has_key_employee_change".target
  • Index Cond: ("rel.has_key_employee_change".source = merged_properties_diff_33.uuid)
297.          

CTE dirty_field_enqueue.ipqwery_trademark

298. 0.002 0.038 ↓ 0.0 0 1

Insert on "state.q".ipqwery_trademarks (cost=3.45..142.36 rows=73 width=130) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: ipqwery_trademarks.partition
299. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_9 (cost=3.45..142.36 rows=73 width=130) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT*_9".uuid, "*SELECT*_9".partition, false, false, NULL::jsonb, "*SELECT*_9".dirty_field_ids, NULL::rel_id[], NULL::integer, now()
300. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=3.45..141.26 rows=73 width=52) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: "rel.has_ipqwery_trademark".target, "rel.has_ipqwery_trademark".target_partition, '{owner_identifiers}'::"state.q"."ipqwery_trademark.field_ids"[]
301. 0.001 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_34.uuid
  • Group Key: merged_properties_diff_34.uuid
302. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_34 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_34.uuid, merged_properties_diff_34.old_exists, merged_properties_diff_34.new_exists, merged_properties_diff_34.new_deleted, merged_properties_diff_34.old_properties, merged_properties_diff_34.new_properties, merged_properties_diff_34.changed_field_ids, merged_properties_diff_34.change_count, merged_properties_diff_34.dirty_field_ids, merged_properties_diff_34.dirty_rel_ids, merged_properties_diff_34.updated_at
  • Filter: (merged_properties_diff_34.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
303. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_ipqwery_trademark" (cost=2.99..140.07 rows=73 width=36) (never executed)

  • Output: "rel.has_ipqwery_trademark".source_partition, "rel.has_ipqwery_trademark".source_entity_def_id, "rel.has_ipqwery_trademark".source, "rel.has_ipqwery_trademark".target_partition, "rel.has_ipqwery_trademark".target_entity_def_id, "rel.has_ipqwery_trademark".target
  • Recheck Cond: ("rel.has_ipqwery_trademark".source = merged_properties_diff_34.uuid)
304. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_ipqwery_trademark" (cost=0.00..2.98 rows=73 width=0) (never executed)

  • Index Cond: ("rel.has_ipqwery_trademark".source = merged_properties_diff_34.uuid)
305.          

CTE dirty_field_enqueue.siftery_product

306. 0.002 0.038 ↓ 0.0 0 1

Insert on "state.q".siftery_products (cost=0.74..4.79 rows=1 width=130) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: siftery_products.partition
307. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_10 (cost=0.74..4.79 rows=1 width=130) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT*_10".uuid, "*SELECT*_10".partition, false, false, NULL::jsonb, "*SELECT*_10".dirty_field_ids, NULL::rel_id[], NULL::integer, now()
308. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=0.74..4.77 rows=1 width=52) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: "rel.created_siftery_product".target, "rel.created_siftery_product".target_partition, '{created_by_identifier}'::"state.q"."siftery_product.field_ids"[]
309. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_35.uuid
  • Group Key: merged_properties_diff_35.uuid
310. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_35 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_35.uuid, merged_properties_diff_35.old_exists, merged_properties_diff_35.new_exists, merged_properties_diff_35.new_deleted, merged_properties_diff_35.old_properties, merged_properties_diff_35.new_properties, merged_properties_diff_35.changed_field_ids, merged_properties_diff_35.change_count, merged_properties_diff_35.dirty_field_ids, merged_properties_diff_35.dirty_rel_ids, merged_properties_diff_35.updated_at
  • Filter: (merged_properties_diff_35.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
311. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.created_siftery_product" on public."rel.created_siftery_product" (cost=0.29..4.30 rows=1 width=36) (never executed)

  • Output: "rel.created_siftery_product".source_partition, "rel.created_siftery_product".source_entity_def_id, "rel.created_siftery_product".source, "rel.created_siftery_product".target_partition, "rel.created_siftery_product".target_entity_def_id, "rel.created_siftery_product".target
  • Index Cond: ("rel.created_siftery_product".source = merged_properties_diff_35.uuid)
312.          

CTE dirty_field_enqueue.ownership

313. 0.002 0.084 ↓ 0.0 0 1

Insert on "state.q".ownerships (cost=11.21..12.06 rows=3 width=131) (actual time=0.083..0.084 rows=0 loops=1)

  • Output: ownerships.partition
314. 0.002 0.082 ↓ 0.0 0 1

Subquery Scan on *SELECT*_11 (cost=11.21..12.06 rows=3 width=131) (actual time=0.081..0.082 rows=0 loops=1)

  • Output: "*SELECT*_11".uuid, "*SELECT*_11".partition, false, false, NULL::jsonb, "*SELECT*_11".bool, "*SELECT*_11".array_unique, NULL::rel_id[], NULL::integer, now()
315. 0.002 0.080 ↓ 0.0 0 1

GroupAggregate (cost=11.21..12.02 rows=3 width=53) (actual time=0.079..0.080 rows=0 loops=1)

  • Output: "*SELECT* 1_4".target, "*SELECT* 1_4".target_partition, true, array_unique(array_agg_mult("*SELECT* 1_4"."array"))
  • Group Key: "*SELECT* 1_4".target, "*SELECT* 1_4".target_partition
316. 0.004 0.078 ↓ 0.0 0 1

Sort (cost=11.21..11.21 rows=3 width=52) (actual time=0.078..0.078 rows=0 loops=1)

  • Output: "*SELECT* 1_4".target, "*SELECT* 1_4".target_partition, "*SELECT* 1_4"."array
  • Sort Key: "*SELECT* 1_4".target, "*SELECT* 1_4".target_partition
  • Sort Method: quicksort Memory: 25kB
317. 0.002 0.074 ↓ 0.0 0 1

Append (cost=0.74..11.18 rows=3 width=52) (actual time=0.073..0.074 rows=0 loops=1)

318. 0.002 0.037 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_4 (cost=0.74..4.78 rows=1 width=52) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: "*SELECT* 1_4".target, "*SELECT* 1_4".target_partition, "*SELECT* 1_4"."array
319. 0.001 0.035 ↓ 0.0 0 1

Nested Loop (cost=0.74..4.77 rows=1 width=56) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.is_owned".target_partition, "rel.is_owned".target, '{ownee_identifier}'::"state.q"."ownership.field_ids"[]
320. 0.002 0.034 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_36.uuid
  • Group Key: merged_properties_diff_36.uuid
321. 0.032 0.032 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_36 (cost=0.00..0.45 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_36.uuid, merged_properties_diff_36.old_exists, merged_properties_diff_36.new_exists, merged_properties_diff_36.new_deleted, merged_properties_diff_36.old_properties, merged_properties_diff_36.new_properties, merged_properties_diff_36.changed_field_ids, merged_properties_diff_36.change_count, merged_properties_diff_36.dirty_field_ids, merged_properties_diff_36.dirty_rel_ids, merged_properties_diff_36.updated_at
  • Filter: (merged_properties_diff_36.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
322. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.is_owned" on public."rel.is_owned" (cost=0.29..4.30 rows=1 width=36) (never executed)

  • Output: "rel.is_owned".source_partition, "rel.is_owned".source_entity_def_id, "rel.is_owned".source, "rel.is_owned".target_partition, "rel.is_owned".target_entity_def_id, "rel.is_owned".target
  • Index Cond: ("rel.is_owned".source = merged_properties_diff_36.uuid)
323. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_4 (cost=2.75..6.38 rows=2 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 2_4".target, "*SELECT* 2_4".target_partition, "*SELECT* 2_4"."array
324. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.75..6.36 rows=2 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_ownership".target_partition, "rel.has_ownership".target, '{owner_identifier}'::"state.q"."ownership.field_ids"[]
325. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_37.uuid
  • Group Key: merged_properties_diff_37.uuid
326. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_37 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_37.uuid, merged_properties_diff_37.old_exists, merged_properties_diff_37.new_exists, merged_properties_diff_37.new_deleted, merged_properties_diff_37.old_properties, merged_properties_diff_37.new_properties, merged_properties_diff_37.changed_field_ids, merged_properties_diff_37.change_count, merged_properties_diff_37.dirty_field_ids, merged_properties_diff_37.dirty_rel_ids, merged_properties_diff_37.updated_at
  • Filter: (merged_properties_diff_37.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
327. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_ownership" (cost=2.30..5.88 rows=2 width=36) (never executed)

  • Output: "rel.has_ownership".source_partition, "rel.has_ownership".source_entity_def_id, "rel.has_ownership".source, "rel.has_ownership".target_partition, "rel.has_ownership".target_entity_def_id, "rel.has_ownership".target
  • Recheck Cond: ("rel.has_ownership".source = merged_properties_diff_37.uuid)
328. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_ownership" (cost=0.00..2.30 rows=2 width=0) (never executed)

  • Index Cond: ("rel.has_ownership".source = merged_properties_diff_37.uuid)
329.          

CTE dirty_field_enqueue.bombora_topic_surge

330. 0.003 0.039 ↓ 0.0 0 1

Insert on "state.q".bombora_topic_surges (cost=3.26..99.75 rows=49 width=126) (actual time=0.037..0.039 rows=0 loops=1)

  • Output: bombora_topic_surges.partition
331. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_12 (cost=3.26..99.75 rows=49 width=126) (actual time=0.036..0.036 rows=0 loops=1)

  • Output: "*SELECT*_12".uuid, "*SELECT*_12".partition, false, false, NULL::jsonb, "*SELECT*_12".dirty_field_ids, NULL::rel_id[], now()
332. 0.001 0.034 ↓ 0.0 0 1

Nested Loop (cost=3.26..99.01 rows=49 width=52) (actual time=0.034..0.034 rows=0 loops=1)

  • Output: "rel.surges_bombora_topic".target, "rel.surges_bombora_topic".target_partition, '{org_identifier}'::"state.q"."bombora_topic_surge.field_ids"[]
333. 0.002 0.033 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_38.uuid
  • Group Key: merged_properties_diff_38.uuid
334. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_38 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_38.uuid, merged_properties_diff_38.old_exists, merged_properties_diff_38.new_exists, merged_properties_diff_38.new_deleted, merged_properties_diff_38.old_properties, merged_properties_diff_38.new_properties, merged_properties_diff_38.changed_field_ids, merged_properties_diff_38.change_count, merged_properties_diff_38.dirty_field_ids, merged_properties_diff_38.dirty_rel_ids, merged_properties_diff_38.updated_at
  • Filter: (merged_properties_diff_38.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
335. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.surges_bombora_topic" (cost=2.81..98.06 rows=49 width=36) (never executed)

  • Output: "rel.surges_bombora_topic".source_partition, "rel.surges_bombora_topic".source_entity_def_id, "rel.surges_bombora_topic".source, "rel.surges_bombora_topic".target_partition, "rel.surges_bombora_topic".target_entity_def_id, "rel.surges_bombora_topic".target
  • Recheck Cond: ("rel.surges_bombora_topic".source = merged_properties_diff_38.uuid)
336. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.surges_bombora_topic" (cost=0.00..2.80 rows=49 width=0) (never executed)

  • Index Cond: ("rel.surges_bombora_topic".source = merged_properties_diff_38.uuid)
337.          

CTE dirty_field_enqueue.person

338. 0.003 0.079 ↓ 0.0 0 1

Insert on "state.q".people (cost=165.99..191.29 rows=92 width=195) (actual time=0.077..0.079 rows=0 loops=1)

  • Output: people.partition
339. 0.001 0.076 ↓ 0.0 0 1

Subquery Scan on *SELECT*_13 (cost=165.99..191.29 rows=92 width=195) (actual time=0.076..0.076 rows=0 loops=1)

  • Output: "*SELECT*_13".uuid, "*SELECT*_13".partition, false, false, NULL::jsonb, "*SELECT*_13".bool, "*SELECT*_13".array_unique, NULL::rel_id[], NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, NULL::integer, now()
340. 0.003 0.075 ↓ 0.0 0 1

HashAggregate (cost=165.99..189.91 rows=92 width=53) (actual time=0.074..0.075 rows=0 loops=1)

  • Output: "*SELECT* 1_5".source, "*SELECT* 1_5".source_partition, true, array_unique(array_agg_mult("*SELECT* 1_5"."array"))
  • Group Key: "*SELECT* 1_5".source, "*SELECT* 1_5".source_partition
341. 0.002 0.072 ↓ 0.0 0 1

Append (cost=2.92..165.30 rows=92 width=52) (actual time=0.071..0.072 rows=0 loops=1)

342. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_5 (cost=2.92..14.77 rows=6 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 1_5".source, "*SELECT* 1_5".source_partition, "*SELECT* 1_5"."array
343. 0.001 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.92..14.71 rows=6 width=56) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_primary_organization".source_partition, "rel.has_primary_organization".source, '{primary_organization}'::"state.q"."person.field_ids"[]
344. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_39.uuid
  • Group Key: merged_properties_diff_39.uuid
345. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_39 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_39.uuid, merged_properties_diff_39.old_exists, merged_properties_diff_39.new_exists, merged_properties_diff_39.new_deleted, merged_properties_diff_39.old_properties, merged_properties_diff_39.new_properties, merged_properties_diff_39.changed_field_ids, merged_properties_diff_39.change_count, merged_properties_diff_39.dirty_field_ids, merged_properties_diff_39.dirty_rel_ids, merged_properties_diff_39.updated_at
  • Filter: (merged_properties_diff_39.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
346. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_primary_organization" (cost=2.47..14.19 rows=6 width=36) (never executed)

  • Output: "rel.has_primary_organization".source_partition, "rel.has_primary_organization".source_entity_def_id, "rel.has_primary_organization".source, "rel.has_primary_organization".target_partition, "rel.has_primary_organization".target_entity_def_id, "rel.has_primary_organization".target
  • Recheck Cond: ("rel.has_primary_organization".target = merged_properties_diff_39.uuid)
347. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "rel.has_primary_organization.target_source" (cost=0.00..2.47 rows=6 width=0) (never executed)

  • Index Cond: ("rel.has_primary_organization".target = merged_properties_diff_39.uuid)
348. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_5 (cost=3.54..150.07 rows=86 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 2_5".target, "*SELECT* 2_5".target_partition, "*SELECT* 2_5"."array
349. 0.001 0.033 ↓ 0.0 0 1

Nested Loop (cost=3.54..149.21 rows=86 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_alumni".target_partition, "rel.has_alumni".target, '{attended_schools}'::"state.q"."person.field_ids"[]
350. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_40.uuid
  • Group Key: merged_properties_diff_40.uuid
351. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_40 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_40.uuid, merged_properties_diff_40.old_exists, merged_properties_diff_40.new_exists, merged_properties_diff_40.new_deleted, merged_properties_diff_40.old_properties, merged_properties_diff_40.new_properties, merged_properties_diff_40.changed_field_ids, merged_properties_diff_40.change_count, merged_properties_diff_40.dirty_field_ids, merged_properties_diff_40.dirty_rel_ids, merged_properties_diff_40.updated_at
  • Filter: (merged_properties_diff_40.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
352. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_alumni" (cost=3.09..147.89 rows=86 width=36) (never executed)

  • Output: "rel.has_alumni".source_partition, "rel.has_alumni".source_entity_def_id, "rel.has_alumni".source, "rel.has_alumni".target_partition, "rel.has_alumni".target_entity_def_id, "rel.has_alumni".target
  • Recheck Cond: ("rel.has_alumni".source = merged_properties_diff_40.uuid)
353. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_alumni" (cost=0.00..3.07 rows=86 width=0) (never executed)

  • Index Cond: ("rel.has_alumni".source = merged_properties_diff_40.uuid)
354.          

CTE dirty_field_enqueue.investment

355. 0.003 0.082 ↓ 0.0 0 1

Insert on "state.q".investments (cost=75.00..84.90 rows=36 width=126) (actual time=0.081..0.082 rows=0 loops=1)

  • Output: investments.partition
356. 0.001 0.079 ↓ 0.0 0 1

Subquery Scan on *SELECT*_14 (cost=75.00..84.90 rows=36 width=126) (actual time=0.079..0.079 rows=0 loops=1)

  • Output: "*SELECT*_14".uuid, "*SELECT*_14".partition, false, false, NULL::jsonb, "*SELECT*_14".array_unique, NULL::rel_id[], now()
357. 0.002 0.078 ↓ 0.0 0 1

HashAggregate (cost=75.00..84.36 rows=36 width=52) (actual time=0.077..0.078 rows=0 loops=1)

  • Output: "*SELECT* 1_6".target, "*SELECT* 1_6".target_partition, array_unique(array_agg_mult("*SELECT* 1_6"."array"))
  • Group Key: "*SELECT* 1_6".target, "*SELECT* 1_6".target_partition
358. 0.003 0.076 ↓ 0.0 0 1

Append (cost=2.94..74.73 rows=36 width=52) (actual time=0.075..0.076 rows=0 loops=1)

359. 0.001 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_6 (cost=2.94..20.49 rows=9 width=52) (actual time=0.036..0.036 rows=0 loops=1)

  • Output: "*SELECT* 1_6".target, "*SELECT* 1_6".target_partition, "*SELECT* 1_6"."array
360. 0.002 0.035 ↓ 0.0 0 1

Nested Loop (cost=2.94..20.40 rows=9 width=56) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_investment".target_partition, "rel.has_investment".target, '{organization_identifier,organization_diversity_spotlights}'::"state.q"."investment.field_ids"[]
361. 0.002 0.033 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_41.uuid
  • Group Key: merged_properties_diff_41.uuid
362. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_41 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_41.uuid, merged_properties_diff_41.old_exists, merged_properties_diff_41.new_exists, merged_properties_diff_41.new_deleted, merged_properties_diff_41.old_properties, merged_properties_diff_41.new_properties, merged_properties_diff_41.changed_field_ids, merged_properties_diff_41.change_count, merged_properties_diff_41.dirty_field_ids, merged_properties_diff_41.dirty_rel_ids, merged_properties_diff_41.updated_at
  • Filter: (merged_properties_diff_41.changed_field_ids && '{diversity_spotlights,identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
363. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_investment" (cost=2.49..19.85 rows=9 width=36) (never executed)

  • Output: "rel.has_investment".source_partition, "rel.has_investment".source_entity_def_id, "rel.has_investment".source, "rel.has_investment".target_partition, "rel.has_investment".target_entity_def_id, "rel.has_investment".target
  • Recheck Cond: ("rel.has_investment".source = merged_properties_diff_41.uuid)
364. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_investment" (cost=0.00..2.49 rows=9 width=0) (never executed)

  • Index Cond: ("rel.has_investment".source = merged_properties_diff_41.uuid)
365. 0.002 0.037 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_6 (cost=3.08..54.06 rows=27 width=52) (actual time=0.037..0.037 rows=0 loops=1)

  • Output: "*SELECT* 2_6".target, "*SELECT* 2_6".target_partition, "*SELECT* 2_6"."array
366. 0.001 0.035 ↓ 0.0 0 1

Nested Loop (cost=3.08..53.79 rows=27 width=56) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.invested_in".target_partition, "rel.invested_in".target, '{investor_stage,investor_type,investor_identifier}'::"state.q"."investment.field_ids"[]
367. 0.002 0.034 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_42.uuid
  • Group Key: merged_properties_diff_42.uuid
368. 0.032 0.032 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_42 (cost=0.00..0.45 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_42.uuid, merged_properties_diff_42.old_exists, merged_properties_diff_42.new_exists, merged_properties_diff_42.new_deleted, merged_properties_diff_42.old_properties, merged_properties_diff_42.new_properties, merged_properties_diff_42.changed_field_ids, merged_properties_diff_42.change_count, merged_properties_diff_42.dirty_field_ids, merged_properties_diff_42.dirty_rel_ids, merged_properties_diff_42.updated_at
  • Filter: (merged_properties_diff_42.changed_field_ids && '{investor_stage,identifier,investor_type}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
369. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.invested_in" (cost=2.63..53.06 rows=27 width=36) (never executed)

  • Output: "rel.invested_in".source_partition, "rel.invested_in".source_entity_def_id, "rel.invested_in".source, "rel.invested_in".target_partition, "rel.invested_in".target_entity_def_id, "rel.invested_in".target
  • Recheck Cond: ("rel.invested_in".source = merged_properties_diff_42.uuid)
370. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.invested_in" (cost=0.00..2.62 rows=27 width=0) (never executed)

  • Index Cond: ("rel.invested_in".source = merged_properties_diff_42.uuid)
371.          

CTE dirty_field_enqueue.hub

372. 0.002 0.038 ↓ 0.0 0 1

Insert on "state.q".hubs (cost=0.73..4.78 rows=1 width=130) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: hubs.partition
373. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT*_15 (cost=0.73..4.78 rows=1 width=130) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT*_15".uuid, "*SELECT*_15".partition, false, false, NULL::jsonb, "*SELECT*_15".dirty_field_ids, NULL::rel_id[], NULL::integer, now()
374. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=0.73..4.77 rows=1 width=52) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: "rel.hub_is_organization".source, "rel.hub_is_organization".source_partition, '{organization}'::"state.q"."hub.field_ids"[]
375. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_43.uuid
  • Group Key: merged_properties_diff_43.uuid
376. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_43 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_43.uuid, merged_properties_diff_43.old_exists, merged_properties_diff_43.new_exists, merged_properties_diff_43.new_deleted, merged_properties_diff_43.old_properties, merged_properties_diff_43.new_properties, merged_properties_diff_43.changed_field_ids, merged_properties_diff_43.change_count, merged_properties_diff_43.dirty_field_ids, merged_properties_diff_43.dirty_rel_ids, merged_properties_diff_43.updated_at
  • Filter: (merged_properties_diff_43.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
377. 0.000 0.000 ↓ 0.0 0

Index Scan using "rel.hub_is_organization.target_source" on public."rel.hub_is_organization" (cost=0.28..4.30 rows=1 width=36) (never executed)

  • Output: "rel.hub_is_organization".source_partition, "rel.hub_is_organization".source_entity_def_id, "rel.hub_is_organization".source, "rel.hub_is_organization".target_partition, "rel.hub_is_organization".target_entity_def_id, "rel.hub_is_organization".target
  • Index Cond: ("rel.hub_is_organization".target = merged_properties_diff_43.uuid)
378.          

CTE dirty_field_enqueue.apptopia_app

379. 0.003 0.038 ↓ 0.0 0 1

Insert on "state.q".apptopia_apps (cost=3.15..69.63 rows=35 width=130) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: apptopia_apps.partition
380. 0.001 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT*_16 (cost=3.15..69.63 rows=35 width=130) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: "*SELECT*_16".uuid, "*SELECT*_16".partition, false, false, NULL::jsonb, "*SELECT*_16".dirty_field_ids, NULL::rel_id[], NULL::integer, now()
381. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=3.15..69.11 rows=35 width=52) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: "rel.has_apptopia_app".target, "rel.has_apptopia_app".target_partition, '{publisher_identfier}'::"state.q"."apptopia_app.field_ids"[]
382. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_44.uuid
  • Group Key: merged_properties_diff_44.uuid
383. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_44 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_44.uuid, merged_properties_diff_44.old_exists, merged_properties_diff_44.new_exists, merged_properties_diff_44.new_deleted, merged_properties_diff_44.old_properties, merged_properties_diff_44.new_properties, merged_properties_diff_44.changed_field_ids, merged_properties_diff_44.change_count, merged_properties_diff_44.dirty_field_ids, merged_properties_diff_44.dirty_rel_ids, merged_properties_diff_44.updated_at
  • Filter: (merged_properties_diff_44.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
384. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_apptopia_app" (cost=2.70..68.30 rows=35 width=36) (never executed)

  • Output: "rel.has_apptopia_app".source_partition, "rel.has_apptopia_app".source_entity_def_id, "rel.has_apptopia_app".source, "rel.has_apptopia_app".target_partition, "rel.has_apptopia_app".target_entity_def_id, "rel.has_apptopia_app".target
  • Recheck Cond: ("rel.has_apptopia_app".source = merged_properties_diff_44.uuid)
385. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_apptopia_app" (cost=0.00..2.69 rows=35 width=0) (never executed)

  • Index Cond: ("rel.has_apptopia_app".source = merged_properties_diff_44.uuid)
386.          

CTE dirty_field_enqueue.fund

387. 0.002 0.123 ↓ 0.0 0 1

Insert on "state.q".funds (cost=18.57..20.28 rows=6 width=135) (actual time=0.122..0.123 rows=0 loops=1)

  • Output: funds.partition
388. 0.002 0.121 ↓ 0.0 0 1

Subquery Scan on *SELECT*_17 (cost=18.57..20.28 rows=6 width=135) (actual time=0.120..0.121 rows=0 loops=1)

  • Output: "*SELECT*_17".uuid, "*SELECT*_17".partition, false, false, NULL::jsonb, "*SELECT*_17".bool, "*SELECT*_17".array_unique, NULL::rel_id[], NULL::integer, NULL::integer, now()
389. 0.002 0.119 ↓ 0.0 0 1

GroupAggregate (cost=18.57..20.19 rows=6 width=53) (actual time=0.118..0.119 rows=0 loops=1)

  • Output: "*SELECT* 1_7".target, "*SELECT* 1_7".target_partition, true, array_unique(array_agg_mult("*SELECT* 1_7"."array"))
  • Group Key: "*SELECT* 1_7".target, "*SELECT* 1_7".target_partition
390. 0.006 0.117 ↓ 0.0 0 1

Sort (cost=18.57..18.58 rows=6 width=52) (actual time=0.116..0.117 rows=0 loops=1)

  • Output: "*SELECT* 1_7".target, "*SELECT* 1_7".target_partition, "*SELECT* 1_7"."array
  • Sort Key: "*SELECT* 1_7".target, "*SELECT* 1_7".target_partition
  • Sort Method: quicksort Memory: 25kB
391. 0.002 0.111 ↓ 0.0 0 1

Append (cost=2.75..18.49 rows=6 width=52) (actual time=0.110..0.111 rows=0 loops=1)

392. 0.002 0.036 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_7 (cost=2.75..5.70 rows=2 width=52) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "*SELECT* 1_7".target, "*SELECT* 1_7".target_partition, "*SELECT* 1_7"."array
393. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=2.75..5.68 rows=2 width=56) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_invested".target_partition, "rel.has_invested".target, '{investor_identifiers}'::"state.q"."fund.field_ids"[]
394. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_45.uuid
  • Group Key: merged_properties_diff_45.uuid
395. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_45 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_45.uuid, merged_properties_diff_45.old_exists, merged_properties_diff_45.new_exists, merged_properties_diff_45.new_deleted, merged_properties_diff_45.old_properties, merged_properties_diff_45.new_properties, merged_properties_diff_45.changed_field_ids, merged_properties_diff_45.change_count, merged_properties_diff_45.dirty_field_ids, merged_properties_diff_45.dirty_rel_ids, merged_properties_diff_45.updated_at
  • Filter: (merged_properties_diff_45.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
396. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_invested" (cost=2.30..5.20 rows=2 width=36) (never executed)

  • Output: "rel.has_invested".source_partition, "rel.has_invested".source_entity_def_id, "rel.has_invested".source, "rel.has_invested".target_partition, "rel.has_invested".target_entity_def_id, "rel.has_invested".target
  • Recheck Cond: ("rel.has_invested".source = merged_properties_diff_45.uuid)
397. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_invested" (cost=0.00..2.29 rows=2 width=0) (never executed)

  • Index Cond: ("rel.has_invested".source = merged_properties_diff_45.uuid)
398. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_7 (cost=2.75..6.38 rows=2 width=52) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT* 2_7".target, "*SELECT* 2_7".target_partition, "*SELECT* 2_7"."array
399. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=2.75..6.36 rows=2 width=56) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_raised_fund".target_partition, "rel.has_raised_fund".target, '{image_id}'::"state.q"."fund.field_ids"[]
400. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_46.uuid
  • Group Key: merged_properties_diff_46.uuid
401. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_46 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_46.uuid, merged_properties_diff_46.old_exists, merged_properties_diff_46.new_exists, merged_properties_diff_46.new_deleted, merged_properties_diff_46.old_properties, merged_properties_diff_46.new_properties, merged_properties_diff_46.changed_field_ids, merged_properties_diff_46.change_count, merged_properties_diff_46.dirty_field_ids, merged_properties_diff_46.dirty_rel_ids, merged_properties_diff_46.updated_at
  • Filter: (merged_properties_diff_46.changed_field_ids && '{image_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
402. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_raised_fund" (cost=2.30..5.88 rows=2 width=36) (never executed)

  • Output: "rel.has_raised_fund".source_partition, "rel.has_raised_fund".source_entity_def_id, "rel.has_raised_fund".source, "rel.has_raised_fund".target_partition, "rel.has_raised_fund".target_entity_def_id, "rel.has_raised_fund".target
  • Recheck Cond: ("rel.has_raised_fund".source = merged_properties_diff_46.uuid)
403. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_raised_fund" (cost=0.00..2.30 rows=2 width=0) (never executed)

  • Index Cond: ("rel.has_raised_fund".source = merged_properties_diff_46.uuid)
404. 0.002 0.038 ↓ 0.0 0 1

Subquery Scan on *SELECT* 3_3 (cost=2.75..6.38 rows=2 width=52) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: "*SELECT* 3_3".target, "*SELECT* 3_3".target_partition, "*SELECT* 3_3"."array
405. 0.001 0.036 ↓ 0.0 0 1

Nested Loop (cost=2.75..6.36 rows=2 width=56) (actual time=0.036..0.036 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.has_raised_fund_1".target_partition, "rel.has_raised_fund_1".target, '{owner_identifier}'::"state.q"."fund.field_ids"[]
406. 0.002 0.035 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_47.uuid
  • Group Key: merged_properties_diff_47.uuid
407. 0.033 0.033 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_47 (cost=0.00..0.45 rows=1 width=16) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_47.uuid, merged_properties_diff_47.old_exists, merged_properties_diff_47.new_exists, merged_properties_diff_47.new_deleted, merged_properties_diff_47.old_properties, merged_properties_diff_47.new_properties, merged_properties_diff_47.changed_field_ids, merged_properties_diff_47.change_count, merged_properties_diff_47.dirty_field_ids, merged_properties_diff_47.dirty_rel_ids, merged_properties_diff_47.updated_at
  • Filter: (merged_properties_diff_47.changed_field_ids && '{name,permalink,image_id,uuid,entity_def_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
408. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_raised_fund" "rel.has_raised_fund_1" (cost=2.30..5.88 rows=2 width=36) (never executed)

  • Output: "rel.has_raised_fund_1".source_partition, "rel.has_raised_fund_1".source_entity_def_id, "rel.has_raised_fund_1".source, "rel.has_raised_fund_1".target_partition, "rel.has_raised_fund_1".target_entity_def_id, "rel.has_raised_fund_1".target
  • Recheck Cond: ("rel.has_raised_fund_1".source = merged_properties_diff_47.uuid)
409. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_raised_fund" (cost=0.00..2.30 rows=2 width=0) (never executed)

  • Index Cond: ("rel.has_raised_fund_1".source = merged_properties_diff_47.uuid)
410.          

CTE dirty_field_enqueue.event_appearance

411. 0.002 0.040 ↓ 0.0 0 1

Insert on "state.q".event_appearances (cost=2.91..10.82 rows=4 width=131) (actual time=0.039..0.040 rows=0 loops=1)

  • Output: event_appearances.partition
412. 0.002 0.038 ↓ 0.0 0 1

Subquery Scan on *SELECT*_18 (cost=2.91..10.82 rows=4 width=131) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: "*SELECT*_18".uuid, "*SELECT*_18".partition, false, false, NULL::jsonb, "*SELECT*_18".bool, "*SELECT*_18".dirty_field_ids, NULL::rel_id[], NULL::integer, now()
413. 0.002 0.036 ↓ 0.0 0 1

Nested Loop (cost=2.91..10.76 rows=4 width=53) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: "rel.in_event_appearance".target, "rel.in_event_appearance".target_partition, true, '{participant_identifier}'::"state.q"."event_appearance.field_ids"[]
414. 0.002 0.034 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.034..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_48.uuid
  • Group Key: merged_properties_diff_48.uuid
415. 0.032 0.032 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_48 (cost=0.00..0.45 rows=1 width=16) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_48.uuid, merged_properties_diff_48.old_exists, merged_properties_diff_48.new_exists, merged_properties_diff_48.new_deleted, merged_properties_diff_48.old_properties, merged_properties_diff_48.new_properties, merged_properties_diff_48.changed_field_ids, merged_properties_diff_48.change_count, merged_properties_diff_48.dirty_field_ids, merged_properties_diff_48.dirty_rel_ids, merged_properties_diff_48.updated_at
  • Filter: (merged_properties_diff_48.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
416. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.in_event_appearance" (cost=2.45..10.26 rows=4 width=36) (never executed)

  • Output: "rel.in_event_appearance".source_partition, "rel.in_event_appearance".source_entity_def_id, "rel.in_event_appearance".source, "rel.in_event_appearance".target_partition, "rel.in_event_appearance".target_entity_def_id, "rel.in_event_appearance".target
  • Recheck Cond: ("rel.in_event_appearance".source = merged_properties_diff_48.uuid)
417. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.in_event_appearance" (cost=0.00..2.45 rows=4 width=0) (never executed)

  • Index Cond: ("rel.in_event_appearance".source = merged_properties_diff_48.uuid)
418.          

CTE dirty_field_enqueue.ipqwery_patent

419. 0.002 0.037 ↓ 0.0 0 1

Insert on "state.q".ipqwery_patents (cost=27.65..1,546.12 rows=857 width=130) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: ipqwery_patents.partition
420. 0.002 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT*_19 (cost=27.65..1,546.12 rows=857 width=130) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: "*SELECT*_19".uuid, "*SELECT*_19".partition, false, false, NULL::jsonb, "*SELECT*_19".dirty_field_ids, NULL::rel_id[], NULL::integer, now()
421. 0.002 0.033 ↓ 0.0 0 1

Nested Loop (cost=27.65..1,533.26 rows=857 width=52) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: "rel.has_ipqwery_patent".target, "rel.has_ipqwery_patent".target_partition, '{owner_identifiers}'::"state.q"."ipqwery_patent.field_ids"[]
422. 0.001 0.031 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_49.uuid
  • Group Key: merged_properties_diff_49.uuid
423. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_49 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_49.uuid, merged_properties_diff_49.old_exists, merged_properties_diff_49.new_exists, merged_properties_diff_49.new_deleted, merged_properties_diff_49.old_properties, merged_properties_diff_49.new_properties, merged_properties_diff_49.changed_field_ids, merged_properties_diff_49.change_count, merged_properties_diff_49.dirty_field_ids, merged_properties_diff_49.dirty_rel_ids, merged_properties_diff_49.updated_at
  • Filter: (merged_properties_diff_49.changed_field_ids && '{identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
424. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_ipqwery_patent" (cost=27.20..1,524.23 rows=857 width=36) (never executed)

  • Output: "rel.has_ipqwery_patent".source_partition, "rel.has_ipqwery_patent".source_entity_def_id, "rel.has_ipqwery_patent".source, "rel.has_ipqwery_patent".target_partition, "rel.has_ipqwery_patent".target_entity_def_id, "rel.has_ipqwery_patent".target
  • Recheck Cond: ("rel.has_ipqwery_patent".source = merged_properties_diff_49.uuid)
425. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_ipqwery_patent" (cost=0.00..26.98 rows=857 width=0) (never executed)

  • Index Cond: ("rel.has_ipqwery_patent".source = merged_properties_diff_49.uuid)
426.          

CTE dirty_field_enqueue.ipo

427. 0.003 0.084 ↓ 0.0 0 1

Insert on "state.q".ipos (cost=9.59..10.16 rows=2 width=131) (actual time=0.082..0.084 rows=0 loops=1)

  • Output: ipos.partition
428. 0.002 0.081 ↓ 0.0 0 1

Subquery Scan on *SELECT*_20 (cost=9.59..10.16 rows=2 width=131) (actual time=0.080..0.081 rows=0 loops=1)

  • Output: "*SELECT*_20".uuid, "*SELECT*_20".partition, false, false, NULL::jsonb, "*SELECT*_20".bool, "*SELECT*_20".array_unique, NULL::rel_id[], NULL::integer, now()
429. 0.002 0.079 ↓ 0.0 0 1

GroupAggregate (cost=9.59..10.13 rows=2 width=53) (actual time=0.079..0.079 rows=0 loops=1)

  • Output: "*SELECT* 1_8".target, "*SELECT* 1_8".target_partition, true, array_unique(array_agg_mult("*SELECT* 1_8"."array"))
  • Group Key: "*SELECT* 1_8".target, "*SELECT* 1_8".target_partition
430. 0.003 0.077 ↓ 0.0 0 1

Sort (cost=9.59..9.60 rows=2 width=52) (actual time=0.077..0.077 rows=0 loops=1)

  • Output: "*SELECT* 1_8".target, "*SELECT* 1_8".target_partition, "*SELECT* 1_8"."array
  • Sort Key: "*SELECT* 1_8".target, "*SELECT* 1_8".target_partition
  • Sort Method: quicksort Memory: 25kB
431. 0.002 0.074 ↓ 0.0 0 1

Append (cost=0.74..9.58 rows=2 width=52) (actual time=0.074..0.074 rows=0 loops=1)

432. 0.002 0.037 ↓ 0.0 0 1

Subquery Scan on *SELECT* 1_8 (cost=0.74..4.79 rows=1 width=52) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: "*SELECT* 1_8".target, "*SELECT* 1_8".target_partition, "*SELECT* 1_8"."array
433. 0.002 0.035 ↓ 0.0 0 1

Nested Loop (cost=0.74..4.78 rows=1 width=56) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.went_public".target_partition, "rel.went_public".target, '{image_id,organization_identifier}'::"state.q"."ipo.field_ids"[]
434. 0.002 0.033 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_50.uuid
  • Group Key: merged_properties_diff_50.uuid
435. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_50 (cost=0.00..0.45 rows=1 width=16) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_50.uuid, merged_properties_diff_50.old_exists, merged_properties_diff_50.new_exists, merged_properties_diff_50.new_deleted, merged_properties_diff_50.old_properties, merged_properties_diff_50.new_properties, merged_properties_diff_50.changed_field_ids, merged_properties_diff_50.change_count, merged_properties_diff_50.dirty_field_ids, merged_properties_diff_50.dirty_rel_ids, merged_properties_diff_50.updated_at
  • Filter: (merged_properties_diff_50.changed_field_ids && '{image_id,identifier}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
436. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.went_public" on public."rel.went_public" (cost=0.29..4.30 rows=1 width=36) (never executed)

  • Output: "rel.went_public".source_partition, "rel.went_public".source_entity_def_id, "rel.went_public".source, "rel.went_public".target_partition, "rel.went_public".target_entity_def_id, "rel.went_public".target
  • Index Cond: ("rel.went_public".source = merged_properties_diff_50.uuid)
437. 0.001 0.035 ↓ 0.0 0 1

Subquery Scan on *SELECT* 2_8 (cost=0.74..4.79 rows=1 width=52) (actual time=0.035..0.035 rows=0 loops=1)

  • Output: "*SELECT* 2_8".target, "*SELECT* 2_8".target_partition, "*SELECT* 2_8"."array
438. 0.002 0.034 ↓ 0.0 0 1

Nested Loop (cost=0.74..4.78 rows=1 width=56) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: NULL::entity_def_id, "rel.went_public_1".target_partition, "rel.went_public_1".target, '{is_last}'::"state.q"."ipo.field_ids"[]
439. 0.002 0.032 ↓ 0.0 0 1

HashAggregate (cost=0.45..0.46 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_51.uuid
  • Group Key: merged_properties_diff_51.uuid
440. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_51 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_51.uuid, merged_properties_diff_51.old_exists, merged_properties_diff_51.new_exists, merged_properties_diff_51.new_deleted, merged_properties_diff_51.old_properties, merged_properties_diff_51.new_properties, merged_properties_diff_51.changed_field_ids, merged_properties_diff_51.change_count, merged_properties_diff_51.dirty_field_ids, merged_properties_diff_51.dirty_rel_ids, merged_properties_diff_51.updated_at
  • Filter: (merged_properties_diff_51.changed_field_ids && '{last_ipo_id}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
441. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.went_public" on public."rel.went_public" "rel.went_public_1" (cost=0.29..4.30 rows=1 width=36) (never executed)

  • Output: "rel.went_public_1".source_partition, "rel.went_public_1".source_entity_def_id, "rel.went_public_1".source, "rel.went_public_1".target_partition, "rel.went_public_1".target_entity_def_id, "rel.went_public_1".target
  • Index Cond: ("rel.went_public_1".source = merged_properties_diff_51.uuid)
442.          

Initplan (for Insert)

443. 0.070 172.313 ↑ 1.0 1 1

Aggregate (cost=0.45..0.46 rows=1 width=8) (actual time=172.312..172.313 rows=1 loops=1)

  • Output: count(*)
444. 172.243 172.243 ↓ 2.5 50 1

CTE Scan on mutated_rows (cost=0.00..0.40 rows=20 width=0) (actual time=7.127..172.243 rows=50 loops=1)

  • Output: mutated_rows.bool
445. 0.010 16.016 ↑ 1.0 1 1

Aggregate (cost=0.41..0.42 rows=1 width=32) (actual time=16.015..16.016 rows=1 loops=1)

  • Output: array_agg("sink_enqueue.elastic.organization".partition)
446. 0.055 16.006 ↑ 9.0 1 1

HashAggregate (cost=0.20..0.29 rows=9 width=4) (actual time=16.004..16.006 rows=1 loops=1)

  • Output: "sink_enqueue.elastic.organization".partition
  • Group Key: "sink_enqueue.elastic.organization".partition
447. 15.951 15.951 ↓ 5.6 50 1

CTE Scan on "sink_enqueue.elastic.organization" (cost=0.00..0.18 rows=9 width=4) (actual time=15.295..15.951 rows=50 loops=1)

  • Output: "sink_enqueue.elastic.organization".partition
448. 0.012 15.332 ↑ 1.0 1 1

Aggregate (cost=0.09..0.10 rows=1 width=32) (actual time=15.331..15.332 rows=1 loops=1)

  • Output: array_agg("sink_enqueue.algolia.organization".partition)
449. 0.036 15.320 ↑ 2.0 1 1

Unique (cost=0.05..0.06 rows=2 width=4) (actual time=15.250..15.320 rows=1 loops=1)

  • Output: "sink_enqueue.algolia.organization".partition
450. 0.080 15.284 ↓ 25.0 50 1

Sort (cost=0.05..0.06 rows=2 width=4) (actual time=15.248..15.284 rows=50 loops=1)

  • Output: "sink_enqueue.algolia.organization".partition
  • Sort Key: "sink_enqueue.algolia.organization".partition
  • Sort Method: quicksort Memory: 27kB
451. 15.204 15.204 ↓ 25.0 50 1

CTE Scan on "sink_enqueue.algolia.organization" (cost=0.00..0.04 rows=2 width=4) (actual time=14.651..15.204 rows=50 loops=1)

  • Output: "sink_enqueue.algolia.organization".partition
452. 0.010 15.279 ↑ 1.0 1 1

Aggregate (cost=0.41..0.42 rows=1 width=32) (actual time=15.278..15.279 rows=1 loops=1)

  • Output: array_agg("sink_enqueue.pg_sink.organization".partition)
453. 0.055 15.269 ↑ 9.0 1 1

HashAggregate (cost=0.20..0.29 rows=9 width=4) (actual time=15.267..15.269 rows=1 loops=1)

  • Output: "sink_enqueue.pg_sink.organization".partition
  • Group Key: "sink_enqueue.pg_sink.organization".partition
454. 15.214 15.214 ↓ 5.6 50 1

CTE Scan on "sink_enqueue.pg_sink.organization" (cost=0.00..0.18 rows=9 width=4) (actual time=14.619..15.214 rows=50 loops=1)

  • Output: "sink_enqueue.pg_sink.organization".partition
455. 0.005 0.048 ↑ 1.0 1 1

Aggregate (cost=0.18..0.19 rows=1 width=32) (actual time=0.047..0.048 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.event_appearance".partition)
456. 0.001 0.043 ↓ 0.0 0 1

HashAggregate (cost=0.09..0.13 rows=4 width=4) (actual time=0.043..0.043 rows=0 loops=1)

  • Output: "dirty_field_enqueue.event_appearance".partition
  • Group Key: "dirty_field_enqueue.event_appearance".partition
457. 0.042 0.042 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.event_appearance" (cost=0.00..0.08 rows=4 width=4) (actual time=0.041..0.042 rows=0 loops=1)

  • Output: "dirty_field_enqueue.event_appearance".partition
458. 0.004 0.134 ↑ 1.0 1 1

Aggregate (cost=1.05..1.06 rows=1 width=32) (actual time=0.133..0.134 rows=1 loops=1)

  • Output: array_agg("field_aliases.organization".partition)
459. 0.002 0.130 ↓ 0.0 0 1

Append (cost=0.05..0.99 rows=21 width=4) (actual time=0.130..0.130 rows=0 loops=1)

460. 0.002 0.083 ↓ 0.0 0 1

Unique (cost=0.05..0.06 rows=2 width=4) (actual time=0.082..0.083 rows=0 loops=1)

  • Output: "field_aliases.organization".partition
461. 0.005 0.081 ↓ 0.0 0 1

Sort (cost=0.05..0.06 rows=2 width=4) (actual time=0.081..0.081 rows=0 loops=1)

  • Output: "field_aliases.organization".partition
  • Sort Key: "field_aliases.organization".partition
  • Sort Method: quicksort Memory: 25kB
462. 0.076 0.076 ↓ 0.0 0 1

CTE Scan on "field_aliases.organization" (cost=0.00..0.04 rows=2 width=4) (actual time=0.075..0.076 rows=0 loops=1)

  • Output: "field_aliases.organization".partition
463. 0.001 0.045 ↓ 0.0 0 1

HashAggregate (cost=0.43..0.62 rows=19 width=4) (actual time=0.045..0.045 rows=0 loops=1)

  • Output: "dirty_field_enqueue.organization".partition
  • Group Key: "dirty_field_enqueue.organization".partition
464. 0.044 0.044 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.organization" (cost=0.00..0.38 rows=19 width=4) (actual time=0.043..0.044 rows=0 loops=1)

  • Output: "dirty_field_enqueue.organization".partition
465. 0.004 0.046 ↑ 1.0 1 1

Aggregate (cost=2.21..2.22 rows=1 width=32) (actual time=0.045..0.046 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.bombora_topic_surge".partition)
466. 0.002 0.042 ↓ 0.0 0 1

HashAggregate (cost=1.10..1.59 rows=49 width=4) (actual time=0.041..0.042 rows=0 loops=1)

  • Output: "dirty_field_enqueue.bombora_topic_surge".partition
  • Group Key: "dirty_field_enqueue.bombora_topic_surge".partition
467. 0.040 0.040 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.bombora_topic_surge" (cost=0.00..0.98 rows=49 width=4) (actual time=0.039..0.040 rows=0 loops=1)

  • Output: "dirty_field_enqueue.bombora_topic_surge".partition
468. 0.004 0.045 ↑ 1.0 1 1

Aggregate (cost=0.05..0.06 rows=1 width=32) (actual time=0.044..0.045 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.siftery_product".partition)
469. 0.002 0.041 ↓ 0.0 0 1

HashAggregate (cost=0.02..0.03 rows=1 width=4) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: "dirty_field_enqueue.siftery_product".partition
  • Group Key: "dirty_field_enqueue.siftery_product".partition
470. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.siftery_product" (cost=0.00..0.02 rows=1 width=4) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "dirty_field_enqueue.siftery_product".partition
471. 0.004 0.046 ↑ 1.0 1 1

Aggregate (cost=4.14..4.15 rows=1 width=32) (actual time=0.045..0.046 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.degree".partition)
472. 0.000 0.042 ↓ 0.0 0 1

HashAggregate (cost=2.07..2.99 rows=92 width=4) (actual time=0.041..0.042 rows=0 loops=1)

  • Output: "dirty_field_enqueue.degree".partition
  • Group Key: "dirty_field_enqueue.degree".partition
473. 0.070 0.070 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.degree" (cost=0.00..1.84 rows=92 width=4) (actual time=0.039..0.070 rows=0 loops=1)

  • Output: "dirty_field_enqueue.degree".partition
474. 0.004 0.130 ↑ 1.0 1 1

Aggregate (cost=0.27..0.28 rows=1 width=32) (actual time=0.129..0.130 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.fund".partition)
475. 0.002 0.126 ↓ 0.0 0 1

HashAggregate (cost=0.14..0.20 rows=6 width=4) (actual time=0.126..0.126 rows=0 loops=1)

  • Output: "dirty_field_enqueue.fund".partition
  • Group Key: "dirty_field_enqueue.fund".partition
476. 0.124 0.124 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.fund" (cost=0.00..0.12 rows=6 width=4) (actual time=0.124..0.124 rows=0 loops=1)

  • Output: "dirty_field_enqueue.fund".partition
477. 0.005 0.047 ↑ 1.0 1 1

Aggregate (cost=3.29..3.30 rows=1 width=32) (actual time=0.045..0.047 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.ipqwery_trademark".partition)
478. 0.003 0.042 ↓ 0.0 0 1

HashAggregate (cost=1.64..2.37 rows=73 width=4) (actual time=0.041..0.042 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipqwery_trademark".partition
  • Group Key: "dirty_field_enqueue.ipqwery_trademark".partition
479. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.ipqwery_trademark" (cost=0.00..1.46 rows=73 width=4) (actual time=0.039..0.039 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipqwery_trademark".partition
480. 0.005 0.095 ↑ 1.0 1 1

Aggregate (cost=0.09..0.10 rows=1 width=32) (actual time=0.093..0.095 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.ipo".partition)
481. 0.002 0.090 ↓ 0.0 0 1

Unique (cost=0.05..0.06 rows=2 width=4) (actual time=0.089..0.090 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipo".partition
482. 0.003 0.088 ↓ 0.0 0 1

Sort (cost=0.05..0.06 rows=2 width=4) (actual time=0.088..0.088 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipo".partition
  • Sort Key: "dirty_field_enqueue.ipo".partition
  • Sort Method: quicksort Memory: 25kB
483. 0.085 0.085 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.ipo" (cost=0.00..0.04 rows=2 width=4) (actual time=0.085..0.085 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipo".partition
484. 0.004 0.048 ↑ 1.0 1 1

Aggregate (cost=35.84..35.85 rows=1 width=32) (actual time=0.046..0.048 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.press_reference".partition)
485. 0.004 0.044 ↓ 0.0 0 1

HashAggregate (cost=31.34..33.34 rows=200 width=4) (actual time=0.043..0.044 rows=0 loops=1)

  • Output: "dirty_field_enqueue.press_reference".partition
  • Group Key: "dirty_field_enqueue.press_reference".partition
486. 0.040 0.040 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.press_reference" (cost=0.00..27.86 rows=1,393 width=4) (actual time=0.039..0.040 rows=0 loops=1)

  • Output: "dirty_field_enqueue.press_reference".partition
487. 0.004 0.232 ↑ 1.0 1 1

Aggregate (cost=2.65..2.66 rows=1 width=32) (actual time=0.231..0.232 rows=1 loops=1)

  • Output: array_agg("featured_order.employees_featured_order.job".partition)
488. 0.002 0.228 ↓ 0.0 0 1

Append (cost=0.02..2.52 rows=53 width=4) (actual time=0.227..0.228 rows=0 loops=1)

489. 0.002 0.055 ↓ 0.0 0 1

HashAggregate (cost=0.02..0.03 rows=1 width=4) (actual time=0.054..0.055 rows=0 loops=1)

  • Output: "featured_order.employees_featured_order.job".partition
  • Group Key: "featured_order.employees_featured_order.job".partition
490. 0.053 0.053 ↓ 0.0 0 1

CTE Scan on "featured_order.employees_featured_order.job" (cost=0.00..0.02 rows=1 width=4) (actual time=0.052..0.053 rows=0 loops=1)

  • Output: "featured_order.employees_featured_order.job".partition
491. 0.002 0.054 ↓ 0.0 0 1

HashAggregate (cost=0.02..0.03 rows=1 width=4) (actual time=0.053..0.054 rows=0 loops=1)

  • Output: "featured_order.advisors_featured_order.job".partition
  • Group Key: "featured_order.advisors_featured_order.job".partition
492. 0.052 0.052 ↓ 0.0 0 1

CTE Scan on "featured_order.advisors_featured_order.job" (cost=0.00..0.02 rows=1 width=4) (actual time=0.051..0.052 rows=0 loops=1)

  • Output: "featured_order.advisors_featured_order.job".partition
493. 0.003 0.117 ↓ 0.0 0 1

HashAggregate (cost=1.15..1.66 rows=51 width=4) (actual time=0.116..0.117 rows=0 loops=1)

  • Output: "dirty_field_enqueue.job".partition
  • Group Key: "dirty_field_enqueue.job".partition
494. 0.114 0.114 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.job" (cost=0.00..1.02 rows=51 width=4) (actual time=0.114..0.114 rows=0 loops=1)

  • Output: "dirty_field_enqueue.job".partition
495. 0.004 0.046 ↑ 1.0 1 1

Aggregate (cost=1.26..1.27 rows=1 width=32) (actual time=0.045..0.046 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.investor_prediction".partition)
496. 0.002 0.042 ↓ 0.0 0 1

HashAggregate (cost=0.63..0.91 rows=28 width=4) (actual time=0.041..0.042 rows=0 loops=1)

  • Output: "dirty_field_enqueue.investor_prediction".partition
  • Group Key: "dirty_field_enqueue.investor_prediction".partition
497. 0.040 0.040 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.investor_prediction" (cost=0.00..0.56 rows=28 width=4) (actual time=0.039..0.040 rows=0 loops=1)

  • Output: "dirty_field_enqueue.investor_prediction".partition
498. 0.004 0.045 ↑ 1.0 1 1

Aggregate (cost=0.05..0.06 rows=1 width=32) (actual time=0.044..0.045 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.key_employee_change".partition)
499. 0.002 0.041 ↓ 0.0 0 1

HashAggregate (cost=0.02..0.03 rows=1 width=4) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: "dirty_field_enqueue.key_employee_change".partition
  • Group Key: "dirty_field_enqueue.key_employee_change".partition
500. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.key_employee_change" (cost=0.00..0.02 rows=1 width=4) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "dirty_field_enqueue.key_employee_change".partition
501. 0.005 0.090 ↑ 1.0 1 1

Aggregate (cost=1.62..1.63 rows=1 width=32) (actual time=0.088..0.090 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.investment".partition)
502. 0.002 0.085 ↓ 0.0 0 1

HashAggregate (cost=0.81..1.17 rows=36 width=4) (actual time=0.085..0.085 rows=0 loops=1)

  • Output: "dirty_field_enqueue.investment".partition
  • Group Key: "dirty_field_enqueue.investment".partition
503. 0.083 0.083 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.investment" (cost=0.00..0.72 rows=36 width=4) (actual time=0.083..0.083 rows=0 loops=1)

  • Output: "dirty_field_enqueue.investment".partition
504. 0.004 0.282 ↑ 1.0 1 1

Aggregate (cost=2.30..2.31 rows=1 width=32) (actual time=0.281..0.282 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.funding_round".partition)
505. 0.003 0.278 ↓ 0.0 0 1

HashAggregate (cost=1.15..1.66 rows=51 width=4) (actual time=0.277..0.278 rows=0 loops=1)

  • Output: "dirty_field_enqueue.funding_round".partition
  • Group Key: "dirty_field_enqueue.funding_round".partition
506. 0.275 0.275 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.funding_round" (cost=0.00..1.02 rows=51 width=4) (actual time=0.274..0.275 rows=0 loops=1)

  • Output: "dirty_field_enqueue.funding_round".partition
507. 0.005 0.222 ↑ 1.0 1 1

Aggregate (cost=0.59..0.60 rows=1 width=32) (actual time=0.220..0.222 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.acquisition".partition)
508. 0.002 0.217 ↓ 0.0 0 1

HashAggregate (cost=0.29..0.42 rows=13 width=4) (actual time=0.216..0.217 rows=0 loops=1)

  • Output: "dirty_field_enqueue.acquisition".partition
  • Group Key: "dirty_field_enqueue.acquisition".partition
509. 0.215 0.215 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.acquisition" (cost=0.00..0.26 rows=13 width=4) (actual time=0.214..0.215 rows=0 loops=1)

  • Output: "dirty_field_enqueue.acquisition".partition
510. 0.005 0.045 ↑ 1.0 1 1

Aggregate (cost=0.23..0.24 rows=1 width=32) (actual time=0.044..0.045 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.layoff".partition)
511. 0.001 0.040 ↓ 0.0 0 1

HashAggregate (cost=0.11..0.16 rows=5 width=4) (actual time=0.040..0.040 rows=0 loops=1)

  • Output: "dirty_field_enqueue.layoff".partition
  • Group Key: "dirty_field_enqueue.layoff".partition
512. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.layoff" (cost=0.00..0.10 rows=5 width=4) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "dirty_field_enqueue.layoff".partition
513. 0.004 0.045 ↑ 1.0 1 1

Aggregate (cost=0.05..0.06 rows=1 width=32) (actual time=0.044..0.045 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.hub".partition)
514. 0.002 0.041 ↓ 0.0 0 1

HashAggregate (cost=0.02..0.03 rows=1 width=4) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: "dirty_field_enqueue.hub".partition
  • Group Key: "dirty_field_enqueue.hub".partition
515. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.hub" (cost=0.00..0.02 rows=1 width=4) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: "dirty_field_enqueue.hub".partition
516. 0.004 0.045 ↑ 1.0 1 1

Aggregate (cost=1.58..1.59 rows=1 width=32) (actual time=0.044..0.045 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.apptopia_app".partition)
517. 0.002 0.041 ↓ 0.0 0 1

HashAggregate (cost=0.79..1.14 rows=35 width=4) (actual time=0.041..0.041 rows=0 loops=1)

  • Output: "dirty_field_enqueue.apptopia_app".partition
  • Group Key: "dirty_field_enqueue.apptopia_app".partition
518. 0.039 0.039 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.apptopia_app" (cost=0.00..0.70 rows=35 width=4) (actual time=0.039..0.039 rows=0 loops=1)

  • Output: "dirty_field_enqueue.apptopia_app".partition
519. 0.004 0.087 ↑ 1.0 1 1

Aggregate (cost=4.14..4.15 rows=1 width=32) (actual time=0.086..0.087 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.person".partition)
520. 0.003 0.083 ↓ 0.0 0 1

HashAggregate (cost=2.07..2.99 rows=92 width=4) (actual time=0.082..0.083 rows=0 loops=1)

  • Output: "dirty_field_enqueue.person".partition
  • Group Key: "dirty_field_enqueue.person".partition
521. 0.080 0.080 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.person" (cost=0.00..1.84 rows=92 width=4) (actual time=0.079..0.080 rows=0 loops=1)

  • Output: "dirty_field_enqueue.person".partition
522. 0.005 0.046 ↑ 1.0 1 1

Aggregate (cost=23.79..23.80 rows=1 width=32) (actual time=0.045..0.046 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.ipqwery_patent".partition)
523. 0.003 0.041 ↓ 0.0 0 1

HashAggregate (cost=19.28..21.28 rows=200 width=4) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipqwery_patent".partition
  • Group Key: "dirty_field_enqueue.ipqwery_patent".partition
524. 0.038 0.038 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.ipqwery_patent" (cost=0.00..17.14 rows=857 width=4) (actual time=0.038..0.038 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ipqwery_patent".partition
525. 0.005 0.092 ↑ 1.0 1 1

Aggregate (cost=0.14..0.15 rows=1 width=32) (actual time=0.091..0.092 rows=1 loops=1)

  • Output: array_agg("dirty_field_enqueue.ownership".partition)
526. 0.002 0.087 ↓ 0.0 0 1

HashAggregate (cost=0.07..0.10 rows=3 width=4) (actual time=0.086..0.087 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ownership".partition
  • Group Key: "dirty_field_enqueue.ownership".partition
527. 0.085 0.085 ↓ 0.0 0 1

CTE Scan on "dirty_field_enqueue.ownership" (cost=0.00..0.06 rows=3 width=4) (actual time=0.085..0.085 rows=0 loops=1)

  • Output: "dirty_field_enqueue.ownership".partition
528. 0.010 15.619 ↑ 1.0 1 1

Aggregate (cost=0.23..0.24 rows=1 width=32) (actual time=15.618..15.619 rows=1 loops=1)

  • Output: array_agg("sink_enqueue.timeseries.organization".partition)
529. 0.056 15.609 ↑ 5.0 1 1

HashAggregate (cost=0.11..0.16 rows=5 width=4) (actual time=15.607..15.609 rows=1 loops=1)

  • Output: "sink_enqueue.timeseries.organization".partition
  • Group Key: "sink_enqueue.timeseries.organization".partition
530. 15.553 15.553 ↓ 10.0 50 1

CTE Scan on "sink_enqueue.timeseries.organization" (cost=0.00..0.10 rows=5 width=4) (actual time=14.957..15.553 rows=50 loops=1)

  • Output: "sink_enqueue.timeseries.organization".partition
531. 0.009 0.130 ↑ 1.0 1 1

Aggregate (cost=230.40..230.41 rows=1 width=32) (actual time=0.128..0.130 rows=1 loops=1)

  • Output: array_agg("jump_rel.enqueued.195d7065.has_investor_diversity_spot".partition)
532. 0.003 0.121 ↓ 0.0 0 1

HashAggregate (cost=225.90..227.90 rows=200 width=4) (actual time=0.121..0.121 rows=0 loops=1)

  • Output: "jump_rel.enqueued.195d7065.has_investor_diversity_spot".partition
  • Group Key: "jump_rel.enqueued.195d7065.has_investor_diversity_spot".partition
533. 0.118 0.118 ↓ 0.0 0 1

CTE Scan on "jump_rel.enqueued.195d7065.has_investor_diversity_spot" (cost=0.00..200.80 rows=10,040 width=4) (actual time=0.117..0.118 rows=0 loops=1)

  • Output: "jump_rel.enqueued.195d7065.has_investor_diversity_spot".partition
534. 3.841 5.064 ↑ 1.0 1 1

Aggregate (cost=313.05..313.06 rows=1 width=32) (actual time=5.063..5.064 rows=1 loops=1)

  • Output: jsonb_agg(jsonb_build_object('uuid', merged_properties_diff_52.uuid, 'deleted', merged_properties_diff_52.new_deleted, 'properties', merged_properties_diff_52.new_properties, 'changed_field_ids', merged_properties_diff_52.changed_field_ids, 'dirty_field_ids', merged_properties_diff_52.dirty_field_ids, 'dirty_fields_prefetch', (merge_jsonb_agg((jsonb_build_object('has_last_funding_round|forward', (array_agg(jsonb_build_object('investment_type', (entity.properties -> 'investment_type'::text), 'money_raised', (entity.properties -> 'money_raised'::text), 'announced_on', (entity.properties -> 'announced_on'::text))))[1:200])))), 'dirty_rel_ids', merged_properties_diff_52.dirty_rel_ids, 'dirty_rels_prefetch', rels_prefetch_related_data.dirty_rels_prefetch))
535. 0.056 1.223 ↓ 2.5 50 1

Hash Right Join (cost=307.46..312.95 rows=20 width=209) (actual time=1.176..1.223 rows=50 loops=1)

  • Output: merged_properties_diff_52.uuid, merged_properties_diff_52.new_deleted, merged_properties_diff_52.new_properties, merged_properties_diff_52.changed_field_ids, merged_properties_diff_52.dirty_field_ids, (merge_jsonb_agg((jsonb_build_object('has_last_funding_round|forward', (array_agg(jsonb_build_object('investment_type', (entity.properties -> 'investment_type'::text), 'money_raised', (entity.properties -> 'money_raised'::text), 'announced_on', (entity.properties -> 'announced_on'::text))))[1:200])))), merged_properties_diff_52.dirty_rel_ids, rels_prefetch_related_data.dirty_rels_prefetch
  • Hash Cond: (merged_properties_diff_53.uuid = merged_properties_diff_52.uuid)
536. 0.002 0.767 ↓ 0.0 0 1

GroupAggregate (cost=279.64..284.68 rows=19 width=48) (actual time=0.766..0.767 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, merge_jsonb_agg((jsonb_build_object('has_last_funding_round|forward', (array_agg(jsonb_build_object('investment_type', (entity.properties -> 'investment_type'::text), 'money_raised', (entity.properties -> 'money_raised'::text), 'announced_on', (entity.properties -> 'announced_on'::text))))[1:200])))
  • Group Key: merged_properties_diff_53.uuid
537. 0.004 0.765 ↓ 0.0 0 1

Sort (cost=279.64..279.69 rows=19 width=48) (actual time=0.764..0.765 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, (jsonb_build_object('has_last_funding_round|forward', (array_agg(jsonb_build_object('investment_type', (entity.properties -> 'investment_type'::text), 'money_raised', (entity.properties -> 'money_raised'::text), 'announced_on', (entity.properties -> 'announced_on'::text))))[1:200]))
  • Sort Key: merged_properties_diff_53.uuid
  • Sort Method: quicksort Memory: 25kB
538. 0.011 0.761 ↓ 0.0 0 1

Append (cost=9.08..279.24 rows=19 width=48) (actual time=0.761..0.761 rows=0 loops=1)

539. 0.001 0.041 ↓ 0.0 0 1

GroupAggregate (cost=9.08..9.12 rows=1 width=48) (actual time=0.041..0.041 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, jsonb_build_object('has_last_funding_round|forward', (array_agg(jsonb_build_object('investment_type', (entity.properties -> 'investment_type'::text), 'money_raised', (entity.properties -> 'money_raised'::text), 'announced_on', (entity.properties -> 'announced_on'::text))))[1:200])
  • Group Key: merged_properties_diff_53.uuid
540. 0.005 0.040 ↓ 0.0 0 1

Sort (cost=9.08..9.09 rows=1 width=630) (actual time=0.039..0.040 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, entity.properties
  • Sort Key: merged_properties_diff_53.uuid
  • Sort Method: quicksort Memory: 25kB
541. 0.002 0.035 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.71..9.07 rows=1 width=630) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, entity.properties
542. 0.001 0.033 ↓ 0.0 0 1

Nested Loop (cost=0.42..4.90 rows=1 width=36) (actual time=0.033..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, rel_2.target, rel_2.target_partition
543. 0.032 0.032 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_53 (cost=0.00..0.45 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_53.uuid, merged_properties_diff_53.old_exists, merged_properties_diff_53.new_exists, merged_properties_diff_53.new_deleted, merged_properties_diff_53.old_properties, merged_properties_diff_53.new_properties, merged_properties_diff_53.changed_field_ids, merged_properties_diff_53.change_count, merged_properties_diff_53.dirty_field_ids, merged_properties_diff_53.dirty_rel_ids, merged_properties_diff_53.updated_at
  • Filter: (merged_properties_diff_53.dirty_field_ids && '{last_funding_at,last_funding_type,last_funding_total}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
544. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_last_funding_round" on public."rel.has_last_funding_round" rel_2 (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: rel_2.source_partition, rel_2.source_entity_def_id, rel_2.source, rel_2.target_partition, rel_2.target_entity_def_id, rel_2.target
  • Index Cond: (rel_2.source = merged_properties_diff_53.uuid)
545. 0.000 0.000 ↓ 0.0 0

Append (cost=0.29..4.10 rows=8 width=634) (never executed)

546. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.0" on "state.p"."funding_rounds.0" entity (cost=0.29..0.50 rows=1 width=628) (never executed)

  • Output: entity.properties, entity.uuid, entity.partition
  • Index Cond: (entity.uuid = rel_2.target)
  • Filter: ((NOT entity.deleted) AND (rel_2.target_partition = entity.partition))
547. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.1" on "state.p"."funding_rounds.1" entity_1 (cost=0.29..0.50 rows=1 width=632) (never executed)

  • Output: entity_1.properties, entity_1.uuid, entity_1.partition
  • Index Cond: (entity_1.uuid = rel_2.target)
  • Filter: ((NOT entity_1.deleted) AND (rel_2.target_partition = entity_1.partition))
548. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.2" on "state.p"."funding_rounds.2" entity_2 (cost=0.29..0.52 rows=1 width=630) (never executed)

  • Output: entity_2.properties, entity_2.uuid, entity_2.partition
  • Index Cond: (entity_2.uuid = rel_2.target)
  • Filter: ((NOT entity_2.deleted) AND (rel_2.target_partition = entity_2.partition))
549. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.3" on "state.p"."funding_rounds.3" entity_3 (cost=0.29..0.51 rows=1 width=641) (never executed)

  • Output: entity_3.properties, entity_3.uuid, entity_3.partition
  • Index Cond: (entity_3.uuid = rel_2.target)
  • Filter: ((NOT entity_3.deleted) AND (rel_2.target_partition = entity_3.partition))
550. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.4" on "state.p"."funding_rounds.4" entity_4 (cost=0.29..0.52 rows=1 width=637) (never executed)

  • Output: entity_4.properties, entity_4.uuid, entity_4.partition
  • Index Cond: (entity_4.uuid = rel_2.target)
  • Filter: ((NOT entity_4.deleted) AND (rel_2.target_partition = entity_4.partition))
551. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.5" on "state.p"."funding_rounds.5" entity_5 (cost=0.29..0.51 rows=1 width=639) (never executed)

  • Output: entity_5.properties, entity_5.uuid, entity_5.partition
  • Index Cond: (entity_5.uuid = rel_2.target)
  • Filter: ((NOT entity_5.deleted) AND (rel_2.target_partition = entity_5.partition))
552. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.6" on "state.p"."funding_rounds.6" entity_6 (cost=0.29..0.50 rows=1 width=638) (never executed)

  • Output: entity_6.properties, entity_6.uuid, entity_6.partition
  • Index Cond: (entity_6.uuid = rel_2.target)
  • Filter: ((NOT entity_6.deleted) AND (rel_2.target_partition = entity_6.partition))
553. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.7" on "state.p"."funding_rounds.7" entity_7 (cost=0.29..0.50 rows=1 width=630) (never executed)

  • Output: entity_7.properties, entity_7.uuid, entity_7.partition
  • Index Cond: (entity_7.uuid = rel_2.target)
  • Filter: ((NOT entity_7.deleted) AND (rel_2.target_partition = entity_7.partition))
554. 0.002 0.039 ↓ 0.0 0 1

GroupAggregate (cost=6.98..7.01 rows=1 width=48) (actual time=0.039..0.039 rows=0 loops=1)

  • Output: merged_properties_diff_54.uuid, jsonb_build_object('has_hq_location|forward', (array_agg(jsonb_build_object('locations', (entity_8.properties -> 'locations'::text), 'groups', (entity_8.properties -> 'groups'::text))))[1:200])
  • Group Key: merged_properties_diff_54.uuid
555. 0.003 0.037 ↓ 0.0 0 1

Sort (cost=6.98..6.99 rows=1 width=1,513) (actual time=0.037..0.037 rows=0 loops=1)

  • Output: merged_properties_diff_54.uuid, entity_8.properties
  • Sort Key: merged_properties_diff_54.uuid
  • Sort Method: quicksort Memory: 25kB
556. 0.002 0.034 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.84..6.97 rows=1 width=1,513) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_54.uuid, entity_8.properties
557. 0.001 0.032 ↓ 0.0 0 1

Nested Loop (cost=0.42..4.90 rows=1 width=36) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_54.uuid, rel_3.target, rel_3.target_partition
558. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_54 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_54.uuid, merged_properties_diff_54.old_exists, merged_properties_diff_54.new_exists, merged_properties_diff_54.new_deleted, merged_properties_diff_54.old_properties, merged_properties_diff_54.new_properties, merged_properties_diff_54.changed_field_ids, merged_properties_diff_54.change_count, merged_properties_diff_54.dirty_field_ids, merged_properties_diff_54.dirty_rel_ids, merged_properties_diff_54.updated_at
  • Filter: (merged_properties_diff_54.dirty_field_ids && '{location_group_identifiers,location_identifiers}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
559. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_hq_location" on public."rel.has_hq_location" rel_3 (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: rel_3.source_partition, rel_3.source_entity_def_id, rel_3.source, rel_3.target_partition, rel_3.target_entity_def_id, rel_3.target
  • Index Cond: (rel_3.source = merged_properties_diff_54.uuid)
560. 0.000 0.000 ↓ 0.0 0

Append (cost=0.42..2.03 rows=4 width=1,517) (never executed)

561. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.locations.uuid.0" on "state.p"."locations.0" entity_8 (cost=0.42..0.50 rows=1 width=1,514) (never executed)

  • Output: entity_8.properties, entity_8.uuid, entity_8.partition
  • Index Cond: (entity_8.uuid = rel_3.target)
  • Filter: ((NOT entity_8.deleted) AND (rel_3.target_partition = entity_8.partition))
562. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.locations.uuid.1" on "state.p"."locations.1" entity_9 (cost=0.42..0.50 rows=1 width=1,517) (never executed)

  • Output: entity_9.properties, entity_9.uuid, entity_9.partition
  • Index Cond: (entity_9.uuid = rel_3.target)
  • Filter: ((NOT entity_9.deleted) AND (rel_3.target_partition = entity_9.partition))
563. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.locations.uuid.2" on "state.p"."locations.2" entity_10 (cost=0.42..0.50 rows=1 width=1,518) (never executed)

  • Output: entity_10.properties, entity_10.uuid, entity_10.partition
  • Index Cond: (entity_10.uuid = rel_3.target)
  • Filter: ((NOT entity_10.deleted) AND (rel_3.target_partition = entity_10.partition))
564. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.locations.uuid.3" on "state.p"."locations.3" entity_11 (cost=0.42..0.50 rows=1 width=1,518) (never executed)

  • Output: entity_11.properties, entity_11.uuid, entity_11.partition
  • Index Cond: (entity_11.uuid = rel_3.target)
  • Filter: ((NOT entity_11.deleted) AND (rel_3.target_partition = entity_11.partition))
565. 0.002 0.041 ↓ 0.0 0 1

GroupAggregate (cost=6.22..6.25 rows=1 width=48) (actual time=0.040..0.041 rows=0 loops=1)

  • Output: merged_properties_diff_55.uuid, jsonb_build_object('has_key_employee_change|forward', (array_agg(jsonb_build_object('key_event_date', (entity_12.properties -> 'key_event_date'::text))))[1:200])
  • Group Key: merged_properties_diff_55.uuid
566. 0.004 0.039 ↓ 0.0 0 1

Sort (cost=6.22..6.23 rows=1 width=612) (actual time=0.038..0.039 rows=0 loops=1)

  • Output: merged_properties_diff_55.uuid, entity_12.properties
  • Sort Key: merged_properties_diff_55.uuid
  • Sort Method: quicksort Memory: 25kB
567. 0.002 0.035 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.56..6.21 rows=1 width=612) (actual time=0.034..0.035 rows=0 loops=1)

  • Output: merged_properties_diff_55.uuid, entity_12.properties
568. 0.001 0.033 ↓ 0.0 0 1

Nested Loop (cost=0.28..4.76 rows=1 width=36) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_55.uuid, rel_4.target, rel_4.target_partition
569. 0.032 0.032 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_55 (cost=0.00..0.45 rows=1 width=16) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_55.uuid, merged_properties_diff_55.old_exists, merged_properties_diff_55.new_exists, merged_properties_diff_55.new_deleted, merged_properties_diff_55.old_properties, merged_properties_diff_55.new_properties, merged_properties_diff_55.changed_field_ids, merged_properties_diff_55.change_count, merged_properties_diff_55.dirty_field_ids, merged_properties_diff_55.dirty_rel_ids, merged_properties_diff_55.updated_at
  • Filter: (merged_properties_diff_55.dirty_field_ids && '{last_key_employee_change_date}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
570. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_key_employee_change" on public."rel.has_key_employee_change" rel_4 (cost=0.28..4.30 rows=1 width=36) (never executed)

  • Output: rel_4.source_partition, rel_4.source_entity_def_id, rel_4.source, rel_4.target_partition, rel_4.target_entity_def_id, rel_4.target
  • Index Cond: (rel_4.source = merged_properties_diff_55.uuid)
571. 0.000 0.000 ↓ 0.0 0

Append (cost=0.28..1.41 rows=4 width=616) (never executed)

572. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.key_employee_changes.uuid.0" on "state.p"."key_employee_changes.0" entity_12 (cost=0.28..0.35 rows=1 width=620) (never executed)

  • Output: entity_12.properties, entity_12.uuid, entity_12.partition
  • Index Cond: (entity_12.uuid = rel_4.target)
  • Filter: ((NOT entity_12.deleted) AND (rel_4.target_partition = entity_12.partition))
573. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.key_employee_changes.uuid.1" on "state.p"."key_employee_changes.1" entity_13 (cost=0.28..0.35 rows=1 width=619) (never executed)

  • Output: entity_13.properties, entity_13.uuid, entity_13.partition
  • Index Cond: (entity_13.uuid = rel_4.target)
  • Filter: ((NOT entity_13.deleted) AND (rel_4.target_partition = entity_13.partition))
574. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.key_employee_changes.uuid.2" on "state.p"."key_employee_changes.2" entity_14 (cost=0.28..0.35 rows=1 width=617) (never executed)

  • Output: entity_14.properties, entity_14.uuid, entity_14.partition
  • Index Cond: (entity_14.uuid = rel_4.target)
  • Filter: ((NOT entity_14.deleted) AND (rel_4.target_partition = entity_14.partition))
575. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.key_employee_changes.uuid.3" on "state.p"."key_employee_changes.3" entity_15 (cost=0.28..0.35 rows=1 width=608) (never executed)

  • Output: entity_15.properties, entity_15.uuid, entity_15.partition
  • Index Cond: (entity_15.uuid = rel_4.target)
  • Filter: ((NOT entity_15.deleted) AND (rel_4.target_partition = entity_15.partition))
576. 0.002 0.038 ↓ 0.0 0 1

GroupAggregate (cost=9.23..9.27 rows=1 width=48) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: merged_properties_diff_56.uuid, jsonb_build_object('has_last_equity_funding_round|forward', (array_agg(jsonb_build_object('investment_type', (entity_16.properties -> 'investment_type'::text), 'money_raised', (entity_16.properties -> 'money_raised'::text), 'investment_stage', (entity_16.properties -> 'investment_stage'::text))))[1:200])
  • Group Key: merged_properties_diff_56.uuid
577. 0.004 0.036 ↓ 0.0 0 1

Sort (cost=9.23..9.24 rows=1 width=630) (actual time=0.035..0.036 rows=0 loops=1)

  • Output: merged_properties_diff_56.uuid, entity_16.properties
  • Sort Key: merged_properties_diff_56.uuid
  • Sort Method: quicksort Memory: 25kB
578. 0.001 0.032 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.71..9.22 rows=1 width=630) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_56.uuid, entity_16.properties
579. 0.002 0.031 ↓ 0.0 0 1

Nested Loop (cost=0.42..4.90 rows=1 width=36) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_56.uuid, rel_5.target, rel_5.target_partition
580. 0.029 0.029 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_56 (cost=0.00..0.45 rows=1 width=16) (actual time=0.028..0.029 rows=0 loops=1)

  • Output: merged_properties_diff_56.uuid, merged_properties_diff_56.old_exists, merged_properties_diff_56.new_exists, merged_properties_diff_56.new_deleted, merged_properties_diff_56.old_properties, merged_properties_diff_56.new_properties, merged_properties_diff_56.changed_field_ids, merged_properties_diff_56.change_count, merged_properties_diff_56.dirty_field_ids, merged_properties_diff_56.dirty_rel_ids, merged_properties_diff_56.updated_at
  • Filter: (merged_properties_diff_56.dirty_field_ids && '{last_equity_funding_type,last_equity_funding_total,last_funding_stage}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
581. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_last_equity_funding_round" on public."rel.has_last_equity_funding_round" rel_5 (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: rel_5.source_partition, rel_5.source_entity_def_id, rel_5.source, rel_5.target_partition, rel_5.target_entity_def_id, rel_5.target
  • Index Cond: (rel_5.source = merged_properties_diff_56.uuid)
582. 0.000 0.000 ↓ 0.0 0

Append (cost=0.29..4.24 rows=8 width=634) (never executed)

583. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.0" on "state.p"."funding_rounds.0" entity_16 (cost=0.29..0.51 rows=1 width=628) (never executed)

  • Output: entity_16.properties, entity_16.uuid, entity_16.partition
  • Index Cond: (entity_16.uuid = rel_5.target)
  • Filter: ((NOT entity_16.deleted) AND (rel_5.target_partition = entity_16.partition))
584. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.1" on "state.p"."funding_rounds.1" entity_17 (cost=0.29..0.52 rows=1 width=632) (never executed)

  • Output: entity_17.properties, entity_17.uuid, entity_17.partition
  • Index Cond: (entity_17.uuid = rel_5.target)
  • Filter: ((NOT entity_17.deleted) AND (rel_5.target_partition = entity_17.partition))
585. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.2" on "state.p"."funding_rounds.2" entity_18 (cost=0.29..0.54 rows=1 width=630) (never executed)

  • Output: entity_18.properties, entity_18.uuid, entity_18.partition
  • Index Cond: (entity_18.uuid = rel_5.target)
  • Filter: ((NOT entity_18.deleted) AND (rel_5.target_partition = entity_18.partition))
586. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.3" on "state.p"."funding_rounds.3" entity_19 (cost=0.29..0.53 rows=1 width=641) (never executed)

  • Output: entity_19.properties, entity_19.uuid, entity_19.partition
  • Index Cond: (entity_19.uuid = rel_5.target)
  • Filter: ((NOT entity_19.deleted) AND (rel_5.target_partition = entity_19.partition))
587. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.4" on "state.p"."funding_rounds.4" entity_20 (cost=0.29..0.54 rows=1 width=637) (never executed)

  • Output: entity_20.properties, entity_20.uuid, entity_20.partition
  • Index Cond: (entity_20.uuid = rel_5.target)
  • Filter: ((NOT entity_20.deleted) AND (rel_5.target_partition = entity_20.partition))
588. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.5" on "state.p"."funding_rounds.5" entity_21 (cost=0.29..0.53 rows=1 width=639) (never executed)

  • Output: entity_21.properties, entity_21.uuid, entity_21.partition
  • Index Cond: (entity_21.uuid = rel_5.target)
  • Filter: ((NOT entity_21.deleted) AND (rel_5.target_partition = entity_21.partition))
589. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.6" on "state.p"."funding_rounds.6" entity_22 (cost=0.29..0.52 rows=1 width=638) (never executed)

  • Output: entity_22.properties, entity_22.uuid, entity_22.partition
  • Index Cond: (entity_22.uuid = rel_5.target)
  • Filter: ((NOT entity_22.deleted) AND (rel_5.target_partition = entity_22.partition))
590. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.7" on "state.p"."funding_rounds.7" entity_23 (cost=0.29..0.52 rows=1 width=630) (never executed)

  • Output: entity_23.properties, entity_23.uuid, entity_23.partition
  • Index Cond: (entity_23.uuid = rel_5.target)
  • Filter: ((NOT entity_23.deleted) AND (rel_5.target_partition = entity_23.partition))
591. 0.002 0.039 ↓ 0.0 0 1

GroupAggregate (cost=9.36..9.39 rows=1 width=48) (actual time=0.039..0.039 rows=0 loops=1)

  • Output: merged_properties_diff_57.uuid, jsonb_build_object('hub_is_organization|reverse', (array_agg(jsonb_build_object('identifier', (entity_24.properties -> 'identifier'::text))))[1:200])
  • Group Key: merged_properties_diff_57.uuid
592. 0.003 0.037 ↓ 0.0 0 1

Sort (cost=9.36..9.36 rows=1 width=34) (actual time=0.037..0.037 rows=0 loops=1)

  • Output: merged_properties_diff_57.uuid, entity_24.properties
  • Sort Key: merged_properties_diff_57.uuid
  • Sort Method: quicksort Memory: 25kB
593. 0.002 0.034 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.57..9.35 rows=1 width=34) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_57.uuid, entity_24.properties
594. 0.002 0.032 ↓ 0.0 0 1

Nested Loop (cost=0.28..4.76 rows=1 width=36) (actual time=0.031..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_57.uuid, rel_6.source, rel_6.source_partition
595. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_57 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_57.uuid, merged_properties_diff_57.old_exists, merged_properties_diff_57.new_exists, merged_properties_diff_57.new_deleted, merged_properties_diff_57.old_properties, merged_properties_diff_57.new_properties, merged_properties_diff_57.changed_field_ids, merged_properties_diff_57.change_count, merged_properties_diff_57.dirty_field_ids, merged_properties_diff_57.dirty_rel_ids, merged_properties_diff_57.updated_at
  • Filter: (merged_properties_diff_57.dirty_field_ids && '{hubs}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
596. 0.000 0.000 ↓ 0.0 0

Index Scan using "rel.hub_is_organization.target_source" on public."rel.hub_is_organization" rel_6 (cost=0.28..4.30 rows=1 width=36) (never executed)

  • Output: rel_6.source_partition, rel_6.source_entity_def_id, rel_6.source, rel_6.target_partition, rel_6.target_entity_def_id, rel_6.target
  • Index Cond: (rel_6.target = merged_properties_diff_57.uuid)
597. 0.000 0.000 ↓ 0.0 0

Append (cost=0.29..4.55 rows=4 width=38) (never executed)

598. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.hubs.uuid.0" on "state.p"."hubs.0" entity_24 (cost=0.29..1.12 rows=1 width=38) (never executed)

  • Output: entity_24.properties, entity_24.uuid, entity_24.partition
  • Index Cond: (entity_24.uuid = rel_6.source)
  • Filter: ((NOT entity_24.deleted) AND (rel_6.source_partition = entity_24.partition))
599. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.hubs.uuid.1" on "state.p"."hubs.1" entity_25 (cost=0.29..1.14 rows=1 width=38) (never executed)

  • Output: entity_25.properties, entity_25.uuid, entity_25.partition
  • Index Cond: (entity_25.uuid = rel_6.source)
  • Filter: ((NOT entity_25.deleted) AND (rel_6.source_partition = entity_25.partition))
600. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.hubs.uuid.2" on "state.p"."hubs.2" entity_26 (cost=0.29..1.13 rows=1 width=38) (never executed)

  • Output: entity_26.properties, entity_26.uuid, entity_26.partition
  • Index Cond: (entity_26.uuid = rel_6.source)
  • Filter: ((NOT entity_26.deleted) AND (rel_6.source_partition = entity_26.partition))
601. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.hubs.uuid.3" on "state.p"."hubs.3" entity_27 (cost=0.29..1.14 rows=1 width=38) (never executed)

  • Output: entity_27.properties, entity_27.uuid, entity_27.partition
  • Index Cond: (entity_27.uuid = rel_6.source)
  • Filter: ((NOT entity_27.deleted) AND (rel_6.source_partition = entity_27.partition))
602. 0.002 0.040 ↓ 0.0 0 1

GroupAggregate (cost=9.00..9.03 rows=1 width=48) (actual time=0.039..0.040 rows=0 loops=1)

  • Output: merged_properties_diff_58.uuid, jsonb_build_object('has_last_post_money_funding_round|forward', (array_agg(jsonb_build_object('announced_on', (entity_28.properties -> 'announced_on'::text), 'post_money_valuation', (entity_28.properties -> 'post_money_valuation'::text))))[1:200])
  • Group Key: merged_properties_diff_58.uuid
603. 0.004 0.038 ↓ 0.0 0 1

Sort (cost=9.00..9.01 rows=1 width=630) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: merged_properties_diff_58.uuid, entity_28.properties
  • Sort Key: merged_properties_diff_58.uuid
  • Sort Method: quicksort Memory: 25kB
604. 0.002 0.034 ↓ 0.0 0 1

Nested Loop Left Join (cost=0.71..8.99 rows=1 width=630) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_58.uuid, entity_28.properties
605. 0.001 0.032 ↓ 0.0 0 1

Nested Loop (cost=0.42..4.90 rows=1 width=36) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_58.uuid, rel_7.target, rel_7.target_partition
606. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_58 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_58.uuid, merged_properties_diff_58.old_exists, merged_properties_diff_58.new_exists, merged_properties_diff_58.new_deleted, merged_properties_diff_58.old_properties, merged_properties_diff_58.new_properties, merged_properties_diff_58.changed_field_ids, merged_properties_diff_58.change_count, merged_properties_diff_58.dirty_field_ids, merged_properties_diff_58.dirty_rel_ids, merged_properties_diff_58.updated_at
  • Filter: (merged_properties_diff_58.dirty_field_ids && '{valuation_date,valuation}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
607. 0.000 0.000 ↓ 0.0 0

Index Scan using "PK_rel.has_last_post_money_funding_round" on public."rel.has_last_post_money_funding_round" rel_7 (cost=0.42..4.44 rows=1 width=36) (never executed)

  • Output: rel_7.source_partition, rel_7.source_entity_def_id, rel_7.source, rel_7.target_partition, rel_7.target_entity_def_id, rel_7.target
  • Index Cond: (rel_7.source = merged_properties_diff_58.uuid)
608. 0.000 0.000 ↓ 0.0 0

Append (cost=0.29..4.01 rows=8 width=634) (never executed)

609. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.0" on "state.p"."funding_rounds.0" entity_28 (cost=0.29..0.49 rows=1 width=628) (never executed)

  • Output: entity_28.properties, entity_28.uuid, entity_28.partition
  • Index Cond: (entity_28.uuid = rel_7.target)
  • Filter: ((NOT entity_28.deleted) AND (rel_7.target_partition = entity_28.partition))
610. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.1" on "state.p"."funding_rounds.1" entity_29 (cost=0.29..0.49 rows=1 width=632) (never executed)

  • Output: entity_29.properties, entity_29.uuid, entity_29.partition
  • Index Cond: (entity_29.uuid = rel_7.target)
  • Filter: ((NOT entity_29.deleted) AND (rel_7.target_partition = entity_29.partition))
611. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.2" on "state.p"."funding_rounds.2" entity_30 (cost=0.29..0.51 rows=1 width=630) (never executed)

  • Output: entity_30.properties, entity_30.uuid, entity_30.partition
  • Index Cond: (entity_30.uuid = rel_7.target)
  • Filter: ((NOT entity_30.deleted) AND (rel_7.target_partition = entity_30.partition))
612. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.3" on "state.p"."funding_rounds.3" entity_31 (cost=0.29..0.50 rows=1 width=641) (never executed)

  • Output: entity_31.properties, entity_31.uuid, entity_31.partition
  • Index Cond: (entity_31.uuid = rel_7.target)
  • Filter: ((NOT entity_31.deleted) AND (rel_7.target_partition = entity_31.partition))
613. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.4" on "state.p"."funding_rounds.4" entity_32 (cost=0.29..0.51 rows=1 width=637) (never executed)

  • Output: entity_32.properties, entity_32.uuid, entity_32.partition
  • Index Cond: (entity_32.uuid = rel_7.target)
  • Filter: ((NOT entity_32.deleted) AND (rel_7.target_partition = entity_32.partition))
614. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.5" on "state.p"."funding_rounds.5" entity_33 (cost=0.29..0.50 rows=1 width=639) (never executed)

  • Output: entity_33.properties, entity_33.uuid, entity_33.partition
  • Index Cond: (entity_33.uuid = rel_7.target)
  • Filter: ((NOT entity_33.deleted) AND (rel_7.target_partition = entity_33.partition))
615. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.6" on "state.p"."funding_rounds.6" entity_34 (cost=0.29..0.49 rows=1 width=638) (never executed)

  • Output: entity_34.properties, entity_34.uuid, entity_34.partition
  • Index Cond: (entity_34.uuid = rel_7.target)
  • Filter: ((NOT entity_34.deleted) AND (rel_7.target_partition = entity_34.partition))
616. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.funding_rounds.uuid.7" on "state.p"."funding_rounds.7" entity_35 (cost=0.29..0.49 rows=1 width=630) (never executed)

  • Output: entity_35.properties, entity_35.uuid, entity_35.partition
  • Index Cond: (entity_35.uuid = rel_7.target)
  • Filter: ((NOT entity_35.deleted) AND (rel_7.target_partition = entity_35.partition))
617. 0.001 0.038 ↓ 0.0 0 1

GroupAggregate (cost=17.27..17.31 rows=1 width=48) (actual time=0.038..0.038 rows=0 loops=1)

  • Output: merged_properties_diff_59.uuid, jsonb_build_object('has_founder|forward', (array_agg(jsonb_build_object('identifier', (entity_36.properties -> 'identifier'::text))))[1:200])
  • Group Key: merged_properties_diff_59.uuid
618. 0.004 0.037 ↓ 0.0 0 1

Sort (cost=17.27..17.27 rows=2 width=1,190) (actual time=0.036..0.037 rows=0 loops=1)

  • Output: merged_properties_diff_59.uuid, entity_36.properties
  • Sort Key: merged_properties_diff_59.uuid
  • Sort Method: quicksort Memory: 25kB
619. 0.002 0.033 ↓ 0.0 0 1

Nested Loop Left Join (cost=2.86..17.26 rows=2 width=1,190) (actual time=0.032..0.033 rows=0 loops=1)

  • Output: merged_properties_diff_59.uuid, entity_36.properties
620. 0.001 0.031 ↓ 0.0 0 1

Nested Loop (cost=2.44..6.85 rows=2 width=36) (actual time=0.031..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_59.uuid, rel_8.target, rel_8.target_partition
621. 0.030 0.030 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_59 (cost=0.00..0.45 rows=1 width=16) (actual time=0.029..0.030 rows=0 loops=1)

  • Output: merged_properties_diff_59.uuid, merged_properties_diff_59.old_exists, merged_properties_diff_59.new_exists, merged_properties_diff_59.new_deleted, merged_properties_diff_59.old_properties, merged_properties_diff_59.new_properties, merged_properties_diff_59.changed_field_ids, merged_properties_diff_59.change_count, merged_properties_diff_59.dirty_field_ids, merged_properties_diff_59.dirty_rel_ids, merged_properties_diff_59.updated_at
  • Filter: (merged_properties_diff_59.dirty_field_ids && '{founder_identifiers}'::"state.q"."organization.field_ids"[])
  • Rows Removed by Filter: 50
622. 0.000 0.000 ↓ 0.0 0

Bitmap Heap Scan on public."rel.has_founder" rel_8 (cost=2.44..6.38 rows=2 width=36) (never executed)

  • Output: rel_8.source_partition, rel_8.source_entity_def_id, rel_8.source, rel_8.target_partition, rel_8.target_entity_def_id, rel_8.target
  • Recheck Cond: (rel_8.source = merged_properties_diff_59.uuid)
623. 0.000 0.000 ↓ 0.0 0

Bitmap Index Scan on "PK_rel.has_founder" (cost=0.00..2.44 rows=2 width=0) (never executed)

  • Index Cond: (rel_8.source = merged_properties_diff_59.uuid)
624. 0.000 0.000 ↓ 0.0 0

Append (cost=0.42..5.13 rows=8 width=1,194) (never executed)

625. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.0" on "state.p"."people.0" entity_36 (cost=0.42..0.66 rows=1 width=1,190) (never executed)

  • Output: entity_36.properties, entity_36.uuid, entity_36.partition
  • Index Cond: (entity_36.uuid = rel_8.target)
  • Filter: ((NOT entity_36.deleted) AND (rel_8.target_partition = entity_36.partition))
626. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.1" on "state.p"."people.1" entity_37 (cost=0.42..0.63 rows=1 width=1,191) (never executed)

  • Output: entity_37.properties, entity_37.uuid, entity_37.partition
  • Index Cond: (entity_37.uuid = rel_8.target)
  • Filter: ((NOT entity_37.deleted) AND (rel_8.target_partition = entity_37.partition))
627. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.2" on "state.p"."people.2" entity_38 (cost=0.42..0.64 rows=1 width=1,197) (never executed)

  • Output: entity_38.properties, entity_38.uuid, entity_38.partition
  • Index Cond: (entity_38.uuid = rel_8.target)
  • Filter: ((NOT entity_38.deleted) AND (rel_8.target_partition = entity_38.partition))
628. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.3" on "state.p"."people.3" entity_39 (cost=0.42..0.63 rows=1 width=1,192) (never executed)

  • Output: entity_39.properties, entity_39.uuid, entity_39.partition
  • Index Cond: (entity_39.uuid = rel_8.target)
  • Filter: ((NOT entity_39.deleted) AND (rel_8.target_partition = entity_39.partition))
629. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.4" on "state.p"."people.4" entity_40 (cost=0.42..0.63 rows=1 width=1,197) (never executed)

  • Output: entity_40.properties, entity_40.uuid, entity_40.partition
  • Index Cond: (entity_40.uuid = rel_8.target)
  • Filter: ((NOT entity_40.deleted) AND (rel_8.target_partition = entity_40.partition))
630. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.5" on "state.p"."people.5" entity_41 (cost=0.42..0.64 rows=1 width=1,189) (never executed)

  • Output: entity_41.properties, entity_41.uuid, entity_41.partition
  • Index Cond: (entity_41.uuid = rel_8.target)
  • Filter: ((NOT entity_41.deleted) AND (rel_8.target_partition = entity_41.partition))
631. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.6" on "state.p"."people.6" entity_42 (cost=0.42..0.63 rows=1 width=1,194) (never executed)

  • Output: entity_42.properties, entity_42.uuid, entity_42.partition
  • Index Cond: (entity_42.uuid = rel_8.target)
  • Filter: ((NOT entity_42.deleted) AND (rel_8.target_partition = entity_42.partition))
632. 0.000 0.000 ↓ 0.0 0

Index Scan using "idx.people.uuid.7" on "state.p"."people.7" entity_43 (cost=0.42..0.63 rows=1 width=1,198) (never executed)

  • Output: entity_43.properties, entity_43.uuid, entity_43.partition
  • Index Cond: (entity_43.uuid = rel_8.target)
  • Filter: ((NOT entity_43.deleted) AND (rel_8.target_partition = entity_43.partition))
633. 0.001 0.039 ↓ 0.0 0 1

GroupAggregate (cost=96.84..97.01 rows=1 width=48) (actual time=0.039..0.039 rows=0 loops=1)

  • Output: merged_properties_diff_60.uuid, jsonb_build_object('has_investor|forward', (array_agg(jsonb_build_object('permalink', ("organizations.0".properties -> 'permalink'::text), 'entity_def_id', ("organizations.0".properties -> 'entity_def_id'::text), 'image_id', ("organizations.0".properties -> 'image_id'::text), 'name', ("organizations.0".properties -> 'name'::text), 'rank', ("organizations.0".properties -> 'rank'::text), 'uuid', ("organizations.0".properties -> 'uuid'::text))))[1:200])
  • Group Key: merged_properties_diff_60.uuid
634. 0.004 0.038 ↓ 0.0 0 1

Sort (cost=96.84..96.86 rows=6 width=775) (actual time=0.037..0.038 rows=0 loops=1)

  • Output: merged_properties_diff_60.uuid, "organizations.0".properties
  • Sort Key: merged_properties_diff_60.uuid
  • Sort Method: quicksort Memory: 25kB
635. 0.002 0.034 ↓ 0.0 0 1

Nested Loop Left Join (cost=2.89..96.76 rows=6 width=775) (actual time=0.033..0.034 rows=0 loops=1)

  • Output: merged_properties_diff_60.uuid, "organizations.0".properties
636. 0.001 0.032 ↓ 0.0 0 1

Nested Loop (cost=2.47..14.59 rows=6 width=40) (actual time=0.032..0.032 rows=0 loops=1)

  • Output: merged_properties_diff_60.uuid, rel_9.target, rel_9.target_partition, rel_9.target_entity_def_id
637. 0.031 0.031 ↓ 0.0 0 1

CTE Scan on merged_properties_diff merged_properties_diff_60 (cost=0.00..0.45 rows=1 width=16) (actual time=0.030..0.031 rows=0 loops=1)

  • Output: merged_properties_diff_60.uuid, merged_properties_diff_60.old_exists, merged_properties_diff_60.new_exists, merged_properties_diff_60.new_deleted, merged_properties_diff_60.old_properties, merged_properties_diff_60.new_properties, merged_properties_diff_60.changed_field_ids, merged_properties_diff_60.change_count, merged_properties_diff_60.dirty_field_ids, merged_properties_diff_60.dirty_rel_ids, merged_properties_diff_60.updated_at
  • Filter: (merged_proper