@Tags(value={"avro","result","set","writer","serializer","record","recordset","row"}) @CapabilityDescription(value="Writes the contents of a RecordSet in Binary Avro format.") public class AvroRecordSetWriter extends SchemaRegistryRecordSetWriter implements RecordSetWriterFactory
| Constructor and Description |
|---|
AvroRecordSetWriter() |
| Modifier and Type | Method and Description |
|---|---|
RecordSetWriter |
createWriter(ComponentLog logger,
RecordSchema recordSchema,
java.io.OutputStream out)
Creates a new RecordSetWriter that is capable of writing record contents to an OutputStream.
|
protected java.util.Collection<ValidationResult> |
customValidate(ValidationContext validationContext)
Allows subclasses to perform their own validation on the already set
properties.
|
protected AllowableValue |
getDefaultSchemaWriteStrategy() |
protected java.util.Set<SchemaField> |
getRequiredSchemaFields(ValidationContext validationContext) |
protected java.util.List<AllowableValue> |
getSchemaWriteStrategyValues() |
protected java.util.List<PropertyDescriptor> |
getSupportedPropertyDescriptors()
Allows subclasses to register which property descriptor objects are
supported.
|
getConfigurationContext, getDefaultSchemaAccessStrategy, getSchemaAccessStrategyValues, getSchemaAccessWriter, getSchemaWriteStrategy, getSchemaWriteStrategyDescriptor, storeSchemaWriteStrategygetSchema, getSchema, getSchemaAccessStrategy, getSchemaAccessStrategy, getSchemaAccessStrategy, getSchemaAcessStrategyDescriptor, getSuppliedSchemaFields, storeSchemaAccessStrategyabstractClearConfigContext, abstractStoreConfigContext, disabled, enabled, getControllerServiceLookup, getIdentifier, getLogger, getProperty, getStateManager, init, initialize, isEnabledequals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, hashCode, onPropertyModified, toString, validateclone, finalize, getClass, notify, notifyAll, wait, wait, waitgetSchemainitializegetIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validatepublic RecordSetWriter createWriter(ComponentLog logger, RecordSchema recordSchema, java.io.OutputStream out) throws java.io.IOException
RecordSetWriterFactoryCreates a new RecordSetWriter that is capable of writing record contents to an OutputStream.
createWriter in interface RecordSetWriterFactorylogger - the logger to use when logging information. This is passed in, rather than using the logger of the Controller Service
because it allows messages to be logged for the component that is calling this Controller Service.recordSchema - the schema that will be used for writing recordsout - the OutputStream to write tojava.io.IOException - if unable to read from the given InputStreamprotected java.util.List<PropertyDescriptor> getSupportedPropertyDescriptors()
AbstractConfigurableComponentgetSupportedPropertyDescriptors in class SchemaRegistryRecordSetWriterprotected java.util.List<AllowableValue> getSchemaWriteStrategyValues()
getSchemaWriteStrategyValues in class SchemaRegistryRecordSetWriterprotected AllowableValue getDefaultSchemaWriteStrategy()
getDefaultSchemaWriteStrategy in class SchemaRegistryRecordSetWriterprotected java.util.Set<SchemaField> getRequiredSchemaFields(ValidationContext validationContext)
getRequiredSchemaFields in class SchemaRegistryRecordSetWriterprotected java.util.Collection<ValidationResult> customValidate(ValidationContext validationContext)
AbstractConfigurableComponentcustomValidate in class SchemaRegistryRecordSetWritervalidationContext - provides a mechanism for obtaining externally
managed values, such as property values and supplies convenience methods
for operating on those values