private boolean isCfDefUpdated ( ColumnInfo columnInfo , CfDef cfDef , boolean isCql3Enabled , boolean isCounterColumnType , TableInfo tableInfo ) throws Exception { boolean columnPresent = false ; boolean isUpdated = false ; for ( ColumnDef columnDef : cfDef . getColumn_metadata ( ) ) { if ( isColumnPresent ( columnInfo , columnDef , isCql3Enabled ) ) { if ( ! isValidationClassSame ( columnInfo , columnDef , isCql3Enabled , isCounterColumnType ) ) { columnDef . setValidation_class ( CassandraValidationClassMapper . getValidationClass ( columnInfo . getType ( ) , isCql3Enabled ) ) ; // if (columnInfo.isIndexable() && // !columnDef.isSetIndex_type()) // { // IndexInfo indexInfo = // tableInfo.getColumnToBeIndexed(columnInfo.getColumnName()); // columnDef.setIndex_type(CassandraIndexHelper.getIndexType(indexInfo.getIndexType())); // columnDef.isSetIndex_type(); // columnDef.setIndex_typeIsSet(true); // columnDef.setIndex_nameIsSet(true); // } // else // { columnDef . setIndex_nameIsSet ( false ) ; columnDef . setIndex_typeIsSet ( false ) ; // } isUpdated = true ; } columnPresent = true ; break ; } } if ( ! columnPresent ) { cfDef . addToColumn_metadata ( getColumnMetadata ( columnInfo , tableInfo ) ) ; isUpdated = true ; } return isUpdated ; }
Checks if is cf def updated .