File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed
main/java/org/apache/spark/shuffle/sort
test/java/org/apache/spark/shuffle/sort Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change 2424import java.nio.channels.WritableByteChannel;
2525import java.util.Iterator;
2626
27- import org.apache.spark.shuffle.api.ShuffleExecutorComponents;
28- import org.apache.spark.shuffle.api.WritableByteChannelWrapper;
2927import scala.Option;
3028import scala.Product2;
3129import scala.collection.JavaConverters;
5452import org.apache.spark.serializer.SerializationStream;
5553import org.apache.spark.serializer.SerializerInstance;
5654import org.apache.spark.shuffle.ShuffleWriter;
55+ import org.apache.spark.shuffle.api.ShuffleExecutorComponents;
56+ import org.apache.spark.shuffle.api.WritableByteChannelWrapper;
5757import org.apache.spark.storage.BlockManager;
5858import org.apache.spark.unsafe.Platform;
5959import org.apache.spark.util.Utils;
Original file line number Diff line number Diff line change 2222import java.nio.file.Files;
2323import java.util.*;
2424
25- import org.apache.spark.shuffle.sort.io.LocalDiskShuffleExecutorComponents;
2625import org.mockito.stubbing.Answer;
2726import scala.Option;
2827import scala.Product2;
4241import org.apache.spark.ShuffleDependency;
4342import org.apache.spark.SparkConf;
4443import org.apache.spark.TaskContext;
45- import org.apache.spark.TaskContext$;
4644import org.apache.spark.executor.ShuffleWriteMetrics;
4745import org.apache.spark.executor.TaskMetrics;
4846import org.apache.spark.io.CompressionCodec$;
5755import org.apache.spark.security.CryptoStreamUtils;
5856import org.apache.spark.serializer.*;
5957import org.apache.spark.shuffle.IndexShuffleBlockResolver;
58+ import org.apache.spark.shuffle.sort.io.LocalDiskShuffleExecutorComponents;
6059import org.apache.spark.storage.*;
6160import org.apache.spark.util.Utils;
6261
You can’t perform that action at this time.
0 commit comments