CSharpFlink实时计算框架源码下载

【实例简介】
CSharpFlink是一个面向工业应用的实时计算框架，支持自定义数据源、计算和存储，适合物联网、工业互联网私有云或公有云平台建设过程中的数据点实时聚合和表达式计算。
主要特点包括使用最新的.NET 5.0开发，完全跨平台，支持实时数据窗口范围外的数据补发或更新的重新计算，以及C#语言的二次开发等。

// 示例代码
public class Example {
    public static void Main(string[] args) {
        Console.WriteLine("Hello, CSharpFlink!");
    }
}

框架支持单节点或分布式部署，实现了主从结构的分布式部署，主节点负责计算任务分发，工作节点负责任务计算及结果存储。具体应用场景包括数据点的实时时间窗口范围内聚合计算、数据点的历史延迟窗口的一段时间范围内数据补充或更新的重新计算、数据点的表达式计算等。
【实例截图】
【核心代码】
文件清单
└── CSharpFlink-7d43baaabf7f8517cba6def44413e4f1b4563a0d
    ├── CSharpFlink.sln
    ├── doc
    │   ├── CSharpFlink分布式实时计算框架，PC机10万数据点秒级计算测试说明.docx
    │   ├── CSharpFlink简要设计、部署及二次开发说明_20201117.docx
    │   ├── demo.png
    │   ├── framework.png
    │   └── qrcode.jpg
    ├── LICENSE
    ├── README.md
    ├── src
    │   ├── CSharpFlink
    │   │   ├── CSharpFlink.csproj
    │   │   └── Program.cs
    │   └── CSharpFlink.Core
    │       ├── Cache
    │       │   ├── LocalCache.cs
    │       │   ├── MasterCache.cs
    │       │   └── SlaveCache.cs
    │       ├── Calculate
    │       │   ├── CalculateContext.cs
    │       │   ├── Calculate.cs
    │       │   ├── CalculateInpute.cs
    │       │   ├── CalculateOutput.cs
    │       │   ├── CalculateType.cs
    │       │   ├── EventHandler.cs
    │       │   ├── ICalculateContext.cs
    │       │   ├── ICalculate.cs
    │       │   ├── ICalculateInpute.cs
    │       │   ├── ICalculateOutput.cs
    │       │   └── ICalculateTask.cs
    │       ├── Channel
    │       │   ├── EventHandler.cs
    │       │   ├── IChannelMessageHandler.cs
    │       │   ├── MasterMessageHandler.cs
    │       │   ├── MasterServer.cs
    │       │   ├── SlaveClient.cs
    │       │   └── SlaveMessageHandler.cs
    │       ├── Common
    │       │   ├── DateTimeUtil.cs
    │       │   ├── FileUtil.cs
    │       │   ├── FormatArgs.cs
    │       │   ├── Helper.cs
    │       │   ├── MemoryCacheHelper.cs
    │       │   ├── ProtobufHelper.cs
    │       │   ├── SerializeUtil.cs
    │       │   ├── StringExtenstion.cs
    │       │   └── ZipLib.cs
    │       ├── Config
    │       │   └── GlobalConfig.cs
    │       ├── CSharpFlink.Core.csproj
    │       ├── Execution
    │       │   ├── ExecutionEnvironment.cs
    │       │   ├── IExecutionEnvironment.cs
    │       │   └── SourceFunctionThread.cs
    │       ├── Expression
    │       │   ├── ExpressionCalculateType.cs
    │       │   ├── ExpressionTask.cs
    │       │   ├── IExpressionTask.cs
    │       │   └── Operator
    │       │       └── ExpressionCalculate.cs
    │       ├── Log
    │       │   ├── ConsoleContainer.cs
    │       │   ├── ILogContainer.cs
    │       │   ├── ILogFactory.cs
    │       │   ├── ILogger.cs
    │       │   ├── ILoggerProvider.cs
    │       │   ├── LogFactory.cs
    │       │   ├── Logger.cs
    │       │   └── LogUtil.cs
    │       ├── Model
    │       │   ├── IMetaData.cs
    │       │   └── MetaData.cs
    │       ├── Node
    │       │   ├── MasterNode.cs
    │       │   ├── NodeType.cs
    │       │   └── SlaveNode.cs
    │       ├── Protocol
    │       │   ├── DownTransmission.cs
    │       │   ├── TransmissionUtil.cs
    │       │   ├── UpTransmisstionCode.cs
    │       │   └── UpTransmisstion.cs
    │       ├── RPC
    │       │   ├── IRpcTaskExcute.cs
    │       │   ├── RpcClient.cs
    │       │   ├── RpcContext.cs
    │       │   ├── RpcServer.cs
    │       │   ├── RpcTaskExcute.cs
    │       │   └── RpcTaskHandler.cs
    │       ├── Sink
    │       │   ├── SinkContext.cs
    │       │   └── SinkFunction.cs
    │       ├── Source
    │       │   ├── EventHandler.cs
    │       │   ├── Kafka
    │       │   │   ├── IKfConsumer.cs
    │       │   │   ├── KfConsumer.cs
    │       │   │   └── SourceFunctionFromKafka.cs
    │       │   ├── SourceContext.cs
    │       │   └── SourceFunction.cs
    │       ├── Task
    │       │   ├── GlobalContext.cs
    │       │   ├── IGlobalContext.cs
    │       │   ├── IMasterTaskManager.cs
    │       │   ├── ISlaveTaskManager.cs
    │       │   ├── MasterTaskManager.cs
    │       │   ├── SlaveTaskManager.cs
    │       │   └── TaskAssembly.cs
    │       ├── Window
    │       │   ├── AggregateCalculateType.cs
    │       │   ├── DataPool.cs
    │       │   ├── IWindowTask.cs
    │       │   ├── Operator
    │       │   │   ├── Avg.cs
    │       │   │   ├── Max.cs
    │       │   │   ├── Median.cs
    │       │   │   ├── Min.cs
    │       │   │   ├── Mode.cs
    │       │   │   ├── Sum.cs
    │       │   │   └── Variance.cs
    │       │   ├── WindowTask.cs
    │       │   └── WindowTaskUtil.cs
    │       └── Worker
    │           ├── IWorker.cs
    │           └── Worker.cs
    └── test
        ├── TestCommon
        │   ├── Calc.cs
        │   ├── DataType.cs
        │   ├── TestCommon.csproj
        │   └── WindowIntervalType.cs
        ├── TestConfluentKafka
        │   ├── KafkaConf.cfg
        │   ├── KafkaConf.cs
        │   ├── Program.cs
        │   ├── SinkFunction.cs
        │   └── TestConfluentKafka.csproj
        ├── TestMasterNode
        │   ├── Program.cs
        │   └── TestMasterNode.csproj
        ├── TestRPC
        │   ├── Program.cs
        │   ├── RandomSourceFunction.cs
        │   ├── SinkFunction.cs
        │   └── TestRPC.csproj
        ├── TestSlaveNode
        │   ├── Program.cs
        │   └── TestSlaveNode.csproj
        └── TestTask
            ├── Program.cs
            ├── RandomSourceFunction.cs
            ├── SinkFunction.cs
            └── TestTask.csproj

32 directories, 121 files