Skip to content

Commit cc6b297

Browse files
andygrovegandronchik
authored andcommitted
Remove Offset struct (apache#2734)
1 parent 7c3f9b4 commit cc6b297

3 files changed

Lines changed: 4 additions & 13 deletions

File tree

datafusion/core/src/logical_plan/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,8 @@ pub use extension::UserDefinedLogicalNode;
6666
pub use operators::Operator;
6767
pub use plan::{
6868
CreateCatalogSchema, CreateExternalTable, CreateMemoryTable, CrossJoin, DropTable,
69-
EmptyRelation, JoinConstraint, JoinType, Limit, LogicalPlan, Offset, Partitioning,
70-
PlanType, PlanVisitor, Repartition, StringifiedPlan, Subquery, TableScan,
71-
ToStringifiedPlan, Union, Values,
69+
EmptyRelation, JoinConstraint, JoinType, Limit, LogicalPlan, Partitioning, PlanType,
70+
PlanVisitor, Repartition, StringifiedPlan, Subquery, TableScan, ToStringifiedPlan,
71+
Union, Values,
7272
};
7373
pub use registry::FunctionRegistry;

datafusion/core/src/logical_plan/plan.rs

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -297,15 +297,6 @@ pub struct Values {
297297
pub values: Vec<Vec<Expr>>,
298298
}
299299

300-
/// Adjusts the starting point at which the rest of the expressions begin to effect
301-
#[derive(Clone)]
302-
pub struct Offset {
303-
/// The offset
304-
pub offset: usize,
305-
/// The logical plan
306-
pub input: Arc<LogicalPlan>,
307-
}
308-
309300
/// Aggregates its input based on a set of grouping and aggregate
310301
/// expressions (e.g. SUM).
311302
#[derive(Clone)]

datafusion/core/src/physical_plan/limit.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -483,7 +483,7 @@ mod tests {
483483
use crate::physical_plan::coalesce_partitions::CoalescePartitionsExec;
484484
use crate::physical_plan::common;
485485
use crate::prelude::SessionContext;
486-
use crate::{test};
486+
use crate::test;
487487

488488
#[tokio::test]
489489
async fn limit() -> Result<()> {

0 commit comments

Comments
 (0)