Shard Split support for Columnar and Partitioned Table (#6067)

DESCRIPTION:
This PR extends support for Partitioned and Columnar tables in blocking 'citus_split_shard_by_split_points' workflow.
Columnar Support : No special handling required. Just removing checks that fails split for columnar table and adding test coverage.
Partitioned Table Support :

Skip copying of parent table as they are empty, The partitions contain data and are treated as co-located shards that will be copied separately.
Attach partitions to parent on destination after inserting new shard metadata and before creating foreign key constraints.
MISC:
Fix Bug #4949 where Blocking shard moves fails if there is a foreign key between partitioned distributed tables (from child to parent).

TEST:
Added new test 'citus_split_shards_columnar_partitioned' for splitting 'partitioned' and 'columnar + partitioned' table.
Added new test 'shard_move_constraints_blocking' to add coverage for shard move bug fix.
Updated test 'citus_split_shard_by_split_points_negative' to allow columnar and partitioned table.

src/backend/distributed/operations/repair_shards.c

@@ -53,6 +53,18 @@
 #include "utils/rel.h"
 #include "utils/syscache.h"
 
+/* local type declarations */
+
+/*
+ * ShardInterval along with to be executed
+ * DDL command list.
+ */
+typedef struct ShardCommandList
+{
+	ShardInterval *shardInterval;
+	List *ddlCommandList;
+} ShardCommandList;
+
 /* local function forward declarations */
 static void VerifyTablesHaveReplicaIdentity(List *colocatedTableList);
 static bool RelationCanPublishAllModifications(Oid relationId);
@@ -114,6 +126,8 @@ static List * CopyShardContentsCommandList(ShardInterval *shardInterval,
 static List * PostLoadShardCreationCommandList(ShardInterval *shardInterval,
 											   const char *sourceNodeName,
 											   int32 sourceNodePort);
+static ShardCommandList * CreateShardCommandList(ShardInterval *shardInterval,
+												 List *ddlCommandList);
 
 
 /* declarations for dynamic loading */
@@ -1129,6 +1143,22 @@ CopyShardTablesViaLogicalReplication(List *shardIntervalList, char *sourceNodeNa
 }
 
 
+/*
+ * CreateShardCommandList creates a struct for shard interval
+ * along with DDL commands to be executed.
+ */
+static ShardCommandList *
+CreateShardCommandList(ShardInterval *shardInterval, List *ddlCommandList)
+{
+	ShardCommandList *shardCommandList = palloc0(
+		sizeof(ShardCommandList));
+	shardCommandList->shardInterval = shardInterval;
+	shardCommandList->ddlCommandList = ddlCommandList;
+
+	return shardCommandList;
+}
+
+
 /*
  * CopyShardTablesViaBlockWrites copies a shard along with its co-located shards
  * from a source node to target node via COPY command. While the command is in
@@ -1187,10 +1217,28 @@ CopyShardTablesViaBlockWrites(List *shardIntervalList, char *sourceNodeName,
 	}
 
 	/*
-	 * Once all shards are created, we can recreate relationships between shards.
-	 *
-	 * Iterate through the colocated shards and create the foreign constraints and
-	 * attach child tables to their parents in a partitioning hierarchy.
+	 * Once all shards are copied, we can recreate relationships between shards.
+	 * Create DDL commands to Attach child tables to their parents in a partitioning hierarchy.
+	 */
+	List *shardIntervalWithDDCommandsList = NIL;
+	foreach_ptr(shardInterval, shardIntervalList)
+	{
+		if (PartitionTable(shardInterval->relationId))
+		{
+			char *attachPartitionCommand =
+				GenerateAttachShardPartitionCommand(shardInterval);
+
+			ShardCommandList *shardCommandList = CreateShardCommandList(
+				shardInterval,
+				list_make1(attachPartitionCommand));
+			shardIntervalWithDDCommandsList = lappend(shardIntervalWithDDCommandsList,
+													  shardCommandList);
+		}
+	}
+
+	/*
+	 * Iterate through the colocated shards and create DDL commamnds
+	 * to create the foreign constraints.
 	 */
 	foreach_ptr(shardInterval, shardIntervalList)
 	{
@@ -1201,25 +1249,25 @@ CopyShardTablesViaBlockWrites(List *shardIntervalList, char *sourceNodeName,
 													 &shardForeignConstraintCommandList,
 													 &referenceTableForeignConstraintList);
 
-		List *commandList = NIL;
-		commandList = list_concat(commandList, shardForeignConstraintCommandList);
-		commandList = list_concat(commandList, referenceTableForeignConstraintList);
-
-		if (PartitionTable(shardInterval->relationId))
-		{
-			char *attachPartitionCommand =
-				GenerateAttachShardPartitionCommand(shardInterval);
-
-			commandList = lappend(commandList, attachPartitionCommand);
-		}
-
-		char *tableOwner = TableOwner(shardInterval->relationId);
-		SendCommandListToWorkerOutsideTransaction(targetNodeName, targetNodePort,
-												  tableOwner, commandList);
-
-		MemoryContextReset(localContext);
+		ShardCommandList *shardCommandList = CreateShardCommandList(
+			shardInterval,
+			list_concat(shardForeignConstraintCommandList,
+						referenceTableForeignConstraintList));
+		shardIntervalWithDDCommandsList = lappend(shardIntervalWithDDCommandsList,
+												  shardCommandList);
 	}
 
+	/* Now execute the Partitioning & Foreign constraints creation commads. */
+	ShardCommandList *shardCommandList = NULL;
+	foreach_ptr(shardCommandList, shardIntervalWithDDCommandsList)
+	{
+		char *tableOwner = TableOwner(shardCommandList->shardInterval->relationId);
+		SendCommandListToWorkerOutsideTransaction(targetNodeName, targetNodePort,
+												  tableOwner,
+												  shardCommandList->ddlCommandList);
+	}
+
+	MemoryContextReset(localContext);
 	MemoryContextSwitchTo(oldContext);
 }
 

src/backend/distributed/operations/shard_split.c

@@ -82,6 +82,8 @@ static StringInfo CreateSplitCopyCommand(ShardInterval *sourceShardSplitInterval
 										 List *workersForPlacementList);
 static void InsertSplitChildrenShardMetadata(List *shardGroupSplitIntervalListList,
 											 List *workersForPlacementList);
+static void CreatePartitioningHierarchy(List *shardGroupSplitIntervalListList,
+										List *workersForPlacementList);
 static void CreateForeignKeyConstraints(List *shardGroupSplitIntervalListList,
 										List *workersForPlacementList);
 static void TryDropSplitShardsOnFailure(HTAB *mapOfShardToPlacementCreatedByWorkflow);
@@ -135,28 +137,6 @@ ErrorIfCannotSplitShard(SplitOperation splitOperation, ShardInterval *sourceShar
 							errdetail("Splitting shards backed by foreign tables "
 									  "is not supported.")));
 		}
-
-		/*
-		 * At the moment, we do not support copying a shard if that shard's
-		 * relation is in a colocation group with a partitioned table or partition.
-		 */
-		if (PartitionedTable(colocatedTableId))
-		{
-			char *sourceRelationName = get_rel_name(relationId);
-			char *colocatedRelationName = get_rel_name(colocatedTableId);
-
-			ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
-							errmsg("cannot %s of '%s', because it "
-								   "is a partitioned table",
-								   SplitOperationName[splitOperation],
-								   colocatedRelationName),
-							errdetail("In colocation group of '%s', a partitioned "
-									  "relation exists: '%s'. Citus does not support "
-									  "%s of partitioned tables.",
-									  sourceRelationName,
-									  colocatedRelationName,
-									  SplitOperationName[splitOperation])));
-		}
 	}
 
 	/* check shards with inactive placements */
@@ -213,15 +193,6 @@ ErrorIfCannotSplitShardExtended(SplitOperation splitOperation,
 							   SplitTargetName[splitOperation])));
 	}
 
-	if (extern_IsColumnarTableAmTable(shardIntervalToSplit->relationId))
-	{
-		ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
-						errmsg("Cannot %s %s as operation "
-							   "is not supported for Columnar tables.",
-							   SplitOperationName[splitOperation],
-							   SplitTargetName[splitOperation])));
-	}
-
 	uint32 relationReplicationFactor = TableShardReplicationFactor(
 		shardIntervalToSplit->relationId);
 	if (relationReplicationFactor > 1)
@@ -414,8 +385,8 @@ SplitShard(SplitMode splitMode,
 
 
 /*
- * ShardIntervalHashCode computes the hash code for a shard from the
- * placement's shard id.
+ * ShardIntervalHashCode computes the hash code for a Shardinterval using
+ * shardId.
  */
 static uint32
 ShardIntervalHashCode(const void *key, Size keySize)
@@ -526,6 +497,12 @@ BlockingShardSplit(SplitOperation splitOperation,
 			shardGroupSplitIntervalListList,
 			workersForPlacementList);
 
+		/*
+		 * Up to this point, we performed various subtransactions that may
+		 * require additional clean-up in case of failure. The remaining operations
+		 * going forward are part of the same distributed transaction.
+		 */
+
 		/*
 		 * Drop old shards and delete related metadata. Have to do that before
 		 * creating the new shard metadata, because there's cross-checks
@@ -537,6 +514,10 @@ BlockingShardSplit(SplitOperation splitOperation,
 		InsertSplitChildrenShardMetadata(shardGroupSplitIntervalListList,
 										 workersForPlacementList);
 
+		/* create partitioning hierarchy, if any */
+		CreatePartitioningHierarchy(shardGroupSplitIntervalListList,
+									workersForPlacementList);
+
 		/*
 		 * Create foreign keys if exists after the metadata changes happening in
 		 * DropShardList() and InsertSplitChildrenShardMetadata() because the foreign
@@ -719,23 +700,32 @@ DoSplitCopy(WorkerNode *sourceShardNode, List *sourceColocatedShardIntervalList,
 	forboth_ptr(sourceShardIntervalToCopy, sourceColocatedShardIntervalList,
 				splitShardIntervalList, shardGroupSplitIntervalListList)
 	{
-		StringInfo splitCopyUdfCommand = CreateSplitCopyCommand(sourceShardIntervalToCopy,
-																splitShardIntervalList,
-																destinationWorkerNodesList);
+		/*
+		 * Skip copying data for partitioned tables, because they contain no
+		 * data themselves. Their partitions do contain data, but those are
+		 * different colocated shards that will be copied seperately.
+		 */
+		if (!PartitionedTable(sourceShardIntervalToCopy->relationId))
+		{
+			StringInfo splitCopyUdfCommand = CreateSplitCopyCommand(
+				sourceShardIntervalToCopy,
+				splitShardIntervalList,
+				destinationWorkerNodesList);
 
-		Task *splitCopyTask = CreateBasicTask(
-			sourceShardIntervalToCopy->shardId, /* jobId */
-			taskId,
-			READ_TASK,
-			splitCopyUdfCommand->data);
+			Task *splitCopyTask = CreateBasicTask(
+				INVALID_JOB_ID,
+				taskId,
+				READ_TASK,
+				splitCopyUdfCommand->data);
 
-		ShardPlacement *taskPlacement = CitusMakeNode(ShardPlacement);
-		SetPlacementNodeMetadata(taskPlacement, sourceShardNode);
+			ShardPlacement *taskPlacement = CitusMakeNode(ShardPlacement);
+			SetPlacementNodeMetadata(taskPlacement, sourceShardNode);
 
-		splitCopyTask->taskPlacementList = list_make1(taskPlacement);
+			splitCopyTask->taskPlacementList = list_make1(taskPlacement);
 
-		splitCopyTaskList = lappend(splitCopyTaskList, splitCopyTask);
-		taskId++;
+			splitCopyTaskList = lappend(splitCopyTaskList, splitCopyTask);
+			taskId++;
+		}
 	}
 
 	ExecuteTaskListOutsideTransaction(ROW_MODIFY_NONE, splitCopyTaskList,
@@ -955,6 +945,46 @@ InsertSplitChildrenShardMetadata(List *shardGroupSplitIntervalListList,
 }
 
 
+/*
+ * CreatePartitioningHierarchy creates the partitioning
+ * hierarchy between the shardList, if any.
+ */
+static void
+CreatePartitioningHierarchy(List *shardGroupSplitIntervalListList,
+							List *workersForPlacementList)
+{
+	/* Create partition heirarchy between shards */
+	List *shardIntervalList = NIL;
+
+	/*
+	 * Iterate over all the shards in the shard group.
+	 */
+	foreach_ptr(shardIntervalList, shardGroupSplitIntervalListList)
+	{
+		ShardInterval *shardInterval = NULL;
+		WorkerNode *workerPlacementNode = NULL;
+
+		/*
+		 * Iterate on split shards list for a given shard and create constraints.
+		 */
+		forboth_ptr(shardInterval, shardIntervalList, workerPlacementNode,
+					workersForPlacementList)
+		{
+			if (PartitionTable(shardInterval->relationId))
+			{
+				char *attachPartitionCommand =
+					GenerateAttachShardPartitionCommand(shardInterval);
+
+				SendCommandToWorker(
+					workerPlacementNode->workerName,
+					workerPlacementNode->workerPort,
+					attachPartitionCommand);
+			}
+		}
+	}
+}
+
+
 /*
  * Create foreign key constraints on the split children shards.
  */
@@ -1074,7 +1104,7 @@ DropShardList(List *shardIntervalList)
 
 
 /*
- * In case of failure, DropShardPlacementList drops shard placements and their metadata from both the
+ * In case of failure, TryDropSplitShardsOnFailure drops in-progress shard placements from both the
  * coordinator and mx nodes.
  */
 static void

src/test/regress/enterprise_schedule

@@ -34,5 +34,6 @@ test: multi_alter_table_row_level_security
 test: multi_alter_table_row_level_security_escape
 test: stat_statements
 test: shard_move_constraints
+test: shard_move_constraints_blocking
 test: logical_rep_consistency
 test: check_mx

src/test/regress/expected/citus_split_shard_by_split_points_negative.out

@@ -140,34 +140,3 @@ SELECT citus_split_shard_by_split_points(
 	ARRAY['-1073741826'],
 	ARRAY[:worker_1_node, :worker_2_node]);
 ERROR:  Operation split not supported for shard as replication factor '2' is greater than 1.
--- Create distributed table with columnar type.
-SET citus.next_shard_id TO 51271400;
-CREATE TABLE table_to_split_columnar (id bigserial PRIMARY KEY, value char) USING columnar;
-SELECT create_distributed_table('table_to_split_columnar','id');
- create_distributed_table
----------------------------------------------------------------------
-
-(1 row)
-
--- UDF fails for columnar table.
-SELECT citus_split_shard_by_split_points(
-	51271400,
-	ARRAY['-1073741826'],
-	ARRAY[:worker_1_node, :worker_2_node]);
-ERROR:  Cannot split shard as operation is not supported for Columnar tables.
--- Create distributed table which is partitioned.
-SET citus.next_shard_id TO 51271900;
-CREATE TABLE table_to_split_partitioned(id integer, dt date) PARTITION BY RANGE(dt);
-SELECT create_distributed_table('table_to_split_partitioned','id');
- create_distributed_table
----------------------------------------------------------------------
-
-(1 row)
-
--- UDF fails for partitioned table.
-SELECT citus_split_shard_by_split_points(
-	51271900,
-	ARRAY['-1073741826'],
-	ARRAY[:worker_1_node, :worker_2_node]);
-ERROR:  cannot split of 'table_to_split_partitioned', because it is a partitioned table
-DETAIL:  In colocation group of 'table_to_split_partitioned', a partitioned relation exists: 'table_to_split_partitioned'. Citus does not support split of partitioned tables.

src/test/regress/expected/citus_split_shard_columnar_partitioned.out

@@ -0,0 +1,812 @@
+CREATE SCHEMA "citus_split_test_schema_columnar_partitioned";
+SET search_path TO "citus_split_test_schema_columnar_partitioned";
+SET citus.next_shard_id TO 8970000;
+SET citus.next_placement_id TO 8770000;
+SET citus.shard_count TO 1;
+SET citus.shard_replication_factor TO 1;
+-- BEGIN: Create table to split, along with other co-located tables. Add indexes, statistics etc.
+    CREATE TABLE sensors(
+        measureid         integer,
+        eventdatetime     date,
+        measure_data      jsonb,
+        PRIMARY KEY (measureid, eventdatetime, measure_data))
+    PARTITION BY RANGE(eventdatetime);
+    -- Table access method is specified on child tables
+    CREATE TABLE sensorscolumnar(
+        measureid         integer,
+        eventdatetime     date,
+        measure_data      jsonb,
+        PRIMARY KEY (measureid, eventdatetime, measure_data))
+    PARTITION BY RANGE(eventdatetime);
+    -- Create Partitions of table 'sensors'.
+    CREATE TABLE sensors_old PARTITION OF sensors FOR VALUES FROM ('2000-01-01') TO ('2020-01-01');
+    CREATE TABLE sensors_2020_01_01 PARTITION OF sensors FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+    CREATE TABLE sensors_news PARTITION OF sensors FOR VALUES FROM ('2020-05-01') TO ('2025-01-01');
+    CREATE TABLE sensorscolumnar_old PARTITION OF sensorscolumnar FOR VALUES FROM ('2000-01-01') TO ('2020-01-01')  USING COLUMNAR;
+    CREATE TABLE sensorscolumnar_2020_01_01 PARTITION OF sensorscolumnar FOR VALUES FROM ('2020-01-01') TO ('2020-02-01')  USING COLUMNAR;
+    CREATE TABLE sensorscolumnar_news PARTITION OF sensorscolumnar FOR VALUES FROM ('2020-05-01') TO ('2025-01-01') USING COLUMNAR;
+    -- Create index on parent and child partitions.
+    CREATE INDEX index_on_parent ON sensors(lower(measureid::text));
+    CREATE INDEX index_on_child ON sensors_2020_01_01(lower(measure_data::text));
+    CREATE INDEX index_on_parent_columnar ON sensorscolumnar(lower(measureid::text));
+    CREATE INDEX index_on_child_columnar ON sensorscolumnar_2020_01_01(lower(measure_data::text));
+    ALTER INDEX index_on_parent ALTER COLUMN 1 SET STATISTICS 1000;
+    ALTER INDEX index_on_child ALTER COLUMN 1 SET STATISTICS 1000;
+    ALTER INDEX index_on_parent_columnar ALTER COLUMN 1 SET STATISTICS 1000;
+    ALTER INDEX index_on_child_columnar ALTER COLUMN 1 SET STATISTICS 1000;
+    -- Create statistics on parent and child partitions.
+    CREATE STATISTICS s1 (dependencies) ON measureid, eventdatetime FROM sensors;
+    CREATE STATISTICS s2 (dependencies) ON measureid, eventdatetime FROM sensors_2020_01_01;
+    CREATE STATISTICS s1_c (dependencies) ON measureid, eventdatetime FROM sensorscolumnar;
+    CREATE STATISTICS s2_c (dependencies) ON measureid, eventdatetime FROM sensorscolumnar_2020_01_01;
+    CLUSTER sensors_2020_01_01 USING index_on_child;
+    SELECT create_distributed_table('sensors', 'measureid');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+    SELECT create_distributed_table('sensorscolumnar', 'measureid');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+    -- create colocated distributed tables
+    CREATE TABLE colocated_dist_table (measureid integer PRIMARY KEY);
+    SELECT create_distributed_table('colocated_dist_table', 'measureid');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+    CLUSTER colocated_dist_table USING colocated_dist_table_pkey;
+    CREATE TABLE colocated_partitioned_table(
+        measureid         integer,
+        eventdatetime     date,
+        PRIMARY KEY (measureid, eventdatetime))
+    PARTITION BY RANGE(eventdatetime);
+    CREATE TABLE colocated_partitioned_table_2020_01_01 PARTITION OF colocated_partitioned_table FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+    SELECT create_distributed_table('colocated_partitioned_table', 'measureid');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+    CLUSTER colocated_partitioned_table_2020_01_01 USING colocated_partitioned_table_2020_01_01_pkey;
+    -- create reference tables
+    CREATE TABLE reference_table (measureid integer PRIMARY KEY);
+    SELECT create_reference_table('reference_table');
+ create_reference_table
+---------------------------------------------------------------------
+
+(1 row)
+
+    SELECT shard.shardid, logicalrelid, shardminvalue, shardmaxvalue, nodename, nodeport
+    FROM pg_dist_shard AS shard
+    INNER JOIN pg_dist_placement placement ON shard.shardid = placement.shardid
+    INNER JOIN pg_dist_node       node     ON placement.groupid = node.groupid
+    INNER JOIN pg_catalog.pg_class cls     ON shard.logicalrelid = cls.oid
+    INNER JOIN pg_catalog.pg_namespace ns  ON cls.relnamespace = ns.oid
+    WHERE node.noderole = 'primary' AND ns.nspname = 'citus_split_test_schema_columnar_partitioned'
+    ORDER BY logicalrelid, shardminvalue::BIGINT;
+ shardid |              logicalrelid              | shardminvalue | shardmaxvalue | nodename  | nodeport
+---------------------------------------------------------------------
+ 8970000 | sensors                                | -2147483648   | 2147483647    | localhost |    57637
+ 8970004 | sensorscolumnar                        | -2147483648   | 2147483647    | localhost |    57637
+ 8970001 | sensors_old                            | -2147483648   | 2147483647    | localhost |    57637
+ 8970002 | sensors_2020_01_01                     | -2147483648   | 2147483647    | localhost |    57637
+ 8970003 | sensors_news                           | -2147483648   | 2147483647    | localhost |    57637
+ 8970005 | sensorscolumnar_old                    | -2147483648   | 2147483647    | localhost |    57637
+ 8970006 | sensorscolumnar_2020_01_01             | -2147483648   | 2147483647    | localhost |    57637
+ 8970007 | sensorscolumnar_news                   | -2147483648   | 2147483647    | localhost |    57637
+ 8970008 | colocated_dist_table                   | -2147483648   | 2147483647    | localhost |    57637
+ 8970009 | colocated_partitioned_table            | -2147483648   | 2147483647    | localhost |    57637
+ 8970010 | colocated_partitioned_table_2020_01_01 | -2147483648   | 2147483647    | localhost |    57637
+ 8970011 | reference_table                        |               |               | localhost |    57637
+ 8970011 | reference_table                        |               |               | localhost |    57638
+(13 rows)
+
+-- END: Create table to split, along with other co-located tables. Add indexes, statistics etc.
+-- BEGIN: Create constraints for tables.
+    -- from parent to regular dist
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+    -- from parent to parent
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_parent FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table(measureid, eventdatetime);
+    -- from parent to child
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_child FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid, eventdatetime);
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+    -- from child to regular dist
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+    -- from child to parent
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_parent FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table(measureid,eventdatetime);
+    -- from child to child
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_child FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid,eventdatetime);
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+    -- No support for foreign keys, unique constraints, or exclusion constraints in columnar tables.
+    -- Please see: https://github.com/citusdata/citus/tree/main/src/backend/columnar/README.md
+-- END: Create constraints for tables.
+-- BEGIN: Load data into tables
+    INSERT INTO reference_table SELECT i FROM generate_series(0,1000)i;
+    INSERT INTO colocated_dist_table SELECT i FROM generate_series(0,1000)i;
+    INSERT INTO colocated_partitioned_table SELECT i, '2020-01-05' FROM generate_series(0,1000)i;
+    INSERT INTO sensors SELECT i, '2020-01-05', '{}' FROM generate_series(0,1000)i;
+    INSERT INTO sensorscolumnar SELECT i, '2020-01-05', '{}' FROM generate_series(0,1000)i;
+-- END: Load data into tables
+-- BEGIN: Show the current state on workers
+\c - - - :worker_1_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+          relname           |                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ sensors_2020_01_01_8970002 | fkey_from_child_to_child_8970002                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_2020_01_01_8970002 | fkey_from_child_to_dist_8970002                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970008(measureid)
+ sensors_2020_01_01_8970002 | fkey_from_child_to_parent_8970002                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970009(eventdatetime, measureid)
+ sensors_2020_01_01_8970002 | fkey_from_child_to_ref_8970002                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8970002 | fkey_from_parent_to_child_8970000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_2020_01_01_8970002 | fkey_from_parent_to_dist_8970000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970008(measureid)
+ sensors_2020_01_01_8970002 | fkey_from_parent_to_parent_8970000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970009(eventdatetime, measureid)
+ sensors_2020_01_01_8970002 | fkey_from_parent_to_ref_8970000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8970002 | sensors_2020_01_01_8970002_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_8970000            | fkey_from_parent_to_child_8970000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_8970000            | fkey_from_parent_to_dist_8970000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970008(measureid)
+ sensors_8970000            | fkey_from_parent_to_parent_8970000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970009(eventdatetime, measureid)
+ sensors_8970000            | fkey_from_parent_to_ref_8970000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_8970000            | sensors_8970000_measureid_eventdatetime_fkey            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_news_8970003       | fkey_from_parent_to_child_8970000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_news_8970003       | fkey_from_parent_to_dist_8970000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970008(measureid)
+ sensors_news_8970003       | fkey_from_parent_to_parent_8970000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970009(eventdatetime, measureid)
+ sensors_news_8970003       | fkey_from_parent_to_ref_8970000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_old_8970001        | fkey_from_parent_to_child_8970000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970010(eventdatetime, measureid)
+ sensors_old_8970001        | fkey_from_parent_to_dist_8970000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970008(measureid)
+ sensors_old_8970001        | fkey_from_parent_to_parent_8970000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970009(eventdatetime, measureid)
+ sensors_old_8970001        | fkey_from_parent_to_ref_8970000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+(22 rows)
+
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+                   tablename                    |                                                                                                   indexdef
+---------------------------------------------------------------------
+ colocated_dist_table_8970008                   | CREATE UNIQUE INDEX colocated_dist_table_pkey_8970008 ON citus_split_test_schema_columnar_partitioned.colocated_dist_table_8970008 USING btree (measureid)
+ colocated_partitioned_table_2020_01_01_8970010 | CREATE UNIQUE INDEX colocated_partitioned_table_2020_01_01_pkey_8970010 ON citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_2020_01_01_8970010 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_8970009            | CREATE UNIQUE INDEX colocated_partitioned_table_pkey_8970009 ON ONLY citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_8970009 USING btree (measureid, eventdatetime)
+ reference_table_8970011                        | CREATE UNIQUE INDEX reference_table_pkey_8970011 ON citus_split_test_schema_columnar_partitioned.reference_table_8970011 USING btree (measureid)
+ sensors_2020_01_01_8970002                     | CREATE INDEX index_on_child_8970002 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8970002 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8970002                     | CREATE INDEX sensors_2020_01_01_lower_idx_8970002 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8970002 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8970002                     | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8970002 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8970002 USING btree (measureid, eventdatetime, measure_data)
+ sensors_8970000                                | CREATE INDEX index_on_parent_8970000 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8970000 USING btree (lower((measureid)::text))
+ sensors_8970000                                | CREATE UNIQUE INDEX sensors_pkey_8970000 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8970000 USING btree (measureid, eventdatetime, measure_data)
+ sensors_news_8970003                           | CREATE INDEX sensors_news_lower_idx_8970003 ON citus_split_test_schema_columnar_partitioned.sensors_news_8970003 USING btree (lower((measureid)::text))
+ sensors_news_8970003                           | CREATE UNIQUE INDEX sensors_news_pkey_8970003 ON citus_split_test_schema_columnar_partitioned.sensors_news_8970003 USING btree (measureid, eventdatetime, measure_data)
+ sensors_old_8970001                            | CREATE INDEX sensors_old_lower_idx_8970001 ON citus_split_test_schema_columnar_partitioned.sensors_old_8970001 USING btree (lower((measureid)::text))
+ sensors_old_8970001                            | CREATE UNIQUE INDEX sensors_old_pkey_8970001 ON citus_split_test_schema_columnar_partitioned.sensors_old_8970001 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_2020_01_01_8970006             | CREATE INDEX index_on_child_columnar_8970006 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8970006 USING btree (lower((measure_data)::text))
+ sensorscolumnar_2020_01_01_8970006             | CREATE INDEX sensorscolumnar_2020_01_01_lower_idx_8970006 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8970006 USING btree (lower((measureid)::text))
+ sensorscolumnar_2020_01_01_8970006             | CREATE UNIQUE INDEX sensorscolumnar_2020_01_01_pkey_8970006 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8970006 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_8970004                        | CREATE INDEX index_on_parent_columnar_8970004 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8970004 USING btree (lower((measureid)::text))
+ sensorscolumnar_8970004                        | CREATE UNIQUE INDEX sensorscolumnar_pkey_8970004 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8970004 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_news_8970007                   | CREATE INDEX sensorscolumnar_news_lower_idx_8970007 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8970007 USING btree (lower((measureid)::text))
+ sensorscolumnar_news_8970007                   | CREATE UNIQUE INDEX sensorscolumnar_news_pkey_8970007 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8970007 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_old_8970005                    | CREATE INDEX sensorscolumnar_old_lower_idx_8970005 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8970005 USING btree (lower((measureid)::text))
+ sensorscolumnar_old_8970005                    | CREATE UNIQUE INDEX sensorscolumnar_old_pkey_8970005 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8970005 USING btree (measureid, eventdatetime, measure_data)
+(22 rows)
+
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+   stxname
+---------------------------------------------------------------------
+ s1
+ s1_8970000
+ s1_c
+ s1_c_8970004
+ s2
+ s2_8970002
+ s2_c
+ s2_c_8970006
+(8 rows)
+
+    \c - - - :worker_2_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+ relname | Constraint | Definition
+---------------------------------------------------------------------
+(0 rows)
+
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+        tablename        |                                                                     indexdef
+---------------------------------------------------------------------
+ reference_table_8970011 | CREATE UNIQUE INDEX reference_table_pkey_8970011 ON citus_split_test_schema_columnar_partitioned.reference_table_8970011 USING btree (measureid)
+(1 row)
+
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+ stxname
+---------------------------------------------------------------------
+ s1
+ s1_c
+ s2
+ s2_c
+(4 rows)
+
+-- END: Show the current state on workers
+-- BEGIN: Split a shard along its co-located shards
+\c - - - :master_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.next_shard_id TO 8999000;
+    SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset
+    SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset
+    SELECT pg_catalog.citus_split_shard_by_split_points(
+        8970000,
+        ARRAY['-2120000000'],
+        ARRAY[:worker_1_node, :worker_2_node],
+        'block_writes');
+ citus_split_shard_by_split_points
+---------------------------------------------------------------------
+
+(1 row)
+
+-- END: Split a shard along its co-located shards
+-- BEGIN: Validate Shard Info and Data
+    SELECT shard.shardid, logicalrelid, shardminvalue, shardmaxvalue, nodename, nodeport
+    FROM pg_dist_shard AS shard
+    INNER JOIN pg_dist_placement placement ON shard.shardid = placement.shardid
+    INNER JOIN pg_dist_node       node     ON placement.groupid = node.groupid
+    INNER JOIN pg_catalog.pg_class cls     ON shard.logicalrelid = cls.oid
+    INNER JOIN pg_catalog.pg_namespace ns  ON cls.relnamespace = ns.oid
+    WHERE node.noderole = 'primary' AND ns.nspname = 'citus_split_test_schema_columnar_partitioned'
+    ORDER BY logicalrelid, shardminvalue::BIGINT;
+ shardid |              logicalrelid              | shardminvalue | shardmaxvalue | nodename  | nodeport
+---------------------------------------------------------------------
+ 8999000 | sensors                                | -2147483648   | -2120000000   | localhost |    57637
+ 8999001 | sensors                                | -2119999999   | 2147483647    | localhost |    57638
+ 8999008 | sensorscolumnar                        | -2147483648   | -2120000000   | localhost |    57637
+ 8999009 | sensorscolumnar                        | -2119999999   | 2147483647    | localhost |    57638
+ 8999002 | sensors_old                            | -2147483648   | -2120000000   | localhost |    57637
+ 8999003 | sensors_old                            | -2119999999   | 2147483647    | localhost |    57638
+ 8999004 | sensors_2020_01_01                     | -2147483648   | -2120000000   | localhost |    57637
+ 8999005 | sensors_2020_01_01                     | -2119999999   | 2147483647    | localhost |    57638
+ 8999006 | sensors_news                           | -2147483648   | -2120000000   | localhost |    57637
+ 8999007 | sensors_news                           | -2119999999   | 2147483647    | localhost |    57638
+ 8999010 | sensorscolumnar_old                    | -2147483648   | -2120000000   | localhost |    57637
+ 8999011 | sensorscolumnar_old                    | -2119999999   | 2147483647    | localhost |    57638
+ 8999012 | sensorscolumnar_2020_01_01             | -2147483648   | -2120000000   | localhost |    57637
+ 8999013 | sensorscolumnar_2020_01_01             | -2119999999   | 2147483647    | localhost |    57638
+ 8999014 | sensorscolumnar_news                   | -2147483648   | -2120000000   | localhost |    57637
+ 8999015 | sensorscolumnar_news                   | -2119999999   | 2147483647    | localhost |    57638
+ 8999016 | colocated_dist_table                   | -2147483648   | -2120000000   | localhost |    57637
+ 8999017 | colocated_dist_table                   | -2119999999   | 2147483647    | localhost |    57638
+ 8999018 | colocated_partitioned_table            | -2147483648   | -2120000000   | localhost |    57637
+ 8999019 | colocated_partitioned_table            | -2119999999   | 2147483647    | localhost |    57638
+ 8999020 | colocated_partitioned_table_2020_01_01 | -2147483648   | -2120000000   | localhost |    57637
+ 8999021 | colocated_partitioned_table_2020_01_01 | -2119999999   | 2147483647    | localhost |    57638
+ 8970011 | reference_table                        |               |               | localhost |    57637
+ 8970011 | reference_table                        |               |               | localhost |    57638
+(24 rows)
+
+    SELECT count(*) FROM reference_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM colocated_partitioned_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM colocated_dist_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM sensors;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM sensorscolumnar;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+-- END: Validate Shard Info and Data
+-- BEGIN: Show the updated state on workers
+    \c - - - :worker_1_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+          relname           |                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ sensors_2020_01_01_8999004 | fkey_from_child_to_child_8999004                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_2020_01_01_8999004 | fkey_from_child_to_dist_8999004                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999016(measureid)
+ sensors_2020_01_01_8999004 | fkey_from_child_to_parent_8999004                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999018(eventdatetime, measureid)
+ sensors_2020_01_01_8999004 | fkey_from_child_to_ref_8999004                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999004 | fkey_from_parent_to_child_8999000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_2020_01_01_8999004 | fkey_from_parent_to_dist_8999000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999016(measureid)
+ sensors_2020_01_01_8999004 | fkey_from_parent_to_parent_8999000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999018(eventdatetime, measureid)
+ sensors_2020_01_01_8999004 | fkey_from_parent_to_ref_8999000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999004 | sensors_2020_01_01_8999004_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_8999000            | fkey_from_parent_to_child_8999000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_8999000            | fkey_from_parent_to_dist_8999000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999016(measureid)
+ sensors_8999000            | fkey_from_parent_to_parent_8999000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999018(eventdatetime, measureid)
+ sensors_8999000            | fkey_from_parent_to_ref_8999000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_8999000            | sensors_8999000_measureid_eventdatetime_fkey            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_news_8999006       | fkey_from_parent_to_child_8999000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_news_8999006       | fkey_from_parent_to_dist_8999000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999016(measureid)
+ sensors_news_8999006       | fkey_from_parent_to_parent_8999000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999018(eventdatetime, measureid)
+ sensors_news_8999006       | fkey_from_parent_to_ref_8999000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_old_8999002        | fkey_from_parent_to_child_8999000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999020(eventdatetime, measureid)
+ sensors_old_8999002        | fkey_from_parent_to_dist_8999000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999016(measureid)
+ sensors_old_8999002        | fkey_from_parent_to_parent_8999000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999018(eventdatetime, measureid)
+ sensors_old_8999002        | fkey_from_parent_to_ref_8999000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+(22 rows)
+
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+                   tablename                    |                                                                                                   indexdef
+---------------------------------------------------------------------
+ colocated_dist_table_8999016                   | CREATE UNIQUE INDEX colocated_dist_table_pkey_8999016 ON citus_split_test_schema_columnar_partitioned.colocated_dist_table_8999016 USING btree (measureid)
+ colocated_partitioned_table_2020_01_01_8999020 | CREATE UNIQUE INDEX colocated_partitioned_table_2020_01_01_pkey_8999020 ON citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_2020_01_01_8999020 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_8999018            | CREATE UNIQUE INDEX colocated_partitioned_table_pkey_8999018 ON ONLY citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_8999018 USING btree (measureid, eventdatetime)
+ reference_table_8970011                        | CREATE UNIQUE INDEX reference_table_pkey_8970011 ON citus_split_test_schema_columnar_partitioned.reference_table_8970011 USING btree (measureid)
+ sensors_2020_01_01_8999004                     | CREATE INDEX index_on_child_8999004 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999004 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8999004                     | CREATE INDEX sensors_2020_01_01_lower_idx_8999004 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999004 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8999004                     | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8999004 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999004 USING btree (measureid, eventdatetime, measure_data)
+ sensors_8999000                                | CREATE INDEX index_on_parent_8999000 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999000 USING btree (lower((measureid)::text))
+ sensors_8999000                                | CREATE UNIQUE INDEX sensors_pkey_8999000 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999000 USING btree (measureid, eventdatetime, measure_data)
+ sensors_news_8999006                           | CREATE INDEX sensors_news_lower_idx_8999006 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999006 USING btree (lower((measureid)::text))
+ sensors_news_8999006                           | CREATE UNIQUE INDEX sensors_news_pkey_8999006 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999006 USING btree (measureid, eventdatetime, measure_data)
+ sensors_old_8999002                            | CREATE INDEX sensors_old_lower_idx_8999002 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999002 USING btree (lower((measureid)::text))
+ sensors_old_8999002                            | CREATE UNIQUE INDEX sensors_old_pkey_8999002 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999002 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_2020_01_01_8999012             | CREATE INDEX index_on_child_columnar_8999012 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999012 USING btree (lower((measure_data)::text))
+ sensorscolumnar_2020_01_01_8999012             | CREATE INDEX sensorscolumnar_2020_01_01_lower_idx_8999012 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999012 USING btree (lower((measureid)::text))
+ sensorscolumnar_2020_01_01_8999012             | CREATE UNIQUE INDEX sensorscolumnar_2020_01_01_pkey_8999012 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999012 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_8999008                        | CREATE INDEX index_on_parent_columnar_8999008 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999008 USING btree (lower((measureid)::text))
+ sensorscolumnar_8999008                        | CREATE UNIQUE INDEX sensorscolumnar_pkey_8999008 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999008 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_news_8999014                   | CREATE INDEX sensorscolumnar_news_lower_idx_8999014 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999014 USING btree (lower((measureid)::text))
+ sensorscolumnar_news_8999014                   | CREATE UNIQUE INDEX sensorscolumnar_news_pkey_8999014 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999014 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_old_8999010                    | CREATE INDEX sensorscolumnar_old_lower_idx_8999010 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999010 USING btree (lower((measureid)::text))
+ sensorscolumnar_old_8999010                    | CREATE UNIQUE INDEX sensorscolumnar_old_pkey_8999010 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999010 USING btree (measureid, eventdatetime, measure_data)
+(22 rows)
+
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+   stxname
+---------------------------------------------------------------------
+ s1
+ s1_8999000
+ s1_c
+ s1_c_8999008
+ s2
+ s2_8999004
+ s2_c
+ s2_c_8999012
+(8 rows)
+
+    \c - - - :worker_2_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+          relname           |                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ sensors_2020_01_01_8999005 | fkey_from_child_to_child_8999005                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_child_to_dist_8999005                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_2020_01_01_8999005 | fkey_from_child_to_parent_8999005                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_child_to_ref_8999005                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999005 | sensors_2020_01_01_8999005_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_8999001            | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_8999001            | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_8999001            | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_8999001            | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_8999001            | sensors_8999001_measureid_eventdatetime_fkey            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_news_8999007       | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_news_8999007       | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_news_8999007       | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_news_8999007       | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_old_8999003        | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_old_8999003        | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_old_8999003        | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_old_8999003        | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+(22 rows)
+
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+                   tablename                    |                                                                                                   indexdef
+---------------------------------------------------------------------
+ colocated_dist_table_8999017                   | CREATE UNIQUE INDEX colocated_dist_table_pkey_8999017 ON citus_split_test_schema_columnar_partitioned.colocated_dist_table_8999017 USING btree (measureid)
+ colocated_partitioned_table_2020_01_01_8999021 | CREATE UNIQUE INDEX colocated_partitioned_table_2020_01_01_pkey_8999021 ON citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_2020_01_01_8999021 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_8999019            | CREATE UNIQUE INDEX colocated_partitioned_table_pkey_8999019 ON ONLY citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_8999019 USING btree (measureid, eventdatetime)
+ reference_table_8970011                        | CREATE UNIQUE INDEX reference_table_pkey_8970011 ON citus_split_test_schema_columnar_partitioned.reference_table_8970011 USING btree (measureid)
+ sensors_2020_01_01_8999005                     | CREATE INDEX index_on_child_8999005 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999005 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8999005                     | CREATE INDEX sensors_2020_01_01_lower_idx_8999005 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999005 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8999005                     | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8999005 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999005 USING btree (measureid, eventdatetime, measure_data)
+ sensors_8999001                                | CREATE INDEX index_on_parent_8999001 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999001 USING btree (lower((measureid)::text))
+ sensors_8999001                                | CREATE UNIQUE INDEX sensors_pkey_8999001 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999001 USING btree (measureid, eventdatetime, measure_data)
+ sensors_news_8999007                           | CREATE INDEX sensors_news_lower_idx_8999007 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999007 USING btree (lower((measureid)::text))
+ sensors_news_8999007                           | CREATE UNIQUE INDEX sensors_news_pkey_8999007 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999007 USING btree (measureid, eventdatetime, measure_data)
+ sensors_old_8999003                            | CREATE INDEX sensors_old_lower_idx_8999003 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999003 USING btree (lower((measureid)::text))
+ sensors_old_8999003                            | CREATE UNIQUE INDEX sensors_old_pkey_8999003 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999003 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_2020_01_01_8999013             | CREATE INDEX index_on_child_columnar_8999013 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999013 USING btree (lower((measure_data)::text))
+ sensorscolumnar_2020_01_01_8999013             | CREATE INDEX sensorscolumnar_2020_01_01_lower_idx_8999013 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999013 USING btree (lower((measureid)::text))
+ sensorscolumnar_2020_01_01_8999013             | CREATE UNIQUE INDEX sensorscolumnar_2020_01_01_pkey_8999013 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999013 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_8999009                        | CREATE INDEX index_on_parent_columnar_8999009 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999009 USING btree (lower((measureid)::text))
+ sensorscolumnar_8999009                        | CREATE UNIQUE INDEX sensorscolumnar_pkey_8999009 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999009 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_news_8999015                   | CREATE INDEX sensorscolumnar_news_lower_idx_8999015 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999015 USING btree (lower((measureid)::text))
+ sensorscolumnar_news_8999015                   | CREATE UNIQUE INDEX sensorscolumnar_news_pkey_8999015 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999015 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_old_8999011                    | CREATE INDEX sensorscolumnar_old_lower_idx_8999011 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999011 USING btree (lower((measureid)::text))
+ sensorscolumnar_old_8999011                    | CREATE UNIQUE INDEX sensorscolumnar_old_pkey_8999011 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999011 USING btree (measureid, eventdatetime, measure_data)
+(22 rows)
+
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+   stxname
+---------------------------------------------------------------------
+ s1
+ s1_8999001
+ s1_c
+ s1_c_8999009
+ s2
+ s2_8999005
+ s2_c
+ s2_c_8999013
+(8 rows)
+
+-- END: Show the updated state on workers
+-- BEGIN: Split a partition table directly
+\c - - - :master_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.next_shard_id TO 8999100;
+    SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset
+    SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset
+    SELECT pg_catalog.citus_split_shard_by_split_points(
+        8999002, -- sensors_old
+        ARRAY['-2127770000'],
+        ARRAY[:worker_1_node, :worker_2_node],
+        'block_writes');
+ citus_split_shard_by_split_points
+---------------------------------------------------------------------
+
+(1 row)
+
+-- END: Split a partition table directly
+-- BEGIN: Validate Shard Info and Data
+    SELECT shard.shardid, logicalrelid, shardminvalue, shardmaxvalue, nodename, nodeport
+    FROM pg_dist_shard AS shard
+    INNER JOIN pg_dist_placement placement ON shard.shardid = placement.shardid
+    INNER JOIN pg_dist_node       node     ON placement.groupid = node.groupid
+    INNER JOIN pg_catalog.pg_class cls     ON shard.logicalrelid = cls.oid
+    INNER JOIN pg_catalog.pg_namespace ns  ON cls.relnamespace = ns.oid
+    WHERE node.noderole = 'primary' AND ns.nspname = 'citus_split_test_schema_columnar_partitioned'
+    ORDER BY logicalrelid, shardminvalue::BIGINT;
+ shardid |              logicalrelid              | shardminvalue | shardmaxvalue | nodename  | nodeport
+---------------------------------------------------------------------
+ 8999100 | sensors                                | -2147483648   | -2127770000   | localhost |    57637
+ 8999101 | sensors                                | -2127769999   | -2120000000   | localhost |    57638
+ 8999001 | sensors                                | -2119999999   | 2147483647    | localhost |    57638
+ 8999108 | sensorscolumnar                        | -2147483648   | -2127770000   | localhost |    57637
+ 8999109 | sensorscolumnar                        | -2127769999   | -2120000000   | localhost |    57638
+ 8999009 | sensorscolumnar                        | -2119999999   | 2147483647    | localhost |    57638
+ 8999102 | sensors_old                            | -2147483648   | -2127770000   | localhost |    57637
+ 8999103 | sensors_old                            | -2127769999   | -2120000000   | localhost |    57638
+ 8999003 | sensors_old                            | -2119999999   | 2147483647    | localhost |    57638
+ 8999104 | sensors_2020_01_01                     | -2147483648   | -2127770000   | localhost |    57637
+ 8999105 | sensors_2020_01_01                     | -2127769999   | -2120000000   | localhost |    57638
+ 8999005 | sensors_2020_01_01                     | -2119999999   | 2147483647    | localhost |    57638
+ 8999106 | sensors_news                           | -2147483648   | -2127770000   | localhost |    57637
+ 8999107 | sensors_news                           | -2127769999   | -2120000000   | localhost |    57638
+ 8999007 | sensors_news                           | -2119999999   | 2147483647    | localhost |    57638
+ 8999110 | sensorscolumnar_old                    | -2147483648   | -2127770000   | localhost |    57637
+ 8999111 | sensorscolumnar_old                    | -2127769999   | -2120000000   | localhost |    57638
+ 8999011 | sensorscolumnar_old                    | -2119999999   | 2147483647    | localhost |    57638
+ 8999112 | sensorscolumnar_2020_01_01             | -2147483648   | -2127770000   | localhost |    57637
+ 8999113 | sensorscolumnar_2020_01_01             | -2127769999   | -2120000000   | localhost |    57638
+ 8999013 | sensorscolumnar_2020_01_01             | -2119999999   | 2147483647    | localhost |    57638
+ 8999114 | sensorscolumnar_news                   | -2147483648   | -2127770000   | localhost |    57637
+ 8999115 | sensorscolumnar_news                   | -2127769999   | -2120000000   | localhost |    57638
+ 8999015 | sensorscolumnar_news                   | -2119999999   | 2147483647    | localhost |    57638
+ 8999116 | colocated_dist_table                   | -2147483648   | -2127770000   | localhost |    57637
+ 8999117 | colocated_dist_table                   | -2127769999   | -2120000000   | localhost |    57638
+ 8999017 | colocated_dist_table                   | -2119999999   | 2147483647    | localhost |    57638
+ 8999118 | colocated_partitioned_table            | -2147483648   | -2127770000   | localhost |    57637
+ 8999119 | colocated_partitioned_table            | -2127769999   | -2120000000   | localhost |    57638
+ 8999019 | colocated_partitioned_table            | -2119999999   | 2147483647    | localhost |    57638
+ 8999120 | colocated_partitioned_table_2020_01_01 | -2147483648   | -2127770000   | localhost |    57637
+ 8999121 | colocated_partitioned_table_2020_01_01 | -2127769999   | -2120000000   | localhost |    57638
+ 8999021 | colocated_partitioned_table_2020_01_01 | -2119999999   | 2147483647    | localhost |    57638
+ 8970011 | reference_table                        |               |               | localhost |    57637
+ 8970011 | reference_table                        |               |               | localhost |    57638
+(35 rows)
+
+    SELECT count(*) FROM reference_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM colocated_partitioned_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM colocated_dist_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM sensors;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+    SELECT count(*) FROM sensorscolumnar;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+-- END: Validate Shard Info and Data
+-- BEGIN: Show the updated state on workers
+    \c - - - :worker_1_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+          relname           |                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ sensors_2020_01_01_8999104 | fkey_from_child_to_child_8999104                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_2020_01_01_8999104 | fkey_from_child_to_dist_8999104                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999116(measureid)
+ sensors_2020_01_01_8999104 | fkey_from_child_to_parent_8999104                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999118(eventdatetime, measureid)
+ sensors_2020_01_01_8999104 | fkey_from_child_to_ref_8999104                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999104 | fkey_from_parent_to_child_8999100                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_2020_01_01_8999104 | fkey_from_parent_to_dist_8999100                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999116(measureid)
+ sensors_2020_01_01_8999104 | fkey_from_parent_to_parent_8999100                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999118(eventdatetime, measureid)
+ sensors_2020_01_01_8999104 | fkey_from_parent_to_ref_8999100                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999104 | sensors_2020_01_01_8999104_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_8999100            | fkey_from_parent_to_child_8999100                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_8999100            | fkey_from_parent_to_dist_8999100                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999116(measureid)
+ sensors_8999100            | fkey_from_parent_to_parent_8999100                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999118(eventdatetime, measureid)
+ sensors_8999100            | fkey_from_parent_to_ref_8999100                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_8999100            | sensors_8999100_measureid_eventdatetime_fkey            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_news_8999106       | fkey_from_parent_to_child_8999100                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_news_8999106       | fkey_from_parent_to_dist_8999100                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999116(measureid)
+ sensors_news_8999106       | fkey_from_parent_to_parent_8999100                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999118(eventdatetime, measureid)
+ sensors_news_8999106       | fkey_from_parent_to_ref_8999100                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_old_8999102        | fkey_from_parent_to_child_8999100                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999120(eventdatetime, measureid)
+ sensors_old_8999102        | fkey_from_parent_to_dist_8999100                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999116(measureid)
+ sensors_old_8999102        | fkey_from_parent_to_parent_8999100                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999118(eventdatetime, measureid)
+ sensors_old_8999102        | fkey_from_parent_to_ref_8999100                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+(22 rows)
+
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+                   tablename                    |                                                                                                   indexdef
+---------------------------------------------------------------------
+ colocated_dist_table_8999116                   | CREATE UNIQUE INDEX colocated_dist_table_pkey_8999116 ON citus_split_test_schema_columnar_partitioned.colocated_dist_table_8999116 USING btree (measureid)
+ colocated_partitioned_table_2020_01_01_8999120 | CREATE UNIQUE INDEX colocated_partitioned_table_2020_01_01_pkey_8999120 ON citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_2020_01_01_8999120 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_8999118            | CREATE UNIQUE INDEX colocated_partitioned_table_pkey_8999118 ON ONLY citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_8999118 USING btree (measureid, eventdatetime)
+ reference_table_8970011                        | CREATE UNIQUE INDEX reference_table_pkey_8970011 ON citus_split_test_schema_columnar_partitioned.reference_table_8970011 USING btree (measureid)
+ sensors_2020_01_01_8999104                     | CREATE INDEX index_on_child_8999104 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999104 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8999104                     | CREATE INDEX sensors_2020_01_01_lower_idx_8999104 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999104 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8999104                     | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8999104 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999104 USING btree (measureid, eventdatetime, measure_data)
+ sensors_8999100                                | CREATE INDEX index_on_parent_8999100 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999100 USING btree (lower((measureid)::text))
+ sensors_8999100                                | CREATE UNIQUE INDEX sensors_pkey_8999100 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999100 USING btree (measureid, eventdatetime, measure_data)
+ sensors_news_8999106                           | CREATE INDEX sensors_news_lower_idx_8999106 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999106 USING btree (lower((measureid)::text))
+ sensors_news_8999106                           | CREATE UNIQUE INDEX sensors_news_pkey_8999106 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999106 USING btree (measureid, eventdatetime, measure_data)
+ sensors_old_8999102                            | CREATE INDEX sensors_old_lower_idx_8999102 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999102 USING btree (lower((measureid)::text))
+ sensors_old_8999102                            | CREATE UNIQUE INDEX sensors_old_pkey_8999102 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999102 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_2020_01_01_8999112             | CREATE INDEX index_on_child_columnar_8999112 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999112 USING btree (lower((measure_data)::text))
+ sensorscolumnar_2020_01_01_8999112             | CREATE INDEX sensorscolumnar_2020_01_01_lower_idx_8999112 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999112 USING btree (lower((measureid)::text))
+ sensorscolumnar_2020_01_01_8999112             | CREATE UNIQUE INDEX sensorscolumnar_2020_01_01_pkey_8999112 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999112 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_8999108                        | CREATE INDEX index_on_parent_columnar_8999108 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999108 USING btree (lower((measureid)::text))
+ sensorscolumnar_8999108                        | CREATE UNIQUE INDEX sensorscolumnar_pkey_8999108 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999108 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_news_8999114                   | CREATE INDEX sensorscolumnar_news_lower_idx_8999114 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999114 USING btree (lower((measureid)::text))
+ sensorscolumnar_news_8999114                   | CREATE UNIQUE INDEX sensorscolumnar_news_pkey_8999114 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999114 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_old_8999110                    | CREATE INDEX sensorscolumnar_old_lower_idx_8999110 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999110 USING btree (lower((measureid)::text))
+ sensorscolumnar_old_8999110                    | CREATE UNIQUE INDEX sensorscolumnar_old_pkey_8999110 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999110 USING btree (measureid, eventdatetime, measure_data)
+(22 rows)
+
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+   stxname
+---------------------------------------------------------------------
+ s1
+ s1_8999100
+ s1_c
+ s1_c_8999108
+ s2
+ s2_8999104
+ s2_c
+ s2_c_8999112
+(8 rows)
+
+    \c - - - :worker_2_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+          relname           |                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ sensors_2020_01_01_8999005 | fkey_from_child_to_child_8999005                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_child_to_dist_8999005                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_2020_01_01_8999005 | fkey_from_child_to_parent_8999005                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_child_to_ref_8999005                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_2020_01_01_8999005 | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999005 | sensors_2020_01_01_8999005_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_2020_01_01_8999105 | fkey_from_child_to_child_8999105                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_2020_01_01_8999105 | fkey_from_child_to_dist_8999105                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999117(measureid)
+ sensors_2020_01_01_8999105 | fkey_from_child_to_parent_8999105                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999119(eventdatetime, measureid)
+ sensors_2020_01_01_8999105 | fkey_from_child_to_ref_8999105                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999105 | fkey_from_parent_to_child_8999101                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_2020_01_01_8999105 | fkey_from_parent_to_dist_8999101                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999117(measureid)
+ sensors_2020_01_01_8999105 | fkey_from_parent_to_parent_8999101                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999119(eventdatetime, measureid)
+ sensors_2020_01_01_8999105 | fkey_from_parent_to_ref_8999101                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_2020_01_01_8999105 | sensors_2020_01_01_8999105_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_8999001            | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_8999001            | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_8999001            | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_8999001            | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_8999001            | sensors_8999001_measureid_eventdatetime_fkey            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_8999101            | fkey_from_parent_to_child_8999101                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_8999101            | fkey_from_parent_to_dist_8999101                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999117(measureid)
+ sensors_8999101            | fkey_from_parent_to_parent_8999101                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999119(eventdatetime, measureid)
+ sensors_8999101            | fkey_from_parent_to_ref_8999101                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_8999101            | sensors_8999101_measureid_eventdatetime_fkey            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_news_8999007       | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_news_8999007       | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_news_8999007       | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_news_8999007       | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_news_8999107       | fkey_from_parent_to_child_8999101                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_news_8999107       | fkey_from_parent_to_dist_8999101                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999117(measureid)
+ sensors_news_8999107       | fkey_from_parent_to_parent_8999101                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999119(eventdatetime, measureid)
+ sensors_news_8999107       | fkey_from_parent_to_ref_8999101                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_old_8999003        | fkey_from_parent_to_child_8999001                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999021(eventdatetime, measureid)
+ sensors_old_8999003        | fkey_from_parent_to_dist_8999001                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999017(measureid)
+ sensors_old_8999003        | fkey_from_parent_to_parent_8999001                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999019(eventdatetime, measureid)
+ sensors_old_8999003        | fkey_from_parent_to_ref_8999001                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+ sensors_old_8999103        | fkey_from_parent_to_child_8999101                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8999121(eventdatetime, measureid)
+ sensors_old_8999103        | fkey_from_parent_to_dist_8999101                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8999117(measureid)
+ sensors_old_8999103        | fkey_from_parent_to_parent_8999101                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8999119(eventdatetime, measureid)
+ sensors_old_8999103        | fkey_from_parent_to_ref_8999101                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970011(measureid)
+(44 rows)
+
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+                   tablename                    |                                                                                                   indexdef
+---------------------------------------------------------------------
+ colocated_dist_table_8999017                   | CREATE UNIQUE INDEX colocated_dist_table_pkey_8999017 ON citus_split_test_schema_columnar_partitioned.colocated_dist_table_8999017 USING btree (measureid)
+ colocated_dist_table_8999117                   | CREATE UNIQUE INDEX colocated_dist_table_pkey_8999117 ON citus_split_test_schema_columnar_partitioned.colocated_dist_table_8999117 USING btree (measureid)
+ colocated_partitioned_table_2020_01_01_8999021 | CREATE UNIQUE INDEX colocated_partitioned_table_2020_01_01_pkey_8999021 ON citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_2020_01_01_8999021 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_2020_01_01_8999121 | CREATE UNIQUE INDEX colocated_partitioned_table_2020_01_01_pkey_8999121 ON citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_2020_01_01_8999121 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_8999019            | CREATE UNIQUE INDEX colocated_partitioned_table_pkey_8999019 ON ONLY citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_8999019 USING btree (measureid, eventdatetime)
+ colocated_partitioned_table_8999119            | CREATE UNIQUE INDEX colocated_partitioned_table_pkey_8999119 ON ONLY citus_split_test_schema_columnar_partitioned.colocated_partitioned_table_8999119 USING btree (measureid, eventdatetime)
+ reference_table_8970011                        | CREATE UNIQUE INDEX reference_table_pkey_8970011 ON citus_split_test_schema_columnar_partitioned.reference_table_8970011 USING btree (measureid)
+ sensors_2020_01_01_8999005                     | CREATE INDEX index_on_child_8999005 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999005 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8999005                     | CREATE INDEX sensors_2020_01_01_lower_idx_8999005 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999005 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8999005                     | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8999005 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999005 USING btree (measureid, eventdatetime, measure_data)
+ sensors_2020_01_01_8999105                     | CREATE INDEX index_on_child_8999105 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999105 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8999105                     | CREATE INDEX sensors_2020_01_01_lower_idx_8999105 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999105 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8999105                     | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8999105 ON citus_split_test_schema_columnar_partitioned.sensors_2020_01_01_8999105 USING btree (measureid, eventdatetime, measure_data)
+ sensors_8999001                                | CREATE INDEX index_on_parent_8999001 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999001 USING btree (lower((measureid)::text))
+ sensors_8999001                                | CREATE UNIQUE INDEX sensors_pkey_8999001 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999001 USING btree (measureid, eventdatetime, measure_data)
+ sensors_8999101                                | CREATE INDEX index_on_parent_8999101 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999101 USING btree (lower((measureid)::text))
+ sensors_8999101                                | CREATE UNIQUE INDEX sensors_pkey_8999101 ON ONLY citus_split_test_schema_columnar_partitioned.sensors_8999101 USING btree (measureid, eventdatetime, measure_data)
+ sensors_news_8999007                           | CREATE INDEX sensors_news_lower_idx_8999007 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999007 USING btree (lower((measureid)::text))
+ sensors_news_8999007                           | CREATE UNIQUE INDEX sensors_news_pkey_8999007 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999007 USING btree (measureid, eventdatetime, measure_data)
+ sensors_news_8999107                           | CREATE INDEX sensors_news_lower_idx_8999107 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999107 USING btree (lower((measureid)::text))
+ sensors_news_8999107                           | CREATE UNIQUE INDEX sensors_news_pkey_8999107 ON citus_split_test_schema_columnar_partitioned.sensors_news_8999107 USING btree (measureid, eventdatetime, measure_data)
+ sensors_old_8999003                            | CREATE INDEX sensors_old_lower_idx_8999003 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999003 USING btree (lower((measureid)::text))
+ sensors_old_8999003                            | CREATE UNIQUE INDEX sensors_old_pkey_8999003 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999003 USING btree (measureid, eventdatetime, measure_data)
+ sensors_old_8999103                            | CREATE INDEX sensors_old_lower_idx_8999103 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999103 USING btree (lower((measureid)::text))
+ sensors_old_8999103                            | CREATE UNIQUE INDEX sensors_old_pkey_8999103 ON citus_split_test_schema_columnar_partitioned.sensors_old_8999103 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_2020_01_01_8999013             | CREATE INDEX index_on_child_columnar_8999013 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999013 USING btree (lower((measure_data)::text))
+ sensorscolumnar_2020_01_01_8999013             | CREATE INDEX sensorscolumnar_2020_01_01_lower_idx_8999013 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999013 USING btree (lower((measureid)::text))
+ sensorscolumnar_2020_01_01_8999013             | CREATE UNIQUE INDEX sensorscolumnar_2020_01_01_pkey_8999013 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999013 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_2020_01_01_8999113             | CREATE INDEX index_on_child_columnar_8999113 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999113 USING btree (lower((measure_data)::text))
+ sensorscolumnar_2020_01_01_8999113             | CREATE INDEX sensorscolumnar_2020_01_01_lower_idx_8999113 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999113 USING btree (lower((measureid)::text))
+ sensorscolumnar_2020_01_01_8999113             | CREATE UNIQUE INDEX sensorscolumnar_2020_01_01_pkey_8999113 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_2020_01_01_8999113 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_8999009                        | CREATE INDEX index_on_parent_columnar_8999009 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999009 USING btree (lower((measureid)::text))
+ sensorscolumnar_8999009                        | CREATE UNIQUE INDEX sensorscolumnar_pkey_8999009 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999009 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_8999109                        | CREATE INDEX index_on_parent_columnar_8999109 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999109 USING btree (lower((measureid)::text))
+ sensorscolumnar_8999109                        | CREATE UNIQUE INDEX sensorscolumnar_pkey_8999109 ON ONLY citus_split_test_schema_columnar_partitioned.sensorscolumnar_8999109 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_news_8999015                   | CREATE INDEX sensorscolumnar_news_lower_idx_8999015 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999015 USING btree (lower((measureid)::text))
+ sensorscolumnar_news_8999015                   | CREATE UNIQUE INDEX sensorscolumnar_news_pkey_8999015 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999015 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_news_8999115                   | CREATE INDEX sensorscolumnar_news_lower_idx_8999115 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999115 USING btree (lower((measureid)::text))
+ sensorscolumnar_news_8999115                   | CREATE UNIQUE INDEX sensorscolumnar_news_pkey_8999115 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_news_8999115 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_old_8999011                    | CREATE INDEX sensorscolumnar_old_lower_idx_8999011 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999011 USING btree (lower((measureid)::text))
+ sensorscolumnar_old_8999011                    | CREATE UNIQUE INDEX sensorscolumnar_old_pkey_8999011 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999011 USING btree (measureid, eventdatetime, measure_data)
+ sensorscolumnar_old_8999111                    | CREATE INDEX sensorscolumnar_old_lower_idx_8999111 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999111 USING btree (lower((measureid)::text))
+ sensorscolumnar_old_8999111                    | CREATE UNIQUE INDEX sensorscolumnar_old_pkey_8999111 ON citus_split_test_schema_columnar_partitioned.sensorscolumnar_old_8999111 USING btree (measureid, eventdatetime, measure_data)
+(43 rows)
+
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+   stxname
+---------------------------------------------------------------------
+ s1
+ s1_8999001
+ s1_8999101
+ s1_c
+ s1_c_8999009
+ s1_c_8999109
+ s2
+ s2_8999005
+ s2_8999105
+ s2_c
+ s2_c_8999013
+ s2_c_8999113
+(12 rows)
+
+-- END: Show the updated state on workers
+--BEGIN : Cleanup
+    \c - postgres - :master_port
+    DROP SCHEMA "citus_split_test_schema_columnar_partitioned" CASCADE;
+NOTICE:  drop cascades to 5 other objects
+DETAIL:  drop cascades to table citus_split_test_schema_columnar_partitioned.sensors
+drop cascades to table citus_split_test_schema_columnar_partitioned.sensorscolumnar
+drop cascades to table citus_split_test_schema_columnar_partitioned.colocated_dist_table
+drop cascades to table citus_split_test_schema_columnar_partitioned.colocated_partitioned_table
+drop cascades to table citus_split_test_schema_columnar_partitioned.reference_table
+--END : Cleanup

src/test/regress/expected/shard_move_constraints_blocking.out

@@ -0,0 +1,362 @@
+CREATE SCHEMA "blocking shard Move Fkeys Indexes";
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SET citus.next_shard_id TO 8970000;
+SET citus.next_placement_id TO 8770000;
+SET citus.shard_count TO 4;
+SET citus.shard_replication_factor TO 1;
+-- create a non-superuser role
+CREATE ROLE mx_rebalancer_blocking_role_ent WITH LOGIN;
+GRANT ALL ON SCHEMA "blocking shard Move Fkeys Indexes" TO mx_rebalancer_blocking_role_ent;
+-- connect with this new role
+\c - mx_rebalancer_blocking_role_ent - :master_port
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SET citus.next_shard_id TO 8970000;
+SET citus.next_placement_id TO 8770000;
+SET citus.shard_count TO 4;
+SET citus.shard_replication_factor TO 1;
+CREATE TABLE sensors(
+measureid         integer,
+eventdatetime     date,
+measure_data      jsonb,
+PRIMARY KEY (measureid, eventdatetime, measure_data))
+PARTITION BY RANGE(eventdatetime);
+CREATE TABLE sensors_old PARTITION OF sensors FOR VALUES FROM ('2000-01-01') TO ('2020-01-01');
+CREATE TABLE sensors_2020_01_01 PARTITION OF sensors FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+CREATE TABLE sensors_news PARTITION OF sensors FOR VALUES FROM ('2020-05-01') TO ('2025-01-01');
+CREATE INDEX index_on_parent ON sensors(lower(measureid::text));
+CREATE INDEX index_on_child ON sensors_2020_01_01(lower(measure_data::text));
+CREATE INDEX hash_index ON sensors USING HASH((measure_data->'IsFailed'));
+CREATE INDEX index_with_include ON sensors ((measure_data->'IsFailed')) INCLUDE (measure_data, eventdatetime);
+CREATE STATISTICS s1 (dependencies) ON measureid, eventdatetime FROM sensors;
+CREATE STATISTICS s2 (dependencies) ON measureid, eventdatetime FROM sensors_2020_01_01;
+ALTER INDEX index_on_parent ALTER COLUMN 1 SET STATISTICS 1000;
+ALTER INDEX index_on_child ALTER COLUMN 1 SET STATISTICS 1000;
+CLUSTER sensors_2020_01_01 USING index_on_child;
+SELECT create_distributed_table('sensors', 'measureid', colocate_with:='none');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+-- due to https://github.com/citusdata/citus/issues/5121
+\c - postgres - :master_port
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SELECT update_distributed_table_colocation('sensors_old', 'sensors');
+ update_distributed_table_colocation
+---------------------------------------------------------------------
+
+(1 row)
+
+SELECT update_distributed_table_colocation('sensors_2020_01_01', 'sensors');
+ update_distributed_table_colocation
+---------------------------------------------------------------------
+
+(1 row)
+
+SELECT update_distributed_table_colocation('sensors_news', 'sensors');
+ update_distributed_table_colocation
+---------------------------------------------------------------------
+
+(1 row)
+
+\c - mx_rebalancer_blocking_role_ent - :master_port
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SET citus.shard_count TO 4;
+SET citus.shard_replication_factor TO 1;
+SET citus.next_shard_id TO 8970016;
+SET citus.next_placement_id TO 8770016;
+-- create a colocated distributed tables and create foreign keys FROM/TO
+-- the partitions
+CREATE TABLE colocated_dist_table (measureid integer PRIMARY KEY);
+SELECT create_distributed_table('colocated_dist_table', 'measureid', colocate_with:='sensors');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+CLUSTER colocated_dist_table USING colocated_dist_table_pkey;
+CREATE TABLE colocated_partitioned_table(
+	measureid         integer,
+	eventdatetime     date,
+	PRIMARY KEY (measureid, eventdatetime))
+PARTITION BY RANGE(eventdatetime);
+CREATE TABLE colocated_partitioned_table_2020_01_01 PARTITION OF colocated_partitioned_table FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+SELECT create_distributed_table('colocated_partitioned_table', 'measureid', colocate_with:='sensors');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+CLUSTER colocated_partitioned_table_2020_01_01 USING colocated_partitioned_table_2020_01_01_pkey;
+CREATE TABLE reference_table (measureid integer PRIMARY KEY);
+SELECT create_reference_table('reference_table');
+ create_reference_table
+---------------------------------------------------------------------
+
+(1 row)
+
+-- this table is used to make sure that index backed
+-- replica identites can have clustered indexes
+-- and no index statistics
+CREATE TABLE index_backed_rep_identity(key int NOT NULL);
+CREATE UNIQUE INDEX uqx ON index_backed_rep_identity(key);
+ALTER TABLE index_backed_rep_identity REPLICA IDENTITY USING INDEX uqx;
+CLUSTER index_backed_rep_identity USING uqx;
+SELECT create_distributed_table('index_backed_rep_identity', 'key', colocate_with:='sensors');
+ create_distributed_table
+---------------------------------------------------------------------
+
+(1 row)
+
+-- from parent to regular dist
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+-- from parent to parent
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_parent FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table(measureid, eventdatetime);
+-- from parent to child
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_child FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid, eventdatetime);
+-- from parent to reference table
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+-- from child to regular dist
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+-- from child to parent
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_parent FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table(measureid,eventdatetime);
+-- from child to child
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_child FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid,eventdatetime);
+-- from child to reference table
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+-- load some data
+INSERT INTO reference_table SELECT i FROM generate_series(0,1000)i;
+INSERT INTO colocated_dist_table SELECT i FROM generate_series(0,1000)i;
+INSERT INTO colocated_partitioned_table SELECT i, '2020-01-05' FROM generate_series(0,1000)i;
+INSERT INTO sensors SELECT i, '2020-01-05', '{}' FROM generate_series(0,1000)i;
+\c - postgres - :worker_1_port
+SET search_path TO "blocking shard Move Fkeys Indexes", public, pg_catalog;
+-- show the current state of the constraints
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_8970000'::regclass ORDER BY 1,2;
+                  Constraint                  |                                                         Definition
+---------------------------------------------------------------------
+ fkey_from_parent_to_child_8970000            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+ fkey_from_parent_to_dist_8970000             | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970016(measureid)
+ fkey_from_parent_to_parent_8970000           | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970020(eventdatetime, measureid)
+ fkey_from_parent_to_ref_8970000              | FOREIGN KEY (measureid) REFERENCES reference_table_8970028(measureid)
+ sensors_8970000_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+(5 rows)
+
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_2020_01_01_8970008'::regclass ORDER BY 1,2;
+                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ fkey_from_child_to_child_8970008                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+ fkey_from_child_to_dist_8970008                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970016(measureid)
+ fkey_from_child_to_parent_8970008                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970020(eventdatetime, measureid)
+ fkey_from_child_to_ref_8970008                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970028(measureid)
+ fkey_from_parent_to_child_8970000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+ fkey_from_parent_to_dist_8970000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970016(measureid)
+ fkey_from_parent_to_parent_8970000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970020(eventdatetime, measureid)
+ fkey_from_parent_to_ref_8970000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970028(measureid)
+ sensors_2020_01_01_8970008_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+(9 rows)
+
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_8970000' ORDER BY 1,2;
+    tablename    |                                                                                           indexdef
+---------------------------------------------------------------------
+ sensors_8970000 | CREATE INDEX hash_index_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING hash (((measure_data -> 'IsFailed'::text)))
+ sensors_8970000 | CREATE INDEX index_on_parent_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING btree (lower((measureid)::text))
+ sensors_8970000 | CREATE INDEX index_with_include_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING btree (((measure_data -> 'IsFailed'::text))) INCLUDE (measure_data, eventdatetime)
+ sensors_8970000 | CREATE UNIQUE INDEX sensors_pkey_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING btree (measureid, eventdatetime, measure_data)
+(4 rows)
+
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_2020_01_01_8970008' ORDER BY 1,2;
+         tablename          |                                                                                                                indexdef
+---------------------------------------------------------------------
+ sensors_2020_01_01_8970008 | CREATE INDEX index_on_child_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8970008 | CREATE INDEX sensors_2020_01_01_expr_idx_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING hash (((measure_data -> 'IsFailed'::text)))
+ sensors_2020_01_01_8970008 | CREATE INDEX sensors_2020_01_01_expr_measure_data_eventdatetime_idx_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (((measure_data -> 'IsFailed'::text))) INCLUDE (measure_data, eventdatetime)
+ sensors_2020_01_01_8970008 | CREATE INDEX sensors_2020_01_01_lower_idx_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8970008 | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (measureid, eventdatetime, measure_data)
+(5 rows)
+
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='index_backed_rep_identity_8970029' ORDER BY 1,2;
+             tablename             |                                                          indexdef
+---------------------------------------------------------------------
+ index_backed_rep_identity_8970029 | CREATE UNIQUE INDEX uqx_8970029 ON "blocking shard Move Fkeys Indexes".index_backed_rep_identity_8970029 USING btree (key)
+(1 row)
+
+SELECT indisclustered FROM pg_index where indisclustered AND indrelid = 'index_backed_rep_identity_8970029'::regclass;
+ indisclustered
+---------------------------------------------------------------------
+ t
+(1 row)
+
+SELECT stxname FROM pg_statistic_ext
+WHERE stxnamespace IN (
+	SELECT oid
+	FROM pg_namespace
+	WHERE nspname IN ('blocking shard Move Fkeys Indexes')
+)
+ORDER BY stxname ASC;
+  stxname
+---------------------------------------------------------------------
+ s1
+ s1_8970000
+ s1_8970002
+ s2
+ s2_8970008
+ s2_8970010
+(6 rows)
+
+SELECT count(*) FROM pg_index
+WHERE indisclustered
+	and
+indrelid IN
+('sensors_2020_01_01_8970008'::regclass, 'colocated_dist_table_8970016'::regclass, 'colocated_partitioned_table_2020_01_01_8970024'::regclass);
+ count
+---------------------------------------------------------------------
+     3
+(1 row)
+
+\c - - - :master_port
+-- make sure that constrainst are moved sanely with logical replication
+SELECT citus_move_shard_placement(8970000, 'localhost', :worker_1_port, 'localhost', :worker_2_port, shard_transfer_mode:='block_writes');
+ citus_move_shard_placement
+---------------------------------------------------------------------
+
+(1 row)
+
+CALL citus_cleanup_orphaned_shards();
+NOTICE:  cleaned up 8 orphaned shards
+\c - postgres - :worker_2_port
+SET search_path TO "blocking shard Move Fkeys Indexes", public, pg_catalog;
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_8970000'::regclass ORDER BY 1,2;
+                  Constraint                  |                                                         Definition
+---------------------------------------------------------------------
+ fkey_from_parent_to_child_8970000            | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+ fkey_from_parent_to_dist_8970000             | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970016(measureid)
+ fkey_from_parent_to_parent_8970000           | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970020(eventdatetime, measureid)
+ fkey_from_parent_to_ref_8970000              | FOREIGN KEY (measureid) REFERENCES reference_table_8970028(measureid)
+ sensors_8970000_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+(5 rows)
+
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_2020_01_01_8970008'::regclass ORDER BY 1,2;
+                       Constraint                        |                                                         Definition
+---------------------------------------------------------------------
+ fkey_from_child_to_child_8970008                        | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+ fkey_from_child_to_dist_8970008                         | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970016(measureid)
+ fkey_from_child_to_parent_8970008                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970020(eventdatetime, measureid)
+ fkey_from_child_to_ref_8970008                          | FOREIGN KEY (measureid) REFERENCES reference_table_8970028(measureid)
+ fkey_from_parent_to_child_8970000                       | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+ fkey_from_parent_to_dist_8970000                        | FOREIGN KEY (measureid) REFERENCES colocated_dist_table_8970016(measureid)
+ fkey_from_parent_to_parent_8970000                      | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_8970020(eventdatetime, measureid)
+ fkey_from_parent_to_ref_8970000                         | FOREIGN KEY (measureid) REFERENCES reference_table_8970028(measureid)
+ sensors_2020_01_01_8970008_measureid_eventdatetime_fkey | FOREIGN KEY (eventdatetime, measureid) REFERENCES colocated_partitioned_table_2020_01_01_8970024(eventdatetime, measureid)
+(9 rows)
+
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_8970000' ORDER BY 1,2;
+    tablename    |                                                                                           indexdef
+---------------------------------------------------------------------
+ sensors_8970000 | CREATE INDEX hash_index_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING hash (((measure_data -> 'IsFailed'::text)))
+ sensors_8970000 | CREATE INDEX index_on_parent_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING btree (lower((measureid)::text))
+ sensors_8970000 | CREATE INDEX index_with_include_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING btree (((measure_data -> 'IsFailed'::text))) INCLUDE (measure_data, eventdatetime)
+ sensors_8970000 | CREATE UNIQUE INDEX sensors_pkey_8970000 ON ONLY "blocking shard Move Fkeys Indexes".sensors_8970000 USING btree (measureid, eventdatetime, measure_data)
+(4 rows)
+
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_2020_01_01_8970008' ORDER BY 1,2;
+         tablename          |                                                                                                                indexdef
+---------------------------------------------------------------------
+ sensors_2020_01_01_8970008 | CREATE INDEX index_on_child_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (lower((measure_data)::text))
+ sensors_2020_01_01_8970008 | CREATE INDEX sensors_2020_01_01_expr_idx_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING hash (((measure_data -> 'IsFailed'::text)))
+ sensors_2020_01_01_8970008 | CREATE INDEX sensors_2020_01_01_expr_measure_data_eventdatetime_idx_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (((measure_data -> 'IsFailed'::text))) INCLUDE (measure_data, eventdatetime)
+ sensors_2020_01_01_8970008 | CREATE INDEX sensors_2020_01_01_lower_idx_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (lower((measureid)::text))
+ sensors_2020_01_01_8970008 | CREATE UNIQUE INDEX sensors_2020_01_01_pkey_8970008 ON "blocking shard Move Fkeys Indexes".sensors_2020_01_01_8970008 USING btree (measureid, eventdatetime, measure_data)
+(5 rows)
+
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='index_backed_rep_identity_8970029' ORDER BY 1,2;
+             tablename             |                                                          indexdef
+---------------------------------------------------------------------
+ index_backed_rep_identity_8970029 | CREATE UNIQUE INDEX uqx_8970029 ON "blocking shard Move Fkeys Indexes".index_backed_rep_identity_8970029 USING btree (key)
+(1 row)
+
+SELECT indisclustered FROM pg_index where indisclustered AND indrelid = 'index_backed_rep_identity_8970029'::regclass;
+ indisclustered
+---------------------------------------------------------------------
+ t
+(1 row)
+
+SELECT stxname FROM pg_statistic_ext
+WHERE stxnamespace IN (
+	SELECT oid
+	FROM pg_namespace
+	WHERE nspname IN ('blocking shard Move Fkeys Indexes')
+)
+ORDER BY stxname ASC;
+  stxname
+---------------------------------------------------------------------
+ s1
+ s1_8970000
+ s1_8970001
+ s1_8970003
+ s2
+ s2_8970008
+ s2_8970009
+ s2_8970011
+(8 rows)
+
+SELECT count(*) FROM pg_index
+WHERE indisclustered
+	and
+indrelid IN
+('sensors_2020_01_01_8970008'::regclass, 'colocated_dist_table_8970016'::regclass, 'colocated_partitioned_table_2020_01_01_8970024'::regclass);
+ count
+---------------------------------------------------------------------
+     3
+(1 row)
+
+\c - mx_rebalancer_blocking_role_ent - :master_port
+-- verify that the data is consistent
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SELECT count(*) FROM reference_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+SELECT count(*) FROM colocated_partitioned_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+SELECT count(*) FROM colocated_dist_table;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+SELECT count(*) FROM sensors;
+ count
+---------------------------------------------------------------------
+  1001
+(1 row)
+
+-- we should be able to change/drop constraints
+ALTER INDEX index_on_parent RENAME TO index_on_parent_renamed;
+ALTER INDEX index_on_child RENAME TO index_on_child_renamed;
+ALTER INDEX index_on_parent_renamed ALTER COLUMN 1 SET STATISTICS 200;
+ALTER INDEX index_on_child_renamed ALTER COLUMN 1 SET STATISTICS 200;
+DROP STATISTICS s1,s2;
+DROP INDEX index_on_parent_renamed;
+DROP INDEX index_on_child_renamed;
+ALTER TABLE sensors DROP CONSTRAINT fkey_from_parent_to_dist;
+ALTER TABLE sensors DROP CONSTRAINT fkey_from_parent_to_parent;
+ALTER TABLE sensors DROP CONSTRAINT fkey_from_parent_to_child;
+ALTER TABLE sensors_2020_01_01 DROP CONSTRAINT fkey_from_child_to_dist;
+ALTER TABLE sensors_2020_01_01 DROP CONSTRAINT fkey_from_child_to_parent;
+ALTER TABLE sensors_2020_01_01 DROP CONSTRAINT fkey_from_child_to_child;
+-- cleanup
+\c - postgres - :master_port
+DROP SCHEMA "blocking shard Move Fkeys Indexes" CASCADE;
+NOTICE:  drop cascades to 5 other objects
+DETAIL:  drop cascades to table "blocking shard Move Fkeys Indexes".sensors
+drop cascades to table "blocking shard Move Fkeys Indexes".colocated_dist_table
+drop cascades to table "blocking shard Move Fkeys Indexes".colocated_partitioned_table
+drop cascades to table "blocking shard Move Fkeys Indexes".reference_table
+drop cascades to table "blocking shard Move Fkeys Indexes".index_backed_rep_identity

src/test/regress/split_schedule

@@ -13,3 +13,6 @@ test: worker_split_text_copy_test
 test: citus_split_shard_by_split_points_negative
 test: citus_split_shard_by_split_points
 test: citus_split_shard_by_split_points_failure
+# Name citus_split_shard_by_split_points_columnar_partitioned was too long and being truncated.
+# use citus_split_shard_columnar_partitioned instead.
+test: citus_split_shard_columnar_partitioned

src/test/regress/sql/citus_split_shard_by_split_points_negative.sql

@@ -121,25 +121,3 @@ SELECT citus_split_shard_by_split_points(
 	51261400,
 	ARRAY['-1073741826'],
 	ARRAY[:worker_1_node, :worker_2_node]);
-
--- Create distributed table with columnar type.
-SET citus.next_shard_id TO 51271400;
-CREATE TABLE table_to_split_columnar (id bigserial PRIMARY KEY, value char) USING columnar;
-SELECT create_distributed_table('table_to_split_columnar','id');
-
--- UDF fails for columnar table.
-SELECT citus_split_shard_by_split_points(
-	51271400,
-	ARRAY['-1073741826'],
-	ARRAY[:worker_1_node, :worker_2_node]);
-
--- Create distributed table which is partitioned.
-SET citus.next_shard_id TO 51271900;
-CREATE TABLE table_to_split_partitioned(id integer, dt date) PARTITION BY RANGE(dt);
-SELECT create_distributed_table('table_to_split_partitioned','id');
-
--- UDF fails for partitioned table.
-SELECT citus_split_shard_by_split_points(
-	51271900,
-	ARRAY['-1073741826'],
-	ARRAY[:worker_1_node, :worker_2_node]);

src/test/regress/sql/citus_split_shard_columnar_partitioned.sql

@@ -0,0 +1,294 @@
+CREATE SCHEMA "citus_split_test_schema_columnar_partitioned";
+SET search_path TO "citus_split_test_schema_columnar_partitioned";
+SET citus.next_shard_id TO 8970000;
+SET citus.next_placement_id TO 8770000;
+SET citus.shard_count TO 1;
+SET citus.shard_replication_factor TO 1;
+
+-- BEGIN: Create table to split, along with other co-located tables. Add indexes, statistics etc.
+    CREATE TABLE sensors(
+        measureid         integer,
+        eventdatetime     date,
+        measure_data      jsonb,
+        PRIMARY KEY (measureid, eventdatetime, measure_data))
+    PARTITION BY RANGE(eventdatetime);
+
+    -- Table access method is specified on child tables
+    CREATE TABLE sensorscolumnar(
+        measureid         integer,
+        eventdatetime     date,
+        measure_data      jsonb,
+        PRIMARY KEY (measureid, eventdatetime, measure_data))
+    PARTITION BY RANGE(eventdatetime);
+
+    -- Create Partitions of table 'sensors'.
+    CREATE TABLE sensors_old PARTITION OF sensors FOR VALUES FROM ('2000-01-01') TO ('2020-01-01');
+    CREATE TABLE sensors_2020_01_01 PARTITION OF sensors FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+    CREATE TABLE sensors_news PARTITION OF sensors FOR VALUES FROM ('2020-05-01') TO ('2025-01-01');
+
+    CREATE TABLE sensorscolumnar_old PARTITION OF sensorscolumnar FOR VALUES FROM ('2000-01-01') TO ('2020-01-01')  USING COLUMNAR;
+    CREATE TABLE sensorscolumnar_2020_01_01 PARTITION OF sensorscolumnar FOR VALUES FROM ('2020-01-01') TO ('2020-02-01')  USING COLUMNAR;
+    CREATE TABLE sensorscolumnar_news PARTITION OF sensorscolumnar FOR VALUES FROM ('2020-05-01') TO ('2025-01-01') USING COLUMNAR;
+
+    -- Create index on parent and child partitions.
+    CREATE INDEX index_on_parent ON sensors(lower(measureid::text));
+    CREATE INDEX index_on_child ON sensors_2020_01_01(lower(measure_data::text));
+
+    CREATE INDEX index_on_parent_columnar ON sensorscolumnar(lower(measureid::text));
+    CREATE INDEX index_on_child_columnar ON sensorscolumnar_2020_01_01(lower(measure_data::text));
+
+    ALTER INDEX index_on_parent ALTER COLUMN 1 SET STATISTICS 1000;
+    ALTER INDEX index_on_child ALTER COLUMN 1 SET STATISTICS 1000;
+
+    ALTER INDEX index_on_parent_columnar ALTER COLUMN 1 SET STATISTICS 1000;
+    ALTER INDEX index_on_child_columnar ALTER COLUMN 1 SET STATISTICS 1000;
+
+    -- Create statistics on parent and child partitions.
+    CREATE STATISTICS s1 (dependencies) ON measureid, eventdatetime FROM sensors;
+    CREATE STATISTICS s2 (dependencies) ON measureid, eventdatetime FROM sensors_2020_01_01;
+
+    CREATE STATISTICS s1_c (dependencies) ON measureid, eventdatetime FROM sensorscolumnar;
+    CREATE STATISTICS s2_c (dependencies) ON measureid, eventdatetime FROM sensorscolumnar_2020_01_01;
+
+    CLUSTER sensors_2020_01_01 USING index_on_child;
+    SELECT create_distributed_table('sensors', 'measureid');
+    SELECT create_distributed_table('sensorscolumnar', 'measureid');
+
+    -- create colocated distributed tables
+    CREATE TABLE colocated_dist_table (measureid integer PRIMARY KEY);
+    SELECT create_distributed_table('colocated_dist_table', 'measureid');
+    CLUSTER colocated_dist_table USING colocated_dist_table_pkey;
+
+    CREATE TABLE colocated_partitioned_table(
+        measureid         integer,
+        eventdatetime     date,
+        PRIMARY KEY (measureid, eventdatetime))
+    PARTITION BY RANGE(eventdatetime);
+    CREATE TABLE colocated_partitioned_table_2020_01_01 PARTITION OF colocated_partitioned_table FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+    SELECT create_distributed_table('colocated_partitioned_table', 'measureid');
+    CLUSTER colocated_partitioned_table_2020_01_01 USING colocated_partitioned_table_2020_01_01_pkey;
+
+    -- create reference tables
+    CREATE TABLE reference_table (measureid integer PRIMARY KEY);
+    SELECT create_reference_table('reference_table');
+
+    SELECT shard.shardid, logicalrelid, shardminvalue, shardmaxvalue, nodename, nodeport
+    FROM pg_dist_shard AS shard
+    INNER JOIN pg_dist_placement placement ON shard.shardid = placement.shardid
+    INNER JOIN pg_dist_node       node     ON placement.groupid = node.groupid
+    INNER JOIN pg_catalog.pg_class cls     ON shard.logicalrelid = cls.oid
+    INNER JOIN pg_catalog.pg_namespace ns  ON cls.relnamespace = ns.oid
+    WHERE node.noderole = 'primary' AND ns.nspname = 'citus_split_test_schema_columnar_partitioned'
+    ORDER BY logicalrelid, shardminvalue::BIGINT;
+-- END: Create table to split, along with other co-located tables. Add indexes, statistics etc.
+
+-- BEGIN: Create constraints for tables.
+    -- from parent to regular dist
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+
+    -- from parent to parent
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_parent FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table(measureid, eventdatetime);
+
+    -- from parent to child
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_child FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid, eventdatetime);
+
+    ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+
+    -- from child to regular dist
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+
+    -- from child to parent
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_parent FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table(measureid,eventdatetime);
+
+    -- from child to child
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_child FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid,eventdatetime);
+
+    ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+
+    -- No support for foreign keys, unique constraints, or exclusion constraints in columnar tables.
+    -- Please see: https://github.com/citusdata/citus/tree/main/src/backend/columnar/README.md
+
+-- END: Create constraints for tables.
+
+-- BEGIN: Load data into tables
+    INSERT INTO reference_table SELECT i FROM generate_series(0,1000)i;
+    INSERT INTO colocated_dist_table SELECT i FROM generate_series(0,1000)i;
+    INSERT INTO colocated_partitioned_table SELECT i, '2020-01-05' FROM generate_series(0,1000)i;
+    INSERT INTO sensors SELECT i, '2020-01-05', '{}' FROM generate_series(0,1000)i;
+    INSERT INTO sensorscolumnar SELECT i, '2020-01-05', '{}' FROM generate_series(0,1000)i;
+-- END: Load data into tables
+
+-- BEGIN: Show the current state on workers
+\c - - - :worker_1_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+
+    \c - - - :worker_2_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+-- END: Show the current state on workers
+
+-- BEGIN: Split a shard along its co-located shards
+\c - - - :master_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.next_shard_id TO 8999000;
+    SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset
+    SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset
+
+    SELECT pg_catalog.citus_split_shard_by_split_points(
+        8970000,
+        ARRAY['-2120000000'],
+        ARRAY[:worker_1_node, :worker_2_node],
+        'block_writes');
+-- END: Split a shard along its co-located shards
+
+-- BEGIN: Validate Shard Info and Data
+    SELECT shard.shardid, logicalrelid, shardminvalue, shardmaxvalue, nodename, nodeport
+    FROM pg_dist_shard AS shard
+    INNER JOIN pg_dist_placement placement ON shard.shardid = placement.shardid
+    INNER JOIN pg_dist_node       node     ON placement.groupid = node.groupid
+    INNER JOIN pg_catalog.pg_class cls     ON shard.logicalrelid = cls.oid
+    INNER JOIN pg_catalog.pg_namespace ns  ON cls.relnamespace = ns.oid
+    WHERE node.noderole = 'primary' AND ns.nspname = 'citus_split_test_schema_columnar_partitioned'
+    ORDER BY logicalrelid, shardminvalue::BIGINT;
+
+    SELECT count(*) FROM reference_table;
+    SELECT count(*) FROM colocated_partitioned_table;
+    SELECT count(*) FROM colocated_dist_table;
+    SELECT count(*) FROM sensors;
+    SELECT count(*) FROM sensorscolumnar;
+-- END: Validate Shard Info and Data
+
+-- BEGIN: Show the updated state on workers
+    \c - - - :worker_1_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+
+    \c - - - :worker_2_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+-- END: Show the updated state on workers
+
+-- BEGIN: Split a partition table directly
+\c - - - :master_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.next_shard_id TO 8999100;
+    SELECT nodeid AS worker_1_node FROM pg_dist_node WHERE nodeport=:worker_1_port \gset
+    SELECT nodeid AS worker_2_node FROM pg_dist_node WHERE nodeport=:worker_2_port \gset
+
+    SELECT pg_catalog.citus_split_shard_by_split_points(
+        8999002, -- sensors_old
+        ARRAY['-2127770000'],
+        ARRAY[:worker_1_node, :worker_2_node],
+        'block_writes');
+-- END: Split a partition table directly
+
+-- BEGIN: Validate Shard Info and Data
+    SELECT shard.shardid, logicalrelid, shardminvalue, shardmaxvalue, nodename, nodeport
+    FROM pg_dist_shard AS shard
+    INNER JOIN pg_dist_placement placement ON shard.shardid = placement.shardid
+    INNER JOIN pg_dist_node       node     ON placement.groupid = node.groupid
+    INNER JOIN pg_catalog.pg_class cls     ON shard.logicalrelid = cls.oid
+    INNER JOIN pg_catalog.pg_namespace ns  ON cls.relnamespace = ns.oid
+    WHERE node.noderole = 'primary' AND ns.nspname = 'citus_split_test_schema_columnar_partitioned'
+    ORDER BY logicalrelid, shardminvalue::BIGINT;
+
+    SELECT count(*) FROM reference_table;
+    SELECT count(*) FROM colocated_partitioned_table;
+    SELECT count(*) FROM colocated_dist_table;
+    SELECT count(*) FROM sensors;
+    SELECT count(*) FROM sensorscolumnar;
+-- END: Validate Shard Info and Data
+
+-- BEGIN: Show the updated state on workers
+    \c - - - :worker_1_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+
+    \c - - - :worker_2_port
+    SET search_path TO "citus_split_test_schema_columnar_partitioned";
+    SET citus.show_shards_for_app_name_prefixes = '*';
+    SELECT tbl.relname, fk."Constraint", fk."Definition"
+            FROM pg_catalog.pg_class tbl
+            JOIN public.table_fkeys fk on tbl.oid = fk.relid
+            WHERE tbl.relname like '%_89%'
+            ORDER BY 1, 2;
+    SELECT tablename, indexdef FROM pg_indexes WHERE tablename like '%_89%' ORDER BY 1,2;
+    SELECT stxname FROM pg_statistic_ext
+    WHERE stxnamespace IN (
+        SELECT oid
+        FROM pg_namespace
+        WHERE nspname IN ('citus_split_test_schema_columnar_partitioned')
+    )
+    ORDER BY stxname ASC;
+-- END: Show the updated state on workers
+
+--BEGIN : Cleanup
+    \c - postgres - :master_port
+    DROP SCHEMA "citus_split_test_schema_columnar_partitioned" CASCADE;
+--END : Cleanup

src/test/regress/sql/shard_move_constraints_blocking.sql

@@ -0,0 +1,201 @@
+CREATE SCHEMA "blocking shard Move Fkeys Indexes";
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SET citus.next_shard_id TO 8970000;
+SET citus.next_placement_id TO 8770000;
+SET citus.shard_count TO 4;
+SET citus.shard_replication_factor TO 1;
+
+-- create a non-superuser role
+CREATE ROLE mx_rebalancer_blocking_role_ent WITH LOGIN;
+GRANT ALL ON SCHEMA "blocking shard Move Fkeys Indexes" TO mx_rebalancer_blocking_role_ent;
+
+-- connect with this new role
+\c - mx_rebalancer_blocking_role_ent - :master_port
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SET citus.next_shard_id TO 8970000;
+SET citus.next_placement_id TO 8770000;
+SET citus.shard_count TO 4;
+SET citus.shard_replication_factor TO 1;
+
+CREATE TABLE sensors(
+measureid         integer,
+eventdatetime     date,
+measure_data      jsonb,
+PRIMARY KEY (measureid, eventdatetime, measure_data))
+PARTITION BY RANGE(eventdatetime);
+
+CREATE TABLE sensors_old PARTITION OF sensors FOR VALUES FROM ('2000-01-01') TO ('2020-01-01');
+CREATE TABLE sensors_2020_01_01 PARTITION OF sensors FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+CREATE TABLE sensors_news PARTITION OF sensors FOR VALUES FROM ('2020-05-01') TO ('2025-01-01');
+
+CREATE INDEX index_on_parent ON sensors(lower(measureid::text));
+CREATE INDEX index_on_child ON sensors_2020_01_01(lower(measure_data::text));
+CREATE INDEX hash_index ON sensors USING HASH((measure_data->'IsFailed'));
+CREATE INDEX index_with_include ON sensors ((measure_data->'IsFailed')) INCLUDE (measure_data, eventdatetime);
+
+CREATE STATISTICS s1 (dependencies) ON measureid, eventdatetime FROM sensors;
+CREATE STATISTICS s2 (dependencies) ON measureid, eventdatetime FROM sensors_2020_01_01;
+
+ALTER INDEX index_on_parent ALTER COLUMN 1 SET STATISTICS 1000;
+ALTER INDEX index_on_child ALTER COLUMN 1 SET STATISTICS 1000;
+
+CLUSTER sensors_2020_01_01 USING index_on_child;
+SELECT create_distributed_table('sensors', 'measureid', colocate_with:='none');
+
+-- due to https://github.com/citusdata/citus/issues/5121
+\c - postgres - :master_port
+SET search_path TO "blocking shard Move Fkeys Indexes";
+
+SELECT update_distributed_table_colocation('sensors_old', 'sensors');
+SELECT update_distributed_table_colocation('sensors_2020_01_01', 'sensors');
+SELECT update_distributed_table_colocation('sensors_news', 'sensors');
+
+\c - mx_rebalancer_blocking_role_ent - :master_port
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SET citus.shard_count TO 4;
+SET citus.shard_replication_factor TO 1;
+SET citus.next_shard_id TO 8970016;
+SET citus.next_placement_id TO 8770016;
+
+-- create a colocated distributed tables and create foreign keys FROM/TO
+-- the partitions
+CREATE TABLE colocated_dist_table (measureid integer PRIMARY KEY);
+SELECT create_distributed_table('colocated_dist_table', 'measureid', colocate_with:='sensors');
+
+CLUSTER colocated_dist_table USING colocated_dist_table_pkey;
+
+CREATE TABLE colocated_partitioned_table(
+	measureid         integer,
+	eventdatetime     date,
+	PRIMARY KEY (measureid, eventdatetime))
+PARTITION BY RANGE(eventdatetime);
+
+CREATE TABLE colocated_partitioned_table_2020_01_01 PARTITION OF colocated_partitioned_table FOR VALUES FROM ('2020-01-01') TO ('2020-02-01');
+SELECT create_distributed_table('colocated_partitioned_table', 'measureid', colocate_with:='sensors');
+
+CLUSTER colocated_partitioned_table_2020_01_01 USING colocated_partitioned_table_2020_01_01_pkey;
+
+CREATE TABLE reference_table (measureid integer PRIMARY KEY);
+SELECT create_reference_table('reference_table');
+
+-- this table is used to make sure that index backed
+-- replica identites can have clustered indexes
+-- and no index statistics
+CREATE TABLE index_backed_rep_identity(key int NOT NULL);
+CREATE UNIQUE INDEX uqx ON index_backed_rep_identity(key);
+ALTER TABLE index_backed_rep_identity REPLICA IDENTITY USING INDEX uqx;
+CLUSTER index_backed_rep_identity USING uqx;
+SELECT create_distributed_table('index_backed_rep_identity', 'key', colocate_with:='sensors');
+
+-- from parent to regular dist
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+
+-- from parent to parent
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_parent FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table(measureid, eventdatetime);
+
+-- from parent to child
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_child FOREIGN KEY (measureid, eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid, eventdatetime);
+
+-- from parent to reference table
+ALTER TABLE sensors ADD CONSTRAINT fkey_from_parent_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+
+-- from child to regular dist
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_dist FOREIGN KEY (measureid) REFERENCES colocated_dist_table(measureid);
+
+-- from child to parent
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_parent FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table(measureid,eventdatetime);
+
+-- from child to child
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_child FOREIGN KEY (measureid,eventdatetime) REFERENCES colocated_partitioned_table_2020_01_01(measureid,eventdatetime);
+
+-- from child to reference table
+ALTER TABLE sensors_2020_01_01 ADD CONSTRAINT fkey_from_child_to_ref FOREIGN KEY (measureid) REFERENCES reference_table(measureid);
+
+-- load some data
+INSERT INTO reference_table SELECT i FROM generate_series(0,1000)i;
+INSERT INTO colocated_dist_table SELECT i FROM generate_series(0,1000)i;
+INSERT INTO colocated_partitioned_table SELECT i, '2020-01-05' FROM generate_series(0,1000)i;
+INSERT INTO sensors SELECT i, '2020-01-05', '{}' FROM generate_series(0,1000)i;
+
+\c - postgres - :worker_1_port
+SET search_path TO "blocking shard Move Fkeys Indexes", public, pg_catalog;
+
+-- show the current state of the constraints
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_8970000'::regclass ORDER BY 1,2;
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_2020_01_01_8970008'::regclass ORDER BY 1,2;
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_8970000' ORDER BY 1,2;
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_2020_01_01_8970008' ORDER BY 1,2;
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='index_backed_rep_identity_8970029' ORDER BY 1,2;
+SELECT indisclustered FROM pg_index where indisclustered AND indrelid = 'index_backed_rep_identity_8970029'::regclass;
+
+SELECT stxname FROM pg_statistic_ext
+WHERE stxnamespace IN (
+	SELECT oid
+	FROM pg_namespace
+	WHERE nspname IN ('blocking shard Move Fkeys Indexes')
+)
+ORDER BY stxname ASC;
+
+SELECT count(*) FROM pg_index
+WHERE indisclustered
+	and
+indrelid IN
+('sensors_2020_01_01_8970008'::regclass, 'colocated_dist_table_8970016'::regclass, 'colocated_partitioned_table_2020_01_01_8970024'::regclass);
+\c - - - :master_port
+-- make sure that constrainst are moved sanely with logical replication
+SELECT citus_move_shard_placement(8970000, 'localhost', :worker_1_port, 'localhost', :worker_2_port, shard_transfer_mode:='block_writes');
+CALL citus_cleanup_orphaned_shards();
+
+
+\c - postgres - :worker_2_port
+SET search_path TO "blocking shard Move Fkeys Indexes", public, pg_catalog;
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_8970000'::regclass ORDER BY 1,2;
+SELECT "Constraint", "Definition" FROM table_fkeys WHERE relid='sensors_2020_01_01_8970008'::regclass ORDER BY 1,2;
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_8970000' ORDER BY 1,2;
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='sensors_2020_01_01_8970008' ORDER BY 1,2;
+SELECT tablename, indexdef FROM pg_indexes WHERE tablename ='index_backed_rep_identity_8970029' ORDER BY 1,2;
+SELECT indisclustered FROM pg_index where indisclustered AND indrelid = 'index_backed_rep_identity_8970029'::regclass;
+
+SELECT stxname FROM pg_statistic_ext
+WHERE stxnamespace IN (
+	SELECT oid
+	FROM pg_namespace
+	WHERE nspname IN ('blocking shard Move Fkeys Indexes')
+)
+ORDER BY stxname ASC;
+
+SELECT count(*) FROM pg_index
+WHERE indisclustered
+	and
+indrelid IN
+('sensors_2020_01_01_8970008'::regclass, 'colocated_dist_table_8970016'::regclass, 'colocated_partitioned_table_2020_01_01_8970024'::regclass);
+
+\c - mx_rebalancer_blocking_role_ent - :master_port
+-- verify that the data is consistent
+SET search_path TO "blocking shard Move Fkeys Indexes";
+SELECT count(*) FROM reference_table;
+SELECT count(*) FROM colocated_partitioned_table;
+SELECT count(*) FROM colocated_dist_table;
+SELECT count(*) FROM sensors;
+
+-- we should be able to change/drop constraints
+ALTER INDEX index_on_parent RENAME TO index_on_parent_renamed;
+ALTER INDEX index_on_child RENAME TO index_on_child_renamed;
+
+ALTER INDEX index_on_parent_renamed ALTER COLUMN 1 SET STATISTICS 200;
+ALTER INDEX index_on_child_renamed ALTER COLUMN 1 SET STATISTICS 200;
+
+DROP STATISTICS s1,s2;
+
+DROP INDEX index_on_parent_renamed;
+DROP INDEX index_on_child_renamed;
+ALTER TABLE sensors DROP CONSTRAINT fkey_from_parent_to_dist;
+ALTER TABLE sensors DROP CONSTRAINT fkey_from_parent_to_parent;
+ALTER TABLE sensors DROP CONSTRAINT fkey_from_parent_to_child;
+ALTER TABLE sensors_2020_01_01 DROP CONSTRAINT fkey_from_child_to_dist;
+ALTER TABLE sensors_2020_01_01 DROP CONSTRAINT fkey_from_child_to_parent;
+ALTER TABLE sensors_2020_01_01 DROP CONSTRAINT fkey_from_child_to_child;
+
+-- cleanup
+\c - postgres - :master_port
+DROP SCHEMA "blocking shard Move Fkeys Indexes" CASCADE;