Class SerdeUtils
java.lang.Object
org.apache.storm.sql.runtime.utils.SerdeUtils
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic ObjectconvertAvroUtf8(Object value) Convert a Avro object to a Java object, changing the Avro Utf8 type to Java String.static SchemegetScheme(String inputFormatClass, Properties properties, List<String> fieldNames) Get a Scheme instance based on specific configurations.static IOutputSerializergetSerializer(String outputFormatClass, Properties properties, List<String> fieldNames) Get a OutputSerializer instance based on specific configurations.
- 
Constructor Details- 
SerdeUtilspublic SerdeUtils()
 
- 
- 
Method Details- 
getSchemepublic 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
 
- 
getSerializerpublic 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
 
- 
convertAvroUtf8Convert a Avro object to a Java object, changing the Avro Utf8 type to Java String.- Parameters:
- value- Avro object
- Returns:
- Java object
 
 
-