(DataOutput out, boolean writeIdentifiers)
| 139 | protected abstract void generatedCodeSetIterator(Iterator<Object> l) throws ExecException; |
| 140 | |
| 141 | protected void write(DataOutput out, boolean writeIdentifiers) throws IOException { |
| 142 | if (writeIdentifiers) { |
| 143 | int id = getSchemaTupleIdentifier(); |
| 144 | if (id < BinInterSedes.UNSIGNED_BYTE_MAX) { |
| 145 | out.writeByte(BinInterSedes.SCHEMA_TUPLE_BYTE_INDEX); |
| 146 | out.writeByte(id); |
| 147 | } else if (id < BinInterSedes.UNSIGNED_SHORT_MAX) { |
| 148 | out.writeByte(BinInterSedes.SCHEMA_TUPLE_SHORT_INDEX); |
| 149 | out.writeShort(id); |
| 150 | } else { |
| 151 | out.writeByte(BinInterSedes.SCHEMA_TUPLE); |
| 152 | out.writeInt(id); |
| 153 | } |
| 154 | } |
| 155 | writeElements(out); |
| 156 | } |
| 157 | |
| 158 | protected static void write(DataOutput out, DataBag v) throws IOException { |
| 159 | bis.writeDatum(out, v, DataType.BAG); |
no test coverage detected