public class ColumnMappingFactory extends Object
Constructor and Description |
---|
ColumnMappingFactory() |
Modifier and Type | Method and Description |
---|---|
static ColumnMapping |
get(String columnSpec,
ColumnEncoding defaultEncoding,
String columnName,
TypeInfo columnType)
Generate the proper instance of a ColumnMapping
|
static ColumnMapping |
getMap(String columnSpec,
ColumnEncoding keyEncoding,
ColumnEncoding valueEncoding,
String columnName,
TypeInfo columnType) |
static boolean |
isPrefix(String maybePrefix) |
static Map.Entry<String,String> |
parseMapping(String columnSpec)
Consumes the column mapping specification and breaks it into column family and column
qualifier.
|
public static ColumnMapping get(String columnSpec, ColumnEncoding defaultEncoding, String columnName, TypeInfo columnType)
columnSpec
- Specification for mapping this column to AccumulodefaultEncoding
- The default encoding in which values should be encoded to Accumulopublic static ColumnMapping getMap(String columnSpec, ColumnEncoding keyEncoding, ColumnEncoding valueEncoding, String columnName, TypeInfo columnType)
public static boolean isPrefix(String maybePrefix)
public static Map.Entry<String,String> parseMapping(String columnSpec) throws InvalidColumnMappingException
InvalidColumnMappingException
Copyright © 2016 The Apache Software Foundation. All rights reserved.