#[derive(Debug, Default, Clone, PartialEq)]
pub struct ThriftHiveMetastoreDropPartitionByNameWithEnvironmentContextArgsRecv {
pub db_name: ::pilota::FastStr,
pub tbl_name: ::pilota::FastStr,
pub part_name: ::pilota::FastStr,
pub delete_data: bool,
pub environment_context: EnvironmentContext,
}
impl ::pilota::thrift::Message
for ThriftHiveMetastoreDropPartitionByNameWithEnvironmentContextArgsRecv
{
fn encode<T: ::pilota::thrift::TOutputProtocol>(
&self,
__protocol: &mut T,
) -> ::std::result::Result<(), ::pilota::thrift::ThriftException> {
#[allow(unused_imports)]
use ::pilota::thrift::TOutputProtocolExt;
let struct_ident = ::pilota::thrift::TStructIdentifier {
name: "ThriftHiveMetastoreDropPartitionByNameWithEnvironmentContextArgsRecv",
};
__protocol.write_struct_begin(&struct_ident)?;
__protocol.write_faststr_field(1, (&self.db_name).clone())?;
__protocol.write_faststr_field(2, (&self.tbl_name).clone())?;
__protocol.write_faststr_field(3, (&self.part_name).clone())?;
__protocol.write_bool_field(4, *&self.delete_data)?;
__protocol.write_struct_field(
5,
&self.environment_context,
::pilota::thrift::TType::Struct,
)?;
__protocol.write_field_stop()?;
__protocol.write_struct_end()?;
::std::result::Result::Ok(())
}
fn decode<T: ::pilota::thrift::TInputProtocol>(
__protocol: &mut T,
) -> ::std::result::Result<Self, ::pilota::thrift::ThriftException> {
#[allow(unused_imports)]
use ::pilota::{thrift::TLengthProtocolExt, Buf};
let mut var_1 = None;
let mut var_2 = None;
let mut var_3 = None;
let mut var_4 = None;
let mut var_5 = None;
let mut __pilota_decoding_field_id = None;
__protocol.read_struct_begin()?;
if let ::std::result::Result::Err(mut err) = (|| {
loop {
let field_ident = __protocol.read_field_begin()?;
if field_ident.field_type == ::pilota::thrift::TType::Stop {
__protocol.field_stop_len();
break;
} else {
__protocol.field_begin_len(field_ident.field_type, field_ident.id);
}
__pilota_decoding_field_id = field_ident.id;
match field_ident.id {
Some(1) if field_ident.field_type == ::pilota::thrift::TType::Binary => {
var_1 = Some(__protocol.read_faststr()?);
}
Some(2) if field_ident.field_type == ::pilota::thrift::TType::Binary => {
var_2 = Some(__protocol.read_faststr()?);
}
Some(3) if field_ident.field_type == ::pilota::thrift::TType::Binary => {
var_3 = Some(__protocol.read_faststr()?);
}
Some(4) if field_ident.field_type == ::pilota::thrift::TType::Bool => {
var_4 = Some(__protocol.read_bool()?);
}
Some(5) if field_ident.field_type == ::pilota::thrift::TType::Struct => {
var_5 = Some(::pilota::thrift::Message::decode(__protocol)?);
}
_ => {
__protocol.skip(field_ident.field_type)?;
}
}
__protocol.read_field_end()?;
__protocol.field_end_len();
}
::std::result::Result::Ok::<_, ::pilota::thrift::ThriftException>(())
})() {
if let Some(field_id) = __pilota_decoding_field_id {
err.prepend_msg(&format!("decode struct `ThriftHiveMetastoreDropPartitionByNameWithEnvironmentContextArgsRecv` field(#{}) failed, caused by: ", field_id));
}
return ::std::result::Result::Err(err);
};
__protocol.read_struct_end()?;
let Some(var_1) = var_1 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field db_name is required".to_string(),
));
};
let Some(var_2) = var_2 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field tbl_name is required".to_string(),
));
};
let Some(var_3) = var_3 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field part_name is required".to_string(),
));
};
let Some(var_4) = var_4 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field delete_data is required".to_string(),
));
};
let Some(var_5) = var_5 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field environment_context is required".to_string(),
));
};
let data = Self {
db_name: var_1,
tbl_name: var_2,
part_name: var_3,
delete_data: var_4,
environment_context: var_5,
};
::std::result::Result::Ok(data)
}
fn decode_async<'a, T: ::pilota::thrift::TAsyncInputProtocol>(
__protocol: &'a mut T,
) -> ::std::pin::Pin<
::std::boxed::Box<
dyn ::std::future::Future<
Output = ::std::result::Result<Self, ::pilota::thrift::ThriftException>,
> + Send
+ 'a,
>,
> {
::std::boxed::Box::pin(async move {
let mut var_1 = None;
let mut var_2 = None;
let mut var_3 = None;
let mut var_4 = None;
let mut var_5 = None;
let mut __pilota_decoding_field_id = None;
__protocol.read_struct_begin().await?;
if let ::std::result::Result::Err(mut err) = async {
loop {
let field_ident = __protocol.read_field_begin().await?;
if field_ident.field_type == ::pilota::thrift::TType::Stop {
break;
} else {
}
__pilota_decoding_field_id = field_ident.id;
match field_ident.id {
Some(1) if field_ident.field_type == ::pilota::thrift::TType::Binary => {
var_1 = Some(__protocol.read_faststr().await?);
}
Some(2) if field_ident.field_type == ::pilota::thrift::TType::Binary => {
var_2 = Some(__protocol.read_faststr().await?);
}
Some(3) if field_ident.field_type == ::pilota::thrift::TType::Binary => {
var_3 = Some(__protocol.read_faststr().await?);
}
Some(4) if field_ident.field_type == ::pilota::thrift::TType::Bool => {
var_4 = Some(__protocol.read_bool().await?);
}
Some(5) if field_ident.field_type == ::pilota::thrift::TType::Struct => {
var_5 = Some(
<EnvironmentContext as ::pilota::thrift::Message>::decode_async(
__protocol,
)
.await?,
);
}
_ => {
__protocol.skip(field_ident.field_type).await?;
}
}
__protocol.read_field_end().await?;
}
::std::result::Result::Ok::<_, ::pilota::thrift::ThriftException>(())
}
.await
{
if let Some(field_id) = __pilota_decoding_field_id {
err.prepend_msg(&format!("decode struct `ThriftHiveMetastoreDropPartitionByNameWithEnvironmentContextArgsRecv` field(#{}) failed, caused by: ", field_id));
}
return ::std::result::Result::Err(err);
};
__protocol.read_struct_end().await?;
let Some(var_1) = var_1 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field db_name is required".to_string(),
));
};
let Some(var_2) = var_2 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field tbl_name is required".to_string(),
));
};
let Some(var_3) = var_3 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field part_name is required".to_string(),
));
};
let Some(var_4) = var_4 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field delete_data is required".to_string(),
));
};
let Some(var_5) = var_5 else {
return ::std::result::Result::Err(::pilota::thrift::new_protocol_exception(
::pilota::thrift::ProtocolExceptionKind::InvalidData,
"field environment_context is required".to_string(),
));
};
let data = Self {
db_name: var_1,
tbl_name: var_2,
part_name: var_3,
delete_data: var_4,
environment_context: var_5,
};
::std::result::Result::Ok(data)
})
}
fn size<T: ::pilota::thrift::TLengthProtocol>(&self, __protocol: &mut T) -> usize {
#[allow(unused_imports)]
use ::pilota::thrift::TLengthProtocolExt;
__protocol.struct_begin_len(&::pilota::thrift::TStructIdentifier {
name: "ThriftHiveMetastoreDropPartitionByNameWithEnvironmentContextArgsRecv",
}) + __protocol.faststr_field_len(Some(1), &self.db_name)
+ __protocol.faststr_field_len(Some(2), &self.tbl_name)
+ __protocol.faststr_field_len(Some(3), &self.part_name)
+ __protocol.bool_field_len(Some(4), *&self.delete_data)
+ __protocol.struct_field_len(Some(5), &self.environment_context)
+ __protocol.field_stop_len()
+ __protocol.struct_end_len()
}
}