Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
titleGridIoManager.TransmissionSender.java
collapsetrue

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.
    }
}


Copy partition on the fly

...