[Feature][Connector-V2] StarRocks-sink support schema evolution #8082
Conversation
…ing with Elasticsearch's automatic index creation apache#7430
…utomatic index creation conflict apache#7430
…utomatically creating indexes based on templates apache#7430
…utomatic index creation conflict apache#7430
…utomatic index creation conflict apache#7430
| } | ||
|
|
||
| @TestTemplate | ||
| public void testStarRocksSinkWithSchemaEvolutionCase(TestContainer container) |
There was a problem hiding this comment.
| @@ -40,16 +39,15 @@ | |||
| public class StarRocksSink extends AbstractSimpleSink<SeaTunnelRow, Void> | |||
| implements SupportSaveMode { | |||
There was a problem hiding this comment.
please Implements SchemaEvolution API
https://github.com/apache/seatunnel/blob/dev/seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportSchemaEvolutionSink.java
https://github.com/apache/seatunnel/blob/dev/seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SupportSchemaEvolutionSinkWriter.java
|
|
||
| @Slf4j | ||
| public class StarRocksSinkWriter extends AbstractSinkWriter<SeaTunnelRow, Void> { | ||
| public class StarRocksSinkWriter extends AbstractSinkWriter<SeaTunnelRow, Void> | ||
| implements SupportSchemaEvolutionSinkWriter, SupportSchemaEvolutionSink { |
There was a problem hiding this comment.
move SupportSchemaEvolutionSink to StarRocksSink
There was a problem hiding this comment.
ok，thanks，I was negligent
| throw new SeaTunnelException( | ||
| "Unsupported schemaChangeEvent for event type: " + event.getEventType()); | ||
| } | ||
| this.tableSchema = |
There was a problem hiding this comment.
| this.tableSchema = | |
| this.tableSchema = TableSchemaChangeEventDispatcher.reset(..).apply(event); |
|
reference |
ok,I'll try again,thanks |
| * @param afterColumn column before the new column | ||
| * @return alter table sql for sink table after schema change | ||
| */ | ||
| public static String buildAlterTableSql( |
There was a problem hiding this comment.
It doesn't need to be so complicated, please simplify the code.
reference
#8134
There was a problem hiding this comment.
ok,I optimizing the code,thanks.
Feature #8034
Purpose of this pull request
Does this PR introduce any user-facing change?
How was this patch tested?
Check list
New License Guide
release-note.