public final class SerdeUtils extends Object
Constructor and Description |
---|
SerdeUtils() |
Modifier and Type | Method and Description |
---|---|
static Object |
convertAvroUtf8(Object value) |
static Object |
convertAvroUtf8Array(org.apache.avro.generic.GenericData.Array value) |
static Object |
convertAvroUtf8Map(Map<Object,Object> value) |
static Scheme |
getScheme(String inputFormatClass,
Properties properties,
List<String> fieldNames) |
static IOutputSerializer |
getSerializer(String outputFormatClass,
Properties properties,
List<String> fieldNames) |
public static Scheme getScheme(String inputFormatClass, Properties properties, List<String> fieldNames)
public static IOutputSerializer getSerializer(String outputFormatClass, Properties properties, List<String> fieldNames)
public static Object convertAvroUtf8Array(org.apache.avro.generic.GenericData.Array value)
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.