virajjasani commented on code in PR #2025:
URL: https://github.com/apache/phoenix/pull/2025#discussion_r1835677207
##########
phoenix-core-client/src/main/java/org/apache/phoenix/query/QueryConstants.java:
##########
@@ -640,4 +650,35 @@ enum JoinType {INNER, LEFT_OUTER}
+ SYSTEM_TASK_SPLIT_POLICY_CLASSNAME + "',\n" +
TRANSACTIONAL + "=" + Boolean.FALSE + ",\n" +
STORE_NULLS + "=" + Boolean.TRUE;
+
+ String CREATE_CDC_STREAM_STATUS_METADATA = "CREATE TABLE " +
SYSTEM_CATALOG_SCHEMA + ".\"" +
+ SYSTEM_CDC_STREAM_STATUS_TABLE + "\"(\n" +
+ // PK columns
+ TABLE_NAME + " VARCHAR NOT NULL," +
+ STREAM_STATUS + " VARCHAR NOT NULL," +
+ // Non-PK columns
+ STREAM_NAME + " VARCHAR,\n" +
+ "CONSTRAINT " + SYSTEM_TABLE_PK_NAME + " PRIMARY KEY (" +
+ TABLE_NAME + "," + STREAM_STATUS + "))\n" +
+ HConstants.VERSIONS + "=%s,\n" +
+ ColumnFamilyDescriptorBuilder.KEEP_DELETED_CELLS + "=%s,\n" +
+ TRANSACTIONAL + "=" + Boolean.FALSE;
+
+ String CREATE_CDC_STREAM_METADATA = "CREATE TABLE " +
SYSTEM_CATALOG_SCHEMA + ".\"" +
+ SYSTEM_CDC_STREAM_TABLE + "\"(\n" +
+ // PK columns
+ TABLE_NAME + " VARCHAR NOT NULL," +
+ STREAM_NAME + " VARCHAR NOT NULL," +
+ PARTITION_ID + " VARCHAR NOT NULL," +
+ // Non-PK columns
+ PARENT_PARTITION_ID + " VARCHAR," +
+ PARTITION_START_TIME + " BIGINT," +
Review Comment:
I see, in this case we can use LONG directly instead of DATE.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@phoenix.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
