THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public class TransmissionSender implements Closeable { /** * @param file Source file to send to remote. * @param params Additional transfer file description keys. * @param plc The policy of handling data on remote. * @throws IgniteCheckedException If fails. */ public void send( File file, Map<String, Serializable> params, TransmissionPolicy plc ) throws IgniteCheckedException, InterruptedException, IOException { send(file, 0, file.length(), params, plc); } /** * @param file Source file to send to remote. * @param plc The policy of handling data on remote. * @throws IgniteCheckedException If fails. */ public void send( File file, TransmissionPolicy plc ) throws IgniteCheckedException, InterruptedException, IOException { send(file, send(file, 0, file.length(), new HashMap<>(), plc); } /** * @param file Source file to send to remote. * @param offset Position to start trasfer at. * @param cnt Number of bytes to transfer. * @param params Additional transfer file description keys. * @param plc The policy of handling data on remote. * @throws IgniteCheckedException If fails. */ public void send( File file, long offset, long cnt, Map<String, Serializable> params, TransmissionPolicy plc ) throws IgniteCheckedException, InterruptedException, IOException { .. // Impl. } } |
...