本文整理了Java中org.apache.hadoop.hive.metastore.api.Partition.setLastAccessTime()
方法的一些代码示例,展示了Partition.setLastAccessTime()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Partition.setLastAccessTime()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.metastore.api.Partition
类名称:Partition
方法名:setLastAccessTime
暂无
代码示例来源:origin: apache/hive
public void setLastAccessTime(int lastAccessTime) {
tPartition.setLastAccessTime(lastAccessTime);
}
代码示例来源:origin: apache/drill
public void setLastAccessTime(int lastAccessTime) {
tPartition.setLastAccessTime(lastAccessTime);
}
代码示例来源:origin: apache/hive
part.setTableName(tblName);
if (fields[4] != null) part.setCreateTime(MetastoreDirectSqlUtils.extractSqlInt(fields[4]));
if (fields[5] != null) part.setLastAccessTime(MetastoreDirectSqlUtils.extractSqlInt(fields[5]));
Long writeId = MetastoreDirectSqlUtils.extractSqlLong(fields[14]);
if (writeId != null) {
代码示例来源:origin: apache/hive
private static void makeTestChangesOnPartition(Partition partition) {
partition.getParameters().put("hmsTestParam001", "testValue001");
partition.setCreateTime(NEW_CREATE_TIME);
partition.setLastAccessTime(NEW_CREATE_TIME);
partition.getSd().setLocation(partition.getSd().getLocation()+"/hh=01");
partition.getSd().getCols().add(new FieldSchema("newcol", "string", ""));
}
代码示例来源:origin: apache/incubator-gobblin
/**
* Convert a {@link HivePartition} into a {@link Partition}.
*/
public static Partition getPartition(HivePartition hivePartition) {
State props = hivePartition.getProps();
Partition partition = new Partition();
partition.setDbName(hivePartition.getDbName());
partition.setTableName(hivePartition.getTableName());
partition.setValues(hivePartition.getValues());
partition.setParameters(getParameters(props));
if (hivePartition.getCreateTime().isPresent()) {
partition.setCreateTime(Ints.checkedCast(hivePartition.getCreateTime().get()));
} else if (props.contains(HiveConstants.CREATE_TIME)) {
partition.setCreateTime(props.getPropAsInt(HiveConstants.CREATE_TIME));
}
if (props.contains(HiveConstants.LAST_ACCESS_TIME)) {
partition.setLastAccessTime(props.getPropAsInt(HiveConstants.LAST_ACCESS_TIME));
}
partition.setSd(getStorageDescriptor(hivePartition));
return partition;
}
代码示例来源:origin: apache/hive
newPart.setLastAccessTime(3);
Partition newPart1 =
client.getPartition(DEFAULT_DATABASE_NAME, tableName, Collections.singletonList("a2"));
代码示例来源:origin: apache/hive
newPart.setLastAccessTime(3);
Partition newPart1 =
client.getPartition(dbName, tableName, Collections.singletonList("a2"));
代码示例来源:origin: apache/hive
assertEquals("Unexpected partition value.", partition3.getValues(), multiParts.get(2).getValues());
part.setLastAccessTime((int)(System.currentTimeMillis()/1000));
msc.alter_partition(dbName, tblName, part);
listSize++;
代码示例来源:origin: apache/hive
newPart.setLastAccessTime(3);
Partition newPart1 =
client.getPartition(catName, dbName, tableName, Collections.singletonList("a2"));
代码示例来源:origin: apache/hive
unsetLastAccessTime();
} else {
setLastAccessTime((Integer)value);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
public void setLastAccessTime(int lastAccessTime) {
tPartition.setLastAccessTime(lastAccessTime);
}
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
public void setLastAccessTime(int lastAccessTime) {
tPartition.setLastAccessTime(lastAccessTime);
}
}
代码示例来源:origin: airbnb/reair
/**
* Remove (or set to 0) fields in the partition object that should not be compared.
*
* @param partition the partition to remove non-comparable fields
* @return the partition with non-comparable fields removed
*/
public static Partition stripNonComparables(Partition partition) {
Partition newPartition = new Partition(partition);
newPartition.setCreateTime(0);
newPartition.setLastAccessTime(0);
return newPartition;
}
代码示例来源:origin: airbnb/reair
/**
* Remove (or set to 0) fields in the partition object that should not be compared.
*
* @param partition the partition to remove non-comparable fields
* @return the partition with non-comparable fields removed
*/
public static Partition stripNonComparables(Partition partition) {
Partition newPartition = new Partition(partition);
newPartition.setCreateTime(0);
newPartition.setLastAccessTime(0);
return newPartition;
}
代码示例来源:origin: com.netflix.metacat/metacat-converters
result.setLastAccessTime(dateToEpochSeconds(auditDto.getLastModifiedDate()));
代码示例来源:origin: com.linkedin.gobblin/gobblin-hive-registration
/**
* Convert a {@link HivePartition} into a {@link Partition}.
*/
public static Partition getPartition(HivePartition hivePartition) {
State props = hivePartition.getProps();
Partition partition = new Partition();
partition.setDbName(hivePartition.getDbName());
partition.setTableName(hivePartition.getTableName());
partition.setValues(hivePartition.getValues());
partition.setParameters(getParameters(props));
if (hivePartition.getCreateTime().isPresent()) {
partition.setCreateTime(Ints.checkedCast(hivePartition.getCreateTime().get()));
} else if (props.contains(HiveConstants.CREATE_TIME)) {
partition.setCreateTime(props.getPropAsInt(HiveConstants.CREATE_TIME));
}
if (props.contains(HiveConstants.LAST_ACCESS_TIME)) {
partition.setLastAccessTime(props.getPropAsInt(HiveConstants.LAST_ACCESS_TIME));
}
partition.setSd(getStorageDescriptor(hivePartition));
return partition;
}
代码示例来源:origin: org.apache.gobblin/gobblin-hive-registration
/**
* Convert a {@link HivePartition} into a {@link Partition}.
*/
public static Partition getPartition(HivePartition hivePartition) {
State props = hivePartition.getProps();
Partition partition = new Partition();
partition.setDbName(hivePartition.getDbName());
partition.setTableName(hivePartition.getTableName());
partition.setValues(hivePartition.getValues());
partition.setParameters(getParameters(props));
if (hivePartition.getCreateTime().isPresent()) {
partition.setCreateTime(Ints.checkedCast(hivePartition.getCreateTime().get()));
} else if (props.contains(HiveConstants.CREATE_TIME)) {
partition.setCreateTime(props.getPropAsInt(HiveConstants.CREATE_TIME));
}
if (props.contains(HiveConstants.LAST_ACCESS_TIME)) {
partition.setLastAccessTime(props.getPropAsInt(HiveConstants.LAST_ACCESS_TIME));
}
partition.setSd(getStorageDescriptor(hivePartition));
return partition;
}
代码示例来源:origin: Netflix/metacat
result.setLastAccessTime(dateToEpochSeconds(auditDto.getLastModifiedDate()));
代码示例来源:origin: org.spark-project.hive/hive-metastore
unsetLastAccessTime();
} else {
setLastAccessTime((Integer)value);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
unsetLastAccessTime();
} else {
setLastAccessTime((Integer)value);
内容来源于网络,如有侵权,请联系作者删除!