Package org.apache.nifi.processors.standard.enrichment

Class SqlJoinStrategy

java.lang.Object

org.apache.nifi.processors.standard.enrichment.SqlJoinStrategy

All Implemented Interfaces:

RecordJoinStrategy

public class SqlJoinStrategy
extends Object
implements RecordJoinStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final SqlJoinCache	cache
private final int	defaultPrecision
private final int	defaultScale
static final String	ENRICHMENT_TABLE_NAME
private final org.apache.nifi.logging.ComponentLog	logger
static final String	ORIGINAL_TABLE_NAME
private final org.apache.nifi.components.PropertyValue	sqlPropertyValue

Constructor Summary

Constructors

Constructor	Description
SqlJoinStrategy(SqlJoinCache cache, org.apache.nifi.components.PropertyValue sqlPropertyValue, org.apache.nifi.logging.ComponentLog logger, int defaultPrecision, int defaultScale)

Method Summary

Modifier and Type	Method	Description
private void	closeQuietly(AutoCloseable closeable)
private void	closeQuietly(AutoCloseable... closeables)
RecordJoinResult	join(RecordJoinInput originalInput, RecordJoinInput enrichmentInput, Map<String,String> combinedAttributes, org.apache.nifi.processor.ProcessSession session, RecordSchema outputSchema)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ENRICHMENT_TABLE_NAME

public static final String ENRICHMENT_TABLE_NAME

See Also:

• Constant Field Values

ORIGINAL_TABLE_NAME

public static final String ORIGINAL_TABLE_NAME

See Also:

• Constant Field Values

cache

private final SqlJoinCache cache

logger

private final org.apache.nifi.logging.ComponentLog logger

sqlPropertyValue

private final org.apache.nifi.components.PropertyValue sqlPropertyValue

defaultPrecision

private final int defaultPrecision

defaultScale

private final int defaultScale

Constructor Details

SqlJoinStrategy

public SqlJoinStrategy(SqlJoinCache cache,
 org.apache.nifi.components.PropertyValue sqlPropertyValue,
 org.apache.nifi.logging.ComponentLog logger,
 int defaultPrecision,
 int defaultScale)

Method Details

join

public RecordJoinResult join(RecordJoinInput originalInput,
 RecordJoinInput enrichmentInput,
 Map<String,String> combinedAttributes,
 org.apache.nifi.processor.ProcessSession session,
 RecordSchema outputSchema)
                      throws SQLException

Specified by:

join in interface RecordJoinStrategy

Throws:

SQLException

closeQuietly

private void closeQuietly(AutoCloseable... closeables)

closeQuietly

private void closeQuietly(AutoCloseable closeable)