public static void validatePartitionInformation ( TypeInfoCacheSupport . TypeInfo typeInfo , LinkedHashMap < String , String > partitionValMap , String qualifiedTableName ) throws HiveStageCheckedException { Set < String > partitionNamesInHive = typeInfo . getPartitionTypeInfo ( ) . keySet ( ) ; Set < String > partitionNames = partitionValMap . keySet ( ) ; if ( ! ( partitionNamesInHive . size ( ) == partitionNames . size ( ) && partitionNamesInHive . containsAll ( partitionNames ) ) ) { LOG . error ( Utils . format ( "Partition mismatch. In Hive: {}, In Record : {}" , partitionNamesInHive . size ( ) , partitionNames . size ( ) ) ) ; throw new HiveStageCheckedException ( Errors . HIVE_27 , qualifiedTableName ) ; } }
Checks whether the number of partition columns and names match w . r . t hive .