hbase_thrift::hbase

Struct THbaseProcessFunctions

Source 
pub struct THbaseProcessFunctions;

Implementations§

Source§

impl THbaseProcessFunctions

Source

pub fn process_enable_table<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_disable_table<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_is_table_enabled<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_compact<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_major_compact<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_table_names<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_table_names_with_is_table_enabled<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_column_descriptors<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_table_regions<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_create_table<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_delete_table<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_ver<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_ver_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_row<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_row_with_columns<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_row_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_row_with_columns_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_rows<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_rows_with_columns<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_rows_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_rows_with_columns_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_mutate_row<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_mutate_row_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_mutate_rows<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_mutate_rows_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_atomic_increment<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_delete_all<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_delete_all_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_delete_all_row<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_increment<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_increment_rows<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_delete_all_row_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_open_with_scan<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_open<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_open_with_stop<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_open_with_prefix<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_open_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_open_with_stop_ts<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_get<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_get_list<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_scanner_close<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_region_info<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_append<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_check_and_put<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_thrift_server_type<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_get_cluster_id<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_grant<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Source

pub fn process_revoke<H: HbaseSyncHandler>( handler: &H, incoming_sequence_number: i32, i_prot: &mut dyn TInputProtocol, o_prot: &mut dyn TOutputProtocol, ) -> Result<()>

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.