Skip to content
GitLab
Projects
Groups
Topics
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Register
Sign in
Toggle navigation
Menu
TAE HWAN KIM
KSB_AI_Framework_1903
Commits
8b65cd01
Commit
8b65cd01
authored
Jun 11, 2020
by
HooYoungAhn
Browse files
Update 2.5.12.TfStreamPredictionMnist.md
parent
2b4cf403
Pipeline
#1074
canceled with stages
Changes
1
Pipelines
1
Hide whitespace changes
Inline
Side-by-side
manual1903/2.5.12.TfStreamPredictionMnist.md
View file @
8b65cd01
...
...
@@ -37,6 +37,7 @@ Kafka 스트림으로 입력받은 이미지 데이터를 텐서플로우 기반
#### Reader
Kafka 스트림을 입력받기 위해 KafkaReader를 선택하고, 아래 표와 같이 속성을 설정합니다.
field | value | 설명
--|---|--
topic | mnist_input | 이미지 데이터를 입력받기 위한 Kafka Topic 이름
...
...
@@ -46,6 +47,7 @@ bootStrapServer | csle1:9092 | Kafka 서버 접속주소 (IP, 포트번호)
#### Writer
이미지 분류 결과를 Kafka 스트림으로 출력하기 위해 KafkaWriter를 선택하고, 아래 표와 같이 속성을 설정합니다.
field | value | 설명
--|---|--
topic | mnist_output | 이미지 분류 결과를 출력하기 위한 Kafka Topic 이름
...
...
@@ -55,18 +57,21 @@ bootStrapServer | csle1:9092 | Kafka 서버 접속주소 (IP, 포트번호)
#### Controller
Spark 기반의 스트림 데이터 처리를 위해 SparkSessionOrStreamController를 선택하고, 아래 표와 같이 속성을 설정합니다.
field | value | 설명
--|---|--
operationPeriod | 1 | 스트림 데이터를 처리하는 주기 (초 단위)
#### Runner
Spark 환경 설정을 위해 SimpleSparkRunner를 선택하고, 아래 표와 같이 속성을 설정합니다.
field | value | 설명
--|---|--
inJason | false | false로 설정하는 경우 json 형태의 파라메타를 커맨드라인 파라미터 형태로 변환하여 호출되는 외부 시스템에 전달. True 이면 json 형태의 파라메타 형태 그대로 외부시스템에 전달
sparkArgs | 아래 표 참고 | Spark Application 설정
sparkArgs 설정은 다음과 같이 합니다.
field | value | 설명
--|---|--
master | local[
\*
] | 마스터
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment