Package org.apache.nifi.schema.inference

Class CachedSchemaAccessStrategy

java.lang.Object

org.apache.nifi.schema.inference.CachedSchemaAccessStrategy

All Implemented Interfaces:

SchemaAccessStrategy

public class CachedSchemaAccessStrategy
extends Object
implements SchemaAccessStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final SchemaAccessStrategy	backupStrategy
private final org.apache.nifi.logging.ComponentLog	logger
private final RecordSchemaCacheService	schemaCacheService

Constructor Summary

Constructors

Constructor	Description
CachedSchemaAccessStrategy(RecordSchemaCacheService schemaCacheService, SchemaAccessStrategy backupStrategy, org.apache.nifi.logging.ComponentLog logger)

Method Summary

Modifier and Type	Method	Description
RecordSchema	getSchema(Map<String,String> variables, InputStream contentStream, RecordSchema readSchema)
Set<SchemaField>	getSuppliedSchemaFields()

Methods inherited from class java.lang.Object

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

Field Details

schemaCacheService

private final RecordSchemaCacheService schemaCacheService

backupStrategy

private final SchemaAccessStrategy backupStrategy

logger

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

Constructor Details

CachedSchemaAccessStrategy

public CachedSchemaAccessStrategy(RecordSchemaCacheService schemaCacheService,
 SchemaAccessStrategy backupStrategy,
 org.apache.nifi.logging.ComponentLog logger)

Method Details

getSchema

public RecordSchema getSchema(Map<String,String> variables,
 InputStream contentStream,
 RecordSchema readSchema)
                       throws SchemaNotFoundException,
IOException

Specified by:

getSchema in interface SchemaAccessStrategy

Throws:

SchemaNotFoundException

IOException

getSuppliedSchemaFields

public Set<SchemaField> getSuppliedSchemaFields()

Specified by:

getSuppliedSchemaFields in interface SchemaAccessStrategy