File tree Expand file tree Collapse file tree 1 file changed +1
-8
lines changed
sql/core/src/main/java/org/apache/spark/sql/execution Expand file tree Collapse file tree 1 file changed +1
-8
lines changed Original file line number Diff line number Diff line change 1919
2020import java .io .IOException ;
2121
22- import com .google .common .annotations .VisibleForTesting ;
23-
2422import org .apache .spark .SparkEnv ;
23+ import org .apache .spark .memory .TaskMemoryManager ;
2524import org .apache .spark .sql .catalyst .InternalRow ;
2625import org .apache .spark .sql .catalyst .expressions .UnsafeProjection ;
2726import org .apache .spark .sql .catalyst .expressions .UnsafeRow ;
3130import org .apache .spark .unsafe .Platform ;
3231import org .apache .spark .unsafe .map .BytesToBytesMap ;
3332import org .apache .spark .unsafe .memory .MemoryLocation ;
34- import org .apache .spark .memory .TaskMemoryManager ;
3533
3634/**
3735 * Unsafe-based HashMap for performing aggregations where the aggregated values are fixed-width.
@@ -218,11 +216,6 @@ public long getPeakMemoryUsedBytes() {
218216 return map .getPeakMemoryUsedBytes ();
219217 }
220218
221- @ VisibleForTesting
222- public int getNumDataPages () {
223- return map .getNumDataPages ();
224- }
225-
226219 /**
227220 * Free the memory associated with this map. This is idempotent and can be called multiple times.
228221 */
You can’t perform that action at this time.
0 commit comments