Package org.apache.nifi.schemaregistry.services

Interface SchemaReferenceReader

All Superinterfaces:

org.apache.nifi.components.ConfigurableComponent, org.apache.nifi.controller.ControllerService

public interface SchemaReferenceReader
extends org.apache.nifi.controller.ControllerService

Service interface responsible for reading Schema Identifier reference information based on attributes or encoded content information

Method Summary

Modifier and Type	Method	Description
SchemaIdentifier	getSchemaIdentifier(Map<String,String> variables, InputStream contentStream)	Get Schema Identifier
Set<SchemaField>	getSuppliedSchemaFields()	Get supplied Record Schema Fields for validation against the set of Record Schema Fields required for writing schema information

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Methods inherited from interface org.apache.nifi.controller.ControllerService

initialize, isStateful, migrateProperties

Method Details

getSchemaIdentifier

SchemaIdentifier getSchemaIdentifier(Map<String,String> variables,
 InputStream contentStream)
                              throws IOException,
SchemaNotFoundException

Get Schema Identifier

Parameters:

variables - Map of variables for Schema Identifier resolution can be null or empty

contentStream - Stream of FlowFile content that may contain encoded Schema Identifier references

Returns:

Schema Identifier

Throws:

IOException - Thrown on failure to read input content stream

SchemaNotFoundException - Thrown on failure to find expected Schema Identifier information

getSuppliedSchemaFields

Set<SchemaField> getSuppliedSchemaFields()

Get supplied Record Schema Fields for validation against the set of Record Schema Fields required for writing schema information

Returns:

Supplied Record Schema Fields