Package com.zendesk.maxwell.schema

Class Table

java.lang.Object

com.zendesk.maxwell.schema.Table

public class Table
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
String	charset
String	database
String	name
int	pkIndex

Constructor Summary

Constructors

Constructor	Description
Table()
Table(String database, String name, String charset, List<ColumnDef> list, List<String> pks)

Method Summary

Modifier and Type	Method	Description
void	addColumn(int index, ColumnDef definition)
void	addColumn(ColumnDef definition)
void	addColumns(List<ColumnDef> definitions)
void	changeColumn(int idx, ColumnPosition position, ColumnDef definition, List<DeferredPositionUpdate> deferred)
Table	copy()
void	diff(List<String> diffs, Table other, String nameA, String nameB)
ColumnDef	findColumn(int index)
ColumnDef	findColumn(String name)
short	findColumnIndex(String name)
String	fullName()
String	getCharset()
List<ColumnDef>	getColumnList()
Set<String>	getColumnNames()
String	getDatabase()
String	getName()
int	getPKIndex()
List<String>	getPKList()
String	getPKString()
List<StringColumnDef>	getStringColumns()
void	moveColumn(String name, ColumnPosition position)
void	removeColumn(int idx)
void	rename(String tableName)
void	renameColumn(int idx, String name)
void	replaceColumn(int idx, ColumnDef definition)
void	setCharset(String charset)
void	setColumnList(List<ColumnDef> list)
void	setDatabase(String database)
void	setDefaultColumnCharsets()
void	setPKList(List<String> pkColumnNames)
void	setTable(String name)

Methods inherited from class java.lang.Object

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

Field Detail

database

public String database

name

public String name

charset

public String charset

pkIndex

public int pkIndex

Constructor Detail

Table

public Table()

Table

public Table(String database,
             String name,
             String charset,
             List<ColumnDef> list,
             List<String> pks)

Method Detail

setTable

public void setTable(String name)

getColumnList

public List<ColumnDef> getColumnList()

getColumnNames

public Set<String> getColumnNames()

setColumnList

public void setColumnList(List<ColumnDef> list)

getStringColumns

public List<StringColumnDef> getStringColumns()

getName

public String getName()

findColumnIndex

public short findColumnIndex(String name)

findColumn

public ColumnDef findColumn(String name)

findColumn

public ColumnDef findColumn(int index)

getPKIndex

public int getPKIndex()

getDatabase

public String getDatabase()

copy

public Table copy()

rename

public void rename(String tableName)

fullName

public String fullName()

diff

public void diff(List<String> diffs,
                 Table other,
                 String nameA,
                 String nameB)

setDefaultColumnCharsets

public void setDefaultColumnCharsets()

addColumn

public void addColumn(int index,
                      ColumnDef definition)

addColumn

public void addColumn(ColumnDef definition)

addColumns

public void addColumns(List<ColumnDef> definitions)

removeColumn

public void removeColumn(int idx)

renameColumn

public void renameColumn(int idx,
                         String name)
                  throws InvalidSchemaError

Throws:

InvalidSchemaError

replaceColumn

public void replaceColumn(int idx,
                          ColumnDef definition)
                   throws InvalidSchemaError

Throws:

InvalidSchemaError

changeColumn

public void changeColumn(int idx,
                         ColumnPosition position,
                         ColumnDef definition,
                         List<DeferredPositionUpdate> deferred)
                  throws InvalidSchemaError

Throws:

InvalidSchemaError

moveColumn

public void moveColumn(String name,
                       ColumnPosition position)
                throws InvalidSchemaError

Throws:

InvalidSchemaError

setDatabase

public void setDatabase(String database)

getCharset

public String getCharset()

setCharset

public void setCharset(String charset)

getPKList

public List<String> getPKList()

getPKString

public String getPKString()

setPKList

public void setPKList(List<String> pkColumnNames)