Skip to content

Commit 6d505af

Browse files
authored
Remove deprecated functions and use statements (#582)
Removes code that has been marked as deprecated for a long time. Signed-off-by: Moritz Hoffmann <[email protected]>
1 parent a85bbbf commit 6d505af

File tree

2 files changed

+0
-27
lines changed

2 files changed

+0
-27
lines changed

differential-dataflow/src/difference.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,6 @@
66
//! dataflow collections would then track for each record the total of counts and heights, which allows
77
//! us to track something like the average.
88
9-
#[deprecated]
10-
pub use self::Abelian as Diff;
11-
129
/// A type that can be an additive identity for all `Semigroup` implementations.
1310
///
1411
/// This method is extracted from `Semigroup` to avoid ambiguity when used.

differential-dataflow/src/trace/mod.rs

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -105,12 +105,6 @@ pub trait TraceReader {
105105
/// this method, or the initial value of `get_logical_compaction()` if this method has not yet been called.
106106
fn set_logical_compaction(&mut self, frontier: AntichainRef<Self::Time>);
107107

108-
/// Deprecated form of `set_logical_compaction`.
109-
#[deprecated(since = "0.11", note = "please use `set_logical_compaction`")]
110-
fn advance_by(&mut self, frontier: AntichainRef<Self::Time>) {
111-
self.set_logical_compaction(frontier);
112-
}
113-
114108
/// Reports the logical compaction frontier.
115109
///
116110
/// All update times beyond this frontier will be presented with their original times, and all update times
@@ -119,12 +113,6 @@ pub trait TraceReader {
119113
/// presented, and should be used carefully, only in accumulation to times that are beyond the frontier.
120114
fn get_logical_compaction(&mut self) -> AntichainRef<Self::Time>;
121115

122-
/// Deprecated form of `get_logical_compaction`.
123-
#[deprecated(since = "0.11", note = "please use `get_logical_compaction`")]
124-
fn advance_frontier(&mut self) -> AntichainRef<Self::Time> {
125-
self.get_logical_compaction()
126-
}
127-
128116
/// Advances the frontier that constrains physical compaction.
129117
///
130118
/// Physical compaction is the ability of the trace to merge the batches of updates it maintains. Physical
@@ -141,12 +129,6 @@ pub trait TraceReader {
141129
/// this method, or the initial value of `get_physical_compaction()` if this method has not yet been called.
142130
fn set_physical_compaction(&mut self, frontier: AntichainRef<Self::Time>);
143131

144-
/// Deprecated form of `set_physical_compaction`.
145-
#[deprecated(since = "0.11", note = "please use `set_physical_compaction`")]
146-
fn distinguish_since(&mut self, frontier: AntichainRef<Self::Time>) {
147-
self.set_physical_compaction(frontier);
148-
}
149-
150132
/// Reports the physical compaction frontier.
151133
///
152134
/// All batches containing updates beyond this frontier will not be merged with other batches. This allows
@@ -155,12 +137,6 @@ pub trait TraceReader {
155137
/// other operators who need to take notice of the physical structure of update batches.
156138
fn get_physical_compaction(&mut self) -> AntichainRef<Self::Time>;
157139

158-
/// Deprecated form of `get_physical_compaction`.
159-
#[deprecated(since = "0.11", note = "please use `get_physical_compaction`")]
160-
fn distinguish_frontier(&mut self) -> AntichainRef<Self::Time> {
161-
self.get_physical_compaction()
162-
}
163-
164140
/// Maps logic across the non-empty sequence of batches in the trace.
165141
///
166142
/// This is currently used only to extract historical data to prime late-starting operators who want to reproduce

0 commit comments

Comments
 (0)