| | |
| | | int compare(ByteBuffer cKey, Integer cIndexID) |
| | | { |
| | | ensureRecordFetched(); |
| | | final int cmp = Importer.indexComparator.compare(keyBuf.array(), 0, keyBuf.limit(), cKey.array(), cKey.limit()); |
| | | int cmp = Importer.indexComparator.compare(keyBuf.array(), 0, keyBuf.limit(), cKey.array(), cKey.limit()); |
| | | if (cmp == 0) |
| | | { |
| | | return (indexID.intValue() == cIndexID.intValue()) ? 0 : 1; |
| | |
| | | { |
| | | if (keyBuf.limit() == 0) |
| | | { |
| | | try |
| | | { |
| | | fetchNextRecord(); |
| | | } |
| | | catch (IOException ex) |
| | | { |
| | | logger.error(ERR_JEB_IMPORT_BUFFER_IO_ERROR, indexMgr.getBufferFileName()); |
| | | throw new RuntimeException(ex); |
| | | } |
| | | getIndexID(); |
| | | } |
| | | } |
| | | } |