in amoro-common/src/main/gen-java/org/apache/amoro/api/TableChange.java [741:830]
public void read(org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocol iprot, TableChange struct) throws org.apache.amoro.shade.thrift.org.apache.thrift.TException {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // INNER_TABLE
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.STRING) {
struct.innerTable = iprot.readString();
struct.setInnerTableIsSet(true);
} else {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // ADD_FILES
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.LIST) {
{
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TList _list48 = iprot.readListBegin();
struct.addFiles = new java.util.ArrayList<DataFile>(_list48.size);
@org.apache.amoro.shade.thrift.org.apache.thrift.annotation.Nullable DataFile _elem49;
for (int _i50 = 0; _i50 < _list48.size; ++_i50)
{
_elem49 = new DataFile();
_elem49.read(iprot);
struct.addFiles.add(_elem49);
}
iprot.readListEnd();
}
struct.setAddFilesIsSet(true);
} else {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // DELETE_FILES
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.LIST) {
{
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TList _list51 = iprot.readListBegin();
struct.deleteFiles = new java.util.ArrayList<DataFile>(_list51.size);
@org.apache.amoro.shade.thrift.org.apache.thrift.annotation.Nullable DataFile _elem52;
for (int _i53 = 0; _i53 < _list51.size; ++_i53)
{
_elem52 = new DataFile();
_elem52.read(iprot);
struct.deleteFiles.add(_elem52);
}
iprot.readListEnd();
}
struct.setDeleteFilesIsSet(true);
} else {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // SNAPSHOT_ID
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.I64) {
struct.snapshotId = iprot.readI64();
struct.setSnapshotIdIsSet(true);
} else {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // SNAPSHOT_SEQUENCE
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.I64) {
struct.snapshotSequence = iprot.readI64();
struct.setSnapshotSequenceIsSet(true);
} else {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // PARENT_SNAPSHOT_ID
if (schemeField.type == org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TType.I64) {
struct.parentSnapshotId = iprot.readI64();
struct.setParentSnapshotIdIsSet(true);
} else {
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
iprot.readStructEnd();
// check for required fields of primitive type, which can't be checked in the validate method
struct.validate();
}