5.1 Platform-Agnostic Native API
사용자가 Rheem의 네이티브 API 중 하나를 사용하여 애플리케이션을 코딩하는 방법에 대해 설명한다. Scala API 및 SGD 실행 예제(see Listing 1)
먼저 사용자가 Rheem 컨텍스트를 생성한다. 이 컨텍스트에서는 사용 가능한 플랫폼(Line 1-3)을 지정한다. (이 예에서는 Spark와 JavaStreams) 그리고나서 이 컨텍스트로 Rheem Plan을 초기화 한다.(Line4) 궁극적으로 SGD작업을 정의하는 Rheem 연산자 그래프를 만든다. Rheem Plan은 최소한 하나의 소스 연산자(Line 5) 즉, 입력 데이터 퀀텀을 읽거나 생성하는 연산자와 분기마다 하나의 싱크 연산자(Line 13)가 있어야 한다. 즉, 결과를 검색하거나 저장하는 연산자가 있어야한다.
Rheem Plan에는 최소한 하나의 소스 연산자(Line 5)와 분기마다 하나의 싱크 연산자(Line 13)가 있어야 함을 기억하라. 또한 이 코드가 기본 플랫폼에 전혀 영향을 받지 않는지 확인 하라
그러나 사용자가 Rheem에게 특정 플랫폼에서 주어진 연산자를 강제 실행하기 원할 경우 withTargetPlatform 메서드를 호출 할 수 있다. 마찬가지로 customOperator 메서드를 통해 특정 실행 연산자를 사용하도록 시스템에 강제 설정할 수 있다. 그러면 사용자가 API를 확장하지 않고도 customOperator를 사용할 수 있다.