Skip to content

Commit

Permalink
Add missing docstring
Browse files Browse the repository at this point in the history
  • Loading branch information
comnik committed Aug 8, 2019
1 parent 66997be commit 60e37dc
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion tdiag/src/commands/arrangements.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,13 @@ use DifferentialEvent::{Batch, Merge, MergeShortfall};

use tdiag_connect::receive::ReplayWithShutdown;

/// @TODO
/// Prints the number of tuples maintained in each arrangement.
///
/// 1. Listens to incoming connections from a differential-dataflow
/// program with timely and differential logging enabled;
/// 2. runs a differential-dataflow program to track batching and
/// compaction events and derive number of tuples for each trace;
/// 3. prints the current size alongside arrangement names;
pub fn listen(
timely_configuration: timely::Configuration,
timely_sockets: Vec<Option<std::net::TcpStream>>,
Expand Down Expand Up @@ -78,6 +84,8 @@ pub fn listen(
let events =
differential_replayer.replay_with_shutdown_into(scope, is_running_w.clone());

// @TODO Think about where to put this.
//
// // Track time spent merging.
// events
// .flat_map(|(t, w, event)| {
Expand Down

0 comments on commit 60e37dc

Please sign in to comment.