public class

HdfsConnectorMetadataAdapater

extends HdfsConnectorCapabilitiesAdapter
implements MetadataAware

java.lang.Object
↳	org.mule.modules.hdfs.HdfsConnector
	↳	org.mule.modules.hdfs.adapters.HdfsConnectorCapabilitiesAdapter
		↳	org.mule.modules.hdfs.adapters.HdfsConnectorMetadataAdapater

Known Direct Subclasses

HdfsConnectorLifecycleAdapter

Known Indirect Subclasses

HdfsConnectorConnectionIdentifierAdapter, HdfsConnectorProcessAdapter

Class Overview

A HdfsConnectorMetadataAdapater is a wrapper around HdfsConnector that adds support for querying metadata about the extension.

Summary

Constants
String	DEVKIT_BUILD
String	DEVKIT_VERSION
String	MODULE_NAME
String	MODULE_VERSION

[Expand]

Inherited Constants

From class org.mule.modules.hdfs.HdfsConnector

[Expand]

Inherited Fields

From class org.mule.modules.hdfs.HdfsConnector

Public Constructors
	HdfsConnectorMetadataAdapater()

Public Methods
String	getDevkitBuild()
String	getDevkitVersion()
String	getModuleName()
String	getModuleVersion()

[Expand]

Inherited Methods

From class org.mule.modules.hdfs.adapters.HdfsConnectorCapabilitiesAdapter

From class org.mule.modules.hdfs.HdfsConnector

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) Get the metadata of a path, as described in `readFromPath(String, int, SourceCallback)`, and store it in flow variables.
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: `HDFS_PATH_EXISTS`: a boolean set to true if the path exists `HDFS_CONTENT_SUMMARY`: an instance of ContentSummary if the path exists.
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.

From class java.lang.Object

From interface org.mule.api.Capabilities

Classes

HdfsConnectorMetadataAdapater

Class Overview

Summary

Constants

private static final String DEVKIT_BUILD

private static final String DEVKIT_VERSION

private static final String MODULE_NAME

private static final String MODULE_VERSION

Public Constructors

public HdfsConnectorMetadataAdapater ()

Public Methods

public String getDevkitBuild ()

public String getDevkitVersion ()

public String getModuleName ()

public String getModuleVersion ()