@Override
    public void onNDArrayPartial(INDArray arr, long idx, int... dimensions) {
        try (AeronNDArrayPublisher publisher = AeronNDArrayPublisher.builder().streamId(streamId).ctx(aeronContext)
                        .channel(masterUrl).build()) {
            publisher.publish(NDArrayMessage.builder().arr(arr).dimensions(dimensions).index(idx).build());
            log.debug("NDArray PublishingListener publishing to channel " + masterUrl + ":" + streamId);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
@ Override public void onNDArrayPartial ( INDArray arr , long idx , int ... dimensions ) { try ( AeronNDArrayPublisher publisher = AeronNDArrayPublisher . builder ( ) . streamId ( streamId ) . ctx ( aeronContext ) . channel ( masterUrl ) . build ( ) ) { publisher . publish ( NDArrayMessage . builder ( ) . arr ( arr ) . dimensions ( dimensions ) . index ( idx ) . build ( ) ) ; log . debug ( "NDArray PublishingListener publishing to channel " + masterUrl + ":" + streamId ) ; } catch ( Exception e ) { throw new RuntimeException ( e ) ; } }
Used for partial updates using tensor along
dimension

@param arr        the array to count as an update
@param idx        the index for the tensor along dimension
@param dimensions the dimensions to act on for the tensor along dimension