private void onValidateColumn ( TableInfo tableInfo , CfDef cfDef , ColumnInfo columnInfo ) throws Exception { boolean columnfound = false ; boolean isCounterColumnType = isCounterColumnType ( tableInfo , null ) ; for ( ColumnDef columnDef : cfDef . getColumn_metadata ( ) ) { if ( isMetadataSame ( columnDef , columnInfo , isCql3Enabled ( tableInfo ) , isCounterColumnType ) ) { columnfound = true ; break ; } } if ( ! columnfound ) { throw new SchemaGenerationException ( "Column " + columnInfo . getColumnName ( ) + " does not exist in column family " + tableInfo . getTableName ( ) + "" , "Cassandra" , databaseName , tableInfo . getTableName ( ) ) ; } }
On validate column .