public class SimpleFromAvroTransformer extends AbstractTransformer implements BeanClassLoaderAware
byte[]
から生成された SpecificRecord
オブジェクトを作成するための Apache Avro トランスフォーマー。EXPRESSION_PARSER, logger
コンストラクターと説明 |
---|
SimpleFromAvroTransformer(ClassSE<? extends org.apache.avro.specific.SpecificRecord> defaultType) 指定されたデフォルト型でインスタンスを作成して作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
protected ObjectSE | doTransform(Message<?> message) サブクラスは、変換ロジックを提供するためにこのメソッドを実装する必要があります。 |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setBeanClassLoader(ClassLoaderSE classLoader) |
void | setTypeExpression(Expression expression) 型を判別するためにメッセージに対して評価する式を設定します。 |
void | setTypeExpressionString(StringSE expression) メッセージに対して評価する式を設定して、型 ID を判別します。 |
SimpleFromAvroTransformer | typeExpression(Expression expression) 型を判別するためにメッセージに対して評価する式を設定します。 |
SimpleFromAvroTransformer | typeExpression(StringSE expression) メッセージに対して評価する式を設定して、型 ID を判別します。 |
transform
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
public SimpleFromAvroTransformer(ClassSE<? extends org.apache.avro.specific.SpecificRecord> defaultType)
defaultType
- 型。public void setBeanClassLoader(ClassLoaderSE classLoader)
BeanClassLoaderAware
の setBeanClassLoader
public SimpleFromAvroTransformer typeExpression(Expression expression)
headers['avro_type']
。expression
- 表現。public SimpleFromAvroTransformer typeExpression(StringSE expression)
headers['avro_type']
。expression
- 表現。public void setTypeExpression(Expression expression)
headers['avro_type']
。expression
- 表現。public void setTypeExpressionString(StringSE expression)
headers['avro_type']
。expression
- 表現。protected void onInit()
IntegrationObjectSupport
IntegrationObjectSupport
の onInit
protected ObjectSE doTransform(Message<?> message)
AbstractTransformer
AbstractTransformer
の doTransform
message
- メッセージ。