比较文本

查找两个文本文件之间的差异

显示

视图

实时编辑器隐藏空白更改折叠未更改行关闭换行

比对精度

语法

处理

Diffchecker Desktop 运行Diffchecker最安全的方式。获取Diffchecker桌面应用：您的差异永远不会离开您的电脑！获取桌面版

datafusion #4873

创建于 4年前差异永不过期

6 删除

行
总计
删除

字符
总计
删除

要继续使用此功能，请升级到 Diffchecker Pro 查看价格

524 行

6 添加

行
总计
添加

字符
总计
添加

要继续使用此功能，请升级到 Diffchecker Pro 查看价格

524 行

ProjectionExec {

expr: [

(

Column {

index: 1,

"col1",

(

Column {

index: 0,

"col2",

(

ScalarFunctionExpr {

fun: "<FUNC>",

args: [

CastExpr {

expr: Column {

index: 4,

cast_type: Float32,

cast_options: CastOptions {

safe: false,

Literal {

value: Float32(0),

return_type: Float32,

"sum_col3",

schema: Schema {

fields: [

Field {

data_type: Utf8,

nullable: true,

dict_id: 0,

dict_is_ordered: false,

metadata: {},

Field {

data_type: UInt64,

nullable: true,

dict_id: 0,

dict_is_ordered: false,

metadata: {},

Field {

data_type: Float32,

nullable: true,

dict_id: 0,

dict_is_ordered: false,

metadata: {},

input: CoalesceBatchesExec {

input: HashJoinExec {

left: CoalesceBatchesExec {

input: RepartitionExec {

input: CrossJoinExec {

left: CoalescePartitionsExec {

input: AggregateExec {

mode: FinalPartitioned,

group_by: PhysicalGroupBy {

expr: [

(

Column {

index: 0,

"col2",

null_expr: [],

groups: [

[

false,

aggr_expr: [],

input: CoalesceBatchesExec {

input: RepartitionExec {

input: AggregateExec {

mode: Partial,

group_by: PhysicalGroupBy {

已保存差异

原始文本

打开文件

ProjectionExec {
    expr: [
        (
            Column {
                name: "col1",
                index: 1,
            },
            "col1",
        ),
        (
            Column {
                name: "col2",
                index: 0,
            },
            "col2",
        ),
        (
            ScalarFunctionExpr {
                fun: "<FUNC>",
                name: "coalesce",
                args: [
                    CastExpr {
                        expr: Column {
                            name: "sum_col3",
                            index: 4,
                        },
                        cast_type: Float32,
                        cast_options: CastOptions {
                            safe: false,
                        },
                    },
                    Literal {
                        value: Float32(0),
                    },
                ],
                return_type: Float32,
            },
            "sum_col3",
        ),
    ],
    schema: Schema {
        fields: [
            Field {
                name: "col1",
                data_type: Utf8,
                nullable: true,
                dict_id: 0,
                dict_is_ordered: false,
                metadata: {},
            },
            Field {
                name: "col2",
                data_type: UInt64,
                nullable: true,
                dict_id: 0,
                dict_is_ordered: false,
                metadata: {},
            },
            Field {
                name: "sum_col3",
                data_type: Float32,
                nullable: true,
                dict_id: 0,
                dict_is_ordered: false,
                metadata: {},
            },
        ],
        metadata: {},
    },
    input: CoalesceBatchesExec {
        input: HashJoinExec {
            left: CoalesceBatchesExec {
                input: RepartitionExec {
                    input: CrossJoinExec {
                        left: CoalescePartitionsExec {
                            input: AggregateExec {
                                mode: FinalPartitioned,
                                group_by: PhysicalGroupBy {
                                    expr: [
                                        (
                                            Column {
                                                name: "col2",
                                                index: 0,
                                            },
                                            "col2",
                                        ),
                                    ],
                                    null_expr: [],
                                    groups: [
                                        [
                                            false,
                                        ],
                                    ],
                                },
                                aggr_expr: [],
                                input: CoalesceBatchesExec {
                                    input: RepartitionExec {
                                        input: AggregateExec {
                                            mode: Partial,
                                            group_by: PhysicalGroupBy {
                                                expr: [
                                                    (
                                                        Column {
                                                            name: "col2",
                                                            index: 0,
                                                        },
                                                        "col2",
                                                    ),
                                                ],
                                                null_expr: [],
                                                groups: [
                                                    [
                                                        false,
                                                    ],
                                                ],
                                            },
                                            aggr_expr: [],
                                            input: RepartitionExec {
                                                input: partitions: [...]schema: Schema { fields: [Field { name: "col2", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }projection: Some([1]),
                                                partitioning: RoundRobinBatch(
                                                    10,
                                                ),
                                                state: Mutex {
                                                    data: RepartitionExecState {
                                                        channels: {},
                                                        abort_helper: AbortOnDropMany(
                                                            [],
                                                        ),
                                                    },
                                                },
                                                metrics: ExecutionPlanMetricsSet {
                                                    inner: Mutex {
                                                        data: MetricsSet {
                                                            metrics: [],
                                                        },
                                                    },
                                                },
                                            },
                                            schema: Schema {
                                                fields: [
                                                    Field {
                                                        name: "col2",
                                                        data_type: UInt64,
                                                        nullable: true,
                                                        dict_id: 0,
                                                        dict_is_ordered: false,
                                                        metadata: {},
                                                    },
                                                ],
                                                metadata: {},
                                            },
                                            input_schema: Schema {
                                                fields: [
                                                    Field {
                                                        name: "col2",
                                                        data_type: UInt64,
                                                        nullable: true,
                                                        dict_id: 0,
                                                        dict_is_ordered: false,
                                                        metadata: {},
                                                    },
                                                ],
                                                metadata: {},
                                            },
                                            alias_map: {},
                                            metrics: ExecutionPlanMetricsSet {
                                                inner: Mutex {
                                                    data: MetricsSet {
                                                        metrics: [],
                                                    },
                                                },
                                            },
                                        },
                                        partitioning: Hash(
                                            [
                                                Column {
                                                    name: "col2",
                                                    index: 0,
                                                },
                                            ],
                                            10,
                                        ),
                                        state: Mutex {
                                            data: RepartitionExecState {
                                                channels: {},
                                                abort_helper: AbortOnDropMany(
                                                    [],
                                                ),
                                            },
                                        },
                                        metrics: ExecutionPlanMetricsSet {
                                            inner: Mutex {
                                                data: MetricsSet {
                                                    metrics: [],
                                                },
                                            },
                                        },
                                    },
                                    target_batch_size: 8192,
                                    metrics: ExecutionPlanMetricsSet {
                                        inner: Mutex {
                                            data: MetricsSet {
                                                metrics: [],
                                            },
                                        },
                                    },
                                },
                                schema: Schema {
                                    fields: [
                                        Field {
                                            name: "col2",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                    ],
                                    metadata: {},
                                },
                                input_schema: Schema {
                                    fields: [
                                        Field {
                                            name: "col2",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                    ],
                                    metadata: {},
                                },
                                alias_map: {},
                                metrics: ExecutionPlanMetricsSet {
                                    inner: Mutex {
                                        data: MetricsSet {
                                            metrics: [],
                                        },
                                    },
                                },
                            },
                            metrics: ExecutionPlanMetricsSet {
                                inner: Mutex {
                                    data: MetricsSet {
                                        metrics: [],
                                    },
                                },
                            },
                        },
                        right: AggregateExec {
                            mode: FinalPartitioned,
                            group_by: PhysicalGroupBy {
                                expr: [
                                    (
                                        Column {
                                            name: "col1",
                                            index: 0,
                                        },
                                        "col1",
                                    ),
                                ],
                                null_expr: [],
                                groups: [
                                    [
                                        false,
                                    ],
                                ],
                            },
                            aggr_expr: [],
                            input: CoalesceBatchesExec {
                                input: RepartitionExec {
                                    input: AggregateExec {
                                        mode: Partial,
                                        group_by: PhysicalGroupBy {
                                            expr: [
                                                (
                                                    Column {
                                                        name: "col1",
                                                        index: 0,
                                                    },
                                                    "col1",
                                                ),
                                            ],
                                            null_expr: [],
                                            groups: [
                                                [
                                                    false,
                                                ],
                                            ],
                                        },
                                        aggr_expr: [],
                                        input: RepartitionExec {
                                            input: partitions: [...]schema: Schema { fields: [Field { name: "col1", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }projection: Some([0]),
                                            partitioning: RoundRobinBatch(
                                                10,
                                            ),
                                            state: Mutex {
                                                data: RepartitionExecState {
                                                    channels: {},
                                                    abort_helper: AbortOnDropMany(
                                                        [],
                                                    ),
                                                },
                                            },
                                            metrics: ExecutionPlanMetricsSet {
                                                inner: Mutex {
                                                    data: MetricsSet {
                                                        metrics: [],
                                                    },
                                                },
                                            },
                                        },
                                        schema: Schema {
                                            fields: [
                                                Field {
                                                    name: "col1",
                                                    data_type: Utf8,
                                                    nullable: true,
                                                    dict_id: 0,
                                                    dict_is_ordered: false,
                                                    metadata: {},
                                                },
                                            ],
                                            metadata: {},
                                        },
                                        input_schema: Schema {
                                            fields: [
                                                Field {
                                                    name: "col1",
                                                    data_type: Utf8,
                                                    nullable: true,
                                                    dict_id: 0,
                                                    dict_is_ordered: false,
                                                    metadata: {},
                                                },
                                            ],
                                            metadata: {},
                                        },
                                        alias_map: {},
                                        metrics: ExecutionPlanMetricsSet {
                                            inner: Mutex {
                                                data: MetricsSet {
                                                    metrics: [],
                                                },
                                            },
                                        },
                                    },
                                    partitioning: Hash(
                                        [
                                            Column {
                                                name: "col1",
                                                index: 0,
                                            },
                                        ],
                                        10,
                                    ),
                                    state: Mutex {
                                        data: RepartitionExecState {
                                            channels: {},
                                            abort_helper: AbortOnDropMany(
                                                [],
                                            ),
                                        },
                                    },
                                    metrics: ExecutionPlanMetricsSet {
                                        inner: Mutex {
                                            data: MetricsSet {
                                                metrics: [],
                                            },
                                        },
                                    },
                                },
                                target_batch_size: 8192,
                                metrics: ExecutionPlanMetricsSet {
                                    inner: Mutex {
                                        data: MetricsSet {
                                            metrics: [],
                                        },
                                    },
                                },
                            },
                            schema: Schema {
                                fields: [
                                    Field {
                                        name: "col1",
                                        data_type: Utf8,
                                        nullable: true,
                                        dict_id: 0,
                                        dict_is_ordered: false,
                                        metadata: {},
                                    },
                                ],
                                metadata: {},
                            },
                            input_schema: Schema {
                                fields: [
                                    Field {
                                        name: "col1",
                                        data_type: Utf8,
                                        nullable: true,
                                        dict_id: 0,
                                        dict_is_ordered: false,
                                        metadata: {},
                                    },
                                ],
                                metadata: {},
                            },
                            alias_map: {},
                            metrics: ExecutionPlanMetricsSet {
                                inner: Mutex {
                                    data: MetricsSet {
                                        metrics: [],
                                    },
                                },
                            },
                        },
                        schema: Schema {
                            fields: [
                                Field {
                                    name: "col2",
                                    data_type: UInt64,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                                Field {
                                    name: "col1",
                                    data_type: Utf8,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                            ],
                            metadata: {},
                        },
                        left_fut: OnceAsync,
                    },
                    partitioning: Hash(
                        [
                            Column {
                                name: "col1",
                                index: 1,
                            },
                            Column {
                                name: "col2",
                                index: 0,
                            },
                        ],
                        10,
                    ),
                    state: Mutex {
                        data: RepartitionExecState {
                            channels: {},
                            abort_helper: AbortOnDropMany(
                                [],
                            ),
                        },
                    },
                    metrics: ExecutionPlanMetricsSet {
                        inner: Mutex {
                            data: MetricsSet {
                                metrics: [],
                            },
                        },
                    },
                },
                target_batch_size: 8192,
                metrics: ExecutionPlanMetricsSet {
                    inner: Mutex {
                        data: MetricsSet {
                            metrics: [],
                        },
                    },
                },
            },
            right: ProjectionExec {
                expr: [
                    (
                        Column {
                            name: "col1",
                            index: 0,
                        },
                        "col1",
                    ),
                    (
                        Column {
                            name: "col2",
                            index: 1,
                        },
                        "col2",
                    ),
                    (
                        Column {
                            name: "SUM(tbl.col3)",
                            index: 2,
                        },
                        "sum_col3",
                    ),
                ],
                schema: Schema {
                    fields: [
                        Field {
                            name: "col1",
                            data_type: Utf8,
                            nullable: true,
                            dict_id: 0,
                            dict_is_ordered: false,
                            metadata: {},
                        },
                        Field {
                            name: "col2",
                            data_type: UInt64,
                            nullable: true,
                            dict_id: 0,
                            dict_is_ordered: false,
                            metadata: {},
                        },
                        Field {
                            name: "sum_col3",
                            data_type: UInt64,
                            nullable: true,
                            dict_id: 0,
                            dict_is_ordered: false,
                            metadata: {},
                        },
                    ],
                    metadata: {},
                },
                input: AggregateExec {
                    mode: FinalPartitioned,
                    group_by: PhysicalGroupBy {
                        expr: [
                            (
                                Column {
                                    name: "col1",
                                    index: 0,
                                },
                                "col1",
                            ),
                            (
                                Column {
                                    name: "col2",
                                    index: 1,
                                },
                                "col2",
                            ),
                        ],
                        null_expr: [],
                        groups: [
                            [
                                false,
                                false,
                            ],
                        ],
                    },
                    aggr_expr: [
                        Sum {
                            name: "SUM(tbl.col3)",
                            data_type: UInt64,
                            expr: Column {
                                name: "col3",
                                index: 2,
                            },
                            nullable: true,
                        },
                    ],
                    input: CoalesceBatchesExec {
                        input: RepartitionExec {
                            input: AggregateExec {
                                mode: Partial,
                                group_by: PhysicalGroupBy {
                                    expr: [
                                        (
                                            Column {
                                                name: "col1",
                                                index: 0,
                                            },
                                            "col1",
                                        ),
                                        (
                                            Column {
                                                name: "col2",
                                                index: 1,
                                            },
                                            "col2",
                                        ),
                                    ],
                                    null_expr: [],
                                    groups: [
                                        [
                                            false,
                                            false,
                                        ],
                                    ],
                                },
                                aggr_expr: [
                                    Sum {
                                        name: "SUM(tbl.col3)",
                                        data_type: UInt64,
                                        expr: Column {
                                            name: "col3",
                                            index: 2,
                                        },
                                        nullable: true,
                                    },
                                ],
                                input: RepartitionExec {
                                    input: partitions: [...]schema: Schema { fields: [Field { name: "col1", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: "col2", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: "col3", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }projection: Some([0, 1, 2]),
                                    partitioning: RoundRobinBatch(
                                        10,
                                    ),
                                    state: Mutex {
                                        data: RepartitionExecState {
                                            channels: {},
                                            abort_helper: AbortOnDropMany(
                                                [],
                                            ),
                                        },
                                    },
                                    metrics: ExecutionPlanMetricsSet {
                                        inner: Mutex {
                                            data: MetricsSet {
                                                metrics: [],
                                            },
                                        },
                                    },
                                },
                                schema: Schema {
                                    fields: [
                                        Field {
                                            name: "col1",
                                            data_type: Utf8,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                        Field {
                                            name: "col2",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                        Field {
                                            name: "SUM(tbl.col3)[sum]",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                        Field {
                                            name: "SUM(tbl.col3)[count]",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                    ],
                                    metadata: {},
                                },
                                input_schema: Schema {
                                    fields: [
                                        Field {
                                            name: "col1",
                                            data_type: Utf8,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                        Field {
                                            name: "col2",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                        Field {
                                            name: "col3",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                    ],
                                    metadata: {},
                                },
                                alias_map: {},
                                metrics: ExecutionPlanMetricsSet {
                                    inner: Mutex {
                                        data: MetricsSet {
                                            metrics: [],
                                        },
                                    },
                                },
                            },
                            partitioning: Hash(
                                [
                                    Column {
                                        name: "col1",
                                        index: 0,
                                    },
                                    Column {
                                        name: "col2",
                                        index: 1,
                                    },
                                ],
                                10,
                            ),
                            state: Mutex {
                                data: RepartitionExecState {
                                    channels: {},
                                    abort_helper: AbortOnDropMany(
                                        [],
                                    ),
                                },
                            },
                            metrics: ExecutionPlanMetricsSet {
                                inner: Mutex {
                                    data: MetricsSet {
                                        metrics: [],
                                    },
                                },
                            },
                        },
                        target_batch_size: 8192,
                        metrics: ExecutionPlanMetricsSet {
                            inner: Mutex {
                                data: MetricsSet {
                                    metrics: [],
                                },
                            },
                        },
                    },
                    schema: Schema {
                        fields: [
                            Field {
                                name: "col1",
                                data_type: Utf8,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                            Field {
                                name: "col2",
                                data_type: UInt64,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                            Field {
                                name: "SUM(tbl.col3)",
                                data_type: UInt64,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                        ],
                        metadata: {},
                    },
                    input_schema: Schema {
                        fields: [
                            Field {
                                name: "col1",
                                data_type: Utf8,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                            Field {
                                name: "col2",
                                data_type: UInt64,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                            Field {
                                name: "col3",
                                data_type: UInt64,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                        ],
                        metadata: {},
                    },
                    alias_map: {},
                    metrics: ExecutionPlanMetricsSet {
                        inner: Mutex {
                            data: MetricsSet {
                                metrics: [],
                            },
                        },
                    },
                },
                output_ordering: None,
                alias_map: {
                    Column {
                        name: "SUM(tbl.col3)",
                        index: 2,
                    }: [
                        Column {
                            name: "sum_col3",
                            index: 2,
                        },
                    ],
                },
                metrics: ExecutionPlanMetricsSet {
                    inner: Mutex {
                        data: MetricsSet {
                            metrics: [],
                        },
                    },
                },
            },
            on: [
                (
                    Column {
                        name: "col1",
                        index: 1,
                    },
                    Column {
                        name: "col1",
                        index: 0,
                    },
                ),
                (
                    Column {
                        name: "col2",
                        index: 0,
                    },
                    Column {
                        name: "col2",
                        index: 1,
                    },
                ),
            ],
            filter: None,
            join_type: Left,
            schema: Schema {
                fields: [
                    Field {
                        name: "col2",
                        data_type: UInt64,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "col1",
                        data_type: Utf8,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "col1",
                        data_type: Utf8,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "col2",
                        data_type: UInt64,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "sum_col3",
                        data_type: UInt64,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                ],
                metadata: {},
            },
            left_fut: OnceAsync,
            random_state: RandomState { .. },
            mode: Partitioned,
            metrics: ExecutionPlanMetricsSet {
                inner: Mutex {
                    data: MetricsSet {
                        metrics: [],
                    },
                },
            },
            column_indices: [
                ColumnIndex {
                    index: 0,
                    side: Left,
                },
                ColumnIndex {
                    index: 1,
                    side: Left,
                },
                ColumnIndex {
                    index: 0,
                    side: Right,
                },
                ColumnIndex {
                    index: 1,
                    side: Right,
                },
                ColumnIndex {
                    index: 2,
                    side: Right,
                },
            ],
            null_equals_null: false,
        },
        target_batch_size: 8192,
        metrics: ExecutionPlanMetricsSet {
            inner: Mutex {
                data: MetricsSet {
                    metrics: [],
                },
            },
        },
    },
    output_ordering: None,
    alias_map: {
        Column {
            name: "col1",
            index: 1,
        }: [
            Column {
                name: "col1",
                index: 0,
            },
        ],
        Column {
            name: "col2",
            index: 0,
        }: [
            Column {
                name: "col2",
                index: 1,
            },
        ],
    },
    metrics: ExecutionPlanMetricsSet {
        inner: Mutex {
            data: MetricsSet {
                metrics: [],
            },
        },
    },
}

更改后文本

打开文件

ProjectionExec {
    expr: [
        (
            Column {
                name: "col1",
                index: 1,
            },
            "col1",
        ),
        (
            Column {
                name: "col2",
                index: 0,
            },
            "col2",
        ),
        (
            ScalarFunctionExpr {
                fun: "<FUNC>",
                name: "coalesce",
                args: [
                    CastExpr {
                        expr: Column {
                            name: "sum_col3",
                            index: 4,
                        },
                        cast_type: Float32,
                        cast_options: CastOptions {
                            safe: false,
                        },
                    },
                    Literal {
                        value: Float32(0),
                    },
                ],
                return_type: Float32,
            },
            "sum_col3",
        ),
    ],
    schema: Schema {
        fields: [
            Field {
                name: "col1",
                data_type: Utf8,
                nullable: true,
                dict_id: 0,
                dict_is_ordered: false,
                metadata: {},
            },
            Field {
                name: "col2",
                data_type: UInt64,
                nullable: true,
                dict_id: 0,
                dict_is_ordered: false,
                metadata: {},
            },
            Field {
                name: "sum_col3",
                data_type: Float32,
                nullable: true,
                dict_id: 0,
                dict_is_ordered: false,
                metadata: {},
            },
        ],
        metadata: {},
    },
    input: CoalesceBatchesExec {
        input: HashJoinExec {
            left: CoalesceBatchesExec {
                input: RepartitionExec {
                    input: CrossJoinExec {
                        left: CoalescePartitionsExec {
                            input: AggregateExec {
                                mode: FinalPartitioned,
                                group_by: PhysicalGroupBy {
                                    expr: [
                                        (
                                            Column {
                                                name: "col2",
                                                index: 0,
                                            },
                                            "col2",
                                        ),
                                    ],
                                    null_expr: [],
                                    groups: [
                                        [
                                            false,
                                        ],
                                    ],
                                },
                                aggr_expr: [],
                                input: CoalesceBatchesExec {
                                    input: RepartitionExec {
                                        input: AggregateExec {
                                            mode: Partial,
                                            group_by: PhysicalGroupBy {
                                                expr: [
                                                    (
                                                        Column {
                                                            name: "col2",
                                                            index: 0,
                                                        },
                                                        "col2",
                                                    ),
                                                ],
                                                null_expr: [],
                                                groups: [
                                                    [
                                                        false,
                                                    ],
                                                ],
                                            },
                                            aggr_expr: [],
                                            input: RepartitionExec {
                                                input: partitions: [...]schema: Schema { fields: [Field { name: "col2", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }projection: Some([1]),
                                                partitioning: RoundRobinBatch(
                                                    10,
                                                ),
                                                state: Mutex {
                                                    data: RepartitionExecState {
                                                        channels: {},
                                                        abort_helper: AbortOnDropMany(
                                                            [],
                                                        ),
                                                    },
                                                },
                                                metrics: ExecutionPlanMetricsSet {
                                                    inner: Mutex {
                                                        data: MetricsSet {
                                                            metrics: [],
                                                        },
                                                    },
                                                },
                                            },
                                            schema: Schema {
                                                fields: [
                                                    Field {
                                                        name: "col2",
                                                        data_type: UInt64,
                                                        nullable: true,
                                                        dict_id: 0,
                                                        dict_is_ordered: false,
                                                        metadata: {},
                                                    },
                                                ],
                                                metadata: {},
                                            },
                                            input_schema: Schema {
                                                fields: [
                                                    Field {
                                                        name: "col2",
                                                        data_type: UInt64,
                                                        nullable: true,
                                                        dict_id: 0,
                                                        dict_is_ordered: false,
                                                        metadata: {},
                                                    },
                                                ],
                                                metadata: {},
                                            },
                                            alias_map: {},
                                            metrics: ExecutionPlanMetricsSet {
                                                inner: Mutex {
                                                    data: MetricsSet {
                                                        metrics: [],
                                                    },
                                                },
                                            },
                                        },
                                        partitioning: Hash(
                                            [
                                                Column {
                                                    name: "col2",
                                                    index: 0,
                                                },
                                            ],
                                            10,
                                        ),
                                        state: Mutex {
                                            data: RepartitionExecState {
                                                channels: {},
                                                abort_helper: AbortOnDropMany(
                                                    [],
                                                ),
                                            },
                                        },
                                        metrics: ExecutionPlanMetricsSet {
                                            inner: Mutex {
                                                data: MetricsSet {
                                                    metrics: [],
                                                },
                                            },
                                        },
                                    },
                                    target_batch_size: 8192,
                                    metrics: ExecutionPlanMetricsSet {
                                        inner: Mutex {
                                            data: MetricsSet {
                                                metrics: [],
                                            },
                                        },
                                    },
                                },
                                schema: Schema {
                                    fields: [
                                        Field {
                                            name: "col2",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                    ],
                                    metadata: {},
                                },
                                input_schema: Schema {
                                    fields: [
                                        Field {
                                            name: "col2",
                                            data_type: UInt64,
                                            nullable: true,
                                            dict_id: 0,
                                            dict_is_ordered: false,
                                            metadata: {},
                                        },
                                    ],
                                    metadata: {},
                                },
                                alias_map: {},
                                metrics: ExecutionPlanMetricsSet {
                                    inner: Mutex {
                                        data: MetricsSet {
                                            metrics: [],
                                        },
                                    },
                                },
                            },
                            metrics: ExecutionPlanMetricsSet {
                                inner: Mutex {
                                    data: MetricsSet {
                                        metrics: [],
                                    },
                                },
                            },
                        },
                        right: AggregateExec {
                            mode: FinalPartitioned,
                            group_by: PhysicalGroupBy {
                                expr: [
                                    (
                                        Column {
                                            name: "col1",
                                            index: 0,
                                        },
                                        "col1",
                                    ),
                                ],
                                null_expr: [],
                                groups: [
                                    [
                                        false,
                                    ],
                                ],
                            },
                            aggr_expr: [],
                            input: CoalesceBatchesExec {
                                input: RepartitionExec {
                                    input: AggregateExec {
                                        mode: Partial,
                                        group_by: PhysicalGroupBy {
                                            expr: [
                                                (
                                                    Column {
                                                        name: "col1",
                                                        index: 0,
                                                    },
                                                    "col1",
                                                ),
                                            ],
                                            null_expr: [],
                                            groups: [
                                                [
                                                    false,
                                                ],
                                            ],
                                        },
                                        aggr_expr: [],
                                        input: RepartitionExec {
                                            input: partitions: [...]schema: Schema { fields: [Field { name: "col1", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }projection: Some([0]),
                                            partitioning: RoundRobinBatch(
                                                10,
                                            ),
                                            state: Mutex {
                                                data: RepartitionExecState {
                                                    channels: {},
                                                    abort_helper: AbortOnDropMany(
                                                        [],
                                                    ),
                                                },
                                            },
                                            metrics: ExecutionPlanMetricsSet {
                                                inner: Mutex {
                                                    data: MetricsSet {
                                                        metrics: [],
                                                    },
                                                },
                                            },
                                        },
                                        schema: Schema {
                                            fields: [
                                                Field {
                                                    name: "col1",
                                                    data_type: Utf8,
                                                    nullable: true,
                                                    dict_id: 0,
                                                    dict_is_ordered: false,
                                                    metadata: {},
                                                },
                                            ],
                                            metadata: {},
                                        },
                                        input_schema: Schema {
                                            fields: [
                                                Field {
                                                    name: "col1",
                                                    data_type: Utf8,
                                                    nullable: true,
                                                    dict_id: 0,
                                                    dict_is_ordered: false,
                                                    metadata: {},
                                                },
                                            ],
                                            metadata: {},
                                        },
                                        alias_map: {},
                                        metrics: ExecutionPlanMetricsSet {
                                            inner: Mutex {
                                                data: MetricsSet {
                                                    metrics: [],
                                                },
                                            },
                                        },
                                    },
                                    partitioning: Hash(
                                        [
                                            Column {
                                                name: "col1",
                                                index: 0,
                                            },
                                        ],
                                        10,
                                    ),
                                    state: Mutex {
                                        data: RepartitionExecState {
                                            channels: {},
                                            abort_helper: AbortOnDropMany(
                                                [],
                                            ),
                                        },
                                    },
                                    metrics: ExecutionPlanMetricsSet {
                                        inner: Mutex {
                                            data: MetricsSet {
                                                metrics: [],
                                            },
                                        },
                                    },
                                },
                                target_batch_size: 8192,
                                metrics: ExecutionPlanMetricsSet {
                                    inner: Mutex {
                                        data: MetricsSet {
                                            metrics: [],
                                        },
                                    },
                                },
                            },
                            schema: Schema {
                                fields: [
                                    Field {
                                        name: "col1",
                                        data_type: Utf8,
                                        nullable: true,
                                        dict_id: 0,
                                        dict_is_ordered: false,
                                        metadata: {},
                                    },
                                ],
                                metadata: {},
                            },
                            input_schema: Schema {
                                fields: [
                                    Field {
                                        name: "col1",
                                        data_type: Utf8,
                                        nullable: true,
                                        dict_id: 0,
                                        dict_is_ordered: false,
                                        metadata: {},
                                    },
                                ],
                                metadata: {},
                            },
                            alias_map: {},
                            metrics: ExecutionPlanMetricsSet {
                                inner: Mutex {
                                    data: MetricsSet {
                                        metrics: [],
                                    },
                                },
                            },
                        },
                        schema: Schema {
                            fields: [
                                Field {
                                    name: "col2",
                                    data_type: UInt64,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                                Field {
                                    name: "col1",
                                    data_type: Utf8,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                            ],
                            metadata: {},
                        },
                        left_fut: OnceAsync,
                    },
                    partitioning: Hash(
                        [
                            Column {
                                name: "col2",
                                index: 0,
                            },
                            Column {
                                name: "col1",
                                index: 1,
                            },
                        ],
                        10,
                    ),
                    state: Mutex {
                        data: RepartitionExecState {
                            channels: {},
                            abort_helper: AbortOnDropMany(
                                [],
                            ),
                        },
                    },
                    metrics: ExecutionPlanMetricsSet {
                        inner: Mutex {
                            data: MetricsSet {
                                metrics: [],
                            },
                        },
                    },
                },
                target_batch_size: 8192,
                metrics: ExecutionPlanMetricsSet {
                    inner: Mutex {
                        data: MetricsSet {
                            metrics: [],
                        },
                    },
                },
            },
            right: ProjectionExec {
                expr: [
                    (
                        Column {
                            name: "col1",
                            index: 0,
                        },
                        "col1",
                    ),
                    (
                        Column {
                            name: "col2",
                            index: 1,
                        },
                        "col2",
                    ),
                    (
                        Column {
                            name: "SUM(tbl.col3)",
                            index: 2,
                        },
                        "sum_col3",
                    ),
                ],
                schema: Schema {
                    fields: [
                        Field {
                            name: "col1",
                            data_type: UInt64,
                            nullable: true,
                            dict_id: 0,
                            dict_is_ordered: false,
                            metadata: {},
                        },
                        Field {
                            name: "col2",
                            data_type: Utf8,
                            nullable: true,
                            dict_id: 0,
                            dict_is_ordered: false,
                            metadata: {},
                        },
                        Field {
                            name: "sum_col3",
                            data_type: UInt64,
                            nullable: true,
                            dict_id: 0,
                            dict_is_ordered: false,
                            metadata: {},
                        },
                    ],
                    metadata: {},
                },
                input: ProjectionExec {
                    expr: [
                        (
                            Column {
                                name: "col1",
                                index: 1,
                            },
                            "col1",
                        ),
                        (
                            Column {
                                name: "col2",
                                index: 0,
                            },
                            "col2",
                        ),
                        (
                            Column {
                                name: "SUM(tbl.col3)",
                                index: 2,
                            },
                            "SUM(tbl.col3)",
                        ),
                    ],
                    schema: Schema {
                        fields: [
                            Field {
                                name: "col1",
                                data_type: UInt64,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                            Field {
                                name: "col2",
                                data_type: Utf8,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                            Field {
                                name: "SUM(tbl.col3)",
                                data_type: UInt64,
                                nullable: true,
                                dict_id: 0,
                                dict_is_ordered: false,
                                metadata: {},
                            },
                        ],
                        metadata: {},
                    },
                    input: AggregateExec {
                        mode: FinalPartitioned,
                        group_by: PhysicalGroupBy {
                            expr: [
                                (
                                    Column {
                                        name: "col2",
                                        index: 1,
                                    },
                                    "col2",
                                ),
                                (
                                    Column {
                                        name: "col1",
                                        index: 0,
                                    },
                                    "col1",
                                ),
                            ],
                            null_expr: [],
                            groups: [
                                [
                                    false,
                                    false,
                                ],
                            ],
                        },
                        aggr_expr: [
                            Sum {
                                name: "SUM(tbl.col3)",
                                data_type: UInt64,
                                expr: Column {
                                    name: "col3",
                                    index: 2,
                                },
                                nullable: true,
                            },
                        ],
                        input: CoalesceBatchesExec {
                            input: RepartitionExec {
                                input: AggregateExec {
                                    mode: Partial,
                                    group_by: PhysicalGroupBy {
                                        expr: [
                                            (
                                                Column {
                                                    name: "col2",
                                                    index: 1,
                                                },
                                                "col2",
                                            ),
                                            (
                                                Column {
                                                    name: "col1",
                                                    index: 0,
                                                },
                                                "col1",
                                            ),
                                        ],
                                        null_expr: [],
                                        groups: [
                                            [
                                                false,
                                                false,
                                            ],
                                        ],
                                    },
                                    aggr_expr: [
                                        Sum {
                                            name: "SUM(tbl.col3)",
                                            data_type: UInt64,
                                            expr: Column {
                                                name: "col3",
                                                index: 2,
                                            },
                                            nullable: true,
                                        },
                                    ],
                                    input: RepartitionExec {
                                        input: partitions: [...]schema: Schema { fields: [Field { name: "col1", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: "col2", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: "col3", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }projection: Some([0, 1, 2]),
                                        partitioning: RoundRobinBatch(
                                            10,
                                        ),
                                        state: Mutex {
                                            data: RepartitionExecState {
                                                channels: {},
                                                abort_helper: AbortOnDropMany(
                                                    [],
                                                ),
                                            },
                                        },
                                        metrics: ExecutionPlanMetricsSet {
                                            inner: Mutex {
                                                data: MetricsSet {
                                                    metrics: [],
                                                },
                                            },
                                        },
                                    },
                                    schema: Schema {
                                        fields: [
                                            Field {
                                                name: "col2",
                                                data_type: UInt64,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                            Field {
                                                name: "col1",
                                                data_type: Utf8,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                            Field {
                                                name: "SUM(tbl.col3)[sum]",
                                                data_type: UInt64,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                            Field {
                                                name: "SUM(tbl.col3)[count]",
                                                data_type: UInt64,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                        ],
                                        metadata: {},
                                    },
                                    input_schema: Schema {
                                        fields: [
                                            Field {
                                                name: "col1",
                                                data_type: Utf8,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                            Field {
                                                name: "col2",
                                                data_type: UInt64,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                            Field {
                                                name: "col3",
                                                data_type: UInt64,
                                                nullable: true,
                                                dict_id: 0,
                                                dict_is_ordered: false,
                                                metadata: {},
                                            },
                                        ],
                                        metadata: {},
                                    },
                                    alias_map: {
                                        Column {
                                            name: "col2",
                                            index: 1,
                                        }: [
                                            Column {
                                                name: "col2",
                                                index: 0,
                                            },
                                        ],
                                        Column {
                                            name: "col1",
                                            index: 0,
                                        }: [
                                            Column {
                                                name: "col1",
                                                index: 1,
                                            },
                                        ],
                                    },
                                    metrics: ExecutionPlanMetricsSet {
                                        inner: Mutex {
                                            data: MetricsSet {
                                                metrics: [],
                                            },
                                        },
                                    },
                                },
                                partitioning: Hash(
                                    [
                                        Column {
                                            name: "col2",
                                            index: 0,
                                        },
                                        Column {
                                            name: "col1",
                                            index: 1,
                                        },
                                    ],
                                    10,
                                ),
                                state: Mutex {
                                    data: RepartitionExecState {
                                        channels: {},
                                        abort_helper: AbortOnDropMany(
                                            [],
                                        ),
                                    },
                                },
                                metrics: ExecutionPlanMetricsSet {
                                    inner: Mutex {
                                        data: MetricsSet {
                                            metrics: [],
                                        },
                                    },
                                },
                            },
                            target_batch_size: 8192,
                            metrics: ExecutionPlanMetricsSet {
                                inner: Mutex {
                                    data: MetricsSet {
                                        metrics: [],
                                    },
                                },
                            },
                        },
                        schema: Schema {
                            fields: [
                                Field {
                                    name: "col2",
                                    data_type: Utf8,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                                Field {
                                    name: "col1",
                                    data_type: UInt64,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                                Field {
                                    name: "SUM(tbl.col3)",
                                    data_type: UInt64,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                            ],
                            metadata: {},
                        },
                        input_schema: Schema {
                            fields: [
                                Field {
                                    name: "col1",
                                    data_type: Utf8,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                                Field {
                                    name: "col2",
                                    data_type: UInt64,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                                Field {
                                    name: "col3",
                                    data_type: UInt64,
                                    nullable: true,
                                    dict_id: 0,
                                    dict_is_ordered: false,
                                    metadata: {},
                                },
                            ],
                            metadata: {},
                        },
                        alias_map: {
                            Column {
                                name: "col2",
                                index: 1,
                            }: [
                                Column {
                                    name: "col2",
                                    index: 0,
                                },
                            ],
                            Column {
                                name: "col1",
                                index: 0,
                            }: [
                                Column {
                                    name: "col1",
                                    index: 1,
                                },
                            ],
                        },
                        metrics: ExecutionPlanMetricsSet {
                            inner: Mutex {
                                data: MetricsSet {
                                    metrics: [],
                                },
                            },
                        },
                    },
                    output_ordering: None,
                    alias_map: {
                        Column {
                            name: "col1",
                            index: 1,
                        }: [
                            Column {
                                name: "col1",
                                index: 0,
                            },
                        ],
                        Column {
                            name: "col2",
                            index: 0,
                        }: [
                            Column {
                                name: "col2",
                                index: 1,
                            },
                        ],
                    },
                    metrics: ExecutionPlanMetricsSet {
                        inner: Mutex {
                            data: MetricsSet {
                                metrics: [],
                            },
                        },
                    },
                },
                output_ordering: None,
                alias_map: {
                    Column {
                        name: "SUM(tbl.col3)",
                        index: 2,
                    }: [
                        Column {
                            name: "sum_col3",
                            index: 2,
                        },
                    ],
                },
                metrics: ExecutionPlanMetricsSet {
                    inner: Mutex {
                        data: MetricsSet {
                            metrics: [],
                        },
                    },
                },
            },
            on: [
                (
                    Column {
                        name: "col2",
                        index: 0,
                    },
                    Column {
                        name: "col2",
                        index: 1,
                    },
                ),
                (
                    Column {
                        name: "col1",
                        index: 1,
                    },
                    Column {
                        name: "col1",
                        index: 0,
                    },
                ),
            ],
            filter: None,
            join_type: Left,
            schema: Schema {
                fields: [
                    Field {
                        name: "col2",
                        data_type: UInt64,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "col1",
                        data_type: Utf8,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "col1",
                        data_type: UInt64,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "col2",
                        data_type: Utf8,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                    Field {
                        name: "sum_col3",
                        data_type: UInt64,
                        nullable: true,
                        dict_id: 0,
                        dict_is_ordered: false,
                        metadata: {},
                    },
                ],
                metadata: {},
            },
            left_fut: OnceAsync,
            random_state: RandomState { .. },
            mode: Partitioned,
            metrics: ExecutionPlanMetricsSet {
                inner: Mutex {
                    data: MetricsSet {
                        metrics: [],
                    },
                },
            },
            column_indices: [
                ColumnIndex {
                    index: 0,
                    side: Left,
                },
                ColumnIndex {
                    index: 1,
                    side: Left,
                },
                ColumnIndex {
                    index: 0,
                    side: Right,
                },
                ColumnIndex {
                    index: 1,
                    side: Right,
                },
                ColumnIndex {
                    index: 2,
                    side: Right,
                },
            ],
            null_equals_null: false,
        },
        target_batch_size: 8192,
        metrics: ExecutionPlanMetricsSet {
            inner: Mutex {
                data: MetricsSet {
                    metrics: [],
                },
            },
        },
    },
    output_ordering: None,
    alias_map: {
        Column {
            name: "col1",
            index: 1,
        }: [
            Column {
                name: "col1",
                index: 0,
            },
        ],
        Column {
            name: "col2",
            index: 0,
        }: [
            Column {
                name: "col2",
                index: 1,
            },
        ],
    },
    metrics: ExecutionPlanMetricsSet {
        inner: Mutex {
            data: MetricsSet {
                metrics: [],
            },
        },
    },
}

比较文本

显示

处理

datafusion #4873 @keyframes loading-circle-spin { 100% { transform: rotate(360deg); } }

datafusion #4873