org.apache.storm.sql.runtime.utils

Class SerdeUtils

java.lang.Object

org.apache.storm.sql.runtime.utils.SerdeUtils

public final class SerdeUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
SerdeUtils()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SerdeUtils

public SerdeUtils()

Method Detail

getScheme

public static Scheme getScheme(String inputFormatClass,
                               Properties properties,
                               List<String> fieldNames)

getSerializer

public static IOutputSerializer getSerializer(String outputFormatClass,
                                              Properties properties,
                                              List<String> fieldNames)

convertAvroUtf8

public static Object convertAvroUtf8(Object value)

convertAvroUtf8Map

public static Object convertAvroUtf8Map(Map<Object,Object> value)

convertAvroUtf8Array

public static Object convertAvroUtf8Array(org.apache.avro.generic.GenericData.Array value)