org.apache.hadoop.hive.metastore.api.Partition.setLastAccessTime()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(214)

本文整理了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

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);

相关文章

微信公众号

最新文章

更多

Partition类方法