@@ -87,7 +87,7 @@ public void createTable(
8787 String namespace , String table , TableMetadata metadata , Map <String , String > options )
8888 throws ExecutionException {
8989 try {
90- checkMetadata (metadata );
90+ checkTableMetadata (metadata );
9191 // Insert the table metadata
9292 String tableMetadataKey = getTableMetadataKey (namespace , table );
9393 Map <String , String > readVersionMap = new HashMap <>();
@@ -269,7 +269,7 @@ public void repairTable(
269269 String namespace , String table , TableMetadata metadata , Map <String , String > options )
270270 throws ExecutionException {
271271 try {
272- checkMetadata (metadata );
272+ checkTableMetadata (metadata );
273273 // Upsert the table metadata
274274 String tableMetadataKey = getTableMetadataKey (namespace , table );
275275 Map <String , String > readVersionMap = new HashMap <>();
@@ -473,14 +473,7 @@ private static String getTableNameFromTableMetadataKey(String tableMetadataKey)
473473 return parts .get (1 );
474474 }
475475
476- private void checkMetadata (TableMetadata metadata ) {
477- for (String clusteringKeyName : metadata .getClusteringKeyNames ()) {
478- if (metadata .getColumnDataType (clusteringKeyName ) == DataType .BLOB ) {
479- throw new IllegalArgumentException (
480- CoreError .OBJECT_STORAGE_CLUSTERING_KEY_BLOB_TYPE_NOT_SUPPORTED .buildMessage (
481- clusteringKeyName ));
482- }
483- }
476+ private void checkTableMetadata (TableMetadata metadata ) {
484477 Set <String > secondaryIndexNames = metadata .getSecondaryIndexNames ();
485478 if (!secondaryIndexNames .isEmpty ()) {
486479 throw new IllegalArgumentException (
0 commit comments