io.druid.indexer

Class InputRowSerde

java.lang.Object

io.druid.indexer.InputRowSerde

public class InputRowSerde
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InputRowSerde.DoubleIndexSerdeTypeHelper
static class	InputRowSerde.FloatIndexSerdeTypeHelper
static interface	InputRowSerde.IndexSerdeTypeHelper<T>
static class	InputRowSerde.LongIndexSerdeTypeHelper
static class	InputRowSerde.StringIndexSerdeTypeHelper

Constructor Summary

Constructors

Constructor and Description
InputRowSerde()

Method Summary

Modifier and Type	Method and Description
static InputRow	fromBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap, byte[] data, AggregatorFactory[] aggs)
static Map<String,InputRowSerde.IndexSerdeTypeHelper>	getTypeHelperMap(DimensionsSpec dimensionsSpec)
static byte[]	toBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap, InputRow row, AggregatorFactory[] aggs, boolean reportParseExceptions)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputRowSerde

public InputRowSerde()

Method Detail

getTypeHelperMap

public static Map<String,InputRowSerde.IndexSerdeTypeHelper> getTypeHelperMap(DimensionsSpec dimensionsSpec)

toBytes

public static final byte[] toBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap,
                                   InputRow row,
                                   AggregatorFactory[] aggs,
                                   boolean reportParseExceptions)

fromBytes

public static final InputRow fromBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap,
                                       byte[] data,
                                       AggregatorFactory[] aggs)