public final class SerdeUtils extends Object
| Constructor and Description |
|---|
SerdeUtils() |
| Modifier and Type | Method and Description |
|---|---|
static 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.
|
public static Scheme getScheme(String inputFormatClass, Properties properties, List<String> fieldNames)
Get a Scheme instance based on specific configurations.
inputFormatClass - input format classproperties - PropertiesfieldNames - field namespublic static IOutputSerializer getSerializer(String outputFormatClass, Properties properties, List<String> fieldNames)
Get a OutputSerializer instance based on specific configurations.
outputFormatClass - output format classproperties - PropertiesfieldNames - field namesCopyright © 2021 The Apache Software Foundation. All rights reserved.