(Schema schema)
| 80 | } |
| 81 | |
| 82 | public static void validateSchema(Schema schema) throws DDFException { |
| 83 | if(schema != null && schema.getColumns() != null) { |
| 84 | validateColumnNames(schema.getColumnNames()); |
| 85 | } |
| 86 | } |
| 87 | |
| 88 | private static void validateColumnNames(List<String> names) throws DDFException { |
| 89 | Set<String> columnSet = new HashSet<String>(); |