Class AvroSerializer
- java.lang.Object
-
- org.apache.storm.sql.runtime.serde.avro.AvroSerializer
-
- All Implemented Interfaces:
Serializable
,IOutputSerializer
public class AvroSerializer extends Object implements IOutputSerializer, Serializable
AvroSerializer uses generic(without code generation) instead of specific(with code generation) writers.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AvroSerializer(String schemaString, List<String> fieldNames)
AvroSerializer Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ByteBuffer
write(List<Object> data, ByteBuffer buffer)
Serialize the data to a ByteBuffer.
-
-
-
Method Detail
-
write
public ByteBuffer write(List<Object> data, ByteBuffer buffer)
Description copied from interface:IOutputSerializer
Serialize the data to a ByteBuffer. The caller can pass in a ByteBuffer so that the serializer can reuse the memory.- Specified by:
write
in interfaceIOutputSerializer
- Returns:
- A ByteBuffer contains the serialized result.
-
-