ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [02/14] ignite git commit: IGNITE-1513: Merged Java to core module.
Date Fri, 18 Sep 2015 10:04:06 GMT
http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java
deleted file mode 100644
index 79759e9..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderBiClosure.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawReaderEx;
-import org.apache.ignite.lang.IgniteBiTuple;
-
-/**
- * Reader bi-closure.
- */
-public interface PlatformReaderBiClosure<T1, T2> {
-    /**
-     * Read object from reader.
-     *
-     * @param reader Reader.
-     * @return Object.
-     */
-    IgniteBiTuple<T1, T2> read(PortableRawReaderEx reader);
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java
deleted file mode 100644
index 2d9b44a..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformReaderClosure.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawReaderEx;
-
-/**
- * Reader closure.
- */
-public interface PlatformReaderClosure<T> {
-
-    /**
-     * Read object from reader.
-     *
-     * @param reader Reader.
-     * @return Object.
-     */
-    T read(PortableRawReaderEx reader);
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java
deleted file mode 100644
index 11d8371..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformUtils.java
+++ /dev/null
@@ -1,812 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.Ignite;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.cache.CachePeekMode;
-import org.apache.ignite.internal.GridKernalContext;
-import org.apache.ignite.internal.IgniteKernal;
-import org.apache.ignite.internal.portable.PortableRawReaderEx;
-import org.apache.ignite.internal.portable.PortableRawWriterEx;
-import org.apache.ignite.internal.processors.platform.PlatformContext;
-import org.apache.ignite.internal.processors.platform.PlatformExtendedException;
-import org.apache.ignite.internal.processors.platform.PlatformNativeException;
-import org.apache.ignite.internal.processors.platform.PlatformProcessor;
-import org.apache.ignite.internal.processors.platform.memory.PlatformInputStream;
-import org.apache.ignite.internal.processors.platform.memory.PlatformMemory;
-import org.apache.ignite.internal.processors.platform.memory.PlatformMemoryUtils;
-import org.apache.ignite.internal.processors.platform.memory.PlatformOutputStream;
-import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteBiTuple;
-import org.apache.ignite.lang.IgnitePredicate;
-import org.apache.ignite.lang.IgniteUuid;
-import org.apache.ignite.platform.dotnet.PlatformDotNetConfiguration;
-import org.apache.ignite.platform.dotnet.PlatformDotNetPortableConfiguration;
-import org.apache.ignite.platform.dotnet.PlatformDotNetPortableTypeConfiguration;
-import org.jetbrains.annotations.Nullable;
-
-import javax.cache.CacheException;
-import javax.cache.event.CacheEntryEvent;
-import javax.cache.event.CacheEntryListenerException;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_PREFIX;
-
-/**
- * Platform utility methods.
- */
-@SuppressWarnings({"UnusedDeclaration", "unchecked"})
-public class PlatformUtils {
-    /** Node attribute: platform. */
-    public static final String ATTR_PLATFORM = ATTR_PREFIX  + ".platform";
-
-    /** Platform: CPP. */
-    public static final String PLATFORM_CPP = "cpp";
-
-    /** Platform: .Net. */
-    public static final String PLATFORM_DOTNET = "dotnet";
-
-    /** Operation: prepare .Net platform. */
-    public static final int OP_PREPARE_DOT_NET = 1;
-
-    /** Amount of peek modes available. */
-    private static final int CACHE_PEEK_MODES_CNT = CachePeekMode.values().length;
-
-    /** Cache peek modes. */
-    private static volatile CachePeekMode[][] CACHE_PEEK_MODES;
-
-    /**
-     * Static initializer.
-     */
-    static {
-        int len = 1 << CACHE_PEEK_MODES_CNT;
-
-        synchronized (PlatformUtils.class) {
-            CACHE_PEEK_MODES = new CachePeekMode[len][];
-
-            CACHE_PEEK_MODES[0] = new CachePeekMode[0];
-        }
-    }
-
-    /**
-     * Write nullable collection to the writer.
-     *
-     * @param writer Writer.
-     * @param col Collection to write.
-     */
-    public static <T> void writeNullableCollection(PortableRawWriterEx writer, @Nullable Collection<T> col) {
-        writeNullableCollection(writer, col, null, null);
-    }
-
-    /**
-     * Write nullable collection to the writer.
-     *
-     * @param writer Writer.
-     * @param col Collection to write.
-     * @param writeClo Writer closure.
-     */
-    public static <T> void writeNullableCollection(PortableRawWriterEx writer, @Nullable Collection<T> col,
-        @Nullable PlatformWriterClosure<T> writeClo) {
-        writeNullableCollection(writer, col, writeClo, null);
-    }
-
-    /**
-     * Write collection to the writer.
-     *
-     * @param writer Writer.
-     * @param col Collection to write.
-     * @param writeClo Optional writer closure.
-     * @param filter Optional filter.
-     */
-    public static <T> void writeNullableCollection(PortableRawWriterEx writer, @Nullable Collection<T> col,
-        @Nullable PlatformWriterClosure<T> writeClo, @Nullable IgnitePredicate<T> filter) {
-        if (col != null) {
-            writer.writeBoolean(true);
-
-            writeCollection(writer, col, writeClo, filter);
-        }
-        else
-            writer.writeBoolean(false);
-    }
-
-    /**
-     * Write collection to the writer.
-     *
-     * @param writer Writer.
-     * @param col Collection to write.
-     */
-    public static <T> void writeCollection(PortableRawWriterEx writer, Collection<T> col) {
-        writeCollection(writer, col, null, null);
-    }
-
-    /**
-     * Write collection to the writer.
-     *
-     * @param writer Writer.
-     * @param col Collection to write.
-     * @param writeClo Writer closure.
-     */
-    public static <T> void writeCollection(PortableRawWriterEx writer, Collection<T> col,
-        @Nullable PlatformWriterClosure<T> writeClo) {
-        writeCollection(writer, col, writeClo, null);
-    }
-
-    /**
-     * Write collection to the writer.
-     *
-     * @param writer Writer.
-     * @param col Collection to write.
-     * @param writeClo Optional writer closure.
-     * @param filter Optional filter.
-     */
-    public static <T> void writeCollection(PortableRawWriterEx writer, Collection<T> col,
-        @Nullable PlatformWriterClosure<T> writeClo, @Nullable IgnitePredicate<T> filter) {
-        assert col != null;
-
-        if (filter == null) {
-            writer.writeInt(col.size());
-
-            if (writeClo == null) {
-                for (T entry : col)
-                    writer.writeObject(entry);
-            }
-            else {
-                for (T entry : col)
-                    writeClo.write(writer, entry);
-            }
-        }
-        else {
-            int pos = writer.reserveInt();
-            int cnt = 0;
-
-            for (T entry : col) {
-                if (filter.apply(entry)) {
-                    cnt++;
-
-                    if (writeClo == null)
-                        writer.writeObject(entry);
-                    else
-                        writeClo.write(writer, entry);
-                }
-            }
-
-            writer.writeInt(pos, cnt);
-        }
-    }
-
-    /**
-     * Write nullable map to the writer.
-     *
-     * @param writer Writer.
-     * @param map Map to write.
-     */
-    public static <K, V> void writeNullableMap(PortableRawWriterEx writer, @Nullable Map<K, V> map) {
-        if (map != null) {
-            writer.writeBoolean(true);
-
-            writeMap(writer, map);
-        }
-        else
-            writer.writeBoolean(false);
-    }
-
-    /**
-     * Write nullable map to the writer.
-     *
-     * @param writer Writer.
-     * @param map Map to write.
-     */
-    public static <K, V> void writeMap(PortableRawWriterEx writer, Map<K, V> map) {
-        assert map != null;
-
-        writeMap(writer, map, null);
-    }
-
-    /**
-     * Write nullable map to the writer.
-     *
-     * @param writer Writer.
-     * @param map Map to write.
-     * @param writeClo Writer closure.
-     */
-    public static <K, V> void writeMap(PortableRawWriterEx writer, Map<K, V> map,
-        @Nullable PlatformWriterBiClosure<K, V> writeClo) {
-        assert map != null;
-
-        writer.writeInt(map.size());
-
-        if (writeClo == null) {
-            for (Map.Entry<K, V> entry : map.entrySet()) {
-                writer.writeObject(entry.getKey());
-                writer.writeObject(entry.getValue());
-            }
-        }
-        else {
-            for (Map.Entry<K, V> entry : map.entrySet())
-                writeClo.write(writer, entry.getKey(), entry.getValue());
-        }
-    }
-
-    /**
-     * Read collection.
-     *
-     * @param reader Reader.
-     * @return List.
-     */
-    public static <T> List<T> readCollection(PortableRawReaderEx reader) {
-        return readCollection(reader, null);
-    }
-
-    /**
-     * Read collection.
-     *
-     * @param reader Reader.
-     * @param readClo Optional reader closure.
-     * @return List.
-     */
-    public static <T> List<T> readCollection(PortableRawReaderEx reader, @Nullable PlatformReaderClosure<T> readClo) {
-        int cnt = reader.readInt();
-
-        List<T> res = new ArrayList<>(cnt);
-
-        if (readClo == null) {
-            for (int i = 0; i < cnt; i++)
-                res.add((T)reader.readObjectDetached());
-        }
-        else {
-            for (int i = 0; i < cnt; i++)
-                res.add(readClo.read(reader));
-        }
-
-        return res;
-    }
-
-    /**
-     * Read nullable collection.
-     *
-     * @param reader Reader.
-     * @return List.
-     */
-    public static <T> List<T> readNullableCollection(PortableRawReaderEx reader) {
-        return readNullableCollection(reader, null);
-    }
-
-    /**
-     * Read nullable collection.
-     *
-     * @param reader Reader.
-     * @return List.
-     */
-    public static <T> List<T> readNullableCollection(PortableRawReaderEx reader,
-        @Nullable PlatformReaderClosure<T> readClo) {
-        if (!reader.readBoolean())
-            return null;
-
-        return readCollection(reader, readClo);
-    }
-
-    /**
-     * @param reader Reader.
-     * @return Set.
-     */
-    public static <T> Set<T> readSet(PortableRawReaderEx reader) {
-        int cnt = reader.readInt();
-
-        Set<T> res = U.newHashSet(cnt);
-
-        for (int i = 0; i < cnt; i++)
-            res.add((T)reader.readObjectDetached());
-
-        return res;
-    }
-
-    /**
-     * @param reader Reader.
-     * @return Set.
-     */
-    public static <T> Set<T> readNullableSet(PortableRawReaderEx reader) {
-        if (!reader.readBoolean())
-            return null;
-
-        return readSet(reader);
-    }
-
-    /**
-     * Read map.
-     *
-     * @param reader Reader.
-     * @return Map.
-     */
-    public static <K, V> Map<K, V> readMap(PortableRawReaderEx reader) {
-        return readMap(reader, null);
-    }
-
-    /**
-     * Read map.
-     *
-     * @param reader Reader.
-     * @param readClo Reader closure.
-     * @return Map.
-     */
-    public static <K, V> Map<K, V> readMap(PortableRawReaderEx reader,
-        @Nullable PlatformReaderBiClosure<K, V> readClo) {
-        int cnt = reader.readInt();
-
-        Map<K, V> map = U.newHashMap(cnt);
-
-        if (readClo == null) {
-            for (int i = 0; i < cnt; i++)
-                map.put((K)reader.readObjectDetached(), (V)reader.readObjectDetached());
-        }
-        else {
-            for (int i = 0; i < cnt; i++) {
-                IgniteBiTuple<K, V> entry = readClo.read(reader);
-
-                map.put(entry.getKey(), entry.getValue());
-            }
-        }
-
-        return map;
-    }
-
-    /**
-     * Read nullable map.
-     *
-     * @param reader Reader.
-     * @return Map.
-     */
-    public static <K, V> Map<K, V> readNullableMap(PortableRawReaderEx reader) {
-        if (!reader.readBoolean())
-            return null;
-
-        return readMap(reader);
-    }
-
-    /**
-     * Writes IgniteUuid to a writer.
-     *
-     * @param writer Writer.
-     * @param val Values.
-     */
-    public static void writeIgniteUuid(PortableRawWriterEx writer, IgniteUuid val) {
-        if (val == null)
-            writer.writeUuid(null);
-        else {
-            writer.writeUuid(val.globalId());
-            writer.writeLong(val.localId());
-        }
-    }
-
-    /**
-     * Convert native cache peek modes to Java cache peek modes.
-     *
-     * @param modes Encoded peek modes.
-     * @return Cache peek modes.
-     */
-    public static CachePeekMode[] decodeCachePeekModes(int modes) {
-        // 1. Try getting cache value.
-        CachePeekMode[] res = CACHE_PEEK_MODES[modes];
-
-        if (res == null) {
-            // 2. Calculate modes from scratch.
-            List<CachePeekMode> res0 = new ArrayList<>(CACHE_PEEK_MODES_CNT);
-
-            for (int i = 0; i < CACHE_PEEK_MODES_CNT; i++) {
-                int mask = 1 << i;
-
-                if ((modes & mask) == mask)
-                    res0.add(CachePeekMode.fromOrdinal((byte)i));
-            }
-
-            res = res0.toArray(new CachePeekMode[res0.size()]);
-
-            synchronized (PlatformUtils.class) {
-                CACHE_PEEK_MODES[modes] = res;
-            }
-        }
-
-        return res;
-    }
-
-    /**
-     * Unwrap query exception.
-     *
-     * @param err Initial error.
-     * @return Unwrapped error.
-     */
-    public static IgniteCheckedException unwrapQueryException(Throwable err) {
-        assert err != null;
-
-        Throwable parent = err;
-        Throwable child = parent.getCause();
-
-        while (true) {
-            if (child == null || child == parent)
-                break;
-
-            if (child instanceof IgniteException || child instanceof IgniteCheckedException
-                || child instanceof CacheException) {
-                // Continue unwrapping.
-                parent = child;
-
-                child = parent.getCause();
-
-                continue;
-            }
-
-            break;
-        }
-
-        // Specific exception found, but detailed message doesn't exist. Just pass exception name then.
-        if (parent.getMessage() == null)
-            return new IgniteCheckedException("Query execution failed due to exception: " +
-                parent.getClass().getName(), err);
-
-        return new IgniteCheckedException(parent.getMessage(), err);
-    }
-
-    /**
-     * Apply continuous query events to listener.
-     *
-     * @param ctx Context.
-     * @param lsnrPtr Listener pointer.
-     * @param evts Events.
-     * @throws javax.cache.event.CacheEntryListenerException In case of failure.
-     */
-    public static void applyContinuousQueryEvents(PlatformContext ctx, long lsnrPtr, Iterable<CacheEntryEvent> evts)
-        throws CacheEntryListenerException {
-        assert lsnrPtr != 0;
-        assert evts != null;
-
-        try (PlatformMemory mem = ctx.memory().allocate()) {
-            PlatformOutputStream out = mem.output();
-
-            PortableRawWriterEx writer = ctx.writer(out);
-
-            int cntPos = writer.reserveInt();
-
-            int cnt = 0;
-
-            for (CacheEntryEvent evt : evts) {
-                writeCacheEntryEvent(writer, evt);
-
-                cnt++;
-            }
-
-            writer.writeInt(cntPos, cnt);
-
-            out.synchronize();
-
-            ctx.gateway().continuousQueryListenerApply(lsnrPtr, mem.pointer());
-        }
-        catch (Exception e) {
-            throw toCacheEntryListenerException(e);
-        }
-    }
-
-    /**
-     * Evaluate the filter.
-     *
-     * @param ctx Context.
-     * @param filterPtr Native filter pointer.
-     * @param evt Event.
-     * @return Result.
-     * @throws CacheEntryListenerException In case of failure.
-     */
-    public static boolean evaluateContinuousQueryEvent(PlatformContext ctx, long filterPtr, CacheEntryEvent evt)
-        throws CacheEntryListenerException {
-        assert filterPtr != 0;
-
-        try (PlatformMemory mem = ctx.memory().allocate()) {
-            PlatformOutputStream out = mem.output();
-
-            writeCacheEntryEvent(ctx.writer(out), evt);
-
-            out.synchronize();
-
-            return ctx.gateway().continuousQueryFilterApply(filterPtr, mem.pointer()) == 1;
-        }
-        catch (Exception e) {
-            throw toCacheEntryListenerException(e);
-        }
-    }
-
-    /**
-     * Convert exception into listener exception.
-     *
-     * @param e Listener exception.
-     * @return Exception.
-     */
-    private static CacheEntryListenerException toCacheEntryListenerException(Exception e) {
-        assert e != null;
-
-        return e instanceof CacheEntryListenerException ? (CacheEntryListenerException)e : e.getMessage() != null ?
-            new CacheEntryListenerException(e.getMessage(), e) : new CacheEntryListenerException(e);
-    }
-
-    /**
-     * Write event to the writer.
-     *
-     * @param writer Writer.
-     * @param evt Event.
-     */
-    private static void writeCacheEntryEvent(PortableRawWriterEx writer, CacheEntryEvent evt) {
-        writer.writeObjectDetached(evt.getKey());
-        writer.writeObjectDetached(evt.getOldValue());
-        writer.writeObjectDetached(evt.getValue());
-    }
-
-    /**
-     * Writer error data.
-     *
-     * @param err Error.
-     * @param writer Writer.
-     */
-    public static void writeErrorData(Throwable err, PortableRawWriterEx writer) {
-        writeErrorData(err, writer, null);
-    }
-
-    /**
-     * Write error data.
-     * @param err Error.
-     * @param writer Writer.
-     * @param log Optional logger.
-     */
-    public static void writeErrorData(Throwable err, PortableRawWriterEx writer, @Nullable IgniteLogger log) {
-        // Write additional data if needed.
-        if (err instanceof PlatformExtendedException) {
-            PlatformExtendedException err0 = (PlatformExtendedException)err;
-
-            writer.writeBoolean(true); // Data exists.
-
-            int pos = writer.out().position();
-
-            try {
-                writer.writeBoolean(true); // Optimistically assume that we will be able to write it.
-                err0.writeData(writer);
-            }
-            catch (Exception e) {
-                if (log != null)
-                    U.warn(log, "Failed to write interop exception data: " + e.getMessage(), e);
-
-                writer.out().position(pos);
-
-                writer.writeBoolean(false); // Error occurred.
-                writer.writeString(e.getClass().getName());
-
-                String innerMsg;
-
-                try {
-                    innerMsg = e.getMessage();
-                }
-                catch (Exception innerErr) {
-                    innerMsg = "Exception message is not available.";
-                }
-
-                writer.writeString(innerMsg);
-            }
-        }
-        else
-            writer.writeBoolean(false);
-    }
-
-    /**
-     * Get GridGain platform processor.
-     *
-     * @param grid Ignite instance.
-     * @return Platform processor.
-     */
-    public static PlatformProcessor platformProcessor(Ignite grid) {
-        GridKernalContext ctx = ((IgniteKernal) grid).context();
-
-        return ctx.platform();
-    }
-
-    /**
-     * Gets interop context for the grid.
-     *
-     * @param grid Grid
-     * @return Context.
-     */
-    public static PlatformContext platformContext(Ignite grid) {
-        return platformProcessor(grid).context();
-    }
-
-    /**
-     * Reallocate arbitrary memory chunk.
-     *
-     * @param memPtr Memory pointer.
-     * @param cap Capacity.
-     */
-    public static void reallocate(long memPtr, int cap) {
-        PlatformMemoryUtils.reallocate(memPtr, cap);
-    }
-
-    /**
-     * Get error data.
-     *
-     * @param err Error.
-     * @return Error data.
-     */
-    @SuppressWarnings("UnusedDeclaration")
-    public static byte[] errorData(Throwable err) {
-        if (err instanceof PlatformExtendedException) {
-            PlatformContext ctx = ((PlatformExtendedException)err).context();
-
-            try (PlatformMemory mem = ctx.memory().allocate()) {
-                // Write error data.
-                PlatformOutputStream out = mem.output();
-
-                PortableRawWriterEx writer = ctx.writer(out);
-
-                try {
-                    PlatformUtils.writeErrorData(err, writer, ctx.kernalContext().log(PlatformContext.class));
-                }
-                finally {
-                    out.synchronize();
-                }
-
-                // Read error data into separate array.
-                PlatformInputStream in = mem.input();
-
-                in.synchronize();
-
-                int len = in.remaining();
-
-                assert len > 0;
-
-                byte[] arr = in.array();
-                byte[] res = new byte[len];
-
-                System.arraycopy(arr, 0, res, 0, len);
-
-                return res;
-            }
-        }
-        else
-            return null;
-    }
-
-    /**
-     * Writes invocation result (of a job/service/etc) using a common protocol.
-     *
-     * @param writer Writer.
-     * @param resObj Result.
-     * @param err Error.
-     */
-    public static void writeInvocationResult(PortableRawWriterEx writer, Object resObj, Exception err)
-    {
-        if (err == null) {
-            writer.writeBoolean(true);
-            writer.writeObject(resObj);
-        }
-        else {
-            writer.writeBoolean(false);
-
-            PlatformNativeException nativeErr = null;
-
-            if (err instanceof IgniteCheckedException)
-                nativeErr = ((IgniteCheckedException)err).getCause(PlatformNativeException.class);
-            else if (err instanceof IgniteException)
-                nativeErr = ((IgniteException)err).getCause(PlatformNativeException.class);
-
-            if (nativeErr == null) {
-                writer.writeBoolean(false);
-                writer.writeString(err.getClass().getName());
-                writer.writeString(err.getMessage());
-            }
-            else {
-                writer.writeBoolean(true);
-                writer.writeObject(nativeErr.cause());
-            }
-        }
-    }
-
-    /**
-     * Reads invocation result (of a job/service/etc) using a common protocol.
-     *
-     * @param ctx Platform context.
-     * @param reader Reader.
-     * @return Result.
-     * @throws IgniteCheckedException When invocation result is an error.
-     */
-    public static Object readInvocationResult(PlatformContext ctx, PortableRawReaderEx reader)
-        throws IgniteCheckedException {
-        // 1. Read success flag.
-        boolean success = reader.readBoolean();
-
-        if (success)
-            // 2. Return result as is.
-            return reader.readObjectDetached();
-        else {
-            // 3. Read whether exception is in form of object or string.
-            boolean hasException = reader.readBoolean();
-
-            if (hasException) {
-                // 4. Full exception.
-                Object nativeErr = reader.readObjectDetached();
-
-                assert nativeErr != null;
-
-                throw ctx.createNativeException(nativeErr);
-            }
-            else {
-                // 5. Native exception was not serializable, we have only message.
-                String errMsg = reader.readString();
-
-                assert errMsg != null;
-
-                throw new IgniteCheckedException(errMsg);
-            }
-        }
-    }
-
-    /**
-     * Write .Net configuration to the stream.
-     *
-     * @param writer Writer.
-     * @param cfg Configuration.
-     */
-    public static void writeDotNetConfiguration(PortableRawWriterEx writer, PlatformDotNetConfiguration cfg) {
-        // 1. Write assemblies.
-        writeNullableCollection(writer, cfg.getAssemblies());
-
-        PlatformDotNetPortableConfiguration portableCfg = cfg.getPortableConfiguration();
-
-        if (portableCfg != null) {
-            writer.writeBoolean(true);
-
-            writeNullableCollection(writer, portableCfg.getTypesConfiguration(),
-                new PlatformWriterClosure<PlatformDotNetPortableTypeConfiguration>() {
-                @Override public void write(PortableRawWriterEx writer, PlatformDotNetPortableTypeConfiguration typ) {
-                    writer.writeString(typ.getAssemblyName());
-                    writer.writeString(typ.getTypeName());
-                    writer.writeString(typ.getNameMapper());
-                    writer.writeString(typ.getIdMapper());
-                    writer.writeString(typ.getSerializer());
-                    writer.writeString(typ.getAffinityKeyFieldName());
-                    writer.writeObject(typ.getMetadataEnabled());
-                    writer.writeObject(typ.getKeepDeserialized());
-                }
-            });
-
-            writeNullableCollection(writer, portableCfg.getTypes());
-            writer.writeString(portableCfg.getDefaultNameMapper());
-            writer.writeString(portableCfg.getDefaultIdMapper());
-            writer.writeString(portableCfg.getDefaultSerializer());
-            writer.writeBoolean(portableCfg.isDefaultMetadataEnabled());
-            writer.writeBoolean(portableCfg.isDefaultKeepDeserialized());
-        }
-        else
-            writer.writeBoolean(false);
-    }
-
-    /**
-     * Private constructor.
-     */
-    private PlatformUtils() {
-        // No-op.
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java
deleted file mode 100644
index 6b04ad3..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterBiClosure.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawWriterEx;
-
-/**
- * Interop writer bi-closure.
- */
-public interface PlatformWriterBiClosure<T1, T2> {
-    /**
-     * Write values.
-     *
-     * @param writer Writer.
-     * @param val1 Value 1.
-     * @param val2 Value 2.
-     */
-    public void write(PortableRawWriterEx writer, T1 val1, T2 val2);
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java
deleted file mode 100644
index a67d70a..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/utils/PlatformWriterClosure.java
+++ /dev/null
@@ -1,33 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.platform.utils;
-
-import org.apache.ignite.internal.portable.PortableRawWriterEx;
-
-/**
- * Interop writer closure.
- */
-public interface PlatformWriterClosure<T> {
-    /**
-     * Write value.
-     *
-     * @param writer Writer.
-     * @param val Value.
-     */
-    public void write(PortableRawWriterEx writer, T val);
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java
deleted file mode 100644
index 18f8a43..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/PlatformCppConfiguration.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.cpp;
-
-import org.apache.ignite.configuration.PlatformConfiguration;
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-/**
- * Platform CPP configuration.
- */
-public class PlatformCppConfiguration implements PlatformConfiguration {
-    /**
-     * Default constructor.
-     */
-    public PlatformCppConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copying constructor.
-     *
-     * @param cfg Configuration to copy.
-     */
-    public PlatformCppConfiguration(PlatformConfiguration cfg) {
-        // No-op.
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(PlatformConfiguration.class, this);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java b/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java
deleted file mode 100644
index 6d745a7..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/cpp/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Contains C++ platform-related classes.
- */
-package org.apache.ignite.platform.cpp;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java
deleted file mode 100644
index 97f0dce..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetCacheStoreFactory.java
+++ /dev/null
@@ -1,139 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.processors.platform.dotnet.PlatformDotNetCacheStore;
-
-import javax.cache.configuration.Factory;
-import java.util.Map;
-
-/**
- * Wrapper for .NET cache store implementations.
- * <p>
- * This wrapper should be used if you have an implementation of
- * {@code GridGain.Cache.IGridCacheStore} interface in .NET and
- * would like to configure it a persistence storage for your cache.
- * To do tis you will need to configure the wrapper via
- * {@link org.apache.ignite.configuration.CacheConfiguration#setCacheStoreFactory(javax.cache.configuration.Factory)} property
- * and provide assembly name and class name of your .NET store
- * implementation (both properties are mandatory):
- * <pre name="code" class="xml">
- * &lt;bean class="org.apache.ignite.cache.CacheConfiguration"&gt;
- *     ...
- *     &lt;property name="cacheStoreFactory"&gt;
- *         &lt;bean class="org.gridgain.grid.interop.dotnet.InteropDotNetCacheStoreFactory"&gt;
- *             &lt;property name="assemblyName" value="MyAssembly"/&gt;
- *             &lt;property name="className" value="MyApp.MyCacheStore"/&gt;
- *         &lt;/bean&gt;
- *     &lt;/property&gt;
- *     ...
- * &lt;/bean&gt;
- * </pre>
- * If properly configured, this wrapper will instantiate an instance
- * of your cache store in .NET and delegate all calls to that instance.
- * To create an instance, assembly name and class name are passed to
- * <a target="_blank" href="http://msdn.microsoft.com/en-us/library/d133hta4.aspx">System.Activator.CreateInstance(String, String)</a>
- * method in .NET during node startup. Refer to its documentation for
- * details.
- */
-public class PlatformDotNetCacheStoreFactory implements Factory<PlatformDotNetCacheStore> {
-    /** */
-    private static final long serialVersionUID = 0L;
-
-    /** .Net assembly name. */
-    private String assemblyName;
-
-    /** .Net class name. */
-    private String clsName;
-
-    /** Properties. */
-    private Map<String, ?> props;
-
-    /** Instance. */
-    private transient PlatformDotNetCacheStore instance;
-
-    /**
-     * Gets .NET assembly name.
-     *
-     * @return .NET assembly name.
-     */
-    public String getAssemblyName() {
-        return assemblyName;
-    }
-
-    /**
-     * Set .NET assembly name.
-     *
-     * @param assemblyName .NET assembly name.
-     */
-    public void setAssemblyName(String assemblyName) {
-        this.assemblyName = assemblyName;
-    }
-
-    /**
-     * Gets .NET class name.
-     *
-     * @return .NET class name.
-     */
-    public String getClassName() {
-        return clsName;
-    }
-
-    /**
-     * Sets .NET class name.
-     *
-     * @param clsName .NET class name.
-     */
-    public void setClassName(String clsName) {
-        this.clsName = clsName;
-    }
-
-    /**
-     * Get properties.
-     *
-     * @return Properties.
-     */
-    public Map<String, ?> getProperties() {
-        return props;
-    }
-
-    /**
-     * Set properties.
-     *
-     * @param props Properties.
-     */
-    public void setProperties(Map<String, ?> props) {
-        this.props = props;
-    }
-
-    /** {@inheritDoc} */
-    @SuppressWarnings("unchecked")
-    @Override public PlatformDotNetCacheStore create() {
-        synchronized (this) {
-            if (instance == null) {
-                instance = new PlatformDotNetCacheStore();
-
-                instance.setAssemblyName(assemblyName);
-                instance.setClassName(clsName);
-                instance.setProperties(props);
-            }
-
-            return instance;
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java
deleted file mode 100644
index 0550bab..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetConfiguration.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.configuration.PlatformConfiguration;
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * Mirror of .Net class Configuration.cs
- */
-public class PlatformDotNetConfiguration implements PlatformConfiguration {
-    /** */
-    private PlatformDotNetPortableConfiguration portableCfg;
-
-    /** */
-    private List<String> assemblies;
-
-    /**
-     * Default constructor.
-     */
-    public PlatformDotNetConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copy constructor.
-     *
-     * @param cfg Configuration to copy.
-     */
-    public PlatformDotNetConfiguration(PlatformDotNetConfiguration cfg) {
-        if (cfg.getPortableConfiguration() != null)
-            portableCfg = new PlatformDotNetPortableConfiguration(cfg.getPortableConfiguration());
-
-        if (cfg.getAssemblies() != null)
-            assemblies = new ArrayList<>(cfg.getAssemblies());
-    }
-
-    /**
-     * @return Configuration.
-     */
-    public PlatformDotNetPortableConfiguration getPortableConfiguration() {
-        return portableCfg;
-    }
-
-    /**
-     * @param portableCfg Configuration.
-     */
-    public void setPortableConfiguration(PlatformDotNetPortableConfiguration portableCfg) {
-        this.portableCfg = portableCfg;
-    }
-
-    /**
-     * @return Assemblies.
-     */
-    public List<String> getAssemblies() {
-        return assemblies;
-    }
-
-    /**
-     *
-     * @param assemblies Assemblies.
-     */
-    public void setAssemblies(List<String> assemblies) {
-        this.assemblies = assemblies;
-    }
-
-    /**
-     * @return Configuration copy.
-     */
-    @SuppressWarnings("UnusedDeclaration")
-    private PlatformDotNetConfiguration copy() {
-        return new PlatformDotNetConfiguration(this);
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(PlatformDotNetConfiguration.class, this);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java
deleted file mode 100644
index 8e4b590..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetLifecycleBean.java
+++ /dev/null
@@ -1,109 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.processors.platform.lifecycle.PlatformLifecycleBean;
-import org.apache.ignite.lifecycle.LifecycleBean;
-
-import java.util.Map;
-
-/**
- * Lifecycle bean implementation which can be used to configure .Net lifecycle beans in Java Spring configuration.
- */
-public class PlatformDotNetLifecycleBean extends PlatformLifecycleBean implements LifecycleBean {
-    /** Assembly name. */
-    private String assemblyName;
-
-    /** Class name. */
-    private String clsName;
-
-    /** Properties. */
-    private Map<String, ?> props;
-
-    /**
-     * Constructor.
-     */
-    public PlatformDotNetLifecycleBean() {
-        // No-op.
-    }
-
-    /**
-     * Constructor.
-     *
-     * @param assemblyName Assembly name.
-     * @param clsName Class name.
-     */
-    public PlatformDotNetLifecycleBean(String assemblyName, String clsName) {
-        this.assemblyName = assemblyName;
-        this.clsName = clsName;
-    }
-
-    /**
-     * Get assembly name.
-     *
-     * @return Assembly name.
-     */
-    public String getAssemblyName() {
-        return assemblyName;
-    }
-
-    /**
-     * Set assembly name.
-     *
-     * @param assemblyName Assembly name.
-     */
-    public void setAssemblyName(String assemblyName) {
-        this.assemblyName = assemblyName;
-    }
-
-    /**
-     * Get class name.
-     *
-     * @return Class name.
-     */
-    public String getClassName() {
-        return clsName;
-    }
-
-    /**
-     * Set class name.
-     *
-     * @param clsName Class name.
-     */
-    public void setClassName(String clsName) {
-        this.clsName = clsName;
-    }
-
-    /**
-     * Get properties.
-     *
-     * @return Properties.
-     */
-    public Map<String, ?> getProperties() {
-        return props;
-    }
-
-    /**
-     * Set properties.
-     *
-     * @param props Properties.
-     */
-    public void setProperties(Map<String, ?> props) {
-        this.props = props;
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java
deleted file mode 100644
index dd7b988..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableConfiguration.java
+++ /dev/null
@@ -1,196 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.util.typedef.internal.S;
-
-import java.util.ArrayList;
-import java.util.Collection;
-
-/**
- * Mirror of .Net class PortableConfiguration.cs
- */
-public class PlatformDotNetPortableConfiguration {
-    /** Type cfgs. */
-    private Collection<PlatformDotNetPortableTypeConfiguration> typesCfg;
-
-    /** Types. */
-    private Collection<String> types;
-
-    /** Default name mapper. */
-    private String dfltNameMapper;
-
-    /** Default id mapper. */
-    private String dfltIdMapper;
-
-    /** Default serializer. */
-    private String dfltSerializer;
-
-    /** Default metadata enabled. */
-    private boolean dfltMetadataEnabled = true;
-
-    /** Whether to cache deserialized value in IGridPortableObject */
-    private boolean dfltKeepDeserialized = true;
-
-    /**
-     * Default constructor.
-     */
-    public PlatformDotNetPortableConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copy constructor.
-     * @param cfg configuration to copy.
-     */
-    public PlatformDotNetPortableConfiguration(PlatformDotNetPortableConfiguration cfg) {
-        if (cfg.getTypesConfiguration() != null) {
-            typesCfg = new ArrayList<>();
-
-            for (PlatformDotNetPortableTypeConfiguration typeCfg : cfg.getTypesConfiguration())
-                typesCfg.add(new PlatformDotNetPortableTypeConfiguration(typeCfg));
-        }
-
-        if (cfg.getTypes() != null)
-            types = new ArrayList<>(cfg.getTypes());
-
-        dfltNameMapper = cfg.getDefaultNameMapper();
-        dfltIdMapper = cfg.getDefaultIdMapper();
-        dfltSerializer = cfg.getDefaultSerializer();
-        dfltMetadataEnabled = cfg.isDefaultMetadataEnabled();
-        dfltKeepDeserialized = cfg.isDefaultKeepDeserialized();
-    }
-
-    /**
-     * @return Type cfgs.
-     */
-    public Collection<PlatformDotNetPortableTypeConfiguration> getTypesConfiguration() {
-        return typesCfg;
-    }
-
-    /**
-     * @param typesCfg New type cfgs.
-     */
-    public void setTypesConfiguration(Collection<PlatformDotNetPortableTypeConfiguration> typesCfg) {
-        this.typesCfg = typesCfg;
-    }
-
-    /**
-     * @return Types.
-     */
-    public Collection<String> getTypes() {
-        return types;
-    }
-
-    /**
-     * @param types New types.
-     */
-    public void setTypes(Collection<String> types) {
-        this.types = types;
-    }
-
-    /**
-     * @return Default name mapper.
-     */
-    public String getDefaultNameMapper() {
-        return dfltNameMapper;
-    }
-
-    /**
-     * @param dfltNameMapper New default name mapper.
-     */
-    public void setDefaultNameMapper(String dfltNameMapper) {
-        this.dfltNameMapper = dfltNameMapper;
-    }
-
-    /**
-     * @return Default id mapper.
-     */
-    public String getDefaultIdMapper() {
-        return dfltIdMapper;
-    }
-
-    /**
-     * @param dfltIdMapper New default id mapper.
-     */
-    public void setDefaultIdMapper(String dfltIdMapper) {
-        this.dfltIdMapper = dfltIdMapper;
-    }
-
-    /**
-     * @return Default serializer.
-     */
-    public String getDefaultSerializer() {
-        return dfltSerializer;
-    }
-
-    /**
-     * @param dfltSerializer New default serializer.
-     */
-    public void setDefaultSerializer(String dfltSerializer) {
-        this.dfltSerializer = dfltSerializer;
-    }
-
-    /**
-     * Gets default metadata enabled flag. See {@link #setDefaultMetadataEnabled(boolean)} for more information.
-     *
-     * @return Default metadata enabled flag.
-     */
-    public boolean isDefaultMetadataEnabled() {
-        return dfltMetadataEnabled;
-    }
-
-    /**
-     * Sets default metadata enabled flag. When set to {@code true} all portable types will save it's metadata to
-     * cluster.
-     * <p />
-     * Can be overridden for particular type using
-     * {@link PlatformDotNetPortableTypeConfiguration#setMetadataEnabled(Boolean)}.
-     *
-     * @param dfltMetadataEnabled Default metadata enabled flag.
-     */
-    public void setDefaultMetadataEnabled(boolean dfltMetadataEnabled) {
-        this.dfltMetadataEnabled = dfltMetadataEnabled;
-    }
-
-    /**
-     * Gets default keep deserialized flag. See {@link #setDefaultKeepDeserialized(boolean)} for more information.
-     *
-     * @return  Flag indicates whether to cache deserialized value in IGridPortableObject.
-     */
-    public boolean isDefaultKeepDeserialized() {
-        return dfltKeepDeserialized;
-    }
-
-    /**
-     * Sets default keep deserialized flag.
-     * <p />
-     * Can be overridden for particular type using
-     * {@link PlatformDotNetPortableTypeConfiguration#setKeepDeserialized(Boolean)}.
-     *
-     * @param keepDeserialized Keep deserialized flag.
-     */
-    public void setDefaultKeepDeserialized(boolean keepDeserialized) {
-        this.dfltKeepDeserialized = keepDeserialized;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(PlatformDotNetPortableConfiguration.class, this);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java
deleted file mode 100644
index b04d2a7..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/PlatformDotNetPortableTypeConfiguration.java
+++ /dev/null
@@ -1,214 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform.dotnet;
-
-import org.apache.ignite.internal.util.typedef.internal.S;
-import org.jetbrains.annotations.Nullable;
-
-/**
- * Mirror of .Net class GridDotNetPortableTypeConfiguration.cs
- */
-public class PlatformDotNetPortableTypeConfiguration {
-    /** Assembly name. */
-    private String assemblyName;
-
-    /** Type name. */
-    private String typeName;
-
-    /** Name mapper. */
-    private String nameMapper;
-
-    /** Id mapper. */
-    private String idMapper;
-
-    /** Serializer. */
-    private String serializer;
-
-    /** Affinity key field name. */
-    private String affinityKeyFieldName;
-
-    /** Metadata enabled. */
-    private Boolean metadataEnabled;
-
-    /** Whether to cache deserialized value in IGridPortableObject. */
-    private Boolean keepDeserialized;
-
-    /**
-     * Default constructor.
-     */
-    public PlatformDotNetPortableTypeConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copy constructor.
-     * @param cfg configuration to copy.
-     */
-    public PlatformDotNetPortableTypeConfiguration(PlatformDotNetPortableTypeConfiguration cfg) {
-        assemblyName = cfg.getAssemblyName();
-        typeName = cfg.getTypeName();
-        nameMapper = cfg.getNameMapper();
-        idMapper = cfg.getIdMapper();
-        serializer = cfg.getSerializer();
-        affinityKeyFieldName = cfg.getAffinityKeyFieldName();
-        metadataEnabled = cfg.getMetadataEnabled();
-        keepDeserialized = cfg.isKeepDeserialized();
-    }
-
-    /**
-     * @return Assembly name.
-     */
-    public String getAssemblyName() {
-        return assemblyName;
-    }
-
-    /**
-     * @param assemblyName New assembly name.
-     */
-    public void setAssemblyName(String assemblyName) {
-        this.assemblyName = assemblyName;
-    }
-
-    /**
-     * @return Type name.
-     */
-    public String getTypeName() {
-        return typeName;
-    }
-
-    /**
-     * @param typeName New type name.
-     */
-    public void setTypeName(String typeName) {
-        this.typeName = typeName;
-    }
-
-    /**
-     * @return Name mapper.
-     */
-    public String getNameMapper() {
-        return nameMapper;
-    }
-
-    /**
-     * @param nameMapper New name mapper.
-     */
-    public void setNameMapper(String nameMapper) {
-        this.nameMapper = nameMapper;
-    }
-
-    /**
-     * @return Id mapper.
-     */
-    public String getIdMapper() {
-        return idMapper;
-    }
-
-    /**
-     * @param idMapper New id mapper.
-     */
-    public void setIdMapper(String idMapper) {
-        this.idMapper = idMapper;
-    }
-
-    /**
-     * @return Serializer.
-     */
-    public String getSerializer() {
-        return serializer;
-    }
-
-    /**
-     * @param serializer New serializer.
-     */
-    public void setSerializer(String serializer) {
-        this.serializer = serializer;
-    }
-
-    /**
-     * Gets metadata enabled flag. See {@link #setMetadataEnabled(Boolean)} for more information.
-     *
-     * @return Metadata enabled flag.
-     */
-    public Boolean getMetadataEnabled() {
-        return metadataEnabled;
-    }
-
-    /**
-     * Sets metadata enabled flag.
-     * <p />
-     * When set to {@code null} default value taken from
-     * {@link PlatformDotNetPortableConfiguration#isDefaultMetadataEnabled()} will be used.
-     *
-     * @param metadataEnabled New metadata enabled.
-     */
-    public void setMetadataEnabled(Boolean metadataEnabled) {
-        this.metadataEnabled = metadataEnabled;
-    }
-
-    /**
-     * @return Affinity key field name.
-     */
-    public String getAffinityKeyFieldName() {
-        return affinityKeyFieldName;
-    }
-
-    /**
-     * @param affinityKeyFieldName Affinity key field name.
-     */
-    public void setAffinityKeyFieldName(String affinityKeyFieldName) {
-        this.affinityKeyFieldName = affinityKeyFieldName;
-    }
-
-    /**
-     * Gets keep deserialized flag.
-     *
-     * @return Flag indicates whether to cache deserialized value in IGridPortableObject.
-     * @deprecated Use {@link #getKeepDeserialized()} instead.
-     */
-    @Deprecated
-    @Nullable public Boolean isKeepDeserialized() {
-        return keepDeserialized;
-    }
-
-    /**
-     * Gets keep deserialized flag. See {@link #setKeepDeserialized(Boolean)} for more information.
-     *
-     * @return Flag indicates whether to cache deserialized value in IGridPortableObject.
-     */
-    @Nullable public Boolean getKeepDeserialized() {
-        return keepDeserialized;
-    }
-
-    /**
-     * Sets keep deserialized flag.
-     * <p />
-     * When set to {@code null} default value taken from
-     * {@link PlatformDotNetPortableConfiguration#isDefaultKeepDeserialized()} will be used.
-     *
-     * @param keepDeserialized Keep deserialized flag.
-     */
-    public void setKeepDeserialized(@Nullable Boolean keepDeserialized) {
-        this.keepDeserialized = keepDeserialized;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(PlatformDotNetPortableTypeConfiguration.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java b/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java
deleted file mode 100644
index 0765e01..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/dotnet/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Contains .Net platform-related classes.
- */
-package org.apache.ignite.platform.dotnet;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java b/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java
deleted file mode 100644
index ac89b58..0000000
--- a/modules/platform/src/main/java/org/apache/ignite/platform/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Contains platform-related classes.
- */
-package org.apache.ignite.platform;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java
deleted file mode 100644
index c721e16..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeBroadcastTask.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-import org.apache.ignite.Ignite;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
-import org.apache.ignite.compute.ComputeJobAdapter;
-import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.resources.IgniteInstanceResource;
-import org.jetbrains.annotations.Nullable;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-
-/**
- * Task collecting IDs of all nodes where it was executed.
- */
-public class PlatformComputeBroadcastTask extends ComputeTaskAdapter<Object, Collection<UUID>> {
-    /** {@inheritDoc} */
-    @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) {
-        Map<ComputeJob, ClusterNode> jobs = new HashMap<>();
-
-        for (ClusterNode node : subgrid)
-            jobs.put(new BroadcastJob(), node);
-
-        return jobs;
-    }
-
-    /** {@inheritDoc} */
-    @Nullable @Override public Collection<UUID> reduce(List<ComputeJobResult> results) {
-        List<UUID> ids = new ArrayList<>();
-
-        for (ComputeJobResult res : results)
-            ids.add((UUID)res.getData());
-
-        return ids;
-    }
-
-    /**
-     * Job.
-     */
-    private static class BroadcastJob extends ComputeJobAdapter {
-        /** */
-        @IgniteInstanceResource
-        private Ignite ignite;
-
-        /** {@inheritDoc} */
-        @Nullable @Override public Object execute() {
-            return ignite.cluster().localNode().id();
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java
deleted file mode 100644
index a14e481..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeDecimalTask.java
+++ /dev/null
@@ -1,106 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
-import org.apache.ignite.compute.ComputeJobAdapter;
-import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.internal.util.typedef.F;
-import org.jetbrains.annotations.Nullable;
-
-import java.io.Externalizable;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
-import java.math.BigDecimal;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-
-@SuppressWarnings({"ConstantConditions", "UnusedDeclaration"})
-public class PlatformComputeDecimalTask extends ComputeTaskAdapter<Object[], BigDecimal> {
-    /** {@inheritDoc} */
-    @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object[] arg) {
-        return Collections.singletonMap(new DecimalJob((BigDecimal)arg[0], (String)arg[1]), F.first(subgrid));
-    }
-
-    /** {@inheritDoc} */
-    @SuppressWarnings("ThrowableResultOfMethodCallIgnored")
-    @Nullable @Override public BigDecimal reduce(List<ComputeJobResult> results) {
-        ComputeJobResult res = results.get(0);
-
-        if (res.getException() != null)
-            throw res.getException();
-        else
-            return results.get(0).getData();
-    }
-
-    /**
-     * Job.
-     */
-    private static class DecimalJob extends ComputeJobAdapter implements Externalizable {
-        /** Value. */
-        private BigDecimal val;
-
-        /** Value as string. */
-        private String valStr;
-
-        /**
-         * Constructor.
-         */
-        public DecimalJob() {
-            // No-op.
-        }
-
-        /**
-         * Constructor.
-         *
-         * @param val Value.
-         * @param valStr Value as string.
-         */
-        private DecimalJob(BigDecimal val, String valStr) {
-            this.val = val;
-            this.valStr = valStr;
-        }
-
-        /** {@inheritDoc} */
-        @Nullable @Override public Object execute() {
-            BigDecimal exp = new BigDecimal(valStr.replace(',', '.'));
-
-            if (val != null && !exp.equals(val))
-                throw new IgniteException("Actual=" + val);
-
-            return exp;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void writeExternal(ObjectOutput out) throws IOException {
-            out.writeObject(val);
-            out.writeObject(valStr);
-        }
-
-        /** {@inheritDoc} */
-        @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
-            val = (BigDecimal)in.readObject();
-            valStr = (String)in.readObject();
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java
deleted file mode 100644
index f64ca7d..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEchoTask.java
+++ /dev/null
@@ -1,188 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.cluster.ClusterNode;
-import org.apache.ignite.compute.ComputeJob;
-import org.apache.ignite.compute.ComputeJobAdapter;
-import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.internal.util.typedef.F;
-import org.jetbrains.annotations.Nullable;
-
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-
-/**
- * Test task producing result without any arguments.
- */
-public class PlatformComputeEchoTask extends ComputeTaskAdapter<Integer, Object> {
-    /** Type: NULL. */
-    private static final int TYPE_NULL = 0;
-
-    /** Type: byte. */
-    private static final int TYPE_BYTE = 1;
-
-    /** Type: bool. */
-    private static final int TYPE_BOOL = 2;
-
-    /** Type: short. */
-    private static final int TYPE_SHORT = 3;
-
-    /** Type: char. */
-    private static final int TYPE_CHAR = 4;
-
-    /** Type: int. */
-    private static final int TYPE_INT = 5;
-
-    /** Type: long. */
-    private static final int TYPE_LONG = 6;
-
-    /** Type: float. */
-    private static final int TYPE_FLOAT = 7;
-
-    /** Type: double. */
-    private static final int TYPE_DOUBLE = 8;
-
-    /** Type: array. */
-    private static final int TYPE_ARRAY = 9;
-
-    /** Type: collection. */
-    private static final int TYPE_COLLECTION = 10;
-
-    /** Type: map. */
-    private static final int TYPE_MAP = 11;
-
-    /** Type: portable object which exists in all platforms. */
-    private static final int TYPE_PORTABLE = 12;
-
-    /** Type: portable object which exists only in Java. */
-    private static final int TYPE_PORTABLE_JAVA = 13;
-
-    /** Type: object array. */
-    private static final int TYPE_OBJ_ARRAY = 14;
-
-    /** Type: portable object array. */
-    private static final int TYPE_PORTABLE_ARRAY = 15;
-
-    /** Type: enum. */
-    private static final int TYPE_ENUM = 16;
-
-    /** Type: enum array. */
-    private static final int TYPE_ENUM_ARRAY = 17;
-
-    /** {@inheritDoc} */
-    @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid,
-        @Nullable Integer arg) {
-        return Collections.singletonMap(new EchoJob(arg), F.first(subgrid));
-    }
-
-    /** {@inheritDoc} */
-    @Nullable @Override public Object reduce(List<ComputeJobResult> results) {
-        return results.get(0).getData();
-    }
-
-    /**
-     * Job.
-     */
-    private static class EchoJob extends ComputeJobAdapter {
-        /** Type. */
-        private Integer type;
-
-        /**
-         * Constructor.
-         *
-         * @param type Result type.
-         */
-        public EchoJob(Integer type) {
-            this.type = type;
-        }
-
-        /** {@inheritDoc} */
-        @Nullable @Override public Object execute() {
-            switch (type) {
-                case TYPE_NULL:
-                    return null;
-
-                case TYPE_BYTE:
-                    return (byte)1;
-
-                case TYPE_BOOL:
-                    return true;
-
-                case TYPE_SHORT:
-                    return (short)1;
-
-                case TYPE_CHAR:
-                    return (char)1;
-
-                case TYPE_INT:
-                    return 1;
-
-                case TYPE_LONG:
-                    return (long)1;
-
-                case TYPE_FLOAT:
-                    return (float)1;
-
-                case TYPE_DOUBLE:
-                    return (double)1;
-
-                case TYPE_ARRAY:
-                    return new int[] { 1 };
-
-                case TYPE_COLLECTION:
-                    return Collections.singletonList(1);
-
-                case TYPE_MAP:
-                    return Collections.singletonMap(1, 1);
-
-                case TYPE_PORTABLE:
-                    return new PlatformComputePortable(1);
-
-                case TYPE_PORTABLE_JAVA:
-                    return new PlatformComputeJavaPortable(1);
-
-                case TYPE_OBJ_ARRAY:
-                    return new String[] { "foo", "bar", "baz" };
-
-                case TYPE_PORTABLE_ARRAY:
-                    return new PlatformComputePortable[] {
-                        new PlatformComputePortable(1),
-                        new PlatformComputePortable(2),
-                        new PlatformComputePortable(3)
-                    };
-
-                case TYPE_ENUM:
-                    return PlatformComputeEnum.BAR;
-
-                case TYPE_ENUM_ARRAY:
-                    return new PlatformComputeEnum[] {
-                        PlatformComputeEnum.BAR,
-                        PlatformComputeEnum.BAZ,
-                        PlatformComputeEnum.FOO
-                    };
-
-                default:
-                    throw new IgniteException("Unknown type: " + type);
-            }
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java
deleted file mode 100644
index 7fc0623..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeEnum.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-/**
- * Test enum.
- */
-public enum PlatformComputeEnum
-{
-    FOO,
-    BAR,
-    BAZ
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java
deleted file mode 100644
index 7a940c4..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputeJavaPortable.java
+++ /dev/null
@@ -1,39 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-/**
- * Portable object defined only in Java.
- */
-public class PlatformComputeJavaPortable extends PlatformComputePortable {
-    /**
-     * Constructor.
-     */
-    public PlatformComputeJavaPortable() {
-        // No-op.
-    }
-
-    /**
-     * Constructor.
-     *
-     * @param field Field.
-     */
-    public PlatformComputeJavaPortable(int field) {
-        super(field);
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/8045c820/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java b/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java
deleted file mode 100644
index f31f093..0000000
--- a/modules/platform/src/test/java/org/apache/ignite/platform/PlatformComputePortable.java
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.platform;
-
-/**
- * Portable object for task tests.
- */
-public class PlatformComputePortable {
-    /** Field. */
-    public int field;
-
-    /**
-     * Constructor.
-     */
-    public PlatformComputePortable() {
-        // No-op.
-    }
-
-    /**
-     * Constructor,
-     *
-     * @param field Field.
-     */
-    public PlatformComputePortable(int field) {
-        this.field = field;
-    }
-}
\ No newline at end of file


Mime
View raw message