Uses of Class
org.apache.nifi.processors.standard.PutDatabaseRecord.DMLSettings

Packages that use PutDatabaseRecord.DMLSettings

Package	Description
org.apache.nifi.processors.standard

Uses of PutDatabaseRecord.DMLSettings in org.apache.nifi.processors.standard

Methods in org.apache.nifi.processors.standard with parameters of type PutDatabaseRecord.DMLSettings

Modifier and Type	Method	Description
private void	PutDatabaseRecord.checkValuesForRequiredColumns(RecordSchema recordSchema, TableSchema tableSchema, PutDatabaseRecord.DMLSettings settings, NameNormalizer normalizer)
private void	PutDatabaseRecord.executeDML(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile flowFile, Connection con, RecordReader recordReader, String explicitStatementType, PutDatabaseRecord.DMLSettings settings)
(package private) PutDatabaseRecord.SqlAndIncludedColumns	PutDatabaseRecord.generateDelete(RecordSchema recordSchema, String tableName, String deleteKeys, TableSchema tableSchema, PutDatabaseRecord.DMLSettings settings, NameNormalizer normalizer)
(package private) PutDatabaseRecord.SqlAndIncludedColumns	PutDatabaseRecord.generateInsert(RecordSchema recordSchema, String tableName, TableSchema tableSchema, PutDatabaseRecord.DMLSettings settings, NameNormalizer normalizer)
(package private) String	PutDatabaseRecord.generateTableName(PutDatabaseRecord.DMLSettings settings, String catalog, String schemaName, String tableName, TableSchema tableSchema)
(package private) PutDatabaseRecord.SqlAndIncludedColumns	PutDatabaseRecord.generateUpdate(RecordSchema recordSchema, String tableName, String updateKeys, TableSchema tableSchema, PutDatabaseRecord.DMLSettings settings, NameNormalizer normalizer)
private PutDatabaseRecord.SqlAndIncludedColumns	PutDatabaseRecord.getSqlStatement(StatementType statementType, RecordSchema recordSchema, String qualifiedTableName, String updateKeys, TableSchema tableSchema, PutDatabaseRecord.DMLSettings settings, NameNormalizer normalizer)
private Set<String>	PutDatabaseRecord.normalizeKeyColumnNamesAndCheckForValues(RecordSchema recordSchema, String updateKeys, PutDatabaseRecord.DMLSettings settings, Set<String> updateKeyColumnNames, NameNormalizer normalizer)