tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Enhancement] Change Sort Key Order for AirByte Tables (#25026)

This commit is contained in:
Ashish Bansal (mrphantom) 2023-06-12 00:28:25 -07:00 committed by GitHub
parent ef1fc6a406
commit 82bad405e3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
contrib/destination-starrocks/build.gradle
View File

@ -14,7 +14,7 @@ dependencies {
implementation 'com.fasterxml.jackson.core:jackson-databind:2.14.1'
implementation 'com.alibaba:fastjson:1.2.75'
implementation project(':airbyte-config:config-models')
implementation project(':airbyte-config-oss:config-models-oss')
// implementation project(':airbyte-protocol:protocol-models')
implementation project(':airbyte-integrations:bases:base-java')
implementation files(project(':airbyte-integrations:bases:base-java').airbyteDocker.outputs)

6
contrib/destination-starrocks/src/main/java/io/airbyte/integrations/destination/starrocks/SqlUtil.java
View File

@ -77,11 +77,11 @@ public class SqlUtil {
public static void createTableIfNotExist(Connection conn, String tableName) throws SQLException {
String sql = "CREATE TABLE IF NOT EXISTS " + tableName + " ( \n"
+ "`" + JavaBaseConstants.COLUMN_NAME_AB_ID + "` varchar(40),\n"
+ "`" + JavaBaseConstants.COLUMN_NAME_EMITTED_AT + "` BIGINT,\n"
+ "`" + JavaBaseConstants.COLUMN_NAME_AB_ID + "` varchar(40),\n"
+ "`" + JavaBaseConstants.COLUMN_NAME_DATA + "` String)\n"
+ "DUPLICATE KEY(`" + JavaBaseConstants.COLUMN_NAME_AB_ID + "`,`"
+ JavaBaseConstants.COLUMN_NAME_EMITTED_AT + "`) \n"
+ "DUPLICATE KEY(`" + JavaBaseConstants.COLUMN_NAME_EMITTED_AT + "`,`"
+ JavaBaseConstants.COLUMN_NAME_AB_ID + "`) \n"
+ "DISTRIBUTED BY HASH(`" + JavaBaseConstants.COLUMN_NAME_AB_ID + "`) BUCKETS 16 \n"
+ "PROPERTIES ( \n"
+ "\"replication_num\" = \"1\" \n"