APISonar


org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorFactory.ObjectInspectorOptions.JAVA

> org > apache > hadoop > hive > serde2 > objectinspector > ObjectInspectorFactory > ObjectInspectorOptions > JAVA
org APIs apache APIs hadoop APIs hive APIs serde2 APIs objectinspector APIs ObjectInspectorFactory APIs ObjectInspectorOptions APIs JAVA APIs

Example 1
public static String getTypeNameFromJavaClass(Type t) {
    try {
      ObjectInspector oi = ObjectInspectorFactory.getReflectionObjectInspector(t,
          ObjectInspectorOptions.JAVA);
      return oi.getTypeName();
    } catch (Throwable e) {
      LOG.info(StringUtils.stringifyException(e));
      return "unknown";
    }
  }
Example 2
public static ObjectInspector createLazyStructInspector(
      List<String> columnNames, List<TypeInfo> typeInfos,
      LazyObjectInspectorParameters lazyParams) throws SerDeException {
    ArrayList<ObjectInspector> columnObjectInspectors = new ArrayList<ObjectInspector>(
        typeInfos.size());
    for (int i = 0; i < typeInfos.size(); i++) {
      columnObjectInspectors.add(LazyFactory.createLazyObjectInspector(
          typeInfos.get(i), 1,
          lazyParams, ObjectInspectorOptions.JAVA));
    }
    return LazyObjectInspectorFactory.getLazySimpleStructObjectInspector(
        columnNames, columnObjectInspectors, null, lazyParams.getSeparators()[0],
        lazyParams, ObjectInspectorOptions.JAVA);
  }
Example 3
public void initialize(Configuration job, Properties tbl)
      throws SerDeException {

    cachedObjectInspector = ObjectInspectorFactory
        .getReflectionObjectInspector(S3LogStruct.class,
        ObjectInspectorFactory.ObjectInspectorOptions.JAVA);

    LOG.debug(getClass().getName() + ": initialized");
  }
Example 4
public ObjectInspector createValueObjectInspector(TypeInfo type)
      throws SerDeException {
    return LazyFactory.createLazyObjectInspector(type,
        1, serdeParams, ObjectInspectorOptions.JAVA);
  }
Example 5
public static LazySimpleStructObjectInspector getLazySimpleStructObjectInspector(
      List<String> structFieldNames,
      List<ObjectInspector> structFieldObjectInspectors, byte separator,
      Text nullSequence, boolean lastColumnTakesRest, boolean escaped,
      byte escapeChar) {
    return getLazySimpleStructObjectInspector(structFieldNames,
      structFieldObjectInspectors, null, separator, nullSequence,
      lastColumnTakesRest, escaped, escapeChar, ObjectInspectorOptions.JAVA);
  }
Example 6
private static ObjectInspector getInspector(Type type)
    {
        return ObjectInspectorFactory.getReflectionObjectInspector(type, ObjectInspectorFactory.ObjectInspectorOptions.JAVA);
    }
Example 7
public ObjectInspector initialize(ObjectInspector[] argOIs)
        throws UDFArgumentException {
        this.argOIs = argOIs;
        return ObjectInspectorFactory.getReflectionObjectInspector(String.class,
            ObjectInspectorOptions.JAVA);
    }
Example 8
public ReflectiveMutatorFactory(Configuration configuration, Class<?> recordClass, int recordIdColumn,
      int[] bucketColumnIndexes) {
    this.configuration = configuration;
    this.recordIdColumn = recordIdColumn;
    this.bucketColumnIndexes = bucketColumnIndexes;
    objectInspector = ObjectInspectorFactory.getReflectionObjectInspector(recordClass,
        ObjectInspectorFactory.ObjectInspectorOptions.JAVA);
  }
Example 9
public static ObjectInspector createLazyObjectInspector(TypeInfo typeInfo,
  		byte[] separators, int separatorIndex, Text nullSequence, boolean escaped,
      byte escapeChar) throws SerDeException {
    return createLazyObjectInspector(typeInfo, separators, separatorIndex, nullSequence,
        escaped, escapeChar, false, ObjectInspectorOptions.JAVA);
  }