alluxio.underfs

Interface AtomicFileOutputStreamCallback

All Superinterfaces:

AsyncUfsClient, AutoCloseable, Closeable, UnderFileSystem

All Known Implementing Classes:

AbfsUnderFileSystem, AdlUnderFileSystem, CephfsHadoopUnderFileSystem, CephFSUnderFileSystem, CosnUnderFileSystem, HdfsUnderFileSystem, LocalUnderFileSystem, OzoneUnderFileSystem, WasbUnderFileSystem

public interface AtomicFileOutputStreamCallback
extends UnderFileSystem

A AtomicFileOutputStreamCallback is the callback interface used when using a AtomicFileOutputStream.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.underfs.UnderFileSystem

UnderFileSystem.Factory, UnderFileSystem.SpaceType

Method Summary

Modifier and Type	Method and Description
OutputStream	createDirect(String path, CreateOptions options) Creates a file in the under file system with the specified CreateOptions.

Methods inherited from interface alluxio.underfs.UnderFileSystem

cleanup, connectFromMaster, connectFromWorker, create, create, createNonexistingFile, createNonexistingFile, deleteDirectory, deleteDirectory, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, deleteFile, exists, getAclPair, getBlockSizeByte, getConfiguration, getDirectoryStatus, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, getFileLocations, getFileLocations, getFileStatus, getFileStatus, getFingerprint, getOperationMode, getParsedFingerprint, getParsedFingerprint, getPhysicalStores, getSpace, getStatus, getStatus, getTemporaryToken, getUnderFSType, isDirectory, isExistingDirectory, isFile, isObjectStorage, isSeekable, isTemporaryConnectionToken, listStatus, listStatus, listStatuses, listStatusIterable, mkdirs, mkdirs, open, open, openExistingFile, openExistingFile, openPositionRead, refreshTemporaryToken, renameDirectory, renameFile, renameRenamableDirectory, renameRenamableFile, resolveUri, setAclEntries, setMode, setOwner, setTemporaryTokenRefreshContext, supportsFlush

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface alluxio.underfs.AsyncUfsClient

performListingAsync

Method Detail

createDirect

OutputStream createDirect(String path,
                          CreateOptions options)
                   throws IOException

Creates a file in the under file system with the specified CreateOptions. This stream writes directly to the underlying storage without any atomicity guarantees.

Parameters:

path - the file name

options - the options for create

Returns:

A OutputStream object

Throws:

IOException