Package cz.o2.proxima.direct.core.transaction

Class TransactionCommitTransformation

java.lang.Object

cz.o2.proxima.direct.core.transaction.TransactionCommitTransformation

All Implemented Interfaces:

ContextualTransformation<DirectDataOperator>, DataOperatorAware, Transformation, DirectElementWiseTransform, java.io.Serializable, java.lang.AutoCloseable

public class TransactionCommitTransformation
extends java.lang.Object
implements DirectElementWiseTransform

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
TransactionCommitTransformation()

Method Summary

Modifier and Type	Method	Description
void	close()
void	setup(Repository repo, DirectDataOperator directDataOperator, java.util.Map<java.lang.String,java.lang.Object> cfg)	Read the repository and setup descriptors of target entity and attributes.
void	transform(StreamElement input, CommitCallback commitCallback)	Transform and output any transformed elements.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cz.o2.proxima.core.transform.ContextualTransformation

isContextual, onRestart

Methods inherited from interface cz.o2.proxima.core.transform.DataOperatorAware

as

Methods inherited from interface cz.o2.proxima.direct.core.transform.DirectElementWiseTransform

isDelegateOf

Methods inherited from interface cz.o2.proxima.core.transform.Transformation

asContextualTransform, asElementWiseTransform

Constructor Detail

TransactionCommitTransformation

public TransactionCommitTransformation()

Method Detail

setup

public void setup(Repository repo,
                  DirectDataOperator directDataOperator,
                  java.util.Map<java.lang.String,java.lang.Object> cfg)

Description copied from interface: ContextualTransformation

Read the repository and setup descriptors of target entity and attributes.

Specified by:

setup in interface ContextualTransformation<DirectDataOperator>

Specified by:

setup in interface DirectElementWiseTransform

Parameters:

repo - the repository

directDataOperator - DataOperator that delegated this Transformation

cfg - transformation config map

transform

public void transform(StreamElement input,
                      CommitCallback commitCallback)

Description copied from interface: DirectElementWiseTransform

Transform and output any transformed elements. The complete processing is defined by this method.

Specified by:

transform in interface DirectElementWiseTransform

Parameters:

input - the input StreamElement

commitCallback - asynchronous callback notifying about the result

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable