and Analytics Vasiliki (Vasia) Kalavri
 vkalavri@bu.edu Spring 2020 1/28: Stream ingestion and pub/sub systems Streaming sources Files, e.g. transaction logs Sockets IoT devices and sensors notify unsubscribe advertise(): information reg. future events Publish/Subscribe Systems 17 Pub/Sub levels of de-coupling • Space: interacting parties do not need to know each other • Publishers Decoupling Message-passing RPC/RMI Asynchronous RPC Futures Message Queues Pub/Sub Yes Yes Yes Can you fill this in? 19 Pub/Sub vs. other paradigms Paradigm Space Decoupling Time Decoupling Synchronization

Whitespace Names Examples Source Encoding Keyword Reference Keyword: pub Grammar Zen Hello World hello.zig const std = @import("std"); pub fn main() !void { // If this program is run without stdout to emit. For that you can use a simpler API: hello.zig const warn = @import("std").debug.warn; pub fn main() void { warn("Hello, world!\n"); } $ zig build-exe hello.zig $ ./hello Hello, world! the Unix epoch; that is /// moment of 1970 Jan 1 00:00:00 UTC (this is a doc comment too). pub fn unixEpoch() Timestamp { return Timestamp{ .seconds = 0, .nanos =

Whitespace Names Examples Source Encoding Keyword Reference Keyword: pub Grammar Zen Hello World hello.zig const std = @import("std"); pub fn main() !void { // If this program is run without stdout to emit. For that you can use a simpler API: hello.zig const warn = @import("std").debug.warn; pub fn main() void { warn("Hello, world!\n"); } $ zig build-exe hello.zig $ ./hello Hello, world! the Unix epoch; that is /// moment of 1970 Jan 1 00:00:00 UTC (this is a doc comment too). pub fn unixEpoch() Timestamp { return Timestamp{ .seconds = 0, .nanos =

no external files, so you can use it offline. Hello World hello.zig const std = @import("std"); pub fn main() !void { // If this program is run without stdout attached, exit with an erro var to emit. For that you can use a simpler API: hello.zig const warn = @import("std").debug.warn; pub fn main() void { warn("Hello, world!\n"); } $ zig build-exe hello.zig $ ./hello Hello, world the Unix epoch; that is /// moment of 1970 Jan 1 00:00:00 UTC (this is a doc comment too). pub fn unixEpoch() Timestamp { return Timestamp{ .seconds = 0, .nanos =

3/270 2024/3/7 20:44 Rust算法教程 The Algos (algorithms) https://algo.course.rs/print.html 4/270 冒泡排序 pub fn bubble_sort(arr: &mut [T]) { if arr.len() <= 1 { return; } let number of buckets used in process. /// /// Space complexity is `O(n + k)`, as it sorts not in-place. pub fn bucket_sort(arr: &[usize]) -> Vec { if arr.is_empty() { return vec![]; } 2024/3/7 20:44 Rust算法教程 The Algos (algorithms) https://algo.course.rs/print.html 10/270 鸡尾酒排序 pub fn cocktail_shaker_sort(arr: &mut [T]) { let len = arr.len(); if len == 0 {

用来将路径引入作用域的 use 关键字；以及使项变为公有的 pub 关键字。我们还将讨论 as 关键字、外部包和 glob 运算符。现在，让我们把注意力放在模块上！ 首先，我们将从一系列的规则开始，在你未来组织代码的时候，这些规则可被用作简单的参 考。接下来我们将会详细的解释每条规则。 模块小抄 这里我们提供一个简单的参考，用来解释模块、路径、use 关键词和 pub 关键词如何在编译器 中工作，以及大部分开 crate::garden::vegetables::Asparagus 被找 到。 • 私有 vs 公用: 一个模块里的代码默认对其父模块私有。为了使一个模块公用，应当在声明时 使用 pub mod 替代 mod 。为了使一个公用模块内部的成员公用，应当在声明前使用 pub 。 • use 关键字: 在一个作用域内，use 关键字创建了一个成员的快捷方式，用来减少长路径的 重复。在任何可以引用 crate::garden paragus; pub mod garden; fn main() { let plant = Asparagus {}; println!("I'm growing {:?}!", plant); } pub mod garden; 行告诉编译器应该包含在 src/garden.rs 文件中发现的代码： 文件名：src/garden.rs pub mod vegetables;

додаючи поведінку в процесі. Які ще типи обгорток можуть бути корисними у утиліті для ведення логів? pub trait Logger { /// Запишіть повідомлення із заданим рівнем докладності. fn log(&self, verbosity: u8 max_verbosity: 3, inner: StdoutLogger }; logger.log(5, "FYI"); logger.log(2, "Uhoh"); } 13.4.1 Рішення pub trait Logger { /// Запишіть повідомлення із заданим рівнем докладності. fn log(&self, verbosity: u8 дерево. /// /// Якщо одне й те саме значення додається кілька разів, воно зберігається лише один раз. pub struct BinaryTree { root: Subtree, } impl BinaryTree { fn new() -> Self {

� � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � � use std::fmt::Display ; pub trait Logger } / / / Log a message at the given verbosity level . fn log(&self, verbosity: u8, message: max_verbosity: 3, inner: StderrLogger { ; do_things(&l ( ; { 13.4.1 � � � � � use std::fmt::Display ; pub trait Logger } / / / Log a message at the given verbosity level . fn log(&self, verbosity: u8, message: a binary tree . / / / / / / If the same value is added multiple times, it is only stored once . pub struct BinaryTree BinaryTree Self

Rust ���������� ������ &str��� Rust ���������� ����� String���� Rust ��������� Rust ������� �� pub ���� 7.1 ������ &str ������ &str ��� ��� ������������� Rust ��������� ����� � &str ������������������� ��������� 7.2 ����� ������ Rust ����������� �������������������� Rust �������������������� �� pub ����� ����������������� ��������� ���������� �� ����� UTF-8 ����������� ������ � heap �������������������������� location:&'static str = "��"; println!("��� : {} �� :{}",company,location); } ��� : ����� �� :�� pub struct String String::new() 7.2.2 �� ��������� String::new() ��� String::from() ��������������������

Zig Standard Library, visit the link above. Hello World hello.zig const std = @import("std"); pub fn main() !void { const stdout = std.io.getStdOut().writer(); try stdout.print("Hello, {s} irrelevant. For this common case, there is a simpler API: hello_again.zig const std = @import("std"); pub fn main() void { std.debug.print("Hello, world!\n", .{}); } Shell $ zig build-exe hello_again with: Shell zig test -femit-docs main.zig comments.zig const print = @import("std").debug.print; pub fn main() void { // Comments in Zig start with "//" and end at the next LF byte (end of line).