RecordLineage (Data Pipeline JavaDoc)

java.lang.Object
- com.northconcepts.datapipeline.lineage.RecordLineage

```
public class RecordLineage
extends Object
```
Convenience wrapper to read and write record-level data lineage properties.

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`DATABASE_QUERY` The SQL statement used to query the database.
`static String`	`DATABASE_URL` The JDBC connection URL.
`static String`	`FILE` The `java.io.File` used to create the DataReader.
`static String`	`FILE_COLUMN_NUMBER` The beginning column number in the input file starting with 0.
`static String`	`FILE_LINE_NUMBER` The line number in the input file starting with 0.
`static String`	`RECORD_NUMBER` The sequential record number starting with 0.
`static String`	`RECORD_SCHEMA` The schema for ORC and Parquet files.

Constructor Summary

Constructors
Constructor and Description

RecordLineage()

RecordLineage(Record record)

Constructors
Constructor and Description
`RecordLineage()`
`RecordLineage(Record record)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`String`	`getDatabaseQuery()` The SQL statement used to query the database.
`String`	`getDatabaseUrl()` The JDBC connection URL.
`File`	`getFile()` The `java.io.File` used to create the DataReader.
`Long`	`getFileColumnNumber()` Returns the column number in the input file starting with 0.
`Long`	`getFileLineNumber()` The line number in the input file starting with 0.
`Record`	`getRecord()`
`Long`	`getRecordNumber()` The beginning column number in the input file starting with 0.
`String`	`getRecordSchema()` The schema for ORC and Parquet files.
`RecordLineage`	`setDatabaseQuery(String queryString)` The SQL statement used to query the database.
`RecordLineage`	`setDatabaseUrl(String url)` The JDBC connection URL.
`RecordLineage`	`setFile(File file)` The `java.io.File` used to create the DataReader.
`RecordLineage`	`setFileColumnNumber(Long columnNumber)` The beginning column number in the input file starting with 0.
`RecordLineage`	`setFileLineNumber(Long lineNumber)` The line number in the input file starting with 0.
`RecordLineage`	`setRecord(Record record)`
`RecordLineage`	`setRecordNumber(long recordNumber)` Sets the sequential record number starting with 0.
`RecordLineage`	`setRecordSchema(String recordSchema)` The schema for ORC and Parquet files.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - FILE
```
public static final String FILE
```
    The java.io.File used to create the DataReader.
    
    See Also:
    
    Constant Field Values
  - FILE_LINE_NUMBER
```
public static final String FILE_LINE_NUMBER
```
    The line number in the input file starting with 0.
    
    See Also:
    
    Constant Field Values
  - FILE_COLUMN_NUMBER
```
public static final String FILE_COLUMN_NUMBER
```
    The beginning column number in the input file starting with 0.
    
    See Also:
    
    Constant Field Values
  - RECORD_NUMBER
```
public static final String RECORD_NUMBER
```
    The sequential record number starting with 0.
    
    See Also:
    
    Constant Field Values
  - DATABASE_URL
```
public static final String DATABASE_URL
```
    The JDBC connection URL.
    
    See Also:
    
    Constant Field Values
  - DATABASE_QUERY
```
public static final String DATABASE_QUERY
```
    The SQL statement used to query the database.
    
    See Also:
    
    Constant Field Values
  - RECORD_SCHEMA
```
public static final String RECORD_SCHEMA
```
    The schema for ORC and Parquet files.
    
    See Also:
    
    Constant Field Values
- Constructor Detail
  - RecordLineage
```
public RecordLineage()
```
  - RecordLineage
```
public RecordLineage(Record record)
```
- Method Detail
  - getRecord
```
public Record getRecord()
```
  - setRecord
```
public RecordLineage setRecord(Record record)
```
  - getFile
```
public File getFile()
```
    The java.io.File used to create the DataReader.
  - setFile
```
public RecordLineage setFile(File file)
```
    The java.io.File used to create the DataReader.
  - getFileLineNumber
```
public Long getFileLineNumber()
```
    The line number in the input file starting with 0.
  - setFileLineNumber
```
public RecordLineage setFileLineNumber(Long lineNumber)
```
    The line number in the input file starting with 0.
  - getFileColumnNumber
```
public Long getFileColumnNumber()
```
    Returns the column number in the input file starting with 0.
  - setFileColumnNumber
```
public RecordLineage setFileColumnNumber(Long columnNumber)
```
    The beginning column number in the input file starting with 0.
  - getRecordNumber
```
public Long getRecordNumber()
```
    The beginning column number in the input file starting with 0.
  - setRecordNumber
```
public RecordLineage setRecordNumber(long recordNumber)
```
    Sets the sequential record number starting with 0.
  - getDatabaseUrl
```
public String getDatabaseUrl()
```
    The JDBC connection URL.
  - setDatabaseUrl
```
public RecordLineage setDatabaseUrl(String url)
```
    The JDBC connection URL.
  - getDatabaseQuery
```
public String getDatabaseQuery()
```
    The SQL statement used to query the database.
  - setDatabaseQuery
```
public RecordLineage setDatabaseQuery(String queryString)
```
    The SQL statement used to query the database.
  - getRecordSchema
```
public String getRecordSchema()
```
    The schema for ORC and Parquet files.
  - setRecordSchema
```
public RecordLineage setRecordSchema(String recordSchema)
```
    The schema for ORC and Parquet files.

Class RecordLineage

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

FILE

FILE_LINE_NUMBER

FILE_COLUMN_NUMBER

RECORD_NUMBER

DATABASE_URL

DATABASE_QUERY

RECORD_SCHEMA

Constructor Detail

RecordLineage

RecordLineage

Method Detail

getRecord

setRecord

getFile

setFile

getFileLineNumber

setFileLineNumber

getFileColumnNumber

setFileColumnNumber

getRecordNumber

setRecordNumber

getDatabaseUrl

setDatabaseUrl

getDatabaseQuery

setDatabaseQuery

getRecordSchema

setRecordSchema