Class SerdeUtils

java.lang.Object
org.apache.storm.sql.runtime.utils.SerdeUtils

public final class SerdeUtils extends Object
  • Constructor Details

    • SerdeUtils

      public SerdeUtils()
  • Method Details

    • getScheme

      public static Scheme getScheme(String inputFormatClass, Properties properties, List<String> fieldNames)
      Get a Scheme instance based on specific configurations.
      Parameters:
      inputFormatClass - input format class
      properties - Properties
      fieldNames - field names
      Returns:
      the Scheme instance
    • getSerializer

      public static IOutputSerializer getSerializer(String outputFormatClass, Properties properties, List<String> fieldNames)
      Get a OutputSerializer instance based on specific configurations.
      Parameters:
      outputFormatClass - output format class
      properties - Properties
      fieldNames - field names
      Returns:
      the OutputSerializer instance
    • convertAvroUtf8

      public static Object convertAvroUtf8(Object value)
      Convert a Avro object to a Java object, changing the Avro Utf8 type to Java String.
      Parameters:
      value - Avro object
      Returns:
      Java object