Toggle navigation
Home
com.facebook.presto.hive.metastore.HiveMetastore to com.facebook.presto.hive.metastore.ExtendedHiveMetastore
No. of Instances - 36
No. of Commits - 1
No. of Projects - {'presto'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update Class Instacne Creation
new CachingHiveMetastore(hiveCluster,executor,Duration.valueOf("1m"),Duration.valueOf("15s"))
to
new CachingHiveMetastore(new BridgingHiveMetastore(new ThriftHiveMetastore(hiveCluster)),executor,Duration.valueOf("1m"),Duration.valueOf("15s"))
new CachingHiveMetastore(mockHiveCluster,executor,new Duration(5,TimeUnit.MINUTES),new Duration(1,TimeUnit.MINUTES))
to
new CachingHiveMetastore(new BridgingHiveMetastore(thriftHiveMetastore),executor,new Duration(5,TimeUnit.MINUTES),new Duration(1,TimeUnit.MINUTES))
Add or Remove Method invocation
metastore.getPartitionsByNames(schemaName,tableName,partitionNames.get()).get().values().stream().map(partition -> partition.getSd().getLocation()).filter(location -> !location.startsWith(table.getSd().getLocation()))
to
metastore.getPartitionsByNames(schemaName,tableName,partitionNames.get()).values().stream().map(Optional::get).map(partition -> partition.getStorage().getLocation()).filter(location -> !location.startsWith(table.getStorage().getLocation()))
metastore.getPartitionsByNames(handle.getSchemaName(),handle.getTableName(),partitionNameBatch).orElse(ImmutableMap.of()).values().stream().map(partition -> partition.getSd().getLocation()).filter(location -> !location.startsWith(tableDirectory))
to
metastore.getPartitionsByNames(handle.getSchemaName(),handle.getTableName(),partitionNameBatch).values().stream().filter(Optional::isPresent).map(Optional::get).map(partition -> partition.getStorage().getLocation()).filter(location -> !location.startsWith(tableDirectory))
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1)).get().size()
to
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1)).size()
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1,TEST_PARTITION2)).get().size()
to
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1,TEST_PARTITION2)).size()
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1)).get().size()
to
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1)).size()
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION2)).get().size()
to
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION2)).size()
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1,TEST_PARTITION2)).get().size()
to
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1,TEST_PARTITION2)).size()
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1,TEST_PARTITION2)).get().size()
to
metastore.getPartitionsByNames(TEST_DATABASE,TEST_TABLE,ImmutableList.of(TEST_PARTITION1,TEST_PARTITION2)).size()
Update argument list (Method invocation)
createTable
to
createTable
createTable
to
createTable
Rename Method invocation
createTable
to
replaceTable