Page History
...
- Source : 출처가되는 데이터 소스,청사진 (원소 생산자)
- Materrializer : 각 요소를 실행할 엔진 (처리 노드)
확장
| Code Block | ||||
|---|---|---|---|---|
| ||||
using System.IO;
using Akka.IO;
actorSystem = ActorSystem.Create("ServiceB");
Source<int, NotUsed> source = Source.From(Enumerable.Range(1, 100));
using (var materializer = actorSystem.Materializer())
{
source.RunForeach(i => Console.WriteLine(i.ToString()), materializer);
var factorials = source.Scan( 1 , (acc, next) => acc + next);
var result =
factorials
.Select(num => ByteString.FromString($"{num}\n"))
.RunWith(FileIO.ToFile(new FileInfo("factorials.txt")), materializer);
} |
...
Akka 사전
- Sink : 연산된 결과를 전달받을 대상자(소비자)
- 변환 : 연산 결과를 Sink대상이 이해할수 있는 데이터로 변환하는 과정
...