Repository: incubator-reef
Updated Branches:
  refs/heads/master b6c4e9838 -> a7df272d1


http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Source/REEF/reef-tasks/Tasks/ShellTask/ShellTask.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-tasks/Tasks/ShellTask/ShellTask.cs 
b/lang/cs/Source/REEF/reef-tasks/Tasks/ShellTask/ShellTask.cs
deleted file mode 100644
index c45a715..0000000
--- a/lang/cs/Source/REEF/reef-tasks/Tasks/ShellTask/ShellTask.cs
+++ /dev/null
@@ -1,90 +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.
- */
-
-using Org.Apache.REEF.Utilities.Diagnostics;
-using Org.Apache.REEF.Utilities.Logging;
-using Org.Apache.REEF.Tang.Annotations;
-using System;
-using System.Diagnostics;
-using System.Diagnostics.CodeAnalysis;
-using System.Globalization;
-using System.Text;
-
-[module: SuppressMessage("StyleCop.CSharp.MaintainabilityRules", 
"SA1402:FileMayOnlyContainASingleClass", Justification = "allow name parameter 
class to be embedded")]
-
-namespace Org.Apache.REEF.Tasks
-{
-    public class ShellTask : ITask
-    {
-        [Inject]
-        public ShellTask([Parameter(Value = typeof(Command))] string command)
-        {
-            Cmd = command;
-        }
-
-        public string Cmd { get; set; }
-
-        public byte[] Call(byte[] memento)
-        {
-            return Encoding.UTF8.GetBytes(CommandLineExecute(Cmd));
-        }
-
-        public void Dispose()
-        {
-        }
-
-        private string CommandLineExecute(string command)
-        {
-            string output = string.Empty;
-            try
-            {
-                ProcessStartInfo startInfo = new ProcessStartInfo()
-                {
-                    FileName = "cmd.exe",
-                    Arguments = @"/c " + command,
-                    RedirectStandardOutput = true,
-                    UseShellExecute = false,
-                    CreateNoWindow = true
-                };
-
-                using (Process process = Process.Start(startInfo))
-                {
-                    StringBuilder standardOutput = new StringBuilder();
-
-                    process.WaitForExit(1000);
-
-                    standardOutput.Append(process.StandardOutput.ReadToEnd());
-                    output = standardOutput.ToString();
-                }
-            }
-            catch (Exception e)
-            {
-                output = string.Format(CultureInfo.InvariantCulture, "Failed 
to execute command [{0}] and capture the output, exception {1} with message {2} 
", command, e, e.Message);
-                Exceptions.Caught(e, Level.Error, output, 
Logger.GetLogger(typeof(ShellTask)));
-            }
-
-            return output;
-        }
-
-        [NamedParameter("Shell Command", "cmd", "")]
-        public class Command : Name<string>
-        {
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask1.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask1.cs 
b/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask1.cs
deleted file mode 100644
index 33a81b0..0000000
--- a/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask1.cs
+++ /dev/null
@@ -1,66 +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.
- */
-
-using System.Threading;
-using Org.Apache.REEF.Tang.Annotations;
-
-namespace Org.Apache.REEF.Tasks
-{
-    public class StreamTask1 : ITask
-    {
-        private string _ipAddress;
-
-        [Inject]
-        public StreamTask1([Parameter(typeof(IpAddress))] string ipAddress)
-        {
-            this._ipAddress = ipAddress;
-        }
-
-        [Inject]
-        public StreamTask1()
-        {
-        }
-
-        public byte[] Call(byte[] memento)
-        {
-            System.Console.WriteLine("Hello, Streaming 1!!, Ip: " + 
_ipAddress);
-
-            Thread.Sleep(10000);
-
-            SIFirstNode();
-
-            return null;
-        }
-
-        public void Dispose()
-        {
-        }
-
-        public void SIFirstNode()
-        {
-            //var a = new SIFirstNodeXAM();
-            //a.Process(1111, 2222, ipAddress);
-        }
-
-        [NamedParameter("Ip Address", "IP", "10.121.32.158")]
-        public class IpAddress : Name<string>
-        {
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask2.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask2.cs 
b/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask2.cs
deleted file mode 100644
index 030ecdf..0000000
--- a/lang/cs/Source/REEF/reef-tasks/Tasks/StreamingTasks/StreamTask2.cs
+++ /dev/null
@@ -1,50 +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.
- */
-
-using Org.Apache.REEF.Tang.Annotations;
-
-namespace Org.Apache.REEF.Tasks
-{
-    public class StreamTask2 : ITask
-    {
-        [Inject]
-        public StreamTask2()
-        {
-        }
-
-        public byte[] Call(byte[] memento)
-        {
-            System.Console.WriteLine("Hello, Streaming 2!!");
-
-            SISecondNode();
-
-            return null;
-        }
-
-        public void Dispose()
-        {
-        }
-
-        public void SISecondNode()
-        {
-            //var a = new SISecondNodeXAM();
-            //a.Process(2222, 1111);
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Source/REEF/reef-tasks/Tasks/Tasks.csproj
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-tasks/Tasks/Tasks.csproj 
b/lang/cs/Source/REEF/reef-tasks/Tasks/Tasks.csproj
deleted file mode 100644
index bc86dc8..0000000
--- a/lang/cs/Source/REEF/reef-tasks/Tasks/Tasks.csproj
+++ /dev/null
@@ -1,117 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<!--
-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.
--->
-<Project ToolsVersion="12.0" DefaultTargets="Build" 
xmlns="http://schemas.microsoft.com/developer/msbuild/2003";>
-  <Import 
Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props"
 
Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')"
 />
-  <PropertyGroup>
-    <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
-    <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProjectGuid>{75503F90-7B82-4762-9997-94B5C68F15DB}</ProjectGuid>
-    <OutputType>Library</OutputType>
-    <AppDesignerFolder>Properties</AppDesignerFolder>
-    <RootNamespace>Org.Apache.Reef.Tasks</RootNamespace>
-    <AssemblyName>Org.Apache.Reef.Tasks</AssemblyName>
-    <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
-    <FileAlignment>512</FileAlignment>
-    <RestorePackages>true</RestorePackages>
-    <SolutionDir Condition="$(SolutionDir) == '' Or $(SolutionDir) == 
'*Undefined*'">..\..\..\..</SolutionDir>
-  </PropertyGroup>
-  <Import Project="$(SolutionDir)\Source\build.props" />
-  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' 
">
-    <PlatformTarget>AnyCPU</PlatformTarget>
-    <DebugSymbols>true</DebugSymbols>
-    <DebugType>full</DebugType>
-    <Optimize>false</Optimize>
-    
<OutputPath>$(BinDir)\$(Platform)\$(Configuration)\$(RootNamespace)</OutputPath>
-    <DefineConstants>DEBUG;TRACE</DefineConstants>
-    <ErrorReport>prompt</ErrorReport>
-    <WarningLevel>4</WarningLevel>
-  </PropertyGroup>
-  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|x64' ">
-    <PlatformTarget>AnyCPU</PlatformTarget>
-    <DebugSymbols>true</DebugSymbols>
-    <DebugType>full</DebugType>
-    <Optimize>false</Optimize>
-    
<OutputPath>$(BinDir)\$(Platform)\$(Configuration)\$(RootNamespace)</OutputPath>
-    <DefineConstants>DEBUG;TRACE</DefineConstants>
-    <ErrorReport>prompt</ErrorReport>
-    <WarningLevel>4</WarningLevel>
-  </PropertyGroup>
-  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 
'Release|AnyCPU' ">
-    <PlatformTarget>AnyCPU</PlatformTarget>
-    <DebugType>pdbonly</DebugType>
-    <Optimize>true</Optimize>
-    
<OutputPath>$(BinDir)\$(Platform)\$(Configuration)\$(RootNamespace)</OutputPath>
-    <DefineConstants>TRACE</DefineConstants>
-    <ErrorReport>prompt</ErrorReport>
-    <WarningLevel>4</WarningLevel>
-  </PropertyGroup>
-  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|x64' ">
-    <PlatformTarget>AnyCPU</PlatformTarget>
-    <DebugType>pdbonly</DebugType>
-    <Optimize>true</Optimize>
-    
<OutputPath>$(BinDir)\$(Platform)\$(Configuration)\$(RootNamespace)</OutputPath>
-    <DefineConstants>TRACE</DefineConstants>
-    <ErrorReport>prompt</ErrorReport>
-    <WarningLevel>4</WarningLevel>
-  </PropertyGroup>
-  <ItemGroup>
-    <Reference Include="System" />
-    <Reference Include="System.Core" />
-    <Reference Include="System.Xml.Linq" />
-    <Reference Include="System.Data.DataSetExtensions" />
-    <Reference Include="Microsoft.CSharp" />
-    <Reference Include="System.Data" />
-    <Reference Include="System.Xml" />
-  </ItemGroup>
-  <ItemGroup>
-    <Compile Include="FailedTask\FailedTask.cs" />
-    <Compile Include="HelloTask\HelloService.cs" />
-    <Compile Include="HelloTask\HelloTask.cs" />
-    <Compile Include="HelloTask\HelloTaskMessage.cs" />
-    <Compile Include="Properties\AssemblyInfo.cs" />
-    <Compile Include="ShellTask\ShellTask.cs" />
-    <Compile Include="StreamingTasks\StreamTask1.cs" />
-    <Compile Include="StreamingTasks\StreamTask2.cs" />
-  </ItemGroup>
-  <ItemGroup>
-    <ProjectReference 
Include="$(SolutionDir)\Org.Apache.Reef.Tang\Org.Apache.Reef.Tang.csproj">
-      <Project>{97dbb573-3994-417a-9f69-ffa25f00d2a6}</Project>
-      <Name>Org.Apache.Reef.Tang</Name>
-    </ProjectReference>
-    <ProjectReference 
Include="$(SolutionDir)\Org.Apache.Reef.Utilities\Org.Apache.Reef.Utilities.csproj">
-      <Project>{79e7f89a-1dfb-45e1-8d43-d71a954aeb98}</Project>
-      <Name>Org.Apache.Reef.Utilities</Name>
-    </ProjectReference>
-    <ProjectReference 
Include="..\..\..\..\Org.Apache.Reef.Common\Org.Apache.Reef.Common.csproj">
-      <Project>{545a0582-4105-44ce-b99c-b1379514a630}</Project>
-      <Name>Org.Apache.Reef.Common</Name>
-    </ProjectReference>
-    <ProjectReference 
Include="..\..\..\..\Org.Apache.Reef.Driver\Org.Apache.Reef.Driver.csproj">
-      <Project>{a6baa2a7-f52f-4329-884e-1bcf711d6805}</Project>
-      <Name>Org.Apache.Reef.Driver</Name>
-    </ProjectReference>
-  </ItemGroup>
-  <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
-  <!-- To modify your build process, add your task inside one of the targets 
below and uncomment it. 
-       Other similar extension points exist, see Microsoft.Common.targets.
-  <Target Name="BeforeBuild">
-  </Target>
-  <Target Name="AfterBuild">
-  </Target>
-  -->
-</Project>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Tests/ReefTests/Evaluator.Tests/EvaluatorTests.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Tests/ReefTests/Evaluator.Tests/EvaluatorTests.cs 
b/lang/cs/Tests/ReefTests/Evaluator.Tests/EvaluatorTests.cs
index b3185c0..bde799e 100644
--- a/lang/cs/Tests/ReefTests/Evaluator.Tests/EvaluatorTests.cs
+++ b/lang/cs/Tests/ReefTests/Evaluator.Tests/EvaluatorTests.cs
@@ -27,6 +27,7 @@ using Org.Apache.REEF.Tang.Util;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
 using System;
 using System.IO;
+using Org.Apache.REEF.Examples.Tasks.ShellTask;
 using Org.Apache.REEF.Tang.Implementations.Tang;
 
 namespace Org.Apache.REEF.Test

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestHelloBridgeHandlers.cs
----------------------------------------------------------------------
diff --git 
a/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestHelloBridgeHandlers.cs 
b/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestHelloBridgeHandlers.cs
index 1c4177a..081f383 100644
--- a/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestHelloBridgeHandlers.cs
+++ b/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestHelloBridgeHandlers.cs
@@ -30,6 +30,7 @@ using Org.Apache.REEF.Utilities.Logging;
 using Org.Apache.REEF.Tang.Interface;
 using Org.Apache.REEF.Tang.Util;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
+using Org.Apache.REEF.Examples.Tasks.HelloTask;
 
 namespace Org.Apache.REEF.Test
 {

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestSimpleEventHandlers.cs
----------------------------------------------------------------------
diff --git 
a/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestSimpleEventHandlers.cs 
b/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestSimpleEventHandlers.cs
index 686bef4..f27f3a6 100644
--- a/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestSimpleEventHandlers.cs
+++ b/lang/cs/Tests/ReefTests/Functional.Tests/Bridge/TestSimpleEventHandlers.cs
@@ -25,7 +25,6 @@ using Org.Apache.REEF.Common.Evaluator;
 using Org.Apache.REEF.Driver.Bridge;
 using Org.Apache.REEF.Driver.Defaults;
 using Org.Apache.REEF.Examples.HelloCLRBridge;
-using Org.Apache.REEF.Examples.HelloCLRBridge.handlers;
 using Org.Apache.REEF.Examples.HelloCLRBridge.Handlers;
 using Org.Apache.REEF.Network.Naming;
 using Org.Apache.REEF.Tasks;
@@ -33,6 +32,7 @@ using Org.Apache.REEF.Utilities.Logging;
 using Org.Apache.REEF.Tang.Interface;
 using Org.Apache.REEF.Tang.Util;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
+using Org.Apache.REEF.Examples.Tasks.HelloTask;
 
 namespace Org.Apache.REEF.Test
 {

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Tests/ReefTests/Functional.Tests/Messaging/MessageTask.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Tests/ReefTests/Functional.Tests/Messaging/MessageTask.cs 
b/lang/cs/Tests/ReefTests/Functional.Tests/Messaging/MessageTask.cs
index 2661cf1..ac2ada2 100644
--- a/lang/cs/Tests/ReefTests/Functional.Tests/Messaging/MessageTask.cs
+++ b/lang/cs/Tests/ReefTests/Functional.Tests/Messaging/MessageTask.cs
@@ -22,6 +22,7 @@ using System.Globalization;
 using System.Linq;
 using System.Net;
 using System.Threading;
+using Org.Apache.REEF.Examples.Tasks.HelloTask;
 using Org.Apache.REEF.Network.Naming;
 using Org.Apache.REEF.Tasks;
 using Org.Apache.REEF.Tasks.Events;

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/cs/Tests/ReefTests/ReefTests.csproj
----------------------------------------------------------------------
diff --git a/lang/cs/Tests/ReefTests/ReefTests.csproj 
b/lang/cs/Tests/ReefTests/ReefTests.csproj
index 1aa89ba..7d0955b 100644
--- a/lang/cs/Tests/ReefTests/ReefTests.csproj
+++ b/lang/cs/Tests/ReefTests/ReefTests.csproj
@@ -156,6 +156,18 @@ under the License.
       <Project>{1b983182-9c30-464c-948d-f87eb93a8240}</Project>
       <Name>Org.Apache.REEF.Evaluator</Name>
     </ProjectReference>
+    <ProjectReference 
Include="..\..\Org.Apache.REEF.Examples.HelloCLRBridge\Org.Apache.REEF.Examples.HelloCLRBridge.csproj">
+      <Project>{a78dd8e8-31d0-4506-8738-daa9da86d55b}</Project>
+      <Name>Org.Apache.REEF.Examples.HelloCLRBridge</Name>
+    </ProjectReference>
+    <ProjectReference 
Include="..\..\Org.Apache.REEF.Examples.RetainedEvalCLRBridge\Org.Apache.REEF.Examples.RetainedEvalCLRBridge.csproj">
+      <Project>{05ec65cf-848d-49ab-9e67-57c14ea63044}</Project>
+      <Name>Org.Apache.REEF.Examples.RetainedEvalCLRBridge</Name>
+    </ProjectReference>
+    <ProjectReference 
Include="..\..\Org.Apache.REEF.Examples.Tasks\Org.Apache.REEF.Examples.Tasks.csproj">
+      <Project>{75503f90-7b82-4762-9997-94b5c68f15db}</Project>
+      <Name>Org.Apache.REEF.Examples.Tasks</Name>
+    </ProjectReference>
     <ProjectReference 
Include="..\..\Org.Apache.REEF.Network\Org.Apache.REEF.Network.csproj">
       <Project>{883ce800-6a6a-4e0a-b7fe-c054f4f2c1dc}</Project>
       <Name>Org.Apache.REEF.Network</Name>
@@ -176,14 +188,6 @@ under the License.
       <Project>{5094c35b-4fdb-4322-ac05-45d684501cbf}</Project>
       <Name>CLRBridgeClient</Name>
     </ProjectReference>
-    <ProjectReference 
Include="..\..\Source\REEF\reef-examples\HelloCLRBridge\HelloCLRBridge.csproj">
-      <Project>{a78dd8e8-31d0-4506-8738-daa9da86d55b}</Project>
-      <Name>HelloCLRBridge</Name>
-    </ProjectReference>
-    <ProjectReference 
Include="..\..\Source\REEF\reef-tasks\Tasks\Tasks.csproj">
-      <Project>{75503f90-7b82-4762-9997-94b5c68f15db}</Project>
-      <Name>Tasks</Name>
-    </ProjectReference>
   </ItemGroup>
   <ItemGroup>
     <Content Include="bin\reef-bridge-0.11.0-incubating-SNAPSHOT-shaded.jar">

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/java/reef-tang/tang/src/test/java/org/apache/reef/tang/ClassHierarchyDeserializationTest.java
----------------------------------------------------------------------
diff --git 
a/lang/java/reef-tang/tang/src/test/java/org/apache/reef/tang/ClassHierarchyDeserializationTest.java
 
b/lang/java/reef-tang/tang/src/test/java/org/apache/reef/tang/ClassHierarchyDeserializationTest.java
index f268a3e..7679410 100644
--- 
a/lang/java/reef-tang/tang/src/test/java/org/apache/reef/tang/ClassHierarchyDeserializationTest.java
+++ 
b/lang/java/reef-tang/tang/src/test/java/org/apache/reef/tang/ClassHierarchyDeserializationTest.java
@@ -46,11 +46,11 @@ public class ClassHierarchyDeserializationTest {
         .getResourceAsStream("Task.bin")) {
       final ClassHierarchyProto.Node root = 
ClassHierarchyProto.Node.parseFrom(chin); // A
       final ClassHierarchy ch = new ProtocolBufferClassHierarchy(root);
-      Node n1 = ch.getNode("Org.Apache.Reef.Tasks.StreamTask1, 
Org.Apache.Reef.Tasks, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null");
-      
Assert.assertTrue(n1.getFullName().equals("Org.Apache.Reef.Tasks.StreamTask1, 
Org.Apache.Reef.Tasks, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null"));
+      Node n1 = 
ch.getNode("Org.Apache.REEF.Examples.Tasks.StreamingTasks.StreamTask1, 
Org.Apache.REEF.Examples.Tasks, Version=1.0.0.0, Culture=neutral, 
PublicKeyToken=null");
+      
Assert.assertTrue(n1.getFullName().equals("Org.Apache.REEF.Examples.Tasks.StreamingTasks.StreamTask1,
 Org.Apache.REEF.Examples.Tasks, Version=1.0.0.0, Culture=neutral, 
PublicKeyToken=null"));
 
-      Node n2 = ch.getNode("Org.Apache.Reef.Tasks.HelloTask, 
Org.Apache.Reef.Tasks, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null");
-      
Assert.assertTrue(n2.getFullName().equals("Org.Apache.Reef.Tasks.HelloTask, 
Org.Apache.Reef.Tasks, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null"));
+      Node n2 = 
ch.getNode("Org.Apache.REEF.Examples.Tasks.HelloTask.HelloTask, 
Org.Apache.REEF.Examples.Tasks, Version=1.0.0.0, Culture=neutral, 
PublicKeyToken=null");
+      
Assert.assertTrue(n2.getFullName().equals("Org.Apache.REEF.Examples.Tasks.HelloTask.HelloTask,
 Org.Apache.REEF.Examples.Tasks, Version=1.0.0.0, Culture=neutral, 
PublicKeyToken=null"));
 
       final ConfigurationBuilder taskConfigurationBuilder1 = 
Tang.Factory.getTang()
           .newConfigurationBuilder(ch);

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/java/reef-tang/tang/src/test/resources/Event.bin
----------------------------------------------------------------------
diff --git a/lang/java/reef-tang/tang/src/test/resources/Event.bin 
b/lang/java/reef-tang/tang/src/test/resources/Event.bin
index 8375e6d..e2b4da9 100644
Binary files a/lang/java/reef-tang/tang/src/test/resources/Event.bin and 
b/lang/java/reef-tang/tang/src/test/resources/Event.bin differ

http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/a7df272d/lang/java/reef-tang/tang/src/test/resources/Task.bin
----------------------------------------------------------------------
diff --git a/lang/java/reef-tang/tang/src/test/resources/Task.bin 
b/lang/java/reef-tang/tang/src/test/resources/Task.bin
index 5fc002b..704150b 100644
Binary files a/lang/java/reef-tang/tang/src/test/resources/Task.bin and 
b/lang/java/reef-tang/tang/src/test/resources/Task.bin differ

Reply via email to