Skip to content

Commit a148383

Browse files
committed
try to fix jvm build
1 parent d3f2bd0 commit a148383

2 files changed

Lines changed: 8 additions & 18 deletions

File tree

backends-bolt/pom.xml

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -25,19 +25,6 @@
2525
<version>${project.version}</version>
2626
<scope>compile</scope>
2727
</dependency>
28-
<dependency>
29-
<groupId>org.apache.gluten</groupId>
30-
<artifactId>backends-core</artifactId>
31-
<version>${project.version}</version>
32-
<scope>compile</scope>
33-
</dependency>
34-
<dependency>
35-
<groupId>org.apache.gluten</groupId>
36-
<artifactId>backends-core</artifactId>
37-
<version>${project.version}</version>
38-
<type>test-jar</type>
39-
<scope>test</scope>
40-
</dependency>
4128
<dependency>
4229
<groupId>com.google.protobuf</groupId>
4330
<artifactId>protobuf-java</artifactId>

backends-bolt/src/main/scala/org/apache/gluten/backendsapi/bolt/BoltSparkPlanExecApi.scala

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ class BoltSparkPlanExecApi extends SparkPlanExecApi {
186186
}
187187

188188
/** Transform sequence to Substrait. */
189-
override def genSequenceTransformer(
189+
def genSequenceTransformer(
190190
substraitExprName: String,
191191
children: Seq[ExpressionTransformer],
192192
expr: Sequence): ExpressionTransformer = {
@@ -379,7 +379,7 @@ class BoltSparkPlanExecApi extends SparkPlanExecApi {
379379
* Bolt does not need the sort-based aggregate semantic, so a SortAggregateExec is offloaded as a
380380
* regular hash aggregate transformer.
381381
*/
382-
override def offloadSortAggregate(plan: BaseAggregateExec): HashAggregateExecBaseTransformer =
382+
def offloadSortAggregate(plan: BaseAggregateExec): HashAggregateExecBaseTransformer =
383383
HashAggregateExecBaseTransformer.from(plan)
384384

385385
/** Generate HashAggregateExecPullOutHelper */
@@ -711,7 +711,10 @@ class BoltSparkPlanExecApi extends SparkPlanExecApi {
711711
child: SparkPlan,
712712
numOutputRows: SQLMetric,
713713
dataSize: SQLMetric,
714-
buildThreads: SQLMetric): BuildSideRelation = {
714+
buildThreads: SQLMetric,
715+
buildHashTableTimeMetric: SQLMetric,
716+
serializeHashTableTimeMetric: SQLMetric,
717+
serializedHashTableSizeMetric: SQLMetric): BuildSideRelation = {
715718
val useOffheapBroadcastBuildRelation =
716719
BoltConfig.get.enableBroadcastBuildRelationInOffheap
717720
val serialized: Array[ColumnarBatchSerializeResult] = child
@@ -1045,7 +1048,7 @@ class BoltSparkPlanExecApi extends SparkPlanExecApi {
10451048
}
10461049
}
10471050

1048-
override def validatePaimonScanCapabilities(
1051+
def validatePaimonScanCapabilities(
10491052
hasPrimaryKeys: Boolean,
10501053
allSplitsRawConvertible: Boolean,
10511054
deletionVectorsEnabled: Boolean,
@@ -1098,7 +1101,7 @@ class BoltSparkPlanExecApi extends SparkPlanExecApi {
10981101
}
10991102
}
11001103

1101-
override def rewritePaimonPushdownFilters(
1104+
def rewritePaimonPushdownFilters(
11021105
filters: Seq[Expression],
11031106
primaryKeys: Set[String],
11041107
metadataColumns: Set[String]): Seq[Expression] = {

0 commit comments

Comments
 (0)