Package cz.o2.proxima.core.transform
Interface ContextualTransformation<OP extends DataOperator>
-
- All Superinterfaces:
DataOperatorAware
,java.io.Serializable
,Transformation
- All Known Subinterfaces:
DirectElementWiseTransform
- All Known Implementing Classes:
TransactionalOnlineAttributeWriter.TransactionValidator
,TransactionCommitTransformation
@Evolving public interface ContextualTransformation<OP extends DataOperator> extends Transformation, DataOperatorAware
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default boolean
isContextual()
Verify if this isDataOperator
specific (contextual) object.default void
onRestart()
Called before starting processing after fresh start of processing or after recovery from errorvoid
setup(Repository repo, OP op, java.util.Map<java.lang.String,java.lang.Object> cfg)
Read the repository and setup descriptors of target entity and attributes.-
Methods inherited from interface cz.o2.proxima.core.transform.DataOperatorAware
as, isDelegateOf
-
Methods inherited from interface cz.o2.proxima.core.transform.Transformation
asContextualTransform, asElementWiseTransform
-
-
-
-
Method Detail
-
isContextual
default boolean isContextual()
Description copied from interface:DataOperatorAware
Verify if this isDataOperator
specific (contextual) object.- Specified by:
isContextual
in interfaceDataOperatorAware
- Returns:
- boolean
-
setup
void setup(Repository repo, OP op, java.util.Map<java.lang.String,java.lang.Object> cfg)
Read the repository and setup descriptors of target entity and attributes.- Parameters:
repo
- the repositoryop
-DataOperator
that delegated this Transformationcfg
- transformation config map
-
onRestart
default void onRestart()
Called before starting processing after fresh start of processing or after recovery from error
-
-