Package org.pentaho.di.core.vfs

Class KettleVFSImpl

java.lang.Object

org.pentaho.di.core.vfs.KettleVFSImpl

All Implemented Interfaces:

IKettleVFS

public class KettleVFSImpl
extends Object
implements IKettleVFS

Implementation of IKettleVFS. Implementation of VFS file access for kettle. Use KettleVFS.getInstance( Bowl ) to get an instance.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONNECTION

Method Summary

Modifier and Type	Method	Description
org.apache.commons.vfs2.FileObject	createTempFile(String prefix, String suffix, String directory)
org.apache.commons.vfs2.FileObject	createTempFile(String prefix, String suffix, String directory, VariableSpace space)
org.apache.commons.vfs2.FileObject	createTempFile(String prefix, KettleVFS.Suffix suffix)	Creates a file using "java.io.tmpdir" directory
org.apache.commons.vfs2.FileObject	createTempFile(String prefix, KettleVFS.Suffix suffix, String directory)
org.apache.commons.vfs2.FileObject	createTempFile(String prefix, KettleVFS.Suffix suffix, String directory, VariableSpace space)
org.apache.commons.vfs2.FileObject	createTempFile(String prefix, KettleVFS.Suffix suffix, VariableSpace variableSpace)	Creates a file using "java.io.tmpdir" directory
boolean	fileExists(String vfsFilename)
boolean	fileExists(String vfsFilename, VariableSpace space)
org.apache.commons.vfs2.FileObject	getFileObject(String vfsFilename)
org.apache.commons.vfs2.FileObject	getFileObject(String vfsFilename, org.apache.commons.vfs2.FileSystemOptions fsOptions)
org.apache.commons.vfs2.FileObject	getFileObject(String vfsFilename, VariableSpace space)
org.apache.commons.vfs2.FileObject	getFileObject(String vfsFilename, VariableSpace space, org.apache.commons.vfs2.FileSystemOptions fsOptions)
org.apache.commons.vfs2.FileSystemOptions	getFileSystemOptions(String scheme, String vfsFilename, VariableSpace space, org.apache.commons.vfs2.FileSystemOptions fileSystemOptions)
String	getFriendlyURI(String filename)
String	getFriendlyURI(String filename, VariableSpace space)
InputStream	getInputStream(String vfsFilename)
InputStream	getInputStream(String vfsFilename, VariableSpace space)
OutputStream	getOutputStream(String vfsFilename, boolean append)
OutputStream	getOutputStream(String vfsFilename, VariableSpace space, boolean append)
OutputStream	getOutputStream(String vfsFilename, VariableSpace space, org.apache.commons.vfs2.FileSystemOptions fsOptions, boolean append)
OutputStream	getOutputStream(org.apache.commons.vfs2.FileObject fileObject, boolean append)
String	getTextFileContent(String vfsFilename, String charSetName)	Read a text file (like an XML document).
String	getTextFileContent(String vfsFilename, VariableSpace space, String charSetName)
void	reset()	resets the VariableSpace
org.apache.commons.vfs2.FileName	resolveURI(String vfsFilename)	Resolves the given URI to a file name.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CONNECTION

public static final String CONNECTION

See Also:

• Constant Field Values

Method Details

getFileObject

public org.apache.commons.vfs2.FileObject getFileObject(String vfsFilename)
                                                 throws KettleFileException

Specified by:

getFileObject in interface IKettleVFS

Throws:

KettleFileException

getFileObject

public org.apache.commons.vfs2.FileObject getFileObject(String vfsFilename,
 VariableSpace space)
                                                 throws KettleFileException

Specified by:

getFileObject in interface IKettleVFS

Throws:

KettleFileException

getFileObject

public org.apache.commons.vfs2.FileObject getFileObject(String vfsFilename,
 org.apache.commons.vfs2.FileSystemOptions fsOptions)
                                                 throws KettleFileException

Specified by:

getFileObject in interface IKettleVFS

Throws:

KettleFileException

getFileObject

public org.apache.commons.vfs2.FileObject getFileObject(String vfsFilename,
 VariableSpace space,
 org.apache.commons.vfs2.FileSystemOptions fsOptions)
                                                 throws KettleFileException

Specified by:

getFileObject in interface IKettleVFS

Throws:

KettleFileException

resolveURI

public org.apache.commons.vfs2.FileName resolveURI(String vfsFilename)
                                            throws KettleFileException

Description copied from interface: IKettleVFS

Resolves the given URI to a file name.

Specified by:

resolveURI in interface IKettleVFS

Parameters:

vfsFilename - The URI to resolve.

Returns:

A FileName that matches the URI; never null.

Throws:

KettleFileException - if this is not possible.

getFileSystemOptions

public org.apache.commons.vfs2.FileSystemOptions getFileSystemOptions(String scheme,
 String vfsFilename,
 VariableSpace space,
 org.apache.commons.vfs2.FileSystemOptions fileSystemOptions)
                                                               throws IOException

Specified by:

getFileSystemOptions in interface IKettleVFS

Throws:

IOException

getFriendlyURI

public String getFriendlyURI(String filename)

Specified by:

getFriendlyURI in interface IKettleVFS

getFriendlyURI

public String getFriendlyURI(String filename,
 VariableSpace space)

Specified by:

getFriendlyURI in interface IKettleVFS

getTextFileContent

public String getTextFileContent(String vfsFilename,
 String charSetName)
                          throws KettleFileException

Description copied from interface: IKettleVFS

Read a text file (like an XML document). WARNING DO NOT USE FOR DATA FILES.

Specified by:

getTextFileContent in interface IKettleVFS

Parameters:

vfsFilename - the filename or URL to read from

charSetName - the character set of the string (UTF-8, ISO8859-1, etc)

Returns:

The content of the file as a String

Throws:

KettleFileException

getTextFileContent

public String getTextFileContent(String vfsFilename,
 VariableSpace space,
 String charSetName)
                          throws KettleFileException

Specified by:

getTextFileContent in interface IKettleVFS

Throws:

KettleFileException

fileExists

public boolean fileExists(String vfsFilename)
                   throws KettleFileException

Specified by:

fileExists in interface IKettleVFS

Throws:

KettleFileException

fileExists

public boolean fileExists(String vfsFilename,
 VariableSpace space)
                   throws KettleFileException

Specified by:

fileExists in interface IKettleVFS

Throws:

KettleFileException

getInputStream

public InputStream getInputStream(String vfsFilename)
                           throws KettleFileException

Specified by:

getInputStream in interface IKettleVFS

Throws:

KettleFileException

getInputStream

public InputStream getInputStream(String vfsFilename,
 VariableSpace space)
                           throws KettleFileException

Specified by:

getInputStream in interface IKettleVFS

Throws:

KettleFileException

getOutputStream

public OutputStream getOutputStream(org.apache.commons.vfs2.FileObject fileObject,
 boolean append)
                             throws IOException

Specified by:

getOutputStream in interface IKettleVFS

Throws:

IOException

getOutputStream

public OutputStream getOutputStream(String vfsFilename,
 boolean append)
                             throws KettleFileException

Specified by:

getOutputStream in interface IKettleVFS

Throws:

KettleFileException

getOutputStream

public OutputStream getOutputStream(String vfsFilename,
 VariableSpace space,
 boolean append)
                             throws KettleFileException

Specified by:

getOutputStream in interface IKettleVFS

Throws:

KettleFileException

getOutputStream

public OutputStream getOutputStream(String vfsFilename,
 VariableSpace space,
 org.apache.commons.vfs2.FileSystemOptions fsOptions,
 boolean append)
                             throws KettleFileException

Specified by:

getOutputStream in interface IKettleVFS

Throws:

KettleFileException

createTempFile

public org.apache.commons.vfs2.FileObject createTempFile(String prefix,
 KettleVFS.Suffix suffix)
                                                  throws KettleFileException

Description copied from interface: IKettleVFS

Creates a file using "java.io.tmpdir" directory

Specified by:

createTempFile in interface IKettleVFS

Parameters:

prefix - - file name

Returns:

FileObject

Throws:

KettleFileException

createTempFile

public org.apache.commons.vfs2.FileObject createTempFile(String prefix,
 KettleVFS.Suffix suffix,
 VariableSpace variableSpace)
                                                  throws KettleFileException

Description copied from interface: IKettleVFS

Creates a file using "java.io.tmpdir" directory

Specified by:

createTempFile in interface IKettleVFS

Parameters:

prefix - - file name

suffix - - file extension

variableSpace - is used to get system variables

Returns:

FileObject

Throws:

KettleFileException

createTempFile

public org.apache.commons.vfs2.FileObject createTempFile(String prefix,
 KettleVFS.Suffix suffix,
 String directory)
                                                  throws KettleFileException

Specified by:

createTempFile in interface IKettleVFS

Parameters:

prefix - - file name

suffix - - file extension

directory - - directory where file will be created

Returns:

FileObject

Throws:

KettleFileException

createTempFile

public org.apache.commons.vfs2.FileObject createTempFile(String prefix,
 String suffix,
 String directory)
                                                  throws KettleFileException

Specified by:

createTempFile in interface IKettleVFS

Throws:

KettleFileException

createTempFile

public org.apache.commons.vfs2.FileObject createTempFile(String prefix,
 KettleVFS.Suffix suffix,
 String directory,
 VariableSpace space)
                                                  throws KettleFileException

Specified by:

createTempFile in interface IKettleVFS

Parameters:

prefix - - file name

directory - path to directory where file will be created

space - is used to get system variables

Returns:

FileObject

Throws:

KettleFileException

createTempFile

public org.apache.commons.vfs2.FileObject createTempFile(String prefix,
 String suffix,
 String directory,
 VariableSpace space)
                                                  throws KettleFileException

Specified by:

createTempFile in interface IKettleVFS

Throws:

KettleFileException

reset

public void reset()

Description copied from interface: IKettleVFS

resets the VariableSpace

Specified by:

reset in interface IKettleVFS