org.apache.lens.api.metastore.XPartition.setFactOrDimensionTableName()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(184)

本文整理了Java中org.apache.lens.api.metastore.XPartition.setFactOrDimensionTableName()方法的一些代码示例,展示了XPartition.setFactOrDimensionTableName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XPartition.setFactOrDimensionTableName()方法的具体详情如下:
包路径:org.apache.lens.api.metastore.XPartition
类名称:XPartition
方法名:setFactOrDimensionTableName

XPartition.setFactOrDimensionTableName介绍

[英]Sets the value of the factOrDimensionTableName property.
[中]设置factOrDimensionTableName属性的值。

代码示例

代码示例来源:origin: org.apache.lens/lens-api

public XPartition withFactOrDimensionTableName(String value) {
  setFactOrDimensionTableName(value);
  return this;
}

代码示例来源:origin: apache/lens

public XPartition withFactOrDimensionTableName(String value) {
  setFactOrDimensionTableName(value);
  return this;
}

代码示例来源:origin: apache/lens

/**
 * Sets up query command instances and adds partitions to a table.
 * @throws Exception
 */
@BeforeClass
public void setup() throws Exception {
 LensClient client = new LensClient();
 LensCubeCommands command = new LensCubeCommands();
 command.setClient(client);
 log.debug("Starting to test cube commands");
 URL cubeSpec = TestLensQueryCommands.class.getClassLoader().getResource("schema/cubes/base/sample-cube.xml");
 command.createCube(new File(cubeSpec.toURI()));
 TestLensDimensionCommands.createDimension();
 TestLensDimensionTableCommands.addDim1Table("dim_table", "schema/dimtables/dim_table.xml", "local");
 // Add partition
 URL dataDir = TestLensQueryCommands.class.getClassLoader().getResource("dim2-part");
 XPartition xp = new XPartition();
 xp.setFactOrDimensionTableName("dim_table");
 xp.setLocation(new Path(dataDir.toURI()).toString());
 xp.setUpdatePeriod(XUpdatePeriod.HOURLY);
 XTimePartSpec timePart = new XTimePartSpec();
 XTimePartSpecElement partElement = new XTimePartSpecElement();
 partElement.setKey("dt");
 partElement.setValue(DatatypeFactory.newInstance().newXMLGregorianCalendar(new GregorianCalendar()));
 timePart.getPartSpecElement().add(partElement);
 xp.setTimePartitionSpec(timePart);
 APIResult result = client.addPartitionToDim("dim_table", "local", xp);
 assertEquals(result.getStatus(), APIResult.Status.SUCCEEDED);
}

代码示例来源:origin: apache/lens

private XPartition createPartition(String cubeTableName, final List<XTimePartSpecElement>
  timePartSpecs, String updatePeriod) {
 XPartition xp = cubeObjectFactory.createXPartition();
 xp.setLocation(new Path(new File("target").getAbsolutePath(), "part/test_part").toString());
 xp.setFactOrDimensionTableName(cubeTableName);
 xp.setNonTimePartitionSpec(new XPartSpec());
 xp.setTimePartitionSpec(new XTimePartSpec());
 xp.setPartitionParameters(new XProperties());
 xp.setSerdeParameters(new XProperties());
 for (XTimePartSpecElement timePartSpec : timePartSpecs) {
  xp.getTimePartitionSpec().getPartSpecElement().add(timePartSpec);
 }
 if (updatePeriod==null) {
  xp.setUpdatePeriod(XUpdatePeriod.HOURLY);
 } else {
  XUpdatePeriod updatePeriod1=XUpdatePeriod.valueOf(updatePeriod.toUpperCase());
  xp.setUpdatePeriod(updatePeriod1);
 }
 return xp;
}

代码示例来源:origin: org.apache.lens/lens-cube

public static XPartition xpartitionFromPartition(String cubeTableName, Partition p, List<String> timePartCols)
 throws HiveException {
 XPartition xp = new XPartition();
 xp.setFactOrDimensionTableName(cubeTableName);
 xp.setPartitionParameters(new XProperties());
 xp.setSerdeParameters(new XProperties());

代码示例来源:origin: apache/lens

public static XPartition xpartitionFromPartition(String cubeTableName, Partition p, List<String> timePartCols)
 throws HiveException {
 XPartition xp = new XPartition();
 xp.setFactOrDimensionTableName(cubeTableName);
 xp.setPartitionParameters(new XProperties());
 xp.setSerdeParameters(new XProperties());

代码示例来源:origin: apache/lens

xp.setFactOrDimensionTableName("dim_table");
xp.setLocation(new File("target/test-classes/dim2-part").getAbsolutePath());
xp.setUpdatePeriod(XUpdatePeriod.HOURLY);

相关文章