Concat And Reshape Operator
- 여러 개의 column을 연결하여 하나의 새로운 column을 생성한다.
- selectedColumnId: 선택할 column ID (repeated)
- delimiter: 연결할 column 간의 구분할 구분 기호(required)
- valueColName: 새롭게 생성된 칼럼 이름 (required)
- condition: 연결되는 column의 조건. Enum(KEEP_ORIGINAL_AND_RESULT,REPLACE_SELECTED_WITH_RESULT, REFINEMENT_RESULT_ONLY)(required)
PRCS_YEAR |
PRCS_MON |
PRCS_DAY |
PRCS_HH |
PRCS_MIN |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
00 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
2015 |
09 |
01 |
00 |
05 |
PRCS_YEAR |
PRCS_MON |
PRCS_DAY |
PRCS_HH |
PRCS_MIN |
DATE_TIME |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
00 |
2015_09_01_00_00 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
2015 |
09 |
01 |
00 |
05 |
2015_09_01_00_05 |
- column(0~4)들을 연결하여 하나의 새로운 DATE_TIME column(5)을 갖는 결과 DataFrame을 생성하였다.
- parameter는 다음과 같이 설정하였다.
val concatInfo = ReshapeWithConcatInfo.newBuilder()
.addSelectedColumnId(0)
.addSelectedColumnId(1)
.addSelectedColumnId(2)
.addSelectedColumnId(3)
.addSelectedColumnId(4)
.setDelimiter("_")
.setValColName("DATE_TIME")
.setCondition(KEEP_ORIGINAL_AND_RESULT)
.build