Class SerdeUtils
java.lang.Object
org.apache.storm.sql.runtime.utils.SerdeUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
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 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
-
convertAvroUtf8
Convert a Avro object to a Java object, changing the Avro Utf8 type to Java String.- Parameters:
value- Avro object- Returns:
- Java object
-