com.posco.reuse.kafka.activity
Class SFMessageCreate
java.lang.Object
com.poscoict.glueframework.biz.activity.GlueActivity<GlueContext>
com.posco.reuse.kafka.activity.SFMessageCreate
public class SFMessageCreate
- extends GlueActivity<GlueContext>
avroÇü½ÄÀÇ SFMessageÇüÀÇ °´Ã¼¸¦ »ý¼ºÇÑ´Ù.
Activity Property
- result-key: (Çʼö) »ý¼ºµÈ avro µ¥ÀÌÅ͸¦ GlueContext¿¡ µî·ÏÇÏ´Â Key
- tc-id: (¼±ÅÃ) SFMessage µ¥ÀÌÅÍÀÇ TC-ID °ª
- keys: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ keys °ª. ¸®½ºÆ®Çü µ¥ÀÌŸ·Î | ¸¦ ±¸ºÐÀÚ·Î ÀÔ·Â(¿¹: a|b|c)
- keys-ctx: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ keys °ª. GlueContext¿¡ String[] ÇüÀ¸·Î µî·ÏµÇ¾î ÀÖ´Â °æ¿ì ÇØ´ç °´Ã¼ÀÇ Key
- datas-keys: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼ MapÀÇ Key °ª. ¸®½ºÆ®Çü µ¥ÀÌŸ·Î | ¸¦ ±¸ºÐÀÚ·Î ÀÔ·Â(¿¹: a|b|c)
- datas-keys-ctx: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼ MapÀÇ Key °ª. GlueContext¿¡ String[] ÇüÀ¸·Î µî·ÏµÇ¾î ÀÖ´Â °æ¿ì ÇØ´ç °´Ã¼ÀÇ Key
- data#(data1,data2...) : (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼ MapÀÇ value °ª. Key °ªÀÌ Á¤ÀÇµÈ ¼ø¼´ë·Î ¸ÊÇÎ
- data#-ctx(data1-ctx,data2-ctx...) : (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼ MapÀÇ value °ªÀ» °¡Á® ¿Ã GlueContextÀÇ Key.
- glue-message-convert : (¼±ÅÃ) GlueContextÀÇ GlueMessage¸¦ º¯È¯ÇÏ´Â °æ¿ì ÀÔ·Â(ÀÔ·Â °ª : true)
¿¹Á¦
»ç¿ë ¿¹# 1
»ç¿ë ¿¹# 2
»ç¿ë ¿¹# 3
Methods inherited from class com.poscoict.glueframework.biz.activity.GlueActivity |
commitTransaction, commitTransaction, getDao, getEventList, getName, getProperty, getPropertyNames, getTransition, rollbackTransaction, rollbackTransaction, setEventList, setName, setProperty, setTransition |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SFMessageCreate
public SFMessageCreate()
runActivity
public String runActivity(GlueContext ctx)
- Specified by:
runActivity
in class GlueActivity<GlueContext>
Copyright © 2013–2016 POSCO ICT. All rights reserved.