Class JsonSerializer

java.lang.Object
org.apache.storm.sql.runtime.serde.json.JsonSerializer
All Implemented Interfaces:
Serializable, IOutputSerializer

public class JsonSerializer extends Object implements IOutputSerializer, Serializable
See Also:
  • Constructor Details

    • JsonSerializer

      public JsonSerializer(List<String> fieldNames)
  • Method Details

    • 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 interface IOutputSerializer
      Returns:
      A ByteBuffer contains the serialized result.