|
void
|
appendToPath(String path, int bufferSize, InputStream payload)
Append the current payload to a file located at the designated path.
|
|
void
|
connect(String connectionKey)
Establish the connection to the Hadoop Distributed File System.
|
|
void
|
deleteDirectory(String path)
Delete the file or directory located at the designated path.
|
|
void
|
deleteFile(String path)
Delete the file or directory located at the designated path.
|
|
void
|
disconnect()
Disconnect from the Hadoop Distributed File System.
|
|
Map<String, String>
|
getConfigurationEntries()
|
|
List<String>
|
getConfigurationResources()
|
|
String
|
getDefaultFileSystemName()
|
|
FileSystem
|
getFileSystem()
|
|
String
|
getFileSystemUri()
|
|
void
|
getPathMetaData(String path, MuleEvent muleEvent)
|
|
boolean
|
isConnected()
Are we connected?
|
|
void
|
makeDirectories(String path, String permission)
Make the given file and all non-existent parents into directories.
|
|
Object
|
readFromPath(String path, int bufferSize, SourceCallback sourceCallback)
Read the content of a file designated by its path and streams it to the rest
of the flow, while adding the path metadata in the following inbound
properties:
|
|
void
|
setConfigurationEntries(Map<String, String> configurationEntries)
|
|
void
|
setConfigurationResources(List<String> configurationResources)
|
|
void
|
setDefaultFileSystemName(String defaultFileSystemName)
|
|
void
|
setFileSystem(FileSystem fileSystem)
|
|
void
|
writeToPath(String path, String permission, boolean overwrite, int bufferSize, int replication, long blockSize, String ownerUserName, String ownerGroupName, InputStream payload)
Write the current payload to the designated path, either creating a new file
or appending to an existing one.
|
Known Direct Subclasses