public class InputRowSerde extends Object
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 and Description |
---|
InputRowSerde() |
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) |
public static Map<String,InputRowSerde.IndexSerdeTypeHelper> getTypeHelperMap(DimensionsSpec dimensionsSpec)
public static final byte[] toBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap, InputRow row, AggregatorFactory[] aggs, boolean reportParseExceptions)
public static final InputRow fromBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap, byte[] data, AggregatorFactory[] aggs)
Copyright © 2011–2018. All rights reserved.