本文整理了Java中org.apache.hadoop.hive.metastore.api.Partition.toString()
方法的一些代码示例,展示了Partition.toString()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Partition.toString()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.metastore.api.Partition
类名称:Partition
方法名:toString
暂无
代码示例来源:origin: apache/incubator-gobblin
private static String stringifyPartitionVerbose(Partition partition) {
return partition.toString();
}
代码示例来源:origin: apache/drill
outStream.write(part.getTPartition().toString().getBytes("UTF-8"));
outStream.write(separator);
代码示例来源:origin: apache/hive
outStream.write(part.getTPartition().toString().getBytes("UTF-8"));
outStream.write(separator);
代码示例来源:origin: apache/hive
o2.getKey().getDataContainer().isPartition()) {
ret = o1.getKey().getDataContainer().getPartition().toString()
.compareTo(o2.getKey().getDataContainer().getPartition().toString());
代码示例来源:origin: apache/drill
o2.getKey().getDataContainer().isPartition()) {
ret = o1.getKey().getDataContainer().getPartition().toString()
.compareTo(o2.getKey().getDataContainer().getPartition().toString());
代码示例来源:origin: apache/hive
"Partition does not belong to target table %s. It belongs to the table %s.%s : %s",
TableName.getQualified(catName, dbName, tblName), part.getDbName(),
part.getTableName(), part.toString());
throw new MetaException(errorMsg);
代码示例来源:origin: org.apache.gobblin/gobblin-hive-registration
private static String stringifyPartitionVerbose(Partition partition) {
return partition.toString();
}
代码示例来源:origin: com.linkedin.gobblin/gobblin-hive-registration
private static String stringifyPartitionVerbose(Partition partition) {
return partition.toString();
}
代码示例来源:origin: com.hotels/circus-train-avro
Partition apply(Partition partition, String avroSchemaDestination, String eventId) throws Exception {
if (avroSchemaDestination == null) {
return partition;
}
avroSchemaDestination = addTrailingSlash(avroSchemaDestination);
avroSchemaDestination += eventId;
String avroSchemaSource = partition.getParameters().get(AVRO_SCHEMA_URL_PARAMETER);
copy(avroSchemaSource, avroSchemaDestination);
partition.putToParameters(AVRO_SCHEMA_URL_PARAMETER,
avroSchemaDestination + "/" + getAvroSchemaFileName(avroSchemaSource));
LOG.info("Avro SerDe transformation has been applied to partition '{}'", partition.toString());
return partition;
}
}
代码示例来源:origin: HotelsDotCom/circus-train
Partition apply(Partition partition, String avroSchemaDestination, String eventId) throws Exception {
if (avroSchemaDestination == null) {
return partition;
}
avroSchemaDestination = addTrailingSlash(avroSchemaDestination);
avroSchemaDestination += eventId;
String avroSchemaSource = partition.getParameters().get(AVRO_SCHEMA_URL_PARAMETER);
copy(avroSchemaSource, avroSchemaDestination);
partition.putToParameters(AVRO_SCHEMA_URL_PARAMETER,
avroSchemaDestination + "/" + getAvroSchemaFileName(avroSchemaSource));
LOG.info("Avro SerDe transformation has been applied to partition '{}'", partition.toString());
return partition;
}
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
outStream.write(part.getTPartition().toString().getBytes("UTF-8"));
outStream.write(separator);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
o2.getKey().getDataContainer().isPartition()) {
ret = o1.getKey().getDataContainer().getPartition().toString()
.compareTo(o2.getKey().getDataContainer().getPartition().toString());
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
outStream.writeBytes(part.getTPartition().toString());
outStream.write(separator);
内容来源于网络,如有侵权,请联系作者删除!