Skip to content

Commit 8485fe7

Browse files
blpblp
committed
dbsp: Change &mut self to &self on CollectionHandle::append.
There wasn't a reason for it to take a mutable reference anymore. Most of the commit is updating callers to remove `mut` from input handles. Signed-off-by: Ben Pfaff <blp@feldera.com>
1 parent 5f37983 commit 8485fe7

40 files changed

+67
-67
lines changed

‎crates/dbsp/examples/tutorial/tutorial2.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ fn build_circuit(circuit: &mut RootCircuit) -> Result<CollectionHandle<Record, i
2222

2323
fn main() -> Result<()> {
2424
// Build circuit.
25-
let (circuit, mut input_handle) = RootCircuit::build(build_circuit)?;
25+
let (circuit, input_handle) = RootCircuit::build(build_circuit)?;
2626

2727
// Feed data into circuit.
2828
let path = format!(

‎crates/dbsp/examples/tutorial/tutorial3.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ fn build_circuit(
3232

3333
fn main() -> Result<()> {
3434
// Build circuit.
35-
let (circuit, (mut input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
35+
let (circuit, (input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
3636

3737
// Feed data into circuit.
3838
let path = format!(

‎crates/dbsp/examples/tutorial/tutorial4.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ fn build_circuit(
3939
}
4040

4141
fn main() -> Result<()> {
42-
let (circuit, (mut input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
42+
let (circuit, (input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
4343

4444
let path = format!(
4545
"{}/examples/tutorial/vaccinations.csv",

‎crates/dbsp/examples/tutorial/tutorial5.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ fn build_circuit(
4747
}
4848

4949
fn main() -> Result<()> {
50-
let (circuit, (mut input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
50+
let (circuit, (input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
5151

5252
let path = format!(
5353
"{}/examples/tutorial/vaccinations.csv",

‎crates/dbsp/examples/tutorial/tutorial6.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ fn build_circuit(
5555
}
5656

5757
fn main() -> Result<()> {
58-
let (circuit, (mut input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
58+
let (circuit, (input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
5959

6060
let path = format!(
6161
"{}/examples/tutorial/vaccinations.csv",

‎crates/dbsp/examples/tutorial/tutorial7.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ fn build_circuit(
5858
}
5959

6060
fn main() -> Result<()> {
61-
let (circuit, (mut input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
61+
let (circuit, (input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
6262

6363
let path = format!(
6464
"{}/examples/tutorial/vaccinations.csv",

‎crates/dbsp/examples/tutorial/tutorial8.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ fn build_circuit(
6262
}
6363

6464
fn main() -> Result<()> {
65-
let (circuit, (mut vax_handle, mut pop_handle, output_handle)) =
65+
let (circuit, (vax_handle, pop_handle, output_handle)) =
6666
RootCircuit::build(build_circuit)?;
6767

6868
let path = format!(

‎crates/dbsp/examples/tutorial/tutorial9.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ fn build_circuit(
5858
}
5959

6060
fn main() -> Result<()> {
61-
let (circuit, (mut input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
61+
let (circuit, (input_handle, output_handle)) = RootCircuit::build(build_circuit)?;
6262

6363
let path = format!(
6464
"{}/examples/tutorial/vaccinations.csv",

‎crates/dbsp/src/operator/aggregate/mod.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -952,7 +952,7 @@ mod test {
952952
let sum_weighted_output_clone = sum_weighted_output.clone();
953953
let sum_distinct_output_clone = sum_distinct_output.clone();
954954

955-
let (mut dbsp, mut input_handle) = Runtime::init_circuit(workers, move |circuit| {
955+
let (mut dbsp, input_handle) = Runtime::init_circuit(workers, move |circuit| {
956956
let (input_stream, input_handle) = circuit.add_input_indexed_zset();
957957
input_stream
958958
.weighted_count()

‎crates/dbsp/src/operator/distinct.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -833,7 +833,7 @@ mod test {
833833
let output2 = Arc::new(Mutex::new(OrdIndexedZSet::empty(())));
834834
let output2_clone = output2.clone();
835835

836-
let (mut circuit, mut input) = Runtime::init_circuit(4, move |circuit| {
836+
let (mut circuit, input) = Runtime::init_circuit(4, move |circuit| {
837837
let (input, input_handle) = circuit.add_input_indexed_zset::<usize, usize, isize>();
838838

839839
input

0 commit comments

Comments
 (0)