in paimon-prestosql-common/src/main/java/org/apache/paimon/prestosql/PrestoSqlMetadataBase.java [328:343]
public void dropColumn(
ConnectorSession session, ConnectorTableHandle tableHandle, ColumnHandle column) {
PrestoSqlTableHandle prestosqlTableHandle = (PrestoSqlTableHandle) tableHandle;
Identifier identifier =
new Identifier(
prestosqlTableHandle.getSchemaName(), prestosqlTableHandle.getTableName());
PrestoSqlColumnHandle prestosqlColumnHandle = (PrestoSqlColumnHandle) column;
List<SchemaChange> changes = new ArrayList<>();
changes.add(SchemaChange.dropColumn(prestosqlColumnHandle.getColumnName()));
try {
catalog.alterTable(identifier, changes, false);
} catch (Exception e) {
throw new RuntimeException(
format("table not exists: '%s'", prestosqlTableHandle.getTableName()));
}
}