Package org.openrefine.model.recon

Class ReconciledDataExtensionJob

java.lang.Object

org.openrefine.model.recon.ReconciledDataExtensionJob

All Implemented Interfaces:

Serializable

public class ReconciledDataExtensionJob
extends Object
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReconciledDataExtensionJob.ColumnInfo
static class	ReconciledDataExtensionJob.DataExtension	Data extension corresponding to a single row.
static class	ReconciledDataExtensionJob.DataExtensionConfig
static class	ReconciledDataExtensionJob.DataExtensionProperty
static class	ReconciledDataExtensionJob.DataExtensionQuery
static class	ReconciledDataExtensionJob.QueryView
static class	ReconciledDataExtensionJob.RecordDataExtension	Data extension corresponding to a single record.

Field Summary

Fields

Modifier and Type	Field	Description
List<ReconciledDataExtensionJob.ColumnInfo>	columns
String	endpoint
ReconciledDataExtensionJob.DataExtensionConfig	extension
static com.fasterxml.jackson.databind.ObjectWriter	queryWriter

Constructor Summary

Constructors

Constructor	Description
ReconciledDataExtensionJob(ReconciledDataExtensionJob.DataExtensionConfig obj, String endpoint, String identifierSpace, String schemaSpace)

Method Summary

Modifier and Type	Method	Description
protected ReconciledDataExtensionJob.DataExtension	collectResult(com.fasterxml.jackson.databind.node.ObjectNode record)
Map<String,ReconciledDataExtensionJob.DataExtension>	extend(Set<String> ids)	TODO Although the HTTP code has been unified, there may still be opportunity to refactor a higher level querying library out of this which could be shared with StandardReconConfig.
protected static void	formulateQuery(Set<String> ids, ReconciledDataExtensionJob.DataExtensionConfig node, Writer writer)
int	getBatchSize()
protected static String	postExtendQuery(String endpoint, String query)
protected void	storeCell(List<List<Cell>> rows, int row, int col, Cell cell)

Methods inherited from class java.lang.Object

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

Field Detail

extension

public final ReconciledDataExtensionJob.DataExtensionConfig extension

endpoint

public final String endpoint

columns

public List<ReconciledDataExtensionJob.ColumnInfo> columns

queryWriter

public static final com.fasterxml.jackson.databind.ObjectWriter queryWriter

Constructor Detail

ReconciledDataExtensionJob

public ReconciledDataExtensionJob(ReconciledDataExtensionJob.DataExtensionConfig obj,
                                  String endpoint,
                                  String identifierSpace,
                                  String schemaSpace)

Method Detail

extend

public Map<String,ReconciledDataExtensionJob.DataExtension> extend(Set<String> ids)
                                                                  throws Exception

TODO Although the HTTP code has been unified, there may still be opportunity to refactor a higher level querying library out of this which could be shared with StandardReconConfig. It may also be possible to extract a library to query reconciliation services which could be used outside of OpenRefine.

Throws:

Exception

postExtendQuery

protected static String postExtendQuery(String endpoint,
                                        String query)
                                 throws IOException

Throws:

IOException

collectResult

protected ReconciledDataExtensionJob.DataExtension collectResult(com.fasterxml.jackson.databind.node.ObjectNode record)

storeCell

protected void storeCell(List<List<Cell>> rows,
                         int row,
                         int col,
                         Cell cell)

formulateQuery

protected static void formulateQuery(Set<String> ids,
                                     ReconciledDataExtensionJob.DataExtensionConfig node,
                                     Writer writer)
                              throws IOException

Throws:

IOException

getBatchSize

public int getBatchSize()