Github user xuanyuanking commented on a diff in the pull request:
@@ -0,0 +1,139 @@
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * A ShuffleMapTask divides the elements of an RDD into multiple buckets
(based on a partitioner
+ * specified in the ShuffleDependency).
+ * See [[org.apache.spark.scheduler.Task]] for more information.
+ * @param stageId id of the stage this task belongs to
+ * @param stageAttemptId attempt id of the stage this task belongs to
+ * @param taskBinary broadcast version of the RDD and the
ShuffleDependency. Once deserialized,
+ * the type should be (RDD[_], ShuffleDependency[_, _,
+ * @param partition partition of the RDD this task is associated with
+ * @param locs preferred task execution locations for locality scheduling
+ * @param localProperties copy of thread-local properties set by the user
on the driver side.
+ * @param serializedTaskMetrics a `TaskMetrics` that is created and
serialized on the driver side
+ * and sent to executor side.
+ * @param totalShuffleNum total shuffle number for current job.
+ * The parameters below are optional:
+ * @param jobId id of the job this task belongs to
+ * @param appId id of the app this task belongs to
+ * @param appAttemptId attempt id of the app this task belongs to
+private[spark] class ContinuousShuffleMapTask(
--- End diff --
Implementation about ContinuousShuffleMapTask same with #21293
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org