Class SerdeUtils
- java.lang.Object
-
- org.apache.storm.sql.runtime.utils.SerdeUtils
-
public final class SerdeUtils extends Object
-
-
Constructor Summary
Constructors Constructor Description SerdeUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static 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.
-
-
-
Method Detail
-
getScheme
public static Scheme getScheme(String inputFormatClass, Properties properties, List<String> fieldNames)
Get a Scheme instance based on specific configurations.- Parameters:
inputFormatClass- input format classproperties- PropertiesfieldNames- 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 classproperties- PropertiesfieldNames- field names- Returns:
- the OutputSerializer instance
-
-