Package | Description |
---|---|
com.toolsverse.etl.core.engine |
Modifier and Type | Method and Description |
---|---|
Source |
Task.getSource()
Gets the source.
|
Source |
Destination.getSource()
Gets the source, linked to the destination.
|
Source |
Destination.getSourceToUse()
Gets the source, linked to the destination or if exists - source derived
from the linked destination.
|
Modifier and Type | Method and Description |
---|---|
ListHashMap<String,Source> |
Scenario.getMandatorySources()
Gets the list of mandatory sources.
|
ListHashMap<String,Source> |
Scenario.getSources()
Gets the sources.
|
Modifier and Type | Method and Description |
---|---|
void |
Scenario.addSource(Source source)
Adds the source.
|
void |
Extractor.extract(EtlConfig config,
Scenario scenario,
Source source,
Destination destination,
AddRecordCallback addRecordCallback)
Extracts data from the source.
|
Destination |
Scenario.getDestinationBySource(Source source)
Gets the destination by source.
|
Object |
EtlMetricsTracker.getHighWatermark(EtlConfig config,
Scenario scenario,
Source source,
Destination destination,
Boolean... onLoad)
Gets the high watermark value.
|
TypedKeyValue<String,String> |
EtlMetricsTracker.prepareTrackingExtract(Scenario scenario,
Source source,
Destination destination,
String sql,
EtlConfig config)
Prepare tracking extract.
|
void |
TaskRecorder.recordFinishExtract(Source source)
Record event when the extract has finished running.
|
void |
TaskRecorder.recordStartExtract(Source source,
String code)
Record event when the extract has started.
|
boolean |
MetadataTracker.recreateDestTableIfNeededWhenHWMIsEnabled(Scenario scenario,
Source source,
Destination destination,
EtlConfig config)
Recreate destination table if needed when the high watermark replication
is enabled.
|
void |
Task.setSource(Source value)
Sets the source.
|
void |
Destination.setSource(Source value)
Sets the source, linked to the destination.
|
void |
EtlMetricsTracker.startTrackingExtract(String name,
Source source,
DataSet dataSet,
Destination destination,
String flow)
Start tracking extract.
|
Modifier and Type | Method and Description |
---|---|
void |
Scenario.setMandatorySources(ListHashMap<String,Source> value)
Sets the mandatory sources.
|
void |
Scenario.setSources(ListHashMap<String,Source> value)
Sets the sources.
|
Copyright © 2010-2020 Toolsverse. All Rights Reserved.