Package org.apache.nifi.schema.inference

Class InferSchemaAccessStrategy<T>

java.lang.Object

org.apache.nifi.schema.inference.InferSchemaAccessStrategy<T>

All Implemented Interfaces:

SchemaAccessStrategy

public class InferSchemaAccessStrategy<T>
extends Object
implements SchemaAccessStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.nifi.logging.ComponentLog	logger
private final RecordSourceFactory<T>	recordSourceFactory
private final SchemaInferenceEngine<T>	schemaInference

Constructor Summary

Constructors

Constructor	Description
InferSchemaAccessStrategy(RecordSourceFactory<T> recordSourceFactory, SchemaInferenceEngine<T> schemaInference, 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

recordSourceFactory

private final RecordSourceFactory<T> recordSourceFactory

schemaInference

private final SchemaInferenceEngine<T> schemaInference

logger

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

Constructor Details

InferSchemaAccessStrategy

public InferSchemaAccessStrategy(RecordSourceFactory<T> recordSourceFactory,
 SchemaInferenceEngine<T> schemaInference,
 org.apache.nifi.logging.ComponentLog logger)

Method Details

getSchema

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

Specified by:

getSchema in interface SchemaAccessStrategy

Throws:

IOException

getSuppliedSchemaFields

public Set<SchemaField> getSuppliedSchemaFields()

Specified by:

getSuppliedSchemaFields in interface SchemaAccessStrategy