Added interop data loader.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c8a38a3f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c8a38a3f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c8a38a3f Branch: refs/heads/ignite-44 Commit: c8a38a3f02c2c488332d2e28f204c8bb044a7da2 Parents: 3f25425 Author: vozerov <voze...@gridgain.com> Authored: Wed Dec 24 11:12:57 2014 +0300 Committer: vozerov <voze...@gridgain.com> Committed: Wed Dec 24 11:12:57 2014 +0300 ---------------------------------------------------------------------- .../kernal/processors/interop/GridInteropProcessor.java | 9 +++++++++ .../processors/interop/os/GridOsInteropProcessor.java | 5 +++++ 2 files changed, 14 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c8a38a3f/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java index 78498a5..3c2549e 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java @@ -57,6 +57,15 @@ public interface GridInteropProcessor extends GridProcessor { public GridInteropTarget cache(@Nullable String name) throws IgniteCheckedException; /** + * Gets native wrapper for data loader for cache with the given name. + * + * @param cacheName Cache name ({@code null} for default cache). + * @return Native data loader wrapper. + * @throws IgniteCheckedException If failed. + */ + public GridInteropTarget dataLoader(@Nullable String cacheName) throws IgniteCheckedException; + + /** * Stops grid. * * @param cancel Cancel flag. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c8a38a3f/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/os/GridOsInteropProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/os/GridOsInteropProcessor.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/os/GridOsInteropProcessor.java index d09f126..f19f206 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/os/GridOsInteropProcessor.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/os/GridOsInteropProcessor.java @@ -65,4 +65,9 @@ public class GridOsInteropProcessor extends GridInteropProcessorAdapter { @Override public GridInteropTarget cache(@Nullable String name) throws IgniteCheckedException { throw new UnsupportedOperationException(ERR_MSG); } + + /** {@inheritDoc} */ + @Override public GridInteropTarget dataLoader(@Nullable String cacheName) throws IgniteCheckedException { + throw new UnsupportedOperationException(ERR_MSG); + } }
