spark core 2.0 MemoryLocation
2017-01-22 10:25
162 查看
MemoryLocation is tracked either by a memory address( with off-heap allocation), or by an offset from a JVM objet(in-heap allocation).
public class MemoryLocation {
@Nullable
Object obj;
long offset;
public MemoryLocation(@Nullable Object obj, long offset) {
this.obj = obj;
this.offset = offset;
}
public MemoryLocation() {
this(null, 0);
}
public void setObjAndOffset(Object newObj, long newOffset) {
this.obj = newObj;
this.offset = newOffset;
}
public final Object getBaseObject() {
return obj;
}
public final long getBaseOffset() {
return offset;
}
}
public class MemoryLocation {
@Nullable
Object obj;
long offset;
public MemoryLocation(@Nullable Object obj, long offset) {
this.obj = obj;
this.offset = offset;
}
public MemoryLocation() {
this(null, 0);
}
public void setObjAndOffset(Object newObj, long newOffset) {
this.obj = newObj;
this.offset = newOffset;
}
public final Object getBaseObject() {
return obj;
}
public final long getBaseOffset() {
return offset;
}
}
相关文章推荐
- spark core 2.0 SortShuffleManager
- spark core 2.0 Executor Heartbeat
- spark core 2.0 MetricsConfig
- spark core 2.0 DiskBlockObjectWriter
- spark core 2.0 MemoryBlock Soruce Code Analysis
- spark core 2.0 ChunkedByteBufferOutputStream
- spark core 2.0 TaskSchedulerImpl 源代码解析
- spark core 2.0 RedirectableOutputStream
- spark core 2.0 MemoryManager
- spark core 2.0 TimeTrackingOutputStream
- spark core 2.0 StorageMemoryPool
- spark core 2.0 LongArray
- spark core 2.0 PartitionCoalescer, PartitionGroup, DefaultPartitionCoalescer
- spark core 2.0 ExecutionMemoryPool
- spark core 2.0 BlockManager dropFromMemory
- spark core 2.0 Executor
- spark core 2.0 BypassMergeSortShuffleWriter
- spark core 2.0 UnifiedMemoryManager
- spark core 2.0 CheckpointState RDDCheckpointData Checkpoint LocalRDDCheckpointData
- spark core 2.0 CoarseGrainedSchedulerBackend SchedulerBackend ExecutorAllocationClient 源代码解析