init

src/main/java/com/yuandian/dataflow/Server.java

@@ -0,0 +1,13 @@
+package com.yuandian.dataflow;
+
+/**
+ * Hello world!
+ *
+ */
+public class Server 
+{
+    public static void main( String[] args )
+    {
+        System.out.println( "Hello World!" );
+    }
+}

src/main/java/com/yuandian/dataflow/rpc/scheduler.proto

@@ -0,0 +1,26 @@
+syntax = "proto3";
+
+package com.yuandian.dataflow.rpc;
+// option java_package = "com.yuandian.dataflow.rpc"; 
+
+// option java_outer_classname = "com.yuandian.dataflow.rpc";
+
+
+service DataFlow {
+    rpc Update (State) returns (Response);
+}
+
+message State {
+    map<int32, QueueState> QueueMap = 1;
+
+}
+
+message QueueState {
+    int32 Size = 1; 
+}
+
+message Response {
+    int32 Code = 1;
+    string Message = 2; 
+    bytes Data = 3;
+}