本文整理了Java中org.apache.lens.api.metastore.XPartition.getLocation()
方法的一些代码示例,展示了XPartition.getLocation()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XPartition.getLocation()
方法的具体详情如下:
包路径:org.apache.lens.api.metastore.XPartition
类名称:XPartition
方法名:getLocation
[英]Gets the value of the location property.
[中]获取location属性的值。
代码示例来源:origin: apache/lens
private void createFactPartition(String fileName, String fact, String storage) throws JAXBException, IOException {
XPartition partition = (XPartition) SampleMetastore.readFromXML(fileName);
String partLocation = partition.getLocation();
if (!partLocation.startsWith("/")) {
partition.setLocation("file://" + System.getProperty("lens.home") + "/" + partLocation);
}
result = metaClient.addPartitionToFactTable(fact, storage, partition);
if (result.getStatus().equals(APIResult.Status.FAILED)) {
System.err.println("Adding partition from:" + fileName + " failed");
retCode = 1;
} else {
System.out.println("Added partition from:" + fileName);
}
}
代码示例来源:origin: apache/lens
private void createDimTablePartition(String fileName, String dimTable, String storage)
throws JAXBException, IOException {
XPartition partition = (XPartition) SampleMetastore.readFromXML(fileName);
String partLocation = partition.getLocation();
if (!partLocation.startsWith("/")) {
partition.setLocation("file://" + System.getProperty("lens.home") + "/" + partLocation);
}
result = metaClient.addPartitionToDimensionTable(dimTable, storage, partition);
if (result.getStatus().equals(APIResult.Status.FAILED)) {
System.err.println("Adding partition from:"+ fileName + " failed");
retCode = 1;
} else {
System.out.println("Added partition from:" + fileName);
}
}
代码示例来源:origin: apache/lens
private void createFactPartitions(String fileName, String fact, String storage) throws JAXBException, IOException {
XPartitionList partitionList = (XPartitionList) SampleMetastore.readFromXML(fileName);
for (XPartition partition : partitionList.getPartition()) {
String partLocation = partition.getLocation();
if (!partLocation.startsWith("/")) {
partition.setLocation("file://" + System.getProperty("lens.home") + "/" + partLocation);
}
}
result = metaClient.addPartitionsToFactTable(fact, storage, partitionList);
if (result.getStatus().equals(APIResult.Status.FAILED)) {
System.err.println("Adding partitions from:" + fileName + " failed");
retCode = 1;
} else {
System.out.println("Added partitions from:" + fileName);
}
}
代码示例来源:origin: apache/lens
private void createDimTablePartitions(String fileName, String dimTable, String storage)
throws JAXBException, IOException {
XPartitionList partitionList = (XPartitionList) SampleMetastore.readFromXML(fileName);
for (XPartition partition : partitionList.getPartition()) {
String partLocation = partition.getLocation();
if (!partLocation.startsWith("/")) {
partition.setLocation("file://" + System.getProperty("lens.home") + "/" + partLocation);
}
}
result = metaClient.addPartitionsToDimensionTable(dimTable, storage, partitionList);
if (result.getStatus().equals(APIResult.Status.FAILED)) {
System.err.println("Adding partitions from:" + fileName + " failed");
retCode = 1;
} else {
System.out.println("Added partitions from:" + fileName);
}
}
代码示例来源:origin: apache/lens
public static void updatePartitionFromXPartition(Partition partition, XPartition xp) throws ClassNotFoundException {
partition.getParameters().putAll(mapFromXProperties(xp.getPartitionParameters()));
partition.getTPartition().getSd().getSerdeInfo().setParameters(mapFromXProperties(xp.getSerdeParameters()));
partition.setLocation(xp.getLocation());
if (xp.getInputFormat() != null) {
partition.setInputFormatClass(Class.forName(xp.getInputFormat()).asSubclass(InputFormat.class));
}
if (xp.getOutputFormat() != null) {
Class<? extends HiveOutputFormat> outputFormatClass =
Class.forName(xp.getOutputFormat()).asSubclass(HiveOutputFormat.class);
partition.setOutputFormatClass(outputFormatClass);
}
partition.getParameters().put(MetastoreConstants.PARTITION_UPDATE_PERIOD, xp.getUpdatePeriod().name());
partition.getTPartition().getSd().getSerdeInfo().setSerializationLib(xp.getSerdeClassname());
}
代码示例来源:origin: org.apache.lens/lens-cube
public static void updatePartitionFromXPartition(Partition partition, XPartition xp) throws ClassNotFoundException {
partition.getParameters().putAll(mapFromXProperties(xp.getPartitionParameters()));
partition.getTPartition().getSd().getSerdeInfo().setParameters(mapFromXProperties(xp.getSerdeParameters()));
partition.setLocation(xp.getLocation());
if (xp.getInputFormat() != null) {
partition.setInputFormatClass(Class.forName(xp.getInputFormat()).asSubclass(InputFormat.class));
}
if (xp.getOutputFormat() != null) {
Class<? extends HiveOutputFormat> outputFormatClass =
Class.forName(xp.getOutputFormat()).asSubclass(HiveOutputFormat.class);
partition.setOutputFormatClass(outputFormatClass);
}
partition.getParameters().put(MetastoreConstants.PARTITION_UPDATE_PERIOD, xp.getUpdatePeriod().name());
partition.getTPartition().getSd().getSerdeInfo().setSerializationLib(xp.getSerdeClassname());
}
代码示例来源:origin: apache/lens
assertEquals(partAddResult.getStatus(), Status.FAILED);
xp.setLocation(xp.getLocation() + "/a/b/c");
APIResult partUpdateResult = target().path("metastore/facts/").path(table).path("storages/S1/partition")
.queryParam("sessionid", lensSessionId).request(mediaType)
assertEquals(partitions.getPartition().size(), 1);
XPartition readPartition = partitions.getPartition().get(0);
assertEquals(readPartition.getLocation(), xp.getLocation());
assertEquals(readPartition.getTimePartitionSpec(), xp.getTimePartitionSpec());
assertEquals(readPartition.getNonTimePartitionSpec(), xp.getNonTimePartitionSpec());
代码示例来源:origin: apache/lens
xp.setLocation(xp.getLocation() + "/a/b/c");
APIResult partUpdateResult = target().path("metastore/dimtables/").path(table).path("storages/test/partition")
.queryParam("sessionid", lensSessionId).request(mediaType)
assertEquals(partitions.getPartition().size(), 2);
assertEquals(partitions.getPartition().get(0).getLocation(), xp.getLocation());
assertEquals(partitions.getPartition().get(1).getLocation(), xp.getLocation());
代码示例来源:origin: apache/lens
assertEquals(partAddResult.getStatus(), Status.FAILED);
xp.setLocation(xp.getLocation() + "/a/b/c");
APIResult partUpdateResult = target().path("metastore/facts/").path(table).path("storages/S2/partition")
.queryParam("sessionid", lensSessionId)
assertEquals(partitions.getPartition().size(), 1);
XPartition readPartition = partitions.getPartition().get(0);
assertEquals(readPartition.getLocation(), xp.getLocation());
assertEquals(readPartition.getTimePartitionSpec(), xp.getTimePartitionSpec());
assertEquals(readPartition.getNonTimePartitionSpec(), xp.getNonTimePartitionSpec());
代码示例来源:origin: org.apache.lens/lens-cube
public static StoragePartitionDesc storagePartSpecFromXPartition(
XPartition xpart) {
StoragePartitionDesc partDesc = new StoragePartitionDesc(
xpart.getFactOrDimensionTableName(),
timePartSpecfromXTimePartSpec(xpart.getTimePartitionSpec()),
nonTimePartSpecfromXNonTimePartSpec(xpart.getNonTimePartitionSpec()),
UpdatePeriod.valueOf(xpart.getUpdatePeriod().name()));
partDesc.setPartParams(mapFromXProperties(xpart.getPartitionParameters()));
partDesc.setSerdeParams(mapFromXProperties(xpart.getSerdeParameters()));
partDesc.setLocation(xpart.getLocation());
partDesc.setInputFormat(xpart.getInputFormat());
partDesc.setOutputFormat(xpart.getOutputFormat());
partDesc.setSerializationLib(xpart.getSerdeClassname());
return partDesc;
}
代码示例来源:origin: apache/lens
public static StoragePartitionDesc storagePartSpecFromXPartition(
XPartition xpart) {
StoragePartitionDesc partDesc = new StoragePartitionDesc(
xpart.getFactOrDimensionTableName(),
timePartSpecfromXTimePartSpec(xpart.getTimePartitionSpec()),
nonTimePartSpecfromXNonTimePartSpec(xpart.getNonTimePartitionSpec()),
UpdatePeriod.valueOf(xpart.getUpdatePeriod().name()));
partDesc.setPartParams(mapFromXProperties(xpart.getPartitionParameters()));
partDesc.setSerdeParams(mapFromXProperties(xpart.getSerdeParameters()));
partDesc.setLocation(xpart.getLocation());
partDesc.setInputFormat(xpart.getInputFormat());
partDesc.setOutputFormat(xpart.getOutputFormat());
partDesc.setSerializationLib(xpart.getSerdeClassname());
return partDesc;
}
代码示例来源:origin: org.apache.lens/lens-api
theLocation = this.getLocation();
strategy.appendField(locator, this, "location", buffer, theLocation);
代码示例来源:origin: apache/lens
theLocation = this.getLocation();
strategy.appendField(locator, this, "location", buffer, theLocation);
代码示例来源:origin: org.apache.lens/lens-api
lhsLocation = this.getLocation();
String rhsLocation;
rhsLocation = that.getLocation();
if (!strategy.equals(LocatorUtils.property(thisLocator, "location", lhsLocation), LocatorUtils.property(thatLocator, "location", rhsLocation), lhsLocation, rhsLocation)) {
return false;
代码示例来源:origin: apache/lens
lhsLocation = this.getLocation();
String rhsLocation;
rhsLocation = that.getLocation();
if (!strategy.equals(LocatorUtils.property(thisLocator, "location", lhsLocation), LocatorUtils.property(thatLocator, "location", rhsLocation), lhsLocation, rhsLocation)) {
return false;
代码示例来源:origin: apache/lens
theLocation = this.getLocation();
currentHashCode = strategy.hashCode(LocatorUtils.property(locator, "location", theLocation), currentHashCode, theLocation);
代码示例来源:origin: org.apache.lens/lens-api
theLocation = this.getLocation();
currentHashCode = strategy.hashCode(LocatorUtils.property(locator, "location", theLocation), currentHashCode, theLocation);
内容来源于网络,如有侵权,请联系作者删除!