eu.esdihumboldt.hale.common.headless.transform
Class Transformation
java.lang.Object
eu.esdihumboldt.hale.common.headless.transform.Transformation
public class Transformation
- extends Object
Utility class for handling batch transformation. Uses ExportJob
and
ValidationJob
.
- Author:
- Kai Schwierczek, Simon Templer
Method Summary |
static com.google.common.util.concurrent.ListenableFuture<Boolean> |
transform(InstanceCollection sources,
LimboInstanceSink targetSink,
ExportJob exportJob,
ValidationJob validationJob,
Alignment alignment,
SchemaSpace sourceSchema,
ReportHandler reportHandler,
Object processId)
Transform the given instances, according to the given alignment. |
static com.google.common.util.concurrent.ListenableFuture<Boolean> |
transform(List<InstanceReader> sources,
InstanceWriter target,
TransformationEnvironment environment,
ReportHandler reportHandler,
Object processId)
Transform the instances provided through the given instance readers and
supply the result to the given instance writer. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Transformation
public Transformation()
transform
public static com.google.common.util.concurrent.ListenableFuture<Boolean> transform(List<InstanceReader> sources,
InstanceWriter target,
TransformationEnvironment environment,
ReportHandler reportHandler,
Object processId)
- Transform the instances provided through the given instance readers and
supply the result to the given instance writer.
- Parameters:
sources
- the instance readerstarget
- the target instance writerenvironment
- the transformation environmentreportHandler
- the report handlerprocessId
- the identifier for the transformation process, may be
null
if grouping the jobs to a job family is not
necessary
- Returns:
- the future representing the successful completion of the
transformation (note that a successful completion doesn't
necessary mean there weren't any internal transformation errors)
transform
public static com.google.common.util.concurrent.ListenableFuture<Boolean> transform(InstanceCollection sources,
LimboInstanceSink targetSink,
ExportJob exportJob,
ValidationJob validationJob,
Alignment alignment,
SchemaSpace sourceSchema,
ReportHandler reportHandler,
Object processId)
- Transform the given instances, according to the given alignment.
- Parameters:
sources
- the collection of source instancestargetSink
- the target sinkexportJob
- the export jobvalidationJob
- the validation job, may be null
alignment
- the alignment, may not be changed outside this methodsourceSchema
- the source schemareportHandler
- the report handlerprocessId
- the identifier for the transformation process, may be
null
if grouping the jobs to a job family is not
necessary
- Returns:
- the future representing the successful completion of the
transformation (note that a successful completion doesn't
necessary mean there weren't any internal transformation errors)
Build 2012-12-03_12-30-59
Revision 9d2dd4b0318cda9f1393b1ddd390f7f792d70a2d