Java源码示例:org.apache.hadoop.hive.metastore.api.AggrStats

示例1
public AggrStats getAggrColStatsFor(
  String dbName,
  String tblName,
  List<String> colNames,
  List<String> partName
) throws TException {
  throw new UnsupportedOperationException("getAggrColStatsFor is not supported");
}
 
示例2
@Override
@Loggable(value = Loggable.DEBUG, skipResult = true, name = INVOCATION_LOG_NAME)
public AggrStats get_aggr_stats_for(PartitionsStatsRequest request)
    throws NoSuchObjectException, MetaException, TException {
  DatabaseMapping mapping = databaseMappingService.databaseMapping(request.getDbName());
  return mapping.getClient().get_aggr_stats_for(mapping.transformInboundPartitionsStatsRequest(request));
}
 
示例3
@Test
public void get_aggr_stats_for() throws TException {
  PartitionsStatsRequest request = new PartitionsStatsRequest(DB_P, "table", Collections.emptyList(),
      Collections.emptyList());
  PartitionsStatsRequest inboundRequest = new PartitionsStatsRequest();
  AggrStats expected = new AggrStats();
  when(primaryMapping.transformInboundPartitionsStatsRequest(request)).thenReturn(inboundRequest);
  when(primaryClient.get_aggr_stats_for(inboundRequest)).thenReturn(expected);
  AggrStats result = handler.get_aggr_stats_for(request);
  assertThat(result, is(expected));
}
 
示例4
@Override
public AggrStats getAggrColStatsFor(String dbName, String tblName, List<String> colNames, List<String> partName)
    throws NoSuchObjectException, MetaException, TException {
  return glueMetastoreClientDelegate.getAggrColStatsFor(dbName, tblName, colNames, partName);
}
 
示例5
@Override
public AggrStats getAggrColStatsFor(String dbName, String tblName, List<String> colNames, List<String> partName)
    throws NoSuchObjectException, MetaException, TException {
  return glueMetastoreClientDelegate.getAggrColStatsFor(dbName, tblName, colNames, partName);
}
 
示例6
/**
 * {@inheritDoc}
 */
@Override
public AggrStats get_aggr_stats_for(final PartitionsStatsRequest request) throws TException {
    throw unimplemented("get_aggr_stats_for", new Object[]{request});
}