org.apache.hadoop.hive.ql.metadata.Table.setSerdeParam()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(197)

本文整理了Java中org.apache.hadoop.hive.ql.metadata.Table.setSerdeParam()方法的一些代码示例,展示了Table.setSerdeParam()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.setSerdeParam()方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.metadata.Table
类名称:Table
方法名:setSerdeParam

Table.setSerdeParam介绍

暂无

代码示例

代码示例来源:origin: apache/hive

  1. private static Table createTestTable(String dbName, String tableName) throws HiveException {
  2. Table tbl = new Table(dbName, tableName);
  3. tbl.setInputFormatClass(SequenceFileInputFormat.class.getName());
  4. tbl.setOutputFormatClass(SequenceFileOutputFormat.class.getName());
  5. tbl.setSerializationLib(ThriftDeserializer.class.getName());
  6. tbl.setSerdeParam(serdeConstants.SERIALIZATION_CLASS, Complex.class.getName());
  7. tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, TBinaryProtocol.class
  8. .getName());
  9. return tbl;
  10. }

代码示例来源:origin: apache/hive

  1. table.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: apache/hive

  1. tbl.setOutputFormatClass(SequenceFileOutputFormat.class.getName());
  2. tbl.setSerializationLib(ThriftDeserializer.class.getName());
  3. tbl.setSerdeParam(serdeConstants.SERIALIZATION_CLASS, Complex.class.getName());
  4. tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, TBinaryProtocol.class
  5. .getName());
  6. tbl.setStoredAsSubDirectories(false);

代码示例来源:origin: apache/hive

  1. LOG.warn("SerDe property in input query overrides stored SerDe property");
  2. tab.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: apache/drill

  1. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, getFieldDelim());
  2. tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, getFieldDelim());
  3. tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, getFieldEscape());
  4. tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, getCollItemDelim());
  5. tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, getMapKeyDelim());
  6. tbl.setSerdeParam(serdeConstants.LINE_DELIM, getLineDelim());
  7. tbl.setSerdeParam(serdeConstants.SERIALIZATION_NULL_FORMAT, getNullFormat());
  8. while (iter.hasNext()) {
  9. Map.Entry<String, String> m = iter.next();
  10. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: apache/hive

  1. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, getFieldDelim());
  2. tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, getFieldDelim());
  3. tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, getFieldEscape());
  4. tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, getCollItemDelim());
  5. tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, getMapKeyDelim());
  6. tbl.setSerdeParam(serdeConstants.LINE_DELIM, getLineDelim());
  7. tbl.setSerdeParam(serdeConstants.SERIALIZATION_NULL_FORMAT, getNullFormat());
  8. while (iter.hasNext()) {
  9. Map.Entry<String, String> m = iter.next();
  10. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: apache/drill

  1. LOG.warn("SerDe property in input query overrides stored SerDe property");
  2. tab.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: apache/hive

  1. while (iter.hasNext()) {
  2. Entry<String, String> m = iter.next();
  3. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: apache/hive

  1. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, "1");
  2. tbl.setSerdeParam(serdeConstants.LINE_DELIM, "\n");
  3. tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, "3");
  4. tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, "2");
  5. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, "1");
  6. tbl.setSerializationLib(LazySimpleSerDe.class.getName());
  7. tbl.setStoredAsSubDirectories(false);

代码示例来源:origin: apache/drill

  1. while (iter.hasNext()) {
  2. Entry<String, String> m = iter.next();
  3. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: apache/lens

  1. tbl.setSerdeParam(serdeConstants.LINE_DELIM, "\n");
  2. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, " ");

代码示例来源:origin: org.apache.hive.hcatalog/hive-hcatalog-core

  1. table.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: com.github.hyukjinkwon.hcatalog/hive-hcatalog-core

  1. table.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: org.spark-project.hive.hcatalog/hive-hcatalog-core

  1. table.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: com.facebook.presto.hive/hive-apache

  1. table.setSerdeParam(prop.getKey(), prop.getValue());

代码示例来源:origin: apache/lens

  1. tbl.getTTable().getParameters().putAll(tableParams);
  2. tbl.setInputFormatClass(TextInputFormat.class);
  3. tbl.setSerdeParam(serdeConstants.LINE_DELIM, "\n");
  4. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, " ");

代码示例来源:origin: org.apache.hadoop.hive/hive-exec

  1. tbl.setSerdeParam(Constants.FIELD_DELIM, crtTbl.getFieldDelim());
  2. tbl.setSerdeParam(Constants.SERIALIZATION_FORMAT, crtTbl.getFieldDelim());
  3. tbl.setSerdeParam(Constants.ESCAPE_CHAR, crtTbl.getFieldEscape());
  4. tbl.setSerdeParam(Constants.COLLECTION_DELIM, crtTbl.getCollItemDelim());
  5. tbl.setSerdeParam(Constants.MAPKEY_DELIM, crtTbl.getMapKeyDelim());
  6. tbl.setSerdeParam(Constants.LINE_DELIM, crtTbl.getLineDelim());
  7. while (iter.hasNext()) {
  8. Entry<String, String> m = iter.next();
  9. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: org.apache.lens/lens-cube

  1. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, crtTbl.getFieldDelim());
  2. tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, crtTbl.getFieldDelim());
  3. tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, crtTbl.getFieldEscape());
  4. tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, crtTbl.getCollItemDelim());
  5. tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, crtTbl.getMapKeyDelim());
  6. tbl.setSerdeParam(serdeConstants.LINE_DELIM, crtTbl.getLineDelim());
  7. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: apache/lens

  1. tbl.setSerdeParam(serdeConstants.FIELD_DELIM, crtTbl.getFieldDelim());
  2. tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, crtTbl.getFieldDelim());
  3. tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, crtTbl.getFieldEscape());
  4. tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, crtTbl.getCollItemDelim());
  5. tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, crtTbl.getMapKeyDelim());
  6. tbl.setSerdeParam(serdeConstants.LINE_DELIM, crtTbl.getLineDelim());
  7. tbl.setSerdeParam(m.getKey(), m.getValue());

代码示例来源:origin: com.facebook.presto.hive/hive-apache

  1. while (iter.hasNext()) {
  2. Entry<String, String> m = iter.next();
  3. tbl.setSerdeParam(m.getKey(), m.getValue());

相关文章

Table类方法