com.pervasive.datarush.azure

Class AbstractAzureClient

java.lang.Object

com.pervasive.datarush.azure.AbstractAzureClient

All Implemented Interfaces:

AzureClient

public abstract class AbstractAzureClient
extends Object
implements AzureClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractAzureClient.AzureCredentials

Constructor Summary

Constructors

Constructor and Description
AbstractAzureClient()

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	containerExists(String containerName)
protected abstract void	createContainer(String containerName)
AzureFilePath	createDirectory(AzureFilePath path)
protected abstract void	createEmptyBlob(String containerName, String blobPath)
protected abstract void	createEmptyDirectory(String containerName, String blobPath)
boolean	createNewFile(AzureFilePath path)
void	delete(AzureFilePath path, boolean recursively)
protected abstract void	deleteContainer(String containerName)
protected abstract void	deletePath(String containerName, String blobPath)
boolean	exists(AzureFilePath path)
protected abstract AbstractAzureClient.AzureCredentials	getAzureCredentials()
abstract PathDetails	getDetails(AzureFilePath path)
protected abstract List<PathDetails>	listBlobs(AzureFilePath path)
protected abstract List<PathDetails>	listContainers(AzureFilePath path)
List<PathDetails>	listDirectory(AzureFilePath path)
abstract boolean	move(AzureFilePath from, AzureFilePath to)
abstract InputStream	newInputStream(AzureFilePath path)
abstract SplitInputStream	newInputStream(AzureFilePath path, long start, long length, int buffer)
abstract OutputStream	newOutputStream(AzureFilePath path)
protected abstract boolean	pathExists(String containerName, String blobPath)
com.pervasive.datarush.azure.FileState	whatIsThis(AzureFilePath path)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractAzureClient

public AbstractAzureClient()

Method Detail

createDirectory

public AzureFilePath createDirectory(AzureFilePath path)
                              throws IOException

Specified by:

createDirectory in interface AzureClient

Throws:

IOException

createNewFile

public boolean createNewFile(AzureFilePath path)
                      throws IOException

Specified by:

createNewFile in interface AzureClient

Throws:

IOException

delete

public void delete(AzureFilePath path,
                   boolean recursively)
            throws IOException

Specified by:

delete in interface AzureClient

Throws:

IOException

exists

public boolean exists(AzureFilePath path)
               throws IOException

Specified by:

exists in interface AzureClient

Throws:

IOException

listDirectory

public List<PathDetails> listDirectory(AzureFilePath path)
                                throws IOException

Specified by:

listDirectory in interface AzureClient

Throws:

IOException

whatIsThis

public com.pervasive.datarush.azure.FileState whatIsThis(AzureFilePath path)
                                                  throws IOException

Specified by:

whatIsThis in interface AzureClient

Throws:

IOException

getDetails

public abstract PathDetails getDetails(AzureFilePath path)
                                throws IOException

Specified by:

getDetails in interface AzureClient

Throws:

IOException

move

public abstract boolean move(AzureFilePath from,
                             AzureFilePath to)
                      throws IOException

Specified by:

move in interface AzureClient

Throws:

IOException

newInputStream

public abstract InputStream newInputStream(AzureFilePath path)
                                    throws IOException

Specified by:

newInputStream in interface AzureClient

Throws:

IOException

newInputStream

public abstract SplitInputStream newInputStream(AzureFilePath path,
                                                long start,
                                                long length,
                                                int buffer)
                                         throws IOException

Throws:

IOException

newOutputStream

public abstract OutputStream newOutputStream(AzureFilePath path)
                                      throws IOException

Specified by:

newOutputStream in interface AzureClient

Throws:

IOException

deleteContainer

protected abstract void deleteContainer(String containerName)
                                 throws IOException

Throws:

IOException

deletePath

protected abstract void deletePath(String containerName,
                                   String blobPath)
                            throws IOException

Throws:

IOException

createContainer

protected abstract void createContainer(String containerName)
                                 throws IOException

Throws:

IOException

createEmptyBlob

protected abstract void createEmptyBlob(String containerName,
                                        String blobPath)
                                 throws IOException

Throws:

IOException

createEmptyDirectory

protected abstract void createEmptyDirectory(String containerName,
                                             String blobPath)
                                      throws IOException

Throws:

IOException

containerExists

protected abstract boolean containerExists(String containerName)
                                    throws IOException

Throws:

IOException

pathExists

protected abstract boolean pathExists(String containerName,
                                      String blobPath)
                               throws IOException

Throws:

IOException

listContainers

protected abstract List<PathDetails> listContainers(AzureFilePath path)
                                             throws IOException

Throws:

IOException

listBlobs

protected abstract List<PathDetails> listBlobs(AzureFilePath path)
                                        throws IOException

Throws:

IOException

getAzureCredentials

protected abstract AbstractAzureClient.AzureCredentials getAzureCredentials()