hililiwei opened a new pull request #4246:
URL: https://github.com/apache/iceberg/pull/4246
Some tasks in our production environment have been migrated to
Schema/ResolvedSchema. This PR is mainly used to add support for ResolvedSchema.
1. Add the following `project` to the source:
```java
public Builder project(ResolvedSchema schema) {
this.projectedResolvedSchema = schema;
return this;
}
```
2. Add the following code to the sink:
```java
public Builder tableSchema(ResolvedSchema newTableSchema) {
this.resolvedTableSchema = newTableSchema;
return this;
}
```
3. FlinkDynamicTableFactory replaces CatalogTable with ResolvedSchema and
uses it in `IcebergTableSource`and `IcebergTableSink`.
4. Add a tool class for ResolvedSchema: FlinkResolvedSchemaUtil. Convert the
flink table schema to apache iceberg schema.
5. Add simple test cases.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
