Function arcon_messages::protobuf::create_keyed_element

pub fn create_keyed_element(
    data: Vec<u8>, 
    ts: u64, 
    key: u64
) -> StreamTaskMessage