You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by we...@apache.org on 2015/02/05 22:05:45 UTC
[24/51] [partial] incubator-reef git commit: [REEF-131] Towards the
new .Net project structure This is to change .Net project structure for Tang,
Wake, REEF utilities, Common and Driver:
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroDriverInfo.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroDriverInfo.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroDriverInfo.cs
deleted file mode 100644
index 7a54f4f..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroDriverInfo.cs
+++ /dev/null
@@ -1,65 +0,0 @@
-//<auto-generated />
-namespace Org.Apache.Reef.Common.Avro
-{
- using System.Collections.Generic;
- using System.Runtime.Serialization;
-
- /// <summary>
- /// Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroDriverInfo.
- /// </summary>
- [DataContract(Namespace = "org.apache.reef.webserver")]
- [KnownType(typeof(List<Org.Apache.Reef.Common.Avro.AvroReefServiceInfo>))]
- public partial class AvroDriverInfo
- {
- private const string JsonSchema = @"{""type"":""record"",""name"":""org.apache.reef.webserver.AvroDriverInfo"",""fields"":[{""name"":""remoteId"",""type"":""string""},{""name"":""startTime"",""type"":""string""},{""name"":""services"",""type"":{""type"":""array"",""items"":{""type"":""record"",""name"":""org.apache.reef.webserver.AvroReefServiceInfo"",""fields"":[{""name"":""serviceName"",""type"":""string""},{""name"":""serviceInfo"",""type"":""string""}]}}}]}";
-
- /// <summary>
- /// Gets the schema.
- /// </summary>
- public static string Schema
- {
- get
- {
- return JsonSchema;
- }
- }
-
- /// <summary>
- /// Gets or sets the remoteId field.
- /// </summary>
- [DataMember]
- public string remoteId { get; set; }
-
- /// <summary>
- /// Gets or sets the startTime field.
- /// </summary>
- [DataMember]
- public string startTime { get; set; }
-
- /// <summary>
- /// Gets or sets the services field.
- /// </summary>
- [DataMember]
- public IList<Org.Apache.Reef.Common.Avro.AvroReefServiceInfo> services { get; set; }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AvroDriverInfo"/> class.
- /// </summary>
- public AvroDriverInfo()
- {
- }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AvroDriverInfo"/> class.
- /// </summary>
- /// <param name="remoteId">The remoteId.</param>
- /// <param name="startTime">The startTime.</param>
- /// <param name="services">The services.</param>
- public AvroDriverInfo(string remoteId, string startTime, IList<Org.Apache.Reef.Common.Avro.AvroReefServiceInfo> services)
- {
- this.remoteId = remoteId;
- this.startTime = startTime;
- this.services = services;
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpRequest.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpRequest.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpRequest.cs
deleted file mode 100644
index 1e22569..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpRequest.cs
+++ /dev/null
@@ -1,79 +0,0 @@
-//<auto-generated />
-namespace Org.Apache.Reef.Common.Avro
-{
- using System.Runtime.Serialization;
-
- /// <summary>
- /// Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroHttpRequest.
- /// </summary>
- [DataContract(Namespace = "org.apache.reef.webserver")]
- public partial class AvroHttpRequest
- {
- private const string JsonSchema = @"{""type"":""record"",""name"":""org.apache.reef.webserver.AvroHttpRequest"",""fields"":[{""name"":""requestUrl"",""type"":""string""},{""name"":""pathInfo"",""type"":""string""},{""name"":""queryString"",""type"":""string""},{""name"":""httpMethod"",""type"":""string""},{""name"":""inputStream"",""type"":""bytes""}]}";
-
- /// <summary>
- /// Gets the schema.
- /// </summary>
- public static string Schema
- {
- get
- {
- return JsonSchema;
- }
- }
-
- /// <summary>
- /// Gets or sets the requestUrl field.
- /// </summary>
- [DataMember]
- public string RequestUrl { get; set; }
-
- /// <summary>
- /// Gets or sets the pathInfo field.
- /// </summary>
- [DataMember]
- public string PathInfo { get; set; }
-
- /// <summary>
- /// Gets or sets the queryString field.
- /// </summary>
- [DataMember]
- public string QueryString { get; set; }
-
- /// <summary>
- /// Gets or sets the httpMethod field.
- /// </summary>
- [DataMember]
- public string HttpMethod { get; set; }
-
- /// <summary>
- /// Gets or sets the inputStream field.
- /// </summary>
- [DataMember]
- public byte[] InputStream { get; set; }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AvroHttpRequest"/> class.
- /// </summary>
- public AvroHttpRequest()
- {
- }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AvroHttpRequest"/> class.
- /// </summary>
- /// <param name="requestUrl">The requestUrl.</param>
- /// <param name="pathInfo">The pathInfo.</param>
- /// <param name="queryString">The queryString.</param>
- /// <param name="httpMethod">The httpMethod.</param>
- /// <param name="inputStream">The inputStream.</param>
- public AvroHttpRequest(string requestUrl, string pathInfo, string queryString, string httpMethod, byte[] inputStream)
- {
- RequestUrl = requestUrl;
- PathInfo = pathInfo;
- QueryString = queryString;
- HttpMethod = httpMethod;
- InputStream = inputStream;
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpSerializer.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpSerializer.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpSerializer.cs
deleted file mode 100644
index 886658f..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroHttpSerializer.cs
+++ /dev/null
@@ -1,36 +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 Microsoft.Hadoop.Avro;
-using System.IO;
-
-namespace Org.Apache.Reef.Common.Avro
-{
- public class AvroHttpSerializer
- {
- public static AvroHttpRequest FromBytes(byte[] serializedBytes)
- {
- var serializer = AvroSerializer.Create<AvroHttpRequest>();
- using (var stream = new MemoryStream(serializedBytes))
- {
- return serializer.Deserialize(stream);
- }
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroJsonSerializer.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroJsonSerializer.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroJsonSerializer.cs
deleted file mode 100644
index 9158a16..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroJsonSerializer.cs
+++ /dev/null
@@ -1,52 +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;
-
-using Newtonsoft.Json;
-
-namespace Org.Apache.Reef.Common.Avro
-{
- /// <summary>
- /// Wrapper class for serialize/deserialize Avro json. This avoids having to reference Avro dll in every project
- /// </summary>
- /// <typeparam name="T"> the deserialized type</typeparam>
- public class AvroJsonSerializer<T>
- {
- public static T FromString(string str)
- {
- return JsonConvert.DeserializeObject<T>(str);
- }
-
- public static string ToString(T obj)
- {
- return JsonConvert.SerializeObject(obj);
- }
-
- public static T FromBytes(byte[] bytes)
- {
- return FromString(ByteUtilities.ByteArrarysToString(bytes));
- }
-
- public static byte[] ToBytes(T obj)
- {
- return ByteUtilities.StringToByteArrays(JsonConvert.SerializeObject(obj));
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroReefServiceInfo.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroReefServiceInfo.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroReefServiceInfo.cs
deleted file mode 100644
index 671b067..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/avro/AvroReefServiceInfo.cs
+++ /dev/null
@@ -1,55 +0,0 @@
-//<auto-generated />
-namespace Org.Apache.Reef.Common.Avro
-{
- using System.Runtime.Serialization;
-
- /// <summary>
- /// Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroReefServiceInfo.
- /// </summary>
- [DataContract(Namespace = "org.apache.reef.webserver")]
- public partial class AvroReefServiceInfo
- {
- private const string JsonSchema = @"{""type"":""record"",""name"":""org.apache.reef.webserver.AvroReefServiceInfo"",""fields"":[{""name"":""serviceName"",""type"":""string""},{""name"":""serviceInfo"",""type"":""string""}]}";
-
- /// <summary>
- /// Gets the schema.
- /// </summary>
- public static string Schema
- {
- get
- {
- return JsonSchema;
- }
- }
-
- /// <summary>
- /// Gets or sets the serviceName field.
- /// </summary>
- [DataMember]
- public string serviceName { get; set; }
-
- /// <summary>
- /// Gets or sets the serviceInfo field.
- /// </summary>
- [DataMember]
- public string serviceInfo { get; set; }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AvroReefServiceInfo"/> class.
- /// </summary>
- public AvroReefServiceInfo()
- {
- }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AvroReefServiceInfo"/> class.
- /// </summary>
- /// <param name="serviceName">The serviceName.</param>
- /// <param name="serviceInfo">The serviceInfo.</param>
- public AvroReefServiceInfo(string serviceName, string serviceInfo)
- {
- this.serviceName = serviceName;
- this.serviceInfo = serviceInfo;
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/INodeDescriptor.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/INodeDescriptor.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/INodeDescriptor.cs
deleted file mode 100644
index 672a0cd..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/INodeDescriptor.cs
+++ /dev/null
@@ -1,36 +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.Net;
-
-using Org.Apache.Reef.Common.Capabilities;
-
-namespace Org.Apache.Reef.Common.Catalog
-{
- public interface INodeDescriptor
- {
- IPEndPoint InetSocketAddress { get; set; }
-
- string HostName { get; set; }
-
- CPU Cpu { get; set; }
-
- RAM Ram { get; set; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IRackDescriptor.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IRackDescriptor.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IRackDescriptor.cs
deleted file mode 100644
index ce576c4..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IRackDescriptor.cs
+++ /dev/null
@@ -1,25 +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.
- */
-
-namespace Org.Apache.Reef.Common.Catalog
-{
- public interface IRackDescriptor : IResourceCatalog
- {
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IResourceCatalog.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IResourceCatalog.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IResourceCatalog.cs
deleted file mode 100644
index 0c77b95..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/IResourceCatalog.cs
+++ /dev/null
@@ -1,37 +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.Common.Capabilities;
-using System.Collections.Generic;
-
-namespace Org.Apache.Reef.Common.Catalog
-{
- public interface IResourceCatalog
- {
- string Name { get; set; }
-
- ICollection<ICapability> Capabilities { get; set; }
-
- ICollection<INodeDescriptor> Nodes { get; set; }
-
- ICollection<IRackDescriptor> Racks { get; set; }
-
- INodeDescriptor GetNode(string nodeId);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/NodeDescriptorImpl.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/NodeDescriptorImpl.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/NodeDescriptorImpl.cs
deleted file mode 100644
index 6e0fa67..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/NodeDescriptorImpl.cs
+++ /dev/null
@@ -1,116 +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.Common.Capabilities;
-using System.Collections.Generic;
-using System.Net;
-
-namespace Org.Apache.Reef.Common.Catalog
-{
- public class NodeDescriptorImpl : INodeDescriptor
- {
- private RackDescriptorImpl _rack;
-
- private string _id;
-
- private IPEndPoint _address;
-
- private RAM _ram;
-
- private IList<ICapability> _capabilities;
-
- public NodeDescriptorImpl()
- {
- }
-
- public NodeDescriptorImpl(string id, IPEndPoint addresss, RackDescriptorImpl rack, RAM ram)
- {
- _id = id;
- _address = addresss;
- _rack = rack;
- _ram = ram;
- _capabilities = new List<ICapability>();
- _rack.AddNodeDescriptor(this);
- }
-
- public RackDescriptorImpl Rack
- {
- get
- {
- return _rack;
- }
- }
-
- public string Id
- {
- get
- {
- return _id;
- }
- }
-
- public string HostName { get; set; }
-
- public CPU Cpu
- {
- get
- {
- return new CPU(1);
- }
-
- set
- {
- }
- }
-
- public RAM Ram
- {
- get
- {
- return _ram;
- }
-
- set
- {
- _ram = value;
- }
- }
-
- public IList<ICapability> Capabilities
- {
- get
- {
- return _capabilities;
- }
- }
-
- public IPEndPoint InetSocketAddress
- {
- get
- {
- return _address;
- }
-
- set
- {
- _address = value;
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/RackDescriptorImpl.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/RackDescriptorImpl.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/RackDescriptorImpl.cs
deleted file mode 100644
index 3b28c98..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/RackDescriptorImpl.cs
+++ /dev/null
@@ -1,75 +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.Common.Capabilities;
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace Org.Apache.Reef.Common.Catalog
-{
- public class RackDescriptorImpl : IRackDescriptor
- {
- public RackDescriptorImpl(string name)
- {
- Name = name;
- Capabilities = new List<ICapability>();
- Nodes = new List<INodeDescriptor>();
- }
-
- public string Name { get; set; }
-
- public ICollection<ICapability> Capabilities { get; set; }
-
- public ICollection<INodeDescriptor> Nodes { get; set; }
-
- public ICollection<IRackDescriptor> Racks { get; set; }
-
- public INodeDescriptor GetNode(string nodeId)
- {
- throw new NotImplementedException();
- }
-
- public void AddNodeDescriptor(NodeDescriptorImpl node)
- {
- Nodes.Add(node);
- }
-
- public override string ToString()
- {
- StringBuilder stringBuilder = new StringBuilder();
- stringBuilder.Append("Rack " + Name);
- foreach (INodeDescriptor nodeDescriptor in Nodes)
- {
- stringBuilder.Append(Environment.NewLine + nodeDescriptor);
- }
- return stringBuilder.ToString();
- }
-
- public override int GetHashCode()
- {
- return Name.GetHashCode();
- }
-
- public override bool Equals(object obj)
- {
- return base.Equals(obj);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/ResourceCatalogImpl.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/ResourceCatalogImpl.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/ResourceCatalogImpl.cs
deleted file mode 100644
index 9348b67..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/ResourceCatalogImpl.cs
+++ /dev/null
@@ -1,95 +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.Common.Capabilities;
-using Org.Apache.Reef.Common.ProtoBuf.DriverRuntimeProto;
-using Org.Apache.Reef.Utilities.Logging;
-using System;
-using System.Collections.Generic;
-using System.Globalization;
-using System.Net;
-using System.Text;
-
-namespace Org.Apache.Reef.Common.Catalog
-{
- public class ResourceCatalogImpl : IResourceCatalog
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(ResourceCatalogImpl));
-
- private static string defaultRackName = "default-rack";
-
- private Dictionary<string, RackDescriptorImpl> _racks = new Dictionary<string, RackDescriptorImpl>();
-
- private Dictionary<string, NodeDescriptorImpl> _nodes = new Dictionary<string, NodeDescriptorImpl>();
-
- public string Name { get; set; }
-
- public ICollection<ICapability> Capabilities { get; set; }
-
- public ICollection<INodeDescriptor> Nodes { get; set; }
-
- public ICollection<IRackDescriptor> Racks { get; set; }
-
- public INodeDescriptor GetNode(string nodeId)
- {
- return _nodes[nodeId];
- }
-
- public void Handle(NodeDescriptorProto node)
- {
- string rackName = node.rack_name == null ? node.rack_name : defaultRackName;
- string message = string.Format(
- CultureInfo.InvariantCulture,
- "Catalog new node: id[{0}], rack[{1}], host[{2}], port[{3}], memory[{4}]",
- node.identifier,
- rackName,
- node.host_name,
- node.port,
- node.memory_size);
- LOGGER.Log(Level.Info, message);
- if (!string.IsNullOrWhiteSpace(rackName) && !_racks.ContainsKey(rackName))
- {
- RackDescriptorImpl newRack = new RackDescriptorImpl(rackName);
- _racks.Add(rackName, newRack);
- }
- RackDescriptorImpl rack = _racks[rackName];
- IPAddress ipAddress = null;
- IPAddress.TryParse(node.host_name, out ipAddress);
- if (ipAddress == null)
- {
- Org.Apache.Reef.Utilities.Diagnostics.Exceptions.Throw(new ArgumentException("cannot parse host ipaddress: " + node.host_name), LOGGER);
- }
- IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, node.port);
- RAM ram = new RAM(node.memory_size);
- NodeDescriptorImpl nodeDescriptor = new NodeDescriptorImpl(node.identifier, ipEndPoint, rack, ram);
- _nodes.Add(nodeDescriptor.Id, nodeDescriptor);
- }
-
- public override string ToString()
- {
- StringBuilder stringBuilder = new StringBuilder();
- stringBuilder.Append("=== Resource Catalog ===");
- foreach (IRackDescriptor rackDescriptor in Racks)
- {
- stringBuilder.Append(Environment.NewLine + rackDescriptor);
- }
- return stringBuilder.ToString();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/CPU.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/CPU.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/CPU.cs
deleted file mode 100644
index 0acda2d..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/CPU.cs
+++ /dev/null
@@ -1,60 +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;
-using System.Globalization;
-using Org.Apache.Reef.Common.Api;
-using Org.Apache.Reef.Utilities.Logging;
-
-namespace Org.Apache.Reef.Common.Capabilities
-{
- public class CPU : ICapability
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(CPU));
-
- private int _cores;
-
- public CPU(int cores)
- {
- if (cores <= 0)
- {
- Org.Apache.Reef.Utilities.Diagnostics.Exceptions.Throw(new ArgumentException("cores cannot be non-positive"), LOGGER);
- }
- _cores = cores;
- }
-
- public int Cores
- {
- get
- {
- return _cores;
- }
- }
-
- public override string ToString()
- {
- return string.Format(CultureInfo.InvariantCulture, "CPU Cores = [{0}]", Cores);
- }
-
- public override int GetHashCode()
- {
- return Cores.GetHashCode();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/ICapability.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/ICapability.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/ICapability.cs
deleted file mode 100644
index 8761426..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/ICapability.cs
+++ /dev/null
@@ -1,25 +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.
- */
-
-namespace Org.Apache.Reef.Common.Capabilities
-{
- public interface ICapability
- {
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/RAM.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/RAM.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/RAM.cs
deleted file mode 100644
index ed6e078..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/catalog/capabilities/RAM.cs
+++ /dev/null
@@ -1,51 +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.Globalization;
-
-namespace Org.Apache.Reef.Common.Capabilities
-{
- public class RAM : ICapability
- {
- private int _megaBytes;
-
- public RAM(int megaBytes)
- {
- _megaBytes = megaBytes;
- }
-
- public int MegaBytes
- {
- get
- {
- return _megaBytes;
- }
- }
-
- public override string ToString()
- {
- return string.Format(CultureInfo.InvariantCulture, "RAM(in mega bytes) = [{0}]", MegaBytes);
- }
-
- public override int GetHashCode()
- {
- return MegaBytes.GetHashCode();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/context/ContextMessage.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/context/ContextMessage.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/context/ContextMessage.cs
deleted file mode 100644
index 9c4737c..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/context/ContextMessage.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;
-using Org.Apache.Reef.Utilities.Logging;
-
-namespace Org.Apache.Reef.Common.Context
-{
- public class ContextMessage
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(ContextMessage));
- private readonly string _messageSourcId;
- private readonly byte[] _bytes;
-
- private ContextMessage(string messageSourceId, byte[] bytes)
- {
- _messageSourcId = messageSourceId;
- _bytes = bytes;
- }
-
- public string MessageSourceId
- {
- get { return _messageSourcId; }
- }
-
- public byte[] Bytes
- {
- get { return _bytes; }
- }
-
- /// <summary>
- /// construt a new new ContextMessage with the given content.
- /// </summary>
- /// <param name="messageSourceId">The message's sourceID. This will be accessible in the Driver for routing.</param>
- /// <param name="bytes">The actual content of the message, serialized into a byte[]</param>
- /// <returns>new ContextMessage with the given content.</returns>
- public static ContextMessage From(string messageSourceId, byte[] bytes)
- {
- if (string.IsNullOrEmpty(messageSourceId))
- {
- Org.Apache.Reef.Utilities.Diagnostics.Exceptions.Throw(new ArgumentNullException("messageSourceId"), LOGGER);
- }
- if (bytes == null)
- {
- Org.Apache.Reef.Utilities.Diagnostics.Exceptions.Throw(new ArgumentNullException("bytes"), LOGGER);
- }
- return new ContextMessage(messageSourceId, bytes);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessage.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessage.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessage.cs
deleted file mode 100644
index 183dafa..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessage.cs
+++ /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.
- */
-
-using Org.Apache.Reef.Utilities;
-
-namespace Org.Apache.Reef.Common.Context
-{
- public interface IContextMessage : IMessage, IIdentifiable
- {
- string MessageSourceId { get; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageHandler.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageHandler.cs
deleted file mode 100644
index 7eeb367..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageHandler.cs
+++ /dev/null
@@ -1,27 +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;
-
-namespace Org.Apache.Reef.Common.Context
-{
- public interface IContextMessageHandler : IObserver<byte[]>
- {
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageSource.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageSource.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageSource.cs
deleted file mode 100644
index 6025771..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/context/IContextMessageSource.cs
+++ /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.
- */
-
-using Org.Apache.Reef.Utilities;
-
-namespace Org.Apache.Reef.Common.Context
-{
- public interface IContextMessageSource
- {
- Optional<ContextMessage> Message { get; set; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultLocalHttpDriverConnection.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultLocalHttpDriverConnection.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultLocalHttpDriverConnection.cs
deleted file mode 100644
index 2e6cdc0..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultLocalHttpDriverConnection.cs
+++ /dev/null
@@ -1,45 +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;
-using System;
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public class DefaultLocalHttpDriverConnection : IDriverConnection
- {
- private readonly Uri _queryUri;
-
- [Inject]
- public DefaultLocalHttpDriverConnection()
- {
- _queryUri = new Uri(
- string.Concat(
- Constants.LocalHttpEndpointBaseUri,
- Constants.HttpReefUriSpecification,
- Constants.HttpDriverUriTarget));
- }
-
- public DriverInformation GetDriverInformation(string applicationId)
- {
- // application id not needed for local runtime
- return DriverInformation.GetDriverInformationFromHttp(_queryUri);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnClusterHttpDriverConnection.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnClusterHttpDriverConnection.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnClusterHttpDriverConnection.cs
deleted file mode 100644
index c09647d..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnClusterHttpDriverConnection.cs
+++ /dev/null
@@ -1,44 +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;
-using System;
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public class DefaultYarnClusterHttpDriverConnection : IDriverConnection
- {
- [Inject]
- public DefaultYarnClusterHttpDriverConnection()
- {
- }
-
- public DriverInformation GetDriverInformation(string applicationId)
- {
- // e.g., http://headnodehost:9014/proxy/application_1407519727821_0012/reef/v1/driver
- Uri queryUri = new Uri(
- string.Concat(
- Constants.HDInsightClusterHttpEndpointBaseUri,
- applicationId,
- Constants.HttpReefUriSpecification,
- Constants.HttpDriverUriTarget));
- return DriverInformation.GetDriverInformationFromHttp(queryUri);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnOneBoxHttpDriverConnection.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnOneBoxHttpDriverConnection.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnOneBoxHttpDriverConnection.cs
deleted file mode 100644
index c12984e..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DefaultYarnOneBoxHttpDriverConnection.cs
+++ /dev/null
@@ -1,46 +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;
-using System;
-using System.Globalization;
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public class DefaultYarnOneBoxHttpDriverConnection : IDriverConnection
- {
- [Inject]
- public DefaultYarnOneBoxHttpDriverConnection()
- {
- }
-
- public DriverInformation GetDriverInformation(string applicationId)
- {
- // e.g., http://yingdac1:8088/proxy/application_1407519727821_0012/reef/v1/driver
- string oneBoxHost = string.Format(CultureInfo.InvariantCulture, "http://{0}:8088/proxy/", Environment.MachineName);
- Uri queryUri = new Uri(
- string.Concat(
- oneBoxHost,
- applicationId,
- Constants.HttpReefUriSpecification,
- Constants.HttpDriverUriTarget));
- return DriverInformation.GetDriverInformationFromHttp(queryUri);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DriverInformation.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DriverInformation.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DriverInformation.cs
deleted file mode 100644
index 653627f..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/DriverInformation.cs
+++ /dev/null
@@ -1,136 +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.Common.Avro;
-using Org.Apache.Reef.Utilities.Logging;
-using System;
-using System.Collections.Generic;
-using System.Globalization;
-using System.IO;
-using System.Linq;
-using System.Net;
-using System.Text;
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public class DriverInformation
- {
- private static readonly Logger LOGGER = Logger.GetLogger(typeof(DriverInformation));
-
- private string _rid;
-
- private string _startTime;
-
- private string _nameServerId;
-
- private IList<AvroReefServiceInfo> _services;
-
- public DriverInformation(string rid, string startTime, IList<AvroReefServiceInfo> services)
- {
- _rid = rid;
- _startTime = startTime;
- _services = services;
-
- if (_services == null)
- {
- LOGGER.Log(Level.Warning, "no services information from driver.");
- }
- else
- {
- AvroReefServiceInfo nameServerInfo =
- _services.FirstOrDefault(
- s => s.serviceName.Equals(Constants.NameServerServiceName, StringComparison.OrdinalIgnoreCase));
- if (nameServerInfo != null)
- {
- _nameServerId = nameServerInfo.serviceInfo;
- }
- }
- }
-
- public string DriverRemoteIdentifier
- {
- get
- {
- return _rid;
- }
- }
-
- public string DriverStartTime
- {
- get
- {
- return _startTime;
- }
- }
-
- public string NameServerId
- {
- get
- {
- return _nameServerId;
- }
- }
-
- public static DriverInformation GetDriverInformationFromHttp(Uri queryUri)
- {
- HttpWebRequest request = (HttpWebRequest)WebRequest.Create(queryUri);
- request.AllowAutoRedirect = false;
- request.KeepAlive = false;
- request.ContentType = "text/html";
-
- string driverInfomation;
- AvroDriverInfo info = null;
- try
- {
- using (HttpWebResponse webResponse = (HttpWebResponse)request.GetResponse())
- {
- Stream stream = webResponse.GetResponseStream();
- if (stream == null)
- {
- return null;
- }
- using (StreamReader streamReader = new StreamReader(stream, Encoding.UTF8))
- {
- driverInfomation = streamReader.ReadToEnd();
- LOGGER.Log(Level.Verbose, "Http response line: " + driverInfomation);
- info = AvroJsonSerializer<AvroDriverInfo>.FromString(driverInfomation);
- }
- }
- }
- catch (WebException)
- {
- LOGGER.Log(Level.Warning, string.Format(CultureInfo.InvariantCulture, "In RECOVERY mode, cannot connect to [{0}] for driver information, will try again later.", queryUri));
- return null;
- }
- catch (Exception e)
- {
- Org.Apache.Reef.Utilities.Diagnostics.Exceptions.CaughtAndThrow(e, Level.Error, string.Format(CultureInfo.InvariantCulture, "Cannot read content from {0}.", queryUri), LOGGER);
- }
-
- if (info != null)
- {
- LOGGER.Log(
- Level.Verbose,
- string.Format(CultureInfo.InvariantCulture, "Driver information extracted with remote identier [{0}], start time [{1}], and servics [{2}]", info.remoteId, info.startTime, info.services));
- return new DriverInformation(info.remoteId, info.startTime, info.services);
- }
- return null;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorOperationState.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorOperationState.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorOperationState.cs
deleted file mode 100644
index 77c1e63..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorOperationState.cs
+++ /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.
- */
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public enum EvaluatorOperationState
- {
- /// <summary>
- /// default state
- /// </summary>
- UNINITIATED = 0,
-
- /// <summary>
- /// normal operational state
- /// </summary>
- OPERATIONAL = 1,
-
- /// <summary>
- /// in the process of recovering
- /// </summary>
- RECOVERY = 2
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorRuntimeState.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorRuntimeState.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorRuntimeState.cs
deleted file mode 100644
index d405c25..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorRuntimeState.cs
+++ /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.
- */
-
-namespace Org.Apache.Reef.Common.evaluator
-{
- public enum EvaluatorRuntimeState
- {
- /// <summary>
- /// default state
- /// </summary>
- UNINITIATED = 0,
-
- /// <summary>
- /// normal operational state
- /// </summary>
- RUNNING = 1,
-
- /// <summary>
- /// in the process of recovering
- /// </summary>
- RECOVERY = 2
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorType.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorType.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorType.cs
deleted file mode 100644
index 4de31c8..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/EvaluatorType.cs
+++ /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.
- */
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public enum EvaluatorType
- {
- /// <summary>
- /// default type
- /// </summary>
- UNDECIDED = 0,
-
- /// <summary>
- /// Indicates an Evaluator that runs on the JVM
- /// </summary>
- JVM = 1,
-
- /// <summary>
- /// Indicates an Evaluator that runs on the CLR
- /// </summary>
- CLR = 2
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/IDriverConnection.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/IDriverConnection.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/IDriverConnection.cs
deleted file mode 100644
index 7113246..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/evaluator/IDriverConnection.cs
+++ /dev/null
@@ -1,26 +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.
- */
-
-namespace Org.Apache.Reef.Common.Evaluator
-{
- public interface IDriverConnection
- {
- DriverInformation GetDriverInformation(string applicationId);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStart.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStart.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStart.cs
deleted file mode 100644
index bdd236d..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStart.cs
+++ /dev/null
@@ -1,26 +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.
- */
-
-namespace Org.Apache.Reef.Common.Events
-{
- public interface IContextStart
- {
- string Id { get; set; }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStop.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStop.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStop.cs
deleted file mode 100644
index 90031fb..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/events/IContextStop.cs
+++ /dev/null
@@ -1,26 +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.
- */
-
-namespace Org.Apache.Reef.Common.Events
-{
- public interface IContextStop
- {
- string Id { get; set; }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/EvaluatorException.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/EvaluatorException.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/EvaluatorException.cs
deleted file mode 100644
index 4b62f29..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/EvaluatorException.cs
+++ /dev/null
@@ -1,75 +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.Common.Task;
-using Org.Apache.Reef.Utilities;
-using System;
-
-namespace Org.Apache.Reef.Common.Exceptions
-{
- public class EvaluatorException : System.Exception, IIdentifiable
- {
- private readonly string _evaluatorId;
-
- public EvaluatorException(string evaluatorId)
- {
- _evaluatorId = evaluatorId;
- RunningTask = null;
- }
-
- public EvaluatorException(string evaluatorId, string message, System.Exception cause)
- : base(message, cause)
- {
- _evaluatorId = evaluatorId;
- RunningTask = null;
- }
-
- public EvaluatorException(string evaluatorId, string message)
- : this(evaluatorId, message, (IRunningTask)null)
- {
- }
-
- public EvaluatorException(string evaluatorId, string message, IRunningTask runningTask)
- : base(message)
- {
- _evaluatorId = evaluatorId;
- RunningTask = runningTask;
- }
-
- public EvaluatorException(string evaluatorId, System.Exception cause)
- : this(evaluatorId, cause, null)
- {
- }
-
- public EvaluatorException(string evaluatorId, Exception cause, IRunningTask runningTask)
- : base(string.Empty, cause)
- {
- _evaluatorId = evaluatorId;
- RunningTask = runningTask;
- }
-
- public IRunningTask RunningTask { get; set; }
-
- public string Id
- {
- get { return _evaluatorId; }
- set { }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/JobException.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/JobException.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/JobException.cs
deleted file mode 100644
index 3f98f5e..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/exceptions/JobException.cs
+++ /dev/null
@@ -1,58 +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;
-using System;
-
-namespace Org.Apache.Reef.Common
-{
- public class JobException : Exception, IIdentifiable
- {
- private string _jobId;
-
- public JobException(string jobId)
- {
- _jobId = jobId;
- }
-
- public JobException(string jobId, string message, Exception cause)
- : base(message, cause)
- {
- _jobId = jobId;
- }
-
- public JobException(string jobId, string message)
- : base(message)
- {
- _jobId = jobId;
- }
-
- public JobException(string jobId, Exception cause)
- : base(string.Empty, cause)
- {
- _jobId = jobId;
- }
-
- public string Id
- {
- get { return _jobId; }
- set { }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/io/INameClient.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/io/INameClient.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/io/INameClient.cs
deleted file mode 100644
index 047b048..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/io/INameClient.cs
+++ /dev/null
@@ -1,71 +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;
-using System.Collections.Generic;
-using System.Net;
-
-namespace Org.Apache.Reef.Common.io
-{
- /// <summary>
- /// Client for the Reef name service.
- /// Used to register, unregister, and lookup IP Addresses of known hosts.
- /// </summary>
- public interface INameClient : IDisposable
- {
- /// <summary>
- /// Registers the identifier with the NameService.
- /// Overwrites the previous mapping if the identifier has already
- /// been registered.
- /// </summary>
- /// <param name="id">The key used to map the remote endpoint</param>
- /// <param name="endpoint">The endpoint to map</param>
- void Register(string id, IPEndPoint endpoint);
-
- /// <summary>
- /// Unregisters the remote identifier with the NameService
- /// </summary>
- /// <param name="id">The identifier to unregister</param>
- void Unregister(string id);
-
- /// <summary>
- /// Looks up the IPEndpoint for the registered identifier.
- /// </summary>
- /// <param name="id">The identifier to look up</param>
- /// <returns>The mapped IPEndpoint for the identifier, or null if
- /// the identifier has not been registered with the NameService</returns>
- IPEndPoint Lookup(string id);
-
- /// <summary>
- /// Looks up the IPEndpoint for each of the registered identifiers in the list.
- /// </summary>
- /// <param name="ids">The list of identifiers to look up</param>
- /// <returns>The list of NameAssignments representing a pair of identifer
- /// and mapped IPEndpoint for that identifier. If any of the requested identifiers
- /// are not registered with the NameService, their corresponding NameAssignment
- /// IPEndpoint value will be null.</returns>
- List<NameAssignment> Lookup(List<string> ids);
-
- /// <summary>
- /// Restart the name client in case of failure.
- /// </summary>
- /// <param name="serverEndpoint">The new server endpoint to connect to</param>
- void Restart(IPEndPoint serverEndpoint);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/io/NameAssignment.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/io/NameAssignment.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/io/NameAssignment.cs
deleted file mode 100644
index 4fbbfb0..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/io/NameAssignment.cs
+++ /dev/null
@@ -1,60 +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.Net;
-using System.Net.Sockets;
-
-namespace Org.Apache.Reef.Common.io
-{
- /// <summary>
- /// Tuple containing the string identifier and IPEndpoint.
- /// Used by NameServer and NameClient
- /// </summary>
- public class NameAssignment
- {
- public NameAssignment(string id, IPEndPoint endpoint)
- {
- Identifier = id;
- Endpoint = endpoint;
- }
-
- public NameAssignment(string id, string address, int port)
- {
- Identifier = id;
- IPAddress ipAddress;
- if (!IPAddress.TryParse(address, out ipAddress))
- {
- IPHostEntry hostEntry = Dns.GetHostEntry(address);
- foreach (var ip in hostEntry.AddressList)
- {
- if (ip.AddressFamily == AddressFamily.InterNetwork)
- {
- ipAddress = ip;
- break;
- }
- }
- }
- Endpoint = new IPEndPoint(ipAddress, port);
- }
-
- public string Identifier { get; set; }
-
- public IPEndPoint Endpoint { get; set; }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfiguration.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfiguration.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfiguration.cs
deleted file mode 100644
index 192c98c..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfiguration.cs
+++ /dev/null
@@ -1,45 +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.Diagnostics.CodeAnalysis;
-using Org.Apache.Reef.Tang.Formats;
-using Org.Apache.Reef.Tang.Util;
-
-namespace Org.Apache.Reef.Common.io
-{
- public class NamingConfiguration : ConfigurationModuleBuilder
- {
- [SuppressMessage("Microsoft.Security", "CA2104:Do not declare read only mutable reference types", Justification = "not applicable")]
- public static readonly RequiredParameter<string> NameServerAddress = new RequiredParameter<string>();
-
- [SuppressMessage("Microsoft.Security", "CA2104:Do not declare read only mutable reference types", Justification = "not applicable")]
- public static readonly RequiredParameter<int> NameServerPort = new RequiredParameter<int>();
-
- public static ConfigurationModule ConfigurationModule
- {
- get
- {
- return new NamingConfiguration()
- .BindNamedParameter(GenericType<NamingConfigurationOptions.NameServerAddress>.Class, NameServerAddress)
- .BindNamedParameter(GenericType<NamingConfigurationOptions.NameServerPort>.Class, NameServerPort)
- .Build();
- }
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfigurationOptions.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfigurationOptions.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfigurationOptions.cs
deleted file mode 100644
index 0d222d6..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/io/NamingConfigurationOptions.cs
+++ /dev/null
@@ -1,36 +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.Common.io
-{
- public class NamingConfigurationOptions
- {
- [NamedParameter("IP address of NameServer")]
- public class NameServerAddress : Name<string>
- {
- }
-
- [NamedParameter("Port of NameServer")]
- public class NameServerPort : Name<int>
- {
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/packages.config
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/packages.config b/lang/cs/Source/REEF/reef-common/ReefCommon/packages.config
deleted file mode 100644
index 88cf17b..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/packages.config
+++ /dev/null
@@ -1,26 +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.
--->
-<packages>
- <package id="Microsoft.Hadoop.Avro" version="1.4.0.0" targetFramework="net45" />
- <package id="Newtonsoft.Json" version="6.0.8" targetFramework="net45" />
- <package id="protobuf-net" version="2.0.0.668" targetFramework="net45" />
- <package id="Rx-Core" version="2.2.5" targetFramework="net45" />
- <package id="Rx-Interfaces" version="2.2.5" targetFramework="net45" />
-</packages>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Source/REEF/reef-common/ReefCommon/protobuf/cs/ClientRuntime.pb.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Source/REEF/reef-common/ReefCommon/protobuf/cs/ClientRuntime.pb.cs b/lang/cs/Source/REEF/reef-common/ReefCommon/protobuf/cs/ClientRuntime.pb.cs
deleted file mode 100644
index 8dddaee..0000000
--- a/lang/cs/Source/REEF/reef-common/ReefCommon/protobuf/cs/ClientRuntime.pb.cs
+++ /dev/null
@@ -1,147 +0,0 @@
-//------------------------------------------------------------------------------
-// <auto-generated>
-// This code was generated by a tool.
-//
-// Changes to this file may cause incorrect behavior and will be lost if
-// the code is regenerated.
-// </auto-generated>
-//------------------------------------------------------------------------------
-
-// Generated from: client_runtime.proto
-// Note: requires additional types generated from: reef_service_protos.proto
-
-using Org.Apache.Reef.Common.ProtoBuf.ReefServiceProto;
-
-namespace Org.Apache.Reef.Common.ProtoBuf.ClienRuntimeProto{
- [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"JobSubmissionProto")]
- public partial class JobSubmissionProto : global::ProtoBuf.IExtensible
- {
- public JobSubmissionProto() {}
-
- private string _identifier;
- [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public string identifier
- {
- get { return _identifier; }
- set { _identifier = value; }
- }
- private string _remote_id;
- [global::ProtoBuf.ProtoMember(2, IsRequired = true, Name=@"remote_id", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public string remote_id
- {
- get { return _remote_id; }
- set { _remote_id = value; }
- }
- private string _configuration;
- [global::ProtoBuf.ProtoMember(5, IsRequired = true, Name=@"configuration", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public string configuration
- {
- get { return _configuration; }
- set { _configuration = value; }
- }
- private string _user_name;
- [global::ProtoBuf.ProtoMember(6, IsRequired = true, Name=@"user_name", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public string user_name
- {
- get { return _user_name; }
- set { _user_name = value; }
- }
- private SIZE _driver_size = SIZE.SMALL;
- [global::ProtoBuf.ProtoMember(7, IsRequired = false, Name=@"driver_size", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)]
- [global::System.ComponentModel.DefaultValue(SIZE.SMALL)]
- public SIZE driver_size
- {
- get { return _driver_size; }
- set { _driver_size = value; }
- }
- private int _driver_memory = default(int);
- [global::ProtoBuf.ProtoMember(8, IsRequired = false, Name=@"driver_memory", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)]
- [global::System.ComponentModel.DefaultValue(default(int))]
- public int driver_memory
- {
- get { return _driver_memory; }
- set { _driver_memory = value; }
- }
- private int _priority = default(int);
- [global::ProtoBuf.ProtoMember(9, IsRequired = false, Name=@"priority", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)]
- [global::System.ComponentModel.DefaultValue(default(int))]
- public int priority
- {
- get { return _priority; }
- set { _priority = value; }
- }
- private string _queue = "";
- [global::ProtoBuf.ProtoMember(10, IsRequired = false, Name=@"queue", DataFormat = global::ProtoBuf.DataFormat.Default)]
- [global::System.ComponentModel.DefaultValue("")]
- public string queue
- {
- get { return _queue; }
- set { _queue = value; }
- }
- private readonly global::System.Collections.Generic.List<FileResourceProto> _global_file = new global::System.Collections.Generic.List<FileResourceProto>();
- [global::ProtoBuf.ProtoMember(11, Name=@"global_file", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public global::System.Collections.Generic.List<FileResourceProto> global_file
- {
- get { return _global_file; }
- }
-
- private readonly global::System.Collections.Generic.List<FileResourceProto> _local_File = new global::System.Collections.Generic.List<FileResourceProto>();
- [global::ProtoBuf.ProtoMember(12, Name=@"local_File", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public global::System.Collections.Generic.List<FileResourceProto> local_File
- {
- get { return _local_File; }
- }
-
- private global::ProtoBuf.IExtension extensionObject;
- global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
- { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); }
- }
-
- [global::System.Serializable, global::ProtoBuf.ProtoContract(Name=@"JobControlProto")]
- public partial class JobControlProto : global::ProtoBuf.IExtensible
- {
- public JobControlProto() {}
-
- private string _identifier;
- [global::ProtoBuf.ProtoMember(1, IsRequired = true, Name=@"identifier", DataFormat = global::ProtoBuf.DataFormat.Default)]
- public string identifier
- {
- get { return _identifier; }
- set { _identifier = value; }
- }
- private Signal _signal = Signal.SIG_TERMINATE;
- [global::ProtoBuf.ProtoMember(2, IsRequired = false, Name=@"signal", DataFormat = global::ProtoBuf.DataFormat.TwosComplement)]
- [global::System.ComponentModel.DefaultValue(Signal.SIG_TERMINATE)]
- public Signal signal
- {
- get { return _signal; }
- set { _signal = value; }
- }
- private byte[] _message = null;
- [global::ProtoBuf.ProtoMember(3, IsRequired = false, Name=@"message", DataFormat = global::ProtoBuf.DataFormat.Default)]
- [global::System.ComponentModel.DefaultValue(null)]
- public byte[] message
- {
- get { return _message; }
- set { _message = value; }
- }
- private global::ProtoBuf.IExtension extensionObject;
- global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
- { return global::ProtoBuf.Extensible.GetExtensionObject(ref extensionObject, createIfMissing); }
- }
-
- [global::ProtoBuf.ProtoContract(Name=@"Signal")]
- public enum Signal
- {
-
- [global::ProtoBuf.ProtoEnum(Name=@"SIG_TERMINATE", Value=1)]
- SIG_TERMINATE = 1,
-
- [global::ProtoBuf.ProtoEnum(Name=@"SIG_SUSPEND", Value=2)]
- SIG_SUSPEND = 2,
-
- [global::ProtoBuf.ProtoEnum(Name=@"SIG_RESUME", Value=3)]
- SIG_RESUME = 3
- }
-
-}
\ No newline at end of file