Properties
Private activeRequests
activeRequests: Set<Request<InvocationResponse, AWSError>> = new Set()
activeWorkers
activeWorkers: number = 0
Private Optional awsConfig
awsConfig: ConfigurationOptions
Optional countersUpdatedAt
countersUpdatedAt: undefined | number
Optional executionStartedTimestamp
executionStartedTimestamp: undefined | number
Protected Optional readCapacityLimit
readCapacityLimit: undefined | number
Protected runId
runId: string
Protected Optional setupTarget
setupTarget: undefined | true | false
sourceCommitCount
sourceCommitCount: number = 0
state
state: State = State.Idle
Protected Optional stateFilePath
stateFilePath: undefined | string
targetCommitCount
targetCommitCount: number = 0
Protected Optional terminationRequestedTimestamp
terminationRequestedTimestamp: undefined | number
Private transformationPath
transformationPath: string
workerCount
workerCount: number
Protected workerStates
workerStates: any[]
workerTimeout
workerTimeout: number = 30000
Protected Optional writeCapacityLimit
writeCapacityLimit: undefined | number
Used to execute Transformations using AWS Lambda workers.
const transformer = new LamdaTransformer( transformation, { workerCount: 4, readCapacityLimit: 100, writeCapacityLimit: 300, } ) await transformer.execute()