本文整理了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
暂无
代码示例来源:origin: apache/hive
private static Table createTestTable(String dbName, String tableName) throws HiveException {
Table tbl = new Table(dbName, tableName);
tbl.setInputFormatClass(SequenceFileInputFormat.class.getName());
tbl.setOutputFormatClass(SequenceFileOutputFormat.class.getName());
tbl.setSerializationLib(ThriftDeserializer.class.getName());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_CLASS, Complex.class.getName());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, TBinaryProtocol.class
.getName());
return tbl;
}
代码示例来源:origin: apache/hive
table.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: apache/hive
tbl.setOutputFormatClass(SequenceFileOutputFormat.class.getName());
tbl.setSerializationLib(ThriftDeserializer.class.getName());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_CLASS, Complex.class.getName());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, TBinaryProtocol.class
.getName());
tbl.setStoredAsSubDirectories(false);
代码示例来源:origin: apache/hive
LOG.warn("SerDe property in input query overrides stored SerDe property");
tab.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: apache/drill
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, getFieldDelim());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, getFieldDelim());
tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, getFieldEscape());
tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, getCollItemDelim());
tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, getMapKeyDelim());
tbl.setSerdeParam(serdeConstants.LINE_DELIM, getLineDelim());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_NULL_FORMAT, getNullFormat());
while (iter.hasNext()) {
Map.Entry<String, String> m = iter.next();
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: apache/hive
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, getFieldDelim());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, getFieldDelim());
tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, getFieldEscape());
tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, getCollItemDelim());
tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, getMapKeyDelim());
tbl.setSerdeParam(serdeConstants.LINE_DELIM, getLineDelim());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_NULL_FORMAT, getNullFormat());
while (iter.hasNext()) {
Map.Entry<String, String> m = iter.next();
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: apache/drill
LOG.warn("SerDe property in input query overrides stored SerDe property");
tab.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: apache/hive
while (iter.hasNext()) {
Entry<String, String> m = iter.next();
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: apache/hive
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, "1");
tbl.setSerdeParam(serdeConstants.LINE_DELIM, "\n");
tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, "3");
tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, "2");
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, "1");
tbl.setSerializationLib(LazySimpleSerDe.class.getName());
tbl.setStoredAsSubDirectories(false);
代码示例来源:origin: apache/drill
while (iter.hasNext()) {
Entry<String, String> m = iter.next();
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: apache/lens
tbl.setSerdeParam(serdeConstants.LINE_DELIM, "\n");
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, " ");
代码示例来源:origin: org.apache.hive.hcatalog/hive-hcatalog-core
table.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: com.github.hyukjinkwon.hcatalog/hive-hcatalog-core
table.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: org.spark-project.hive.hcatalog/hive-hcatalog-core
table.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: com.facebook.presto.hive/hive-apache
table.setSerdeParam(prop.getKey(), prop.getValue());
代码示例来源:origin: apache/lens
tbl.getTTable().getParameters().putAll(tableParams);
tbl.setInputFormatClass(TextInputFormat.class);
tbl.setSerdeParam(serdeConstants.LINE_DELIM, "\n");
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, " ");
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
tbl.setSerdeParam(Constants.FIELD_DELIM, crtTbl.getFieldDelim());
tbl.setSerdeParam(Constants.SERIALIZATION_FORMAT, crtTbl.getFieldDelim());
tbl.setSerdeParam(Constants.ESCAPE_CHAR, crtTbl.getFieldEscape());
tbl.setSerdeParam(Constants.COLLECTION_DELIM, crtTbl.getCollItemDelim());
tbl.setSerdeParam(Constants.MAPKEY_DELIM, crtTbl.getMapKeyDelim());
tbl.setSerdeParam(Constants.LINE_DELIM, crtTbl.getLineDelim());
while (iter.hasNext()) {
Entry<String, String> m = iter.next();
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: org.apache.lens/lens-cube
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, crtTbl.getFieldDelim());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, crtTbl.getFieldDelim());
tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, crtTbl.getFieldEscape());
tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, crtTbl.getCollItemDelim());
tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, crtTbl.getMapKeyDelim());
tbl.setSerdeParam(serdeConstants.LINE_DELIM, crtTbl.getLineDelim());
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: apache/lens
tbl.setSerdeParam(serdeConstants.FIELD_DELIM, crtTbl.getFieldDelim());
tbl.setSerdeParam(serdeConstants.SERIALIZATION_FORMAT, crtTbl.getFieldDelim());
tbl.setSerdeParam(serdeConstants.ESCAPE_CHAR, crtTbl.getFieldEscape());
tbl.setSerdeParam(serdeConstants.COLLECTION_DELIM, crtTbl.getCollItemDelim());
tbl.setSerdeParam(serdeConstants.MAPKEY_DELIM, crtTbl.getMapKeyDelim());
tbl.setSerdeParam(serdeConstants.LINE_DELIM, crtTbl.getLineDelim());
tbl.setSerdeParam(m.getKey(), m.getValue());
代码示例来源:origin: com.facebook.presto.hive/hive-apache
while (iter.hasNext()) {
Entry<String, String> m = iter.next();
tbl.setSerdeParam(m.getKey(), m.getValue());
内容来源于网络,如有侵权,请联系作者删除!