@PublicEvolving public static class TableChange.ModifyWatermark extends Object implements TableChange
It is equal to the following statement:
ALTER TABLE <table_name> MODIFY WATERMARK FOR <row_time_column_name> AS <watermark_expression>
TableChange.AddColumn, TableChange.AddUniqueConstraint, TableChange.AddWatermark, TableChange.After, TableChange.ColumnPosition, TableChange.DropColumn, TableChange.DropConstraint, TableChange.DropWatermark, TableChange.First, TableChange.ModifyColumn, TableChange.ModifyColumnComment, TableChange.ModifyColumnName, TableChange.ModifyColumnPosition, TableChange.ModifyPhysicalColumnType, TableChange.ModifyUniqueConstraint, TableChange.ModifyWatermark, TableChange.ResetOption, TableChange.SetOption
Constructor and Description |
---|
ModifyWatermark(WatermarkSpec newWatermark) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
WatermarkSpec |
getNewWatermark()
Returns the modified watermark.
|
int |
hashCode() |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
add, add, add, add, dropColumn, dropConstraint, dropWatermark, modify, modify, modify, modifyColumnComment, modifyColumnName, modifyColumnPosition, modifyPhysicalColumnType, reset, set
public ModifyWatermark(WatermarkSpec newWatermark)
public WatermarkSpec getNewWatermark()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.