Class SerdeUtils
java.lang.Object
org.apache.storm.sql.runtime.utils.SerdeUtils
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic Object
convertAvroUtf8
(Object value) Convert a Avro object to a Java object, changing the Avro Utf8 type to Java String.static Scheme
getScheme
(String inputFormatClass, Properties properties, List<String> fieldNames) Get a Scheme instance based on specific configurations.static IOutputSerializer
getSerializer
(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
-