public class EmptyFileMergingOperatorStreamStateHandle extends FileMergingOperatorStreamStateHandle
FileMergingOperatorStreamStateHandle
that is only used as a placeholder to
prevent file merging directory from being deleted.StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector
OperatorStateHandle.Mode, OperatorStateHandle.StateMetaInfo
Constructor and Description |
---|
EmptyFileMergingOperatorStreamStateHandle(DirectoryStreamStateHandle taskOwnedDirHandle,
DirectoryStreamStateHandle sharedDirHandle,
Map<String,OperatorStateHandle.StateMetaInfo> stateNameToPartitionOffsets,
StreamStateHandle delegateStateHandle) |
Modifier and Type | Method and Description |
---|---|
static EmptyFileMergingOperatorStreamStateHandle |
create(DirectoryStreamStateHandle taskownedDirHandle,
DirectoryStreamStateHandle sharedDirHandle)
Create an empty
EmptyFileMergingOperatorStreamStateHandle . |
discardState, equals, getCheckpointedSize, getSharedDirHandle, getTaskOwnedDirHandle, hashCode, registerSharedStates, toString
asBytesIfInMemory, collectSizeStats, getDelegateStateHandle, getStateNameToPartitionOffsets, getStateSize, getStreamStateHandleID, openInputStream
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
collectSizeStats, getStateSize
public EmptyFileMergingOperatorStreamStateHandle(DirectoryStreamStateHandle taskOwnedDirHandle, DirectoryStreamStateHandle sharedDirHandle, Map<String,OperatorStateHandle.StateMetaInfo> stateNameToPartitionOffsets, StreamStateHandle delegateStateHandle)
public static EmptyFileMergingOperatorStreamStateHandle create(DirectoryStreamStateHandle taskownedDirHandle, DirectoryStreamStateHandle sharedDirHandle)
EmptyFileMergingOperatorStreamStateHandle
.taskownedDirHandle
- the directory where operator state is stored.sharedDirHandle
- the directory where shared state is stored.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.