solana-hbase-reader 3.1.8

Solana HBase storage reader library
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

use {
    crate::{
        hbase::{HBase, Result},
    },
    log::*,
    std::{
        time::{
            Duration,
        },
    },
    hbase_thrift::hbase::{
        HbaseSyncClient,
    },
    thrift::{
        protocol::{
            TBinaryInputProtocol, TBinaryOutputProtocol,
        },
        transport::{TBufferedReadTransport, TBufferedWriteTransport, TIoChannel, TTcpChannel},
    },
};

#[derive(Clone, Debug)]
pub struct HBaseConnection {
    address: String,
    // timeout: Option<Duration>,
}

impl HBaseConnection {
    pub async fn new(
        address: &str,
        _read_only: bool,
        _timeout: Option<Duration>,
    ) -> Result<Self> {
        debug!("Creating HBase connection instance");

        Ok(Self {
            address: address.to_string(),
            // timeout,
        })
    }

    pub fn client(&self) -> HBase {
        let mut channel = TTcpChannel::new();

        channel.open(self.address.clone()).unwrap();

        let (input_chan, output_chan) = channel.split().unwrap();

        let input_prot = TBinaryInputProtocol::new(
            TBufferedReadTransport::new(input_chan),
            true
        );
        let output_prot = TBinaryOutputProtocol::new(
            TBufferedWriteTransport::new(output_chan),
            true
        );

        let client = HbaseSyncClient::new(
            input_prot,
            output_prot
        );

        HBase {
            client,
            // timeout: self.timeout,
        }
    }
}