class IgniteEntryProcessor<K> implements Serializable, CacheEntryProcessor<K, byte[], byte[]> {

    private static final long serialVersionUID = 1;

    private final byte[] requestBytes;

    IgniteEntryProcessor(Request<?> request) {
        this.requestBytes = serializeRequest(request);
    }

    @Override
    public byte[] process(MutableEntry<K, byte[]> entry, Object... arguments) throws EntryProcessorException {<FILL_FUNCTION_BODY>}

}

        return new AbstractBinaryTransaction(requestBytes) {
            @Override
            public boolean exists() {
                return entry.exists();
            }

            @Override
            protected byte[] getRawState() {
                return entry.getValue();
            }

            @Override
            protected void setRawState(byte[] newStateBytes, RemoteBucketState newState) {
                entry.setValue(newStateBytes);
            }
        }.execute();
    
<no_super_class>