Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
* Group the all the input {@link BindingTuple} by {@link AggregationOperator#groupByExprList},
* calculate the aggregation result by using {@link AggregationOperator#aggregatorList}.
*/
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
@ToString
public class AggregationOperator extends PhysicalPlan {
@Getter
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
* DedupeOperator#dedupeList} The result order follow the input order.
*/
@Getter
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
public class DedupeOperator extends PhysicalPlan {
@Getter
private final PhysicalPlan input;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
* The Filter operator only return the results that evaluated to true.
* The NULL and MISSING are handled by the logic defined in {@link BinaryPredicateOperator}.
*/
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
@ToString
@RequiredArgsConstructor
public class FilterOperator extends PhysicalPlan {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
@RequiredArgsConstructor
@Getter
@ToString
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
public class LimitOperator extends PhysicalPlan {
private final PhysicalPlan input;
private final Integer limit;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
* Project the fields specified in {@link ProjectOperator#projectList} from input.
*/
@ToString
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
@RequiredArgsConstructor
public class ProjectOperator extends PhysicalPlan {
@Getter
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
* Calculate the rare result by using the {@link RareTopNOperator#fieldExprList}.
*/
@ToString
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
public class RareTopNOperator extends PhysicalPlan {

@Getter
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
* Remove the fields specified in {@link RemoveOperator#removeList} from input.
*/
@ToString
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
public class RemoveOperator extends PhysicalPlan {
@Getter
private final PhysicalPlan input;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
* The mapping maintain the relation between source and target.
* it means BindingTuple.resolve(target) = BindingTuple.resolve(source).
*/
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
@ToString
public class RenameOperator extends PhysicalPlan {
@Getter
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
* The count indicate how many sorted result should been return.
*/
@ToString
@EqualsAndHashCode
@EqualsAndHashCode(callSuper = false)
public class SortOperator extends PhysicalPlan {
@Getter
private final PhysicalPlan input;
Expand Down