FileSystemSource Class

public final class FileSystemSource
extends CopySource

A copy activity file system source.

Constructor Summary

Constructor Description
FileSystemSource()

Creates an instance of FileSystemSource class.

Method Summary

Modifier and Type Method and Description
static FileSystemSource fromJson(JsonReader jsonReader)

Reads an instance of FileSystemSource from the JsonReader.

Object getAdditionalColumns()

Get the additionalColumns property: Specifies the additional columns to be added to source data.

Object getRecursive()

Get the recursive property: If true, files under the folder path will be read recursively.

String getType()

Get the type property: Copy source type.

FileSystemSource setAdditionalColumns(Object additionalColumns)

Set the additionalColumns property: Specifies the additional columns to be added to source data.

FileSystemSource setMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store.

FileSystemSource setRecursive(Object recursive)

Set the recursive property: If true, files under the folder path will be read recursively.

FileSystemSource setSourceRetryCount(Object sourceRetryCount)

Set the sourceRetryCount property: Source retry count.

FileSystemSource setSourceRetryWait(Object sourceRetryWait)

Set the sourceRetryWait property: Source retry wait.

JsonWriter toJson(JsonWriter jsonWriter)

Methods inherited from CopySource

Methods inherited from java.lang.Object

Constructor Details

FileSystemSource

public FileSystemSource()

Creates an instance of FileSystemSource class.

Method Details

fromJson

public static FileSystemSource fromJson(JsonReader jsonReader)

Reads an instance of FileSystemSource from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of FileSystemSource if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.

Throws:

IOException

- If an error occurs while reading the FileSystemSource.

getAdditionalColumns

public Object getAdditionalColumns()

Get the additionalColumns property: Specifies the additional columns to be added to source data. Type: array of objects(AdditionalColumns) (or Expression with resultType array of objects).

Returns:

the additionalColumns value.

getRecursive

public Object getRecursive()

Get the recursive property: If true, files under the folder path will be read recursively. Default is true. Type: boolean (or Expression with resultType boolean).

Returns:

the recursive value.

getType

public String getType()

Get the type property: Copy source type.

Overrides:

FileSystemSource.getType()

Returns:

the type value.

setAdditionalColumns

public FileSystemSource setAdditionalColumns(Object additionalColumns)

Set the additionalColumns property: Specifies the additional columns to be added to source data. Type: array of objects(AdditionalColumns) (or Expression with resultType array of objects).

Parameters:

additionalColumns - the additionalColumns value to set.

Returns:

the FileSystemSource object itself.

setMaxConcurrentConnections

public FileSystemSource setMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store. Type: integer (or Expression with resultType integer).

Overrides:

FileSystemSource.setMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

setRecursive

public FileSystemSource setRecursive(Object recursive)

Set the recursive property: If true, files under the folder path will be read recursively. Default is true. Type: boolean (or Expression with resultType boolean).

Parameters:

recursive - the recursive value to set.

Returns:

the FileSystemSource object itself.

setSourceRetryCount

public FileSystemSource setSourceRetryCount(Object sourceRetryCount)

Set the sourceRetryCount property: Source retry count. Type: integer (or Expression with resultType integer).

Overrides:

FileSystemSource.setSourceRetryCount(Object sourceRetryCount)

Parameters:

sourceRetryCount

setSourceRetryWait

public FileSystemSource setSourceRetryWait(Object sourceRetryWait)

Set the sourceRetryWait property: Source retry wait. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

FileSystemSource.setSourceRetryWait(Object sourceRetryWait)

Parameters:

sourceRetryWait

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

FileSystemSource.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

Applies to