public class

HdfsConnectorConnectionIdentifierAdapter

extends HdfsConnectorProcessAdapter
implements Connection

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

Class Overview

A HdfsConnectorConnectionIdentifierAdapter is a wrapper around HdfsConnector that implements org.mule.devkit.dynamic.api.helper.Connection interface.

Summary

[Expand]

Inherited Constants

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

From class org.mule.modules.hdfs.HdfsConnector

From interface org.mule.api.lifecycle.Disposable

From interface org.mule.api.lifecycle.Initialisable

From interface org.mule.api.lifecycle.Startable

From interface org.mule.api.lifecycle.Stoppable

[Expand]

Inherited Fields

From class org.mule.modules.hdfs.HdfsConnector

Public Constructors
	HdfsConnectorConnectionIdentifierAdapter()

Public Methods
String	getConnectionIdentifier() Retrieve the identification of this connection

[Expand]

Inherited Methods

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

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

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

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.lifecycle.Disposable

From interface org.mule.api.lifecycle.Initialisable

From interface org.mule.api.lifecycle.Startable

From interface org.mule.api.lifecycle.Stoppable

From interface org.mule.modules.hdfs.basic.Capabilities

From interface org.mule.modules.hdfs.basic.MetadataAware

From interface org.mule.modules.hdfs.connection.Connection

Classes

HdfsConnectorConnectionIdentifierAdapter

Class Overview

Summary

Public Constructors

public HdfsConnectorConnectionIdentifierAdapter ()

Public Methods

public String getConnectionIdentifier ()