Struct iotdb::Session

pub struct Session { /* fields omitted */ }

Implementations

impl Session

pub fn new(
    client: TSIServiceSyncClient<Box<dyn TInputProtocol>, Box<dyn TOutputProtocol>>
) -> Session

pub fn user(&mut self, user: &str) -> &mut Session

pub fn password(&mut self, password: &str) -> &mut Session

pub fn zone_id(&mut self, zone_id: &str) -> &mut Session

pub fn fetch_size(&mut self, fetch_size: i32) -> &mut Session

pub fn protocol_version(&mut self, user: &str) -> &mut Session

pub fn config(&mut self, key: &str, value: &str) -> &mut Session

pub fn config_map(&mut self, map: HashMap<&str, &str>) -> &mut Session

pub fn is_success(&self, status: &TSStatus) -> bool

pub fn open(&mut self) -> Result<&mut Session>

pub fn is_open(&self) -> bool

pub fn close(&mut self) -> Result<()>

pub fn set_storage_group(&mut self, storage_group: &str) -> Result<()>

Set a storage group

pub fn delete_storage_group(&mut self, storage_group: &str) -> Result<()>

Delete a storage group.

pub fn delete_storage_groups(
    &mut self,
    storage_groups: Vec<String>
) -> Result<()>

Delete storage groups.

pub fn create_time_series(
    &mut self,
    ts_path: String,
    data_type: i32,
    encoding: i32,
    compressor: i32
) -> Result<()>

Create single time-series

pub fn create_multi_time_series(
    &mut self,
    ts_path_vec: Vec<String>,
    data_type_vec: Vec<i32>,
    encoding_vec: Vec<i32>,
    compressor_vec: Vec<i32>
) -> Result<()>

Create multiple time-series

pub fn delete_time_series(&mut self, path_vec: Vec<String>) -> Result<()>

Delete multiple time series

pub fn check_time_series_exist(&mut self, path: &str)

Check whether a specific time-series exists

pub fn delete_data(
    &mut self,
    path_vec: Vec<String>,
    timestamp: i64
) -> Result<()>

Delete all data <= time in multiple time-series

pub fn insert_string_records(
    &mut self,
    device_ids: Vec<String>,
    measurements_list: Vec<Vec<String>>,
    values_list: Vec<Vec<String>>,
    timestamps: Vec<i64>
) -> Result<TSStatus>

Insert string records

pub fn insert_record(
    &mut self,
    device_id: String,
    measurements: Vec<String>,
    values: Vec<u8>,
    timestamp: i64
) -> Result<TSStatus>

Insert record

pub fn insert_records(
    &mut self,
    device_ids: Vec<String>,
    measurements_list: Vec<Vec<String>>,
    values_list: Vec<Vec<u8>>,
    timestamps: Vec<i64>
) -> Result<TSStatus>

Insert records

pub fn insert_records_of_one_device(
    &mut self,
    device_id: String,
    measurements_list: Vec<Vec<String>>,
    values_list: Vec<Vec<u8>>,
    timestamps: Vec<i64>
) -> Result<TSStatus>

Insert records of one device

pub fn insert_tablet(
    &mut self,
    device_id: String,
    measurements: Vec<String>,
    values: Vec<u8>,
    timestamps: Vec<u8>,
    types: Vec<i32>,
    size: i32
) -> Result<TSStatus>

Insert tablet

pub fn insert_tablets(
    &mut self,
    device_ids: Vec<String>,
    measurements_list: Vec<Vec<String>>,
    values_list: Vec<Vec<u8>>,
    timestamps_list: Vec<Vec<u8>>,
    types_list: Vec<Vec<i32>>,
    size_list: Vec<i32>
) -> Result<TSStatus>

Insert tablets

pub fn set_time_zone(&mut self, time_zone: &str) -> Result<()>

Set time zone

pub fn query(&mut self, sql: &str) -> Result<TSExecuteStatementResp>

pub fn get_time_zone(&mut self) -> Result<String>

Get time zone

pub fn get_properties(&mut self) -> Result<ServerProperties>

Get properties

pub fn cancel_operation(&mut self, query_id: i64) -> Result<TSStatus>

Cancel operation