Modifier and Type | Method and Description |
---|---|
static DataSet |
CommonEtlUtils.addDimensions(DataSet drivingDataSet,
String keys,
String addColumns,
boolean keepAllFields,
DataSet... dataSetsToJoin)
Add dimensions to the data set.
|
DataSet |
DataSet.copy()
Copy this data set.
|
DataSet |
DataSet.copyEssentials()
Copy essential fields.
|
static DataSet |
CommonEtlUtils.denormalize(DataSet source,
boolean cleanUp)
Pivot data set which has multiple versions of the same field.
|
static DataSet |
CommonEtlUtils.executeSql(DataSet dataSet,
String sql)
Execute sql on any data set.
|
static DataSet |
CommonEtlUtils.executeSql(DataSet dataSet,
String sql,
TypedKeyValue<String,Object>... args)
Execute sql on any data set.
|
static DataSet |
CommonEtlUtils.executeSql(String sql,
DataSet... dataSets)
Execute sql on arrays of data sets.
|
static DataSet |
CommonEtlUtils.executeSql(String sql,
TypedKeyValue<String,Object>[] args,
DataSet... dataSets)
Execute sql on arrays of data sets.
|
static DataSet |
CommonEtlUtils.extractDimension(String keys,
DataSet drivingDataSet,
String name)
Extract dimension from multidimensional data set.
|
static DataSet |
CommonEtlUtils.filter(DataSet dataSet,
String conditions)
Filter data set and keep the source data set intact.
|
static DataSet |
CommonEtlUtils.filter(DataSet dataSet,
String conditions,
boolean keepOriginal)
Filter data set.
|
DataSet |
DataSetProvider.getDataSet()
Gets the data set.
|
DataSet |
DataSet.getDataSet() |
DataSet |
DataSet.getParentDataSet()
Gets the parent data set.
|
static DataSet |
CommonEtlUtils.getSelectedDataSet(DataSet dataSet,
TypedKeyValue<int[],int[]> selected)
Gets the selected data set.
|
static DataSet |
CommonEtlUtils.intersect(DataSet drivingDataSet,
DataSet secondDataSet,
String keys)
Performs intersect operations on two data sets.
|
static DataSet |
CommonEtlUtils.join(DataSet drivingDataSet,
String keys,
String include,
String exclude,
TypedKeyValue<DataSet,Boolean>... dataSetsToJoin)
Joins data sets.
|
static DataSet |
CommonEtlUtils.keyValueDenormalization(DataSet source,
DataSet newDataSet,
String groupByColumns,
String includeColumns,
String keyColumn,
String valueColumn,
boolean ignoreCase,
boolean doTrim,
String fieldsToHave)
This transformation groups rows by combination of 'group by' fields.
|
static DataSet |
CommonEtlUtils.keyValueDenormalization(DataSet source,
DataSet newDataSet,
String groupByColumns,
String includeColumns,
String keyColumn,
String valueColumn,
boolean ignoreCase,
boolean doTrim,
String fieldsToHave,
String combine)
This transformation groups rows by combination of 'group by' fields.
|
static DataSet |
CommonEtlUtils.keyValueNormalization(DataSet source,
String normalizeColumns,
String keyColumn,
String valueColumn,
boolean ignoreEmpty)
This transformation performs key-value normalization.
|
static DataSet |
CommonEtlUtils.keyValueNormalization(DataSet source,
String normalizeColumns,
String keyColumn,
String valueColumn,
boolean ignoreEmpty,
String doNotNormalizeColumns)
This transformation performs key-value normalization.
|
static DataSet |
CommonEtlUtils.matrix(DataSet drivingDataSet,
int maxColsInRow)
This transformation leaves
|
static DataSet |
CommonEtlUtils.minus(DataSet drivingDataSet,
DataSet dataSetToMinus,
String keys)
Performs minus operations on two data sets.
|
static DataSet |
CommonEtlUtils.pivot(DataSet dataSet,
String theKeys,
String theFields,
String theInclude,
String theExclude,
boolean denorm,
boolean ignoreCase,
boolean doTrim,
int maxFields,
String leading)
This method performs pivoting operations on data set, such as grouping,
de-normalization, etc.
|
static DataSet |
CommonEtlUtils.pivot(DataSet dataSet,
String theKeys,
String theFields,
String theInclude,
String theExclude,
boolean denorm,
boolean ignoreCase,
boolean doTrim,
int maxFields,
String leading,
DataSet drivingDataSet)
This method performs pivoting operations on data set, such as grouping,
de-normalization, etc.
|
static DataSet |
CommonEtlUtils.transform(DataSet source,
List<FieldMapping> mapping)
Transform source data set into destination using given mapping.
|
static DataSet |
CommonEtlUtils.union(DataSet dataSet1,
DataSet dataSet2,
String keys,
boolean unionAll,
String include,
String exclude)
Performs union of the two data sets.
|
Modifier and Type | Method and Description |
---|---|
TypedKeyValue<FieldDef,DataSet> |
DataSet.addField(String fieldName,
int fieldType,
String nativeType,
Object value,
String... separator)
Add the field and the value to the data set.
|
TypedKeyValue<FieldDef,DataSet> |
DataSet.addField(String fieldName,
Object value,
String... separator)
Add the field and the value to the data set.
|
TypedKeyValue<FieldDef,DataSet> |
DataSet.addFieldWithType(String fieldName,
int fieldType,
String nativeType,
Object value)
Add the field and the value to the data set.
|
TypedKeyValue<FieldDef,DataSet> |
DataSet.findField(String fieldName,
String... separator)
Find field.
|
static Map<String,DataSet> |
CommonEtlUtils.normalizeNestedDataSet(DataSet source,
Set<String> toExclude)
Normalize nested data set.
|
static Map<String,DataSet> |
CommonEtlUtils.normalizeNestedDataSet(String parentRowId,
String name,
DataSet source,
Map<String,DataSet> existingDimensions,
Set<String> toExclude)
Normalize nested data set.
|
static LinkedHashMap<String,DataSet> |
CommonEtlUtils.split(DataSet dataSet,
String keys)
Splits the data set on multiple data sets using given key field(s).
|
static LinkedHashMap<String,DataSet> |
CommonEtlUtils.split(DataSet dataSet,
String keys,
int dsSize)
Splits the data set on multiple data sets using given key field(s).
|
Modifier and Type | Method and Description |
---|---|
static DataSet |
CommonEtlUtils.addDimensions(DataSet drivingDataSet,
String keys,
String addColumns,
boolean keepAllFields,
DataSet... dataSetsToJoin)
Add dimensions to the data set.
|
static DataSet |
CommonEtlUtils.addDimensions(DataSet drivingDataSet,
String keys,
String addColumns,
boolean keepAllFields,
DataSet... dataSetsToJoin)
Add dimensions to the data set.
|
void |
DataSet.copyPropertiesFrom(DataSet dataSet)
Copy properties from.
|
static DataSet |
CommonEtlUtils.denormalize(DataSet source,
boolean cleanUp)
Pivot data set which has multiple versions of the same field.
|
static DataSet |
CommonEtlUtils.executeSql(DataSet dataSet,
String sql)
Execute sql on any data set.
|
static DataSet |
CommonEtlUtils.executeSql(DataSet dataSet,
String sql,
TypedKeyValue<String,Object>... args)
Execute sql on any data set.
|
static DataSet |
CommonEtlUtils.executeSql(String sql,
DataSet... dataSets)
Execute sql on arrays of data sets.
|
static DataSet |
CommonEtlUtils.executeSql(String sql,
TypedKeyValue<String,Object>[] args,
DataSet... dataSets)
Execute sql on arrays of data sets.
|
static DataSet |
CommonEtlUtils.extractDimension(String keys,
DataSet drivingDataSet,
String name)
Extract dimension from multidimensional data set.
|
static DataSet |
CommonEtlUtils.filter(DataSet dataSet,
String conditions)
Filter data set and keep the source data set intact.
|
static DataSet |
CommonEtlUtils.filter(DataSet dataSet,
String conditions,
boolean keepOriginal)
Filter data set.
|
static DataSetFields |
CommonEtlUtils.getFieldsAfterIncludeExclude(DataSet dataSet,
Set<String> includeFields,
Set<String> excludeFields)
Gets the map of fields after include and exclude.
|
static Object |
CommonEtlUtils.getFieldValue(DataSet dataSet,
String sql,
String fieldName)
Execute sql on any data set and return value of the given field.
|
static Object |
CommonEtlUtils.getFieldValue(DataSet dataSet,
String sql,
String fieldName,
TypedKeyValue<String,Object>... args)
Execute sql on any data set and return value of the given field.
|
static String |
CommonEtlUtils.getKey(DataSet dataSet,
DataSetRecord record,
Map<String,FieldDef> keys,
boolean ignoreCase,
boolean doTrim)
Gets the string representation of the key for the given record and map of
key fields.
|
static DataSetRecord |
CommonEtlUtils.getRecordAfterInlcudeExclude(DataSet dataSet,
DataSetRecord record,
int cols,
boolean isSelective,
Set<String> includeFields,
Set<String> excludeFields)
Gets the record after inlcude and exclude.
|
static DataSet |
CommonEtlUtils.getSelectedDataSet(DataSet dataSet,
TypedKeyValue<int[],int[]> selected)
Gets the selected data set.
|
static DataSet |
CommonEtlUtils.intersect(DataSet drivingDataSet,
DataSet secondDataSet,
String keys)
Performs intersect operations on two data sets.
|
static DataSet |
CommonEtlUtils.join(DataSet drivingDataSet,
String keys,
String include,
String exclude,
TypedKeyValue<DataSet,Boolean>... dataSetsToJoin)
Joins data sets.
|
static DataSet |
CommonEtlUtils.keyValueDenormalization(DataSet source,
DataSet newDataSet,
String groupByColumns,
String includeColumns,
String keyColumn,
String valueColumn,
boolean ignoreCase,
boolean doTrim,
String fieldsToHave)
This transformation groups rows by combination of 'group by' fields.
|
static DataSet |
CommonEtlUtils.keyValueDenormalization(DataSet source,
DataSet newDataSet,
String groupByColumns,
String includeColumns,
String keyColumn,
String valueColumn,
boolean ignoreCase,
boolean doTrim,
String fieldsToHave,
String combine)
This transformation groups rows by combination of 'group by' fields.
|
static DataSet |
CommonEtlUtils.keyValueNormalization(DataSet source,
String normalizeColumns,
String keyColumn,
String valueColumn,
boolean ignoreEmpty)
This transformation performs key-value normalization.
|
static DataSet |
CommonEtlUtils.keyValueNormalization(DataSet source,
String normalizeColumns,
String keyColumn,
String valueColumn,
boolean ignoreEmpty,
String doNotNormalizeColumns)
This transformation performs key-value normalization.
|
static Object |
CommonEtlUtils.lookup(DataSet dataSet,
String conditions,
String fieldName)
Find the field value using given filter conditions and field name.
|
static DataSet |
CommonEtlUtils.matrix(DataSet drivingDataSet,
int maxColsInRow)
This transformation leaves
|
static DataSetData |
CommonEtlUtils.mergeData(DataSetFields fields,
DataSetData to,
DataSetRecord driving,
DataSet... from)
Merge and normalize data.
|
static DataSet |
CommonEtlUtils.minus(DataSet drivingDataSet,
DataSet dataSetToMinus,
String keys)
Performs minus operations on two data sets.
|
static DataSetData |
CommonEtlUtils.normalizeDataSetData(DataSetFields fields,
DataSetData data,
DataSetRecord driving,
DataSet dataSet)
Normalize data set data using given common list of fields, update given
data.
|
static Map<String,DataSet> |
CommonEtlUtils.normalizeNestedDataSet(DataSet source,
Set<String> toExclude)
Normalize nested data set.
|
static Map<String,DataSet> |
CommonEtlUtils.normalizeNestedDataSet(String parentRowId,
String name,
DataSet source,
Map<String,DataSet> existingDimensions,
Set<String> toExclude)
Normalize nested data set.
|
static DataSet |
CommonEtlUtils.pivot(DataSet dataSet,
String theKeys,
String theFields,
String theInclude,
String theExclude,
boolean denorm,
boolean ignoreCase,
boolean doTrim,
int maxFields,
String leading)
This method performs pivoting operations on data set, such as grouping,
de-normalization, etc.
|
static DataSet |
CommonEtlUtils.pivot(DataSet dataSet,
String theKeys,
String theFields,
String theInclude,
String theExclude,
boolean denorm,
boolean ignoreCase,
boolean doTrim,
int maxFields,
String leading,
DataSet drivingDataSet)
This method performs pivoting operations on data set, such as grouping,
de-normalization, etc.
|
void |
DataSet.setInnerDataSet(boolean innerDataSet,
DataSet parent)
Sets the inner data set flag.
|
void |
DataSet.setParentDataSet(DataSet parentDataSet)
Sets the parent data set.
|
static LinkedHashMap<String,DataSet> |
CommonEtlUtils.split(DataSet dataSet,
String keys)
Splits the data set on multiple data sets using given key field(s).
|
static LinkedHashMap<String,DataSet> |
CommonEtlUtils.split(DataSet dataSet,
String keys,
int dsSize)
Splits the data set on multiple data sets using given key field(s).
|
boolean |
DataSet.structureEquals(DataSet dataSet)
Checks if two datasets are structure equal.
|
static DataSet |
CommonEtlUtils.transform(DataSet source,
List<FieldMapping> mapping)
Transform source data set into destination using given mapping.
|
static DataSet |
CommonEtlUtils.union(DataSet dataSet1,
DataSet dataSet2,
String keys,
boolean unionAll,
String include,
String exclude)
Performs union of the two data sets.
|
abstract boolean |
DataSetVisitor.visit(DataSet dataSet,
DataSetRecord record)
Visit data set record.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,DataSet> |
CommonEtlUtils.normalizeNestedDataSet(String parentRowId,
String name,
DataSet source,
Map<String,DataSet> existingDimensions,
Set<String> toExclude)
Normalize nested data set.
|
Modifier and Type | Method and Description |
---|---|
DataSet |
SourceConnectorParams.getDataSet()
Gets data set.
|
DataSet |
BaseStreamingPackage.getDataSet()
Gets the data set.
|
static DataSet |
ConnectorUtils.str2DataSet(DataSet dataSet,
String connectorClassName,
String parameters,
String value)
Populate dataset using given string and connector class name.
|
Modifier and Type | Method and Description |
---|---|
void |
BaseDataSetConnector.addValue(Object colValue,
DataSetRecord record,
DataSet dataSet)
Adds value to the current field of the current record.
|
void |
BaseDataSetConnector.basePostPersist(DataSetConnectorParams params,
DataSet dataSet,
Driver driver)
Executed when persisting is done.
|
void |
DataSetConnector.cleanUp(P params,
DataSet dataSet,
Driver driver)
Cleans up after DataSetConnector populated or persisted DataSet.
|
void |
SourceConnector.cleanUp(SourceConnectorParams params,
DataSet dataSet,
Driver driver) |
static String |
ConnectorUtils.dataSet2Str(DataSet dataSet,
String connectorClassName,
String parameters)
Convert given dataset to the string using given connector.
|
void |
DataSetConnector.inlinePersist(P params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records)
Persists data set row.
|
void |
SourceConnector.inlinePersist(SourceConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
AddFieldValueCallback.onAddFieldValue(DataSet dataSet,
Driver driver,
DataSetRecord record,
FieldDef fieldDef)
Called when value is set for the field.
|
void |
AddRecordCallback.onAddRecord(DataSet dataSet,
Driver driver,
DataSetRecord record,
int index,
String crudAction,
String target)
Called when record is added to the data set.
|
void |
AfterCallback.onAfter(DataSet dataSet,
Driver driver)
Executed when DataSetConnector finishes populating data set.
|
void |
BeforeCallback.onBefore(DataSet dataSet,
Driver driver)
Executed when DataSetConnector starts populating data set.
|
ConnectorResult |
DataSetConnector.persist(P params,
DataSet dataSet,
Driver driver)
Persists data set.
|
ConnectorResult |
SourceConnector.persist(SourceConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
DataSetConnector.populate(P params,
DataSet dataSet,
Driver driver)
Populates data set.
|
ConnectorResult |
SourceConnector.populate(SourceConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
DataSetConnector.postPersist(P params,
DataSet dataSet,
Driver driver)
Called when DataSetConnector finished persisting data set.
|
void |
SourceConnector.postPersist(SourceConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
DataSetConnector.prePersist(P params,
DataSet dataSet,
Driver driver)
Called when DataSetConnector starts persisting data set.
|
void |
SourceConnector.prePersist(SourceConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
SourceConnectorParams.setDataSet(DataSet value)
Set data set.
|
void |
BaseStreamingPackage.setDataSet(DataSet dataSet)
Sets the data set.
|
static DataSet |
ConnectorUtils.str2DataSet(DataSet dataSet,
String connectorClassName,
String parameters,
String value)
Populate dataset using given string and connector class name.
|
ConnectorResult |
DataSetConnector.writeMetaData(P params,
DataSet dataSet,
Driver driver)
Writes meta data.
|
ConnectorResult |
SourceConnector.writeMetaData(SourceConnectorParams params,
DataSet dataSet,
Driver driver) |
Modifier and Type | Method and Description |
---|---|
void |
ExcelXlsxConnector.cleanUp(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelConnector.cleanUp(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelXlsxConnector.inlinePersist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
ExcelConnector.inlinePersist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
ConnectorResult |
ExcelXlsxConnector.persist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
ExcelConnector.persist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
ExcelXlsxConnector.populate(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
ExcelConnector.populate(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelXlsxConnector.postPersist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelConnector.postPersist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelXlsxConnector.prePersist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelConnector.prePersist(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ExcelXlsxConnector.process(org.apache.poi.openxml4j.opc.OPCPackage xlsxPackage,
String sheetName,
ExcelConnectorParams params,
DataSet dataSet,
Driver driver)
Initiates the processing of the XLS workbook file.
|
void |
ExcelXlsxConnector.processSheet(org.apache.poi.xssf.model.StylesTable styles,
org.apache.poi.xssf.eventusermodel.ReadOnlySharedStringsTable strings,
InputStream sheetInputStream,
ExcelConnectorParams params,
DataSet dataSet,
Driver driver)
Parses and shows the content of one sheet using the specified styles and
shared-strings tables.
|
void |
ExcelConnectorParams.updateFilenameAndSheetName(DataSet dataSet)
Update filename and woksheet name.
|
ConnectorResult |
ExcelXlsxConnector.writeMetaData(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
ExcelConnector.writeMetaData(ExcelConnectorParams params,
DataSet dataSet,
Driver driver) |
Constructor and Description |
---|
XlsProcessor(ExcelConnectorParams params,
DataSet dataSet,
Driver driver)
Instantiates a new XlsProcessor.
|
XSSFSheetHandler(org.apache.poi.xssf.model.StylesTable styles,
org.apache.poi.xssf.eventusermodel.ReadOnlySharedStringsTable strings,
ExcelConnectorParams params,
DataSet dataSet,
Driver driver)
Accepts objects needed while parsing.
|
Modifier and Type | Method and Description |
---|---|
void |
HtmlConnector.cleanUp(HtmlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
HtmlConnector.inlinePersist(HtmlConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
ConnectorResult |
HtmlConnector.persist(HtmlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
HtmlConnector.populate(HtmlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
HtmlConnector.postPersist(HtmlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
HtmlConnector.prePersist(HtmlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
HtmlConnector.writeMetaData(HtmlConnectorParams params,
DataSet dataSet,
Driver driver) |
Modifier and Type | Method and Description |
---|---|
static String |
JsonDatasetConnector.asString(DataSet dataSet,
Driver driver)
Convert data set to the json object and return a json string.
|
static String |
JsonConnector.asString(DataSet dataSet,
Driver driver)
Convert data set to the json object and return a json string.
|
void |
JsonConnector.cleanUp(JsonConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
JsonDatasetConnector.cleanUp(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
JsonConnector.inlinePersist(JsonConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
JsonDatasetConnector.inlinePersist(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
ConnectorResult |
JsonConnector.persist(JsonConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
JsonDatasetConnector.persist(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
JsonConnector.populate(JsonConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
JsonDatasetConnector.populate(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
JsonConnector.postPersist(JsonConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
JsonDatasetConnector.postPersist(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
JsonConnector.prePersist(JsonConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
JsonDatasetConnector.prePersist(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
JsonConnector.writeMetaData(JsonConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
JsonDatasetConnector.writeMetaData(JsonDatasetConnectorParams params,
DataSet dataSet,
Driver driver) |
Constructor and Description |
---|
JsonStreamingPackage(DataSet dataSet,
Driver driver,
JsonConnectorParams params) |
Modifier and Type | Method and Description |
---|---|
void |
PdfConnector.cleanUp(PdfConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
PdfConnector.inlinePersist(PdfConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
ConnectorResult |
PdfConnector.persist(PdfConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
PdfConnector.populate(PdfConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
PdfConnector.postPersist(PdfConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
PdfConnector.prePersist(PdfConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
PdfConnector.writeMetaData(PdfConnectorParams params,
DataSet dataSet,
Driver driver) |
Modifier and Type | Method and Description |
---|---|
DataSet |
ConnectorServiceImpl.populateDataSet(ConnectorRequest request)
Populates data set.
|
DataSet |
ConnectorService.populateDataSet(ConnectorRequest request)
Populates data set.
|
Modifier and Type | Method and Description |
---|---|
ConnectorResult |
ConnectorServiceImpl.persistDataSet(ConnectorRequest request,
DataSet dataSet)
Persists data set.
|
ConnectorResult |
ConnectorService.persistDataSet(ConnectorRequest request,
DataSet dataSet)
Persists data set.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlConnector.cleanUp(SqlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
SqlConnector.inlinePersist(SqlConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
ConnectorResult |
SqlConnector.persist(SqlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
SqlConnector.populate(SqlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
SqlConnector.postPersist(SqlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
SqlConnector.prePersist(SqlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
SqlConnector.writeMetaData(SqlConnectorParams params,
DataSet dataSet,
Driver driver) |
Modifier and Type | Method and Description |
---|---|
void |
ClobConnector.cleanUp(ClobConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
KeyValueConnector.cleanUp(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
TextConnector.cleanUp(TextConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ClobConnector.inlinePersist(ClobConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
KeyValueConnector.inlinePersist(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
TextConnector.inlinePersist(TextConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
ConnectorResult |
ClobConnector.persist(ClobConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
KeyValueConnector.persist(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
TextConnector.persist(TextConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
ClobConnector.populate(ClobConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
KeyValueConnector.populate(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
TextConnector.populate(TextConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ClobConnector.postPersist(ClobConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
KeyValueConnector.postPersist(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
TextConnector.postPersist(TextConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
ClobConnector.prePersist(ClobConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
KeyValueConnector.prePersist(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
TextConnector.prePersist(TextConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
ClobConnector.writeMetaData(ClobConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
KeyValueConnector.writeMetaData(KeyValueConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
TextConnector.writeMetaData(TextConnectorParams params,
DataSet dataSet,
Driver driver) |
Constructor and Description |
---|
KeyValueStreamingPackage(DataSet dataSet,
Driver driver,
KeyValueConnectorParams params) |
TextStreamingPackage(DataSet dataSet,
Driver driver,
TextConnectorParams params) |
Modifier and Type | Method and Description |
---|---|
void |
XmlConnector.cleanUp(XmlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
XmlObjectStreamingConnector.cleanUp(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
XmlConnector.inlinePersist(XmlConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
XmlObjectStreamingConnector.inlinePersist(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records) |
void |
XmlObjectConnector.parseNode(XmlUtils xml,
org.w3c.dom.Node node,
XmlObjectConnectorParams params,
Driver driver,
Map<Integer,Boolean> types,
DataSet dataSet,
DataSetRecord record,
XmlUtils.NodeType rootNodeType,
DataSet newDataSet) |
DataSetRecord |
XmlObjectConnector.parseXml(XmlUtils xml,
org.w3c.dom.Node root,
XmlObjectConnectorParams params,
Driver driver,
Map<Integer,Boolean> types,
DataSet dataSet,
DataSetRecord record,
XmlUtils.NodeType rootNodeType,
org.w3c.dom.NodeList nodeList,
XmlUtils.NodeType thisNodeType)
Parses the xml and creates a hierarchy of the data sets.
|
ConnectorResult |
XmlConnector.persist(XmlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
XmlObjectStreamingConnector.persist(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
XmlConnector.populate(XmlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
XmlObjectStreamingConnector.populate(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
XmlObjectConnector.populate(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
XmlConnector.postPersist(XmlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
XmlObjectStreamingConnector.postPersist(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
XmlConnector.prePersist(XmlConnectorParams params,
DataSet dataSet,
Driver driver) |
void |
XmlObjectStreamingConnector.prePersist(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
XmlConnector.writeMetaData(XmlConnectorParams params,
DataSet dataSet,
Driver driver) |
ConnectorResult |
XmlObjectStreamingConnector.writeMetaData(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver) |
Constructor and Description |
---|
XmlStreamingPackage(DataSet dataSet,
Driver driver,
XmlObjectConnectorParams params) |
Modifier and Type | Method and Description |
---|---|
DataSet |
TaskResult.getDataSet()
Gets the data set.
|
DataSet |
Task.getDataSet()
Gets the data set.
|
DataSet |
Source.getDataSet() |
DataSet |
Destination.getDataSet() |
DataSet |
Block.getDataSet()
Gets the
DataSet object associated with the scenario block. |
static DataSet |
Extractor.lookup(EtlConfig config,
Scenario scenario,
String connectionName,
String name,
String sql,
TypedKeyValue<String,Object>... args)
Extract data set, and optionally execute provided SQL statement.
|
static DataSet |
Extractor.lookupNoCache(EtlConfig config,
Scenario scenario,
String connectionName,
String name,
String sql,
TypedKeyValue<String,Object>... args)
Extract data set, and optionally execute provided SQL statement.
|
Modifier and Type | Method and Description |
---|---|
void |
MetadataTracker.createTableAndIndexesOrChangeFieldDataTypeIfNeeded(Scenario scenario,
EtlConfig config,
Destination destination,
DataSet dataSet,
Alias alias,
CodeGen codeGen)
Creates the table and indexes or change field data type if needed.
|
TaskResult |
TaskExecutor.executeOnExceptionTasks(EtlConfig config,
Block block,
Scenario scenario,
DataSet dataSet)
Executes ON_EXCEPTION tasks for the
Block if any exist. |
TaskResult |
OnTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario)
Executes
task after extract or load finished. |
TaskResult |
TaskExecutor.executePostTasks(EtlConfig config,
Block block,
Scenario scenario,
DataSet dataSet)
Executes POST tasks for the
Block if any exist. |
TaskResult |
TaskExecutor.executePreTasks(EtlConfig config,
Block block,
Scenario scenario,
DataSet dataSet)
Executes PRE tasks for the
Block if any exist. |
void |
EtlMetricsTracker.finishTrackingExtract(String name,
DataSet dataSet,
String exception)
Finish tracking extract.
|
boolean |
MetadataTracker.needToUpdateMetadataInTarget(Destination destination,
DataSet dataSet)
Checks if ETL engine needs to update metadata for the destination based
on the existing data.
|
void |
TaskResult.setDataSet(DataSet value)
Sets the data set.
|
void |
Task.setDataSet(DataSet value)
Sets the data set.
|
void |
Source.setDataSet(DataSet value,
boolean adjust) |
void |
Destination.setDataSet(DataSet value,
boolean adjust) |
void |
Block.setDataSet(DataSet value,
boolean adjust)
Sets the
DataSet object associated with the scenario block. |
void |
EtlMetricsTracker.startTrackingExtract(String name,
Source source,
DataSet dataSet,
Destination destination,
String flow)
Start tracking extract.
|
void |
MetadataTracker.updateMetadataInTarget(EtlConfig config,
Destination destination,
DataSet dataSet,
Scenario scenario)
Update metadata in target.
|
void |
MetadataTracker.updateOrderOfFields(Destination destination,
DataSet dataSet)
Update order of fields.
|
Constructor and Description |
---|
TaskResult(DataSet dataSet)
Instantiates a new task result.
|
TaskResult(TaskResult.TaskResultCode result,
DataSet dataSet)
Instantiates a new task result.
|
Modifier and Type | Method and Description |
---|---|
TaskResult |
FileManagerTask.execute(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario)
Execute.
|
TaskResult |
XslTransormTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Validator.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Union.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Transpose.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
SqlTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
SplitDataSet.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
ScriptTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
RemoveDuplicates.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
RegexpTransformator.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Populate.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Pivot.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Order.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
NormalizeNestedDataSet.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario parentScenario) |
TaskResult |
Minus.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Matrix.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
MailTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
KeyValueTransformator.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
KeyValueNormTransformator.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Join.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Intersect.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
FilterDataSet.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
Filter.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
FileMerge.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
FileManagerTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
ExtractDimension.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
EvalTransformator.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
CopyIntoDestinationTableTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
CmdTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
AddDimension.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
Modifier and Type | Method and Description |
---|---|
TaskResult |
InformixDbAccessTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
Modifier and Type | Method and Description |
---|---|
TaskResult |
OracleLoadTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
OracleExtractTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
TaskResult |
OracleCopyTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
Modifier and Type | Method and Description |
---|---|
TaskResult |
CopyIntoRedshiftTableTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
Modifier and Type | Method and Description |
---|---|
TaskResult |
CopyIntoTableTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
Modifier and Type | Method and Description |
---|---|
TaskResult |
BcpTask.executePostTask(EtlConfig config,
Task task,
DataSet dataSet,
Scenario scenario) |
Modifier and Type | Method and Description |
---|---|
static boolean |
EtlUtils.checkCondition(EtlConfig config,
String name,
Scenario scenario,
ConditionalExecution conditionalExecution,
DataSet dataSet)
Checks condition.
|
Modifier and Type | Method and Description |
---|---|
String |
Driver.getColumns(String name,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository)
Gets the columns for "create table" sql.
|
String |
AbstractDriver.getColumns(String name,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository) |
String |
SimpleDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
Driver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository)
Gets the "create table" sql.
|
String |
SimpleDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
Driver.getCursorLoopEndSql(String name,
DataSet dataSet)
Gets the "loop end" sql for the cursor.
|
String |
SimpleDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
Driver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet)
Gets the "loop start" sql for the cursor.
|
String |
SimpleDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
Driver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet)
Gets the "declare cursor" sql.
|
String |
SimpleDriver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
String |
Driver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables)
Gets the "declare cursor variable" sql.
|
Modifier and Type | Method and Description |
---|---|
String |
Db2Driver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
Db2Driver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
Db2Driver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
Db2Driver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
Db2Driver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
Modifier and Type | Method and Description |
---|---|
String |
InformixDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
InformixDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
InformixDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
InformixDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
InformixDriver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
Modifier and Type | Method and Description |
---|---|
String |
MySqlDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
MySqlDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
MySqlDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
MySqlDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
MySqlDriver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
Modifier and Type | Method and Description |
---|---|
String |
OracleDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
OracleDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
OracleDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
OracleDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
OracleDriver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
Modifier and Type | Method and Description |
---|---|
String |
RedshiftDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
PostgresDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
PostgresDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
PostgresDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
PostgresDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
PostgresDriver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
Modifier and Type | Method and Description |
---|---|
String |
SnowflakeDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
Modifier and Type | Method and Description |
---|---|
String |
SybaseDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
MsSqlDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
AzureSynapseAnalyticsDriver.getCreateTableSql(String name,
DataSet dataSet,
boolean isTemporary,
String key,
FieldsRepository fieldsRepository) |
String |
SybaseDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
MsSqlDriver.getCursorLoopEndSql(String name,
DataSet dataSet) |
String |
SybaseDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
MsSqlDriver.getCursorLoopStartSql(String name,
String cursorSql,
DataSet dataSet) |
String |
SybaseDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
MsSqlDriver.getDeclareCursorSql(String sql,
String name,
String cursorSql,
DataSet dataSet) |
String |
MsSqlDriver.getDeclareCursorVarSql(String sql,
DataSet dataSet,
String key,
FieldsRepository fieldsRepository,
Set<String> variables) |
String |
MsSqlDriver.getFetchNextSql(String name,
DataSet dataSet)
Gets the "fetch next" sql.
|
Modifier and Type | Method and Description |
---|---|
DataSet |
JdbcMetadata.getAllRefs(String catalog,
String schema,
String pattern,
String type)
Get the all references including inner tables.
|
DataSet |
BaseMetadata.getColumns(Alias alias,
DataSet dataSet,
DataSetConnectorParams params,
DataSetConnector connector)
Gets the columns.
|
DataSet |
FileMetadata.getColumns(DataSet dataSet)
Gets the columns.
|
DataSet |
JdbcMetadata.getDbFunctions(String catalog,
String schema,
String pattern,
String type)
Gets the database functions.
|
DataSet |
JdbcMetadata.getDbProps(String catalog,
String schema,
String pattern,
String type)
Gets the database properties.
|
DataSet |
BaseMetadata.getDefaultColumns(Alias alias,
DataSet dataSet)
Gets the default columns.
|
DataSet |
JdbcMetadata.getEKColumns(String catalog,
String schema,
String pattern,
String type)
Gets the external key columns.
|
DataSet |
JdbcMetadata.getFKColumns(String catalog,
String schema,
String pattern,
String type)
Gets the foreign key columns.
|
DataSet |
JdbcMetadata.getFunctParameters(String catalog,
String schema,
String pattern,
String type)
Gets the function parameters.
|
DataSet |
JdbcMetadata.getFuncts(String catalog,
String schema,
String pattern,
String type)
Gets the functions.
|
DataSet |
JdbcMetadata.getIndexColumns(String catalog,
String schema,
String pattern,
String type)
Gets the index columns.
|
DataSet |
Metadata.getMetadataByType(String catalog,
String schema,
String pattern,
String type,
String metadataId)
Gets the metadata by type.
|
DataSet |
BaseMetadata.getMetadataByType(String catalog,
String schema,
String pattern,
String type,
String metadataId) |
DataSet |
Metadata.getMetadataByTypePreserveException(String catalog,
String schema,
String pattern,
String type,
String metadataId)
Gets the metadata by type and preserve exception.
|
DataSet |
BaseMetadata.getMetadataByTypePreserveException(String catalog,
String schema,
String pattern,
String type,
String metadataId) |
DataSet |
JdbcMetadata.getParameters(String catalog,
String schema,
String pattern,
String type)
Gets the parameters.
|
DataSet |
JdbcMetadata.getPKColumns(String catalog,
String schema,
String pattern,
String type)
Gets the primary key columns.
|
DataSet |
JdbcMetadata.getProcParameters(String catalog,
String schema,
String pattern,
String type)
Gets the procedure parameters.
|
DataSet |
JdbcMetadata.getProcs(String catalog,
String schema,
String pattern,
String type)
Gets the procedures.
|
DataSet |
JdbcMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the table columns.
|
DataSet |
JdbcMetadata.getTableEKs(String catalog,
String schema,
String pattern,
String type)
Gets the table external keys.
|
DataSet |
JdbcMetadata.getTableEKs(String catalog,
String schema,
String pattern,
String type,
DataSet dataSet)
Gets the table external keys.
|
DataSet |
JdbcMetadata.getTableFKs(String catalog,
String schema,
String pattern,
String type)
Gets the table foreign keys.
|
DataSet |
JdbcMetadata.getTableIndexes(String catalog,
String schema,
String pattern,
String type)
Gets the table indexes.
|
DataSet |
JdbcMetadata.getTablePKs(String catalog,
String schema,
String pattern,
String type)
Gets the table primary key.
|
DataSet |
JdbcMetadata.getTablePrivs(String catalog,
String schema,
String pattern,
String type)
Gets the table privileges.
|
abstract DataSet |
FileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type)
Gets the tables by type.
|
DataSet |
DefaultFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
JdbcMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type)
Gets the tables by type.
|
abstract DataSet |
FileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type)
Gets the tables by type.
|
DataSet |
DefaultFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
JdbcMetadata.getTypes(String catalog,
String schema,
String pattern,
String type)
Gets the types.
|
DataSet |
Metadata.searchDatabase(DatabaseFilter filter)
Search database objects.
|
DataSet |
BaseMetadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
BaseMetadata.getColumns(Alias alias,
DataSet dataSet,
DataSetConnectorParams params,
DataSetConnector connector)
Gets the columns.
|
DataSet |
FileMetadata.getColumns(DataSet dataSet)
Gets the columns.
|
DataSet |
BaseMetadata.getDefaultColumns(Alias alias,
DataSet dataSet)
Gets the default columns.
|
DataSet |
JdbcMetadata.getTableEKs(String catalog,
String schema,
String pattern,
String type,
DataSet dataSet)
Gets the table external keys.
|
boolean |
JdbcMetadata.isUnique(DataSet dataSet,
int row)
Checks if index is unique using given data set with indexes and row which
is a number of the index.
|
static void |
JdbcMetadata.populateTables(List<String> objects,
DataSet tables,
Metadata metadata,
String wildcard,
Set<String> excludedObjects,
Set<String> includedObjects)
Populate tables.
|
Modifier and Type | Method and Description |
---|---|
DataSet |
Db2Metadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table constraints.
|
DataSet |
Db2Metadata.getFunctParameters(String catalog,
String schema,
String pattern,
String type) |
DataSet |
Db2Metadata.getFuncts(String catalog,
String schema,
String pattern,
String type) |
DataSet |
Db2Metadata.getIndexColumns(String catalog,
String schema,
String pattern,
String type) |
DataSet |
Db2Metadata.getPackages(String catalog,
String schema,
String pattern,
String type)
Gets the packages.
|
DataSet |
Db2Metadata.getProcParameters(String catalog,
String schema,
String pattern,
String type) |
DataSet |
Db2Metadata.getProcs(String catalog,
String schema,
String pattern,
String type) |
DataSet |
Db2Metadata.getSequences(String catalog,
String schema,
String pattern,
String type)
Gets the sequences.
|
DataSet |
Db2Metadata.getTableIndexes(String catalog,
String schema,
String pattern,
String type) |
DataSet |
Db2Metadata.getTablesByType(String catalog,
String schema,
String pattern,
String type)
Gets the tables by type.
|
DataSet |
Db2Metadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
Db2Metadata.getUserTypes(String catalog,
String schema,
String pattern,
String type)
Gets the user defined types.
|
DataSet |
Db2Metadata.getXmlSchemas(String catalog,
String schema,
String pattern,
String type)
Gets the xml schemas.
|
DataSet |
Db2Metadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
ExcelXlsxFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the worksheet columns.
|
DataSet |
ExcelFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the worksheet columns.
|
DataSet |
ExcelXlsxFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
ExcelFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
ExcelXlsxFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
ExcelOdbcMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
ExcelFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
Modifier and Type | Method and Description |
---|---|
DataSet |
InformixMetadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table constraints.
|
DataSet |
InformixMetadata.getFuncts(String catalog,
String schema,
String pattern,
String type) |
DataSet |
InformixMetadata.getIndexColumns(String catalog,
String schema,
String pattern,
String type) |
DataSet |
InformixMetadata.getProcParameters(String catalog,
String schema,
String pattern,
String type) |
DataSet |
InformixMetadata.getProcs(String catalog,
String schema,
String pattern,
String type) |
DataSet |
InformixMetadata.getSequences(String catalog,
String schema,
String pattern,
String type)
Gets the sequences.
|
DataSet |
InformixMetadata.getSynonyms(String catalog,
String schema,
String pattern,
String type)
Gets the synonyms.
|
DataSet |
InformixMetadata.getTableIndexes(String catalog,
String schema,
String pattern,
String type) |
DataSet |
InformixMetadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
InformixMetadata.getUserTypes(String catalog,
String schema,
String pattern,
String type)
Gets the user defined types.
|
DataSet |
InformixMetadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
JsonMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
JsonDatasetMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
JsonMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
JsonDatasetMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
JsonMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
JsonDatasetMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
Modifier and Type | Method and Description |
---|---|
DataSet |
MySqlMetadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table constraints.
|
DataSet |
MySqlMetadata.getFuncts(String catalog,
String schema,
String pattern,
String type) |
DataSet |
MySqlMetadata.getProcs(String catalog,
String schema,
String pattern,
String type) |
DataSet |
MySqlMetadata.getRoutines(String schema,
String procType)
Gets the routines.
|
DataSet |
MySqlMetadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
MySqlMetadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
OracleMetadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table or view constraints.
|
DataSet |
OracleMetadata.getDbLinks(String catalog,
String schema,
String pattern,
String type)
Gets the database links.
|
DataSet |
OracleMetadata.getDirectories(String catalog,
String schema,
String pattern,
String type)
Gets the directories.
|
DataSet |
OracleMetadata.getFuncts(String catalog,
String schema,
String pattern,
String type) |
DataSet |
OracleMetadata.getIndexColumns(String catalog,
String schema,
String pattern,
String type) |
DataSet |
OracleMetadata.getJavaClasses(String catalog,
String schema,
String pattern,
String type)
Gets the Java classes.
|
DataSet |
OracleMetadata.getPackageBody(String catalog,
String schema,
String pattern,
String type)
Gets the package body.
|
DataSet |
OracleMetadata.getPackages(String catalog,
String schema,
String pattern,
String type)
Gets the packages.
|
DataSet |
OracleMetadata.getParameters(String catalog,
String schema,
String pattern,
String type,
String metadataId) |
DataSet |
OracleMetadata.getProcs(String catalog,
String schema,
String pattern,
String type) |
DataSet |
OracleMetadata.getQueues(String catalog,
String schema,
String pattern,
String type)
Gets the queues.
|
DataSet |
OracleMetadata.getQueueTables(String catalog,
String schema,
String pattern,
String type)
Gets the queue tables.
|
DataSet |
OracleMetadata.getRecycleBinItems(String catalog,
String schema,
String pattern,
String type)
Gets the recycle bin items.
|
DataSet |
OracleMetadata.getSequences(String catalog,
String schema,
String pattern,
String type)
Gets the sequences.
|
DataSet |
OracleMetadata.getSynonyms(String catalog,
String schema,
String pattern)
Gets the synonyms.
|
DataSet |
OracleMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type) |
DataSet |
OracleMetadata.getTableIndexes(String catalog,
String schema,
String pattern,
String type) |
DataSet |
OracleMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
OracleMetadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
OracleMetadata.getUserTypes(String catalog,
String schema,
String pattern,
String type)
Gets the user defined types.
|
DataSet |
OracleMetadata.getViews(String catalog,
String schema,
String pattern)
Gets the views.
|
DataSet |
OracleMetadata.getXmlSchemas(String catalog,
String schema,
String pattern,
String type)
Gets the xml schemas.
|
DataSet |
OracleMetadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
PostgresMetadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table constraints.
|
DataSet |
PostgresMetadata.getSequences(String catalog,
String schema,
String pattern,
String type)
Gets the sequences.
|
DataSet |
PostgresMetadata.getTriggerEvents(String catalog,
String schema,
String pattern,
String type)
Gets the trigger events.
|
DataSet |
PostgresMetadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
PostgresMetadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
MsSqlMetadata.getAssemblies(String catalog,
String schema,
String pattern,
String type)
Gets the assemblies.
|
DataSet |
SybaseMetadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table constraints.
|
DataSet |
MsSqlMetadata.getConstraints(String catalog,
String schema,
String pattern,
String type)
Gets table constraints.
|
DataSet |
SybaseMetadata.getFuncts(String catalog,
String schema,
String pattern,
String type) |
DataSet |
MsSqlMetadata.getFuncts(String catalog,
String schema,
String pattern,
String type) |
DataSet |
SybaseMetadata.getProcs(String catalog,
String schema,
String pattern,
String type) |
DataSet |
MsSqlMetadata.getProcs(String catalog,
String schema,
String pattern,
String type) |
DataSet |
SybaseMetadata.getRoutines(String catalog,
String schema,
String types)
Gets the routines.
|
DataSet |
MsSqlMetadata.getRoutines(String catalog,
String schema,
String procType)
Gets the routines.
|
DataSet |
MsSqlMetadata.getSynonyms(String catalog,
String schema,
String pattern,
String type)
Gets the synonyms.
|
DataSet |
SybaseMetadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
MsSqlMetadata.getTriggers(String catalog,
String schema,
String pattern,
String type)
Gets the triggers.
|
DataSet |
SybaseMetadata.getUserTypes(String catalog,
String schema,
String pattern,
String type)
Gets the user defined types.
|
DataSet |
MsSqlMetadata.getUserTypes(String catalog,
String schema,
String pattern,
String type)
Gets the user defined types.
|
DataSet |
SybaseMetadata.searchDatabase(DatabaseFilter filter) |
DataSet |
MsSqlMetadata.searchDatabase(DatabaseFilter filter) |
Modifier and Type | Method and Description |
---|---|
DataSet |
TextFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
KeyValueFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
ClobFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
TextFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
KeyValueFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
ClobFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
TextFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
KeyValueFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
ClobFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
Modifier and Type | Method and Description |
---|---|
DataSet |
XmlObjectFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
XmlFileMetadata.getTableColumns(String catalog,
String schema,
String pattern,
String type)
Gets the data set columns.
|
DataSet |
XmlObjectFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
XmlFileMetadata.getTablesByType(InputStream inputSteam,
String name,
String pattern,
String type) |
DataSet |
XmlObjectFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
DataSet |
XmlFileMetadata.getTablesByType(String catalog,
String schema,
String pattern,
String type) |
Modifier and Type | Method and Description |
---|---|
Map<String,DataSet> |
SqlResult.getDataSets()
Gets the map of named data sets.
|
Constructor and Description |
---|
SqlResult(String result,
Map<String,DataSet> dataSets)
Instantiates a new sql result.
|
SqlResult(String result,
Map<String,DataSet> dataSets,
boolean canCommit,
boolean canRollback)
Instantiates a new sql result.
|
Modifier and Type | Method and Description |
---|---|
static void |
SqlUtils.executeScript(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static void |
SqlUtils.executeScript(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
boolean isCallable)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static void |
SqlUtils.executeScript(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
boolean isCallable,
boolean supportsPrepared)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static void |
SqlUtils.executeScriptAndSaveException(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
boolean isCallable,
boolean supportsPrepared,
InfoLogger infoLogger)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static void |
SqlUtils.executeScriptAndSaveException(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
boolean isCallable,
InfoLogger infoLogger)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static String |
SqlUtils.getAlterTableAddColumns(String tableName,
DataSet dataSet,
List<String> missingColumns,
Driver driver)
Gets the SQL for "alter table add column".
|
static String |
SqlUtils.getAlterTableAddColumns(String tableName,
DataSet dataSet,
List<String> missingColumns,
Driver driver,
boolean withNotNull)
Gets the SQL for "alter table add column".
|
static String |
SqlUtils.getFieldsSql(DataSet dataSet,
Driver driver,
String key,
FieldsRepository fieldsRepository)
Gets the fields definitions for all fields in the data set.
|
static String |
SqlUtils.getFieldsSql(DataSet dataSet,
Driver driver,
String key,
FieldsRepository fieldsRepository,
boolean withNotNull)
Gets the fields definitions for all fields in the data set.
|
static String |
SqlUtils.getInsertSelectSql(DataSet dataSet,
Driver driver,
String from,
String to,
boolean withTruncate) |
static void |
SqlUtils.populateDataSet(DataSet dataSet,
Driver driver,
ResultSet rs,
ListHashMap<String,String> fieldsMapping,
boolean unique,
boolean checkKeyField)
Populates data set from the result set.
|
static void |
SqlUtils.populateDataSet(DataSet dataSet,
Driver driver,
ResultSet rs,
ListHashMap<String,String> fieldsMapping,
boolean unique,
boolean checkKeyField,
String filterByField,
String filterByFieldValue)
Populates data set from the result set.
|
static void |
SqlUtils.populateDataSet(DataSet dataSet,
Driver driver,
ResultSet rs,
ListHashMap<String,String> fieldsMapping,
boolean unique,
boolean checkKeyField,
String filterByField,
String filterByFieldValue,
int maxRows,
boolean ignoreGetObjectErrors)
Populates data set from the result set.
|
Copyright © 2010-2020 Toolsverse. All Rights Reserved.