Options
All
  • Public
  • Public/Protected
  • All
Menu

Used to execute Transformations.

This is a basic transformer that performs all the work locally.

const transformer = new Transformer(
  transformation,
  {
    workerCount: 4,
    readCapacityLimit: 100,
    writeCapacityLimit: 300,
  }
)

await transformer.execute()

Hierarchy

Index

Constructors

constructor

  • Parameters

    • transformation: Transformation
    • Default value options: object = {}
      • Optional readCapacityLimit?: undefined | number
      • Optional setupTarget?: undefined | true | false
      • Optional stateFile?: undefined | string
      • Optional workerCount?: undefined | number
      • Optional writeCapacityLimit?: undefined | number

    Returns Transformer

Properties

activeWorkers

activeWorkers: number = 0

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

sourceStatus

sourceStatus: StoreState = StoreState.Unknown

state

state: State = State.Idle

Protected Optional stateFilePath

stateFilePath: undefined | string

targetCommitCount

targetCommitCount: number = 0

targetStatus

targetStatus: StoreState = StoreState.Unknown

Protected Optional terminationRequestedTimestamp

terminationRequestedTimestamp: undefined | number

transformation

transformation: Transformation

workerCount

workerCount: number

Protected workerStates

workerStates: any[]

workerTimeout

workerTimeout: number = 30000

Protected Optional writeCapacityLimit

writeCapacityLimit: undefined | number

Accessors

statusDescription

  • get statusDescription(): string

Methods

Protected bumpCounters

execute

  • execute(): Promise<void>

Protected setup

  • setup(): Promise<void>

terminate

  • terminate(): Promise<void>

Protected updateWorkerState

  • updateWorkerState(index: number, state: any): Promise<void>

Protected workerLoop

  • workerLoop(index: number): Promise<void>

writeStateFile

  • writeStateFile(path: string): Promise<void>

Object literals

counters

counters: object

commitsDeleted

commitsDeleted: number = 0

commitsRead

commitsRead: number = 0

commitsScanned

commitsScanned: number = 0

commitsWritten

commitsWritten: number = 0

throttledReads

throttledReads: number = 0

throttledWrites

throttledWrites: number = 0

workerInvocations

workerInvocations: number = 0

Generated using TypeDoc