rlink-elasticsearch-connector 0.2.0-alpha.1

High performance Stream Processing Framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

// #[macro_use]
// extern crate serde_json;
#[macro_use]
extern crate serde_derive;
#[macro_use]
extern crate log;
#[macro_use]
extern crate rlink_derive;

pub mod elasticsearch_sink;

pub static ES_DATA_TYPES: [u8; 2] = [
    // topic
    rlink::api::element::types::BYTES,
    // body
    rlink::api::element::types::BYTES,
];