Index (gratum 1.2.0-SNAPSHOT API)

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _

A

B

C

D

E

emptyToNull() - Method in Pipeline: Returns a Pipeline where all columns containing empty strings are replaced with null within each row.
enableStrictHostCheck(boolean) - Method in SshSource: Can be used to disable the known host checking, but this has serious security implications which need to be carefully considered before doing this.
encryptPgp(java.lang.String, groovy.lang.Closure) - Method in Pipeline: Encrypts using PGP a stream on the pipeline and rewrite that stream back to the pipeline.
end - Property in LoadStatistic
endRow(int) - Method in XlsxSource.XslxSheetHandler
escaping(boolean) - Method in CsvSource: Turn on/off CSV escaping rules.
eventQueue - Property in LocalConcurrentContext
excelFile - Property in XlsxSource
exchange(Closure<Pipeline>) - Method in Pipeline: This takes a closure that returns a Pipeline which is used to feed the Pipeline returned by exchange().
execute() - Method in AfterStep
execute(gratum.etl.Pipeline, Map<String, Object>, int) - Method in Step
executeBatch() - Method in JdbcBatchHelper

F

file - Property in ArchivedSource
file - Property in ZipSource
FileOpenable - Class in gratum.etl: Represents a file that can be cast to an InputStream or OutputStream giving it the ability to masquerade as an InputStream/OutputStream.
FileOpenable(java.io.File) - Constructor in FileOpenable
files - Property in FileSystemSource
FileSystemSource - Class in gratum.source: Creates a source that enumerates files within a directory, the file itself, and returns a Pipeline that produces a Map object with keys file and stream with types java.io.File and java.io.InputStream respectively.
FileSystemSource(Iterable<File>) - Constructor in FileSystemSource
fillDownBy(Closure<Boolean>) - Method in Pipeline: This returns a Pipeline where the rows with empty columns are filled in using the values in the previous row depending on what the given closure returns.
filter - Property in FileSystemSource
filter(java.util.Map) - Method in Pipeline: This adds a step to the Pipeline that passes all rows where the values of the columns on the given Map are equal to the columns in the row.
finished() - Method in Pipeline
finishWhenQueueIsEmpty - Property in LocalConcurrentContext
flattenWindow(java.lang.String, Closure<List<Map<String, Object>>>) - Method in Pipeline: Collects, or flattens, a set of rows that share the same value in succession within the stream into a List of those matching rows.
format - Property in ArchivedSource
formatRawCellContents(double, int, java.lang.String, boolean) - Method in CustomDateDataFormatter
from(Iterable<Map>) - Method in CollectionSource

G

H

hasQueuedBatches() - Method in JdbcBatchHelper
header(Closure<Void>) - Method in CsvSource: Register a closure to receive the header before processing starts
header(Closure<Void>) - Method in XlsxSource: Attaches a closure that will be called back when the headers are available.
headerClosure - Property in CsvSource
headerClosure - Property in XlsxSource
headerRow - Property in XlsxSource.XslxSheetHandler
headers - Property in XlsxSource.XslxSheetHandler
host - Property in SshSource
http(java.lang.String, okhttp3.OkHttpClient, groovy.lang.Closure) - Method in OkHttpSource: Best practice is to share OkHttpClients when performing multiple http calls or multiple OkHttpSources.
https(java.lang.String, okhttp3.OkHttpClient, groovy.lang.Closure) - Method in OkHttpSource: Best practice is to share OkHttpClients when performing multiple http calls or multiple OkHttpSources.

I

identity(java.lang.String, java.io.File, java.lang.String) - Method in SshSource: This uses a SSH key pair to authenticate the given username.
IGNORE_ROW - Enum Constant in RejectionCategory
includeRoot - Property in JsonSource
incrementRejections(gratum.etl.RejectionCategory) - Method in Step
inject(groovy.lang.Closure) - Method in Pipeline: Delegates to inject(java.lang.String, groovy.lang.Closure) with a default name.
intersect(gratum.etl.Pipeline, java.lang.Object) - Method in Pipeline: Return a Pipeline where all of the rows from this Pipeline and adds a single column "included" with a true/false value depending on whether the current row is occurs in the given Pipeline and the values of the specified columns are equal in both Pipelines.
into() - Method in AbstractSource: This converts the source into a Pipeline to attach steps to.
into() - Method in Source
INVALID_FORMAT - Enum Constant in RejectionCategory
isFinishWhenQueueIsEmpty() - Method in LocalConcurrentContext

J

K

knownHosts(java.io.File) - Method in SshSource: A file containing the list of known hosts the client will use to authorize the connection to the server.

L

M

N

name - Property in AbstractSource
name - Property in Condition
name - Property in JsonSink
name - Property in LoadStatistic
name - Property in Pipeline
name - Property in PipelineWorker
name - Field in Step

O

P

Q

R

S

T

U

V

W

X

Y

Z