public class DelimitedFlatfileTable extends BaseFlatfileTable
Table.BaseFlatfileTable.BaseFlatfileTableOrganizationContext| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
PROP_FIELDDELIMITER |
static java.lang.String |
PROP_QUALIFIER |
_fileName, _isFirstLineHeader, _lineSep, _maxFaults, _rowsToSkip, context, EOF, FILLER, PROP_FILENAME, PROP_ISFIRSTLINEHEADER, PROP_MAXFAULTS, PROP_RECORDDELIMITER, PROP_ROWSTOSKIP_dataFile, _dbdir, _freeIds, _readOnly, _rowCount, CURRENT_META_VERSION, FRID_FILE_EXT, FS, INDICES_DIR_NAME, INVALID_OFFSET, META_FILE_EXT, PIDX_FILE_EXT, SEQ_FILE_EXT, TYPE_FILE_EXTCOLUMNS_ARE_CASE_SENSITIVE, DELIMITED_TABLE_TYPE, EXTERNAL_DB_TABLE_TYPE, FW_TABLE_TYPE, PROP_CATALOG, PROP_CREATE_IF_NOT_EXIST, PROP_DB, PROP_LOADTYPE, PROP_ORDERBY, PROP_REMOTETABLE, PROP_SCHEMA, PROP_VENDOR, PROP_WHERE, TAGGED_EBCDIC_TABLE_TYPEREGULAR_TABLE_TYPE, SYSTEM_TABLE_TYPE| Constructor and Description |
|---|
DelimitedFlatfileTable(java.lang.String name,
Database db) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.String |
getDefaultDataFileExtension() |
protected java.lang.String |
getQualifier() |
protected int |
getQualifierLength() |
protected Row |
getRowByOffset(int idToAssign,
long ptr) |
java.util.Properties |
getTableProperties()
Gets Organization Property.
|
protected boolean |
isEndOfRecord(int recLength,
int nextChar,
BufferedDataInputStream data) |
protected boolean |
isNewLine(int nextChar) |
protected boolean |
isQuoted() |
boolean |
loadExternalTable(java.util.Properties props)
Loads external data using the given properties table - should be called only once
by the table factory.
|
protected void |
parseTableProperties(java.io.ObjectInputStream in) |
protected void |
writeHeader(BufferedDataOutputStream dataFile) |
protected void |
writeRow(BufferedDataOutputStream buffer,
Row row) |
protected void |
writeTableProperties(java.io.ObjectOutputStream out) |
addColumn, addEscapeSequence, createOrLoadDataFile, createOrLoadDataFile, evaluateForNull, fixEscapeSequence, getDataFile, getLobDir, ignoreRowsToSkip, initializeTable, isEOF, isNullString, nextLineLength, reloadFilesAfterTruncate, remount, renameTableFiles, trySettingColumnaddColumn, addConstraint, applyDeletes, applyInserts, applyUpdates, checkpoint, clearDataFileReference, closeFiles, createOrLoadFreeIdsFile, drop, freeRowId, getInputStream, getNextRowId, getOutputStream, getPidxList, getRootDir, getRow, getRowCount, getRowIterator, getTableFile, initFiles, initializeRowCount, isReadOnly, loadOrMigrateMetaFile, migrate, parsePidxFile, populateIndex, remount, removeIndex, rename, resetLobColumns, saveIndicesAfterTruncate, setSequence, shutdown, truncate, tryToRemove, writeFridFile, writeMetaFile, writeNameToFileaddIndex, addRow, applyDeletesToIndices, applyInsertsToIndices, applyUpdatesToIndices, clearCache, deleteRow, getColumn, getColumn, getColumnCount, getColumnIdentifiers, getColumnIndex, getConstraint, getConstraints, getIndexedRows, getIndexedRows, getIndexForColumn, getIndices, getName, getRowIterator, getSequence, getType, hasColumn, hasIndex, isColumnIndexed, isPrimaryKeyConstraintExists, isUniqueConstraintExists, makeRowDecorator, makeTransactableTable, notifyColumnsOfNewLobDir, readColumns, readConstraints, recreateIndices, removeConstraint, setName, setType, toString, truncateIndices, updateRow, writeColumns, writeConstraintscheckConstraints, checkConstraints, checkConstraints, getMatchingRows, hasDeferredConstraint, isDeferAll, migrateaddTableModificationListener, getTableModificationListeners, publishEvent, removeTableModificationListener, setDeferAllConstraintsclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddColumn, addConstraint, addIndex, addRow, addTableModificationListener, applyDeletes, applyInserts, applyUpdates, checkpoint, deleteRow, drop, freeRowId, getColumn, getColumn, getColumnCount, getColumnIdentifiers, getColumnIndex, getConstraint, getConstraints, getIndexedRows, getIndexedRows, getIndexForColumn, getIndices, getMatchingRows, getName, getNextRowId, getRowCount, getRowIterator, getSequence, getTableModificationListeners, getType, hasColumn, hasIndex, isColumnIndexed, isPrimaryKeyConstraintExists, isUniqueConstraintExists, makeRowDecorator, makeTransactableTable, migrate, populateIndex, remount, removeConstraint, removeIndex, removeTableModificationListener, rename, setDeferAllConstraints, setSequence, shutdown, truncate, updateRowpublic static final java.lang.String PROP_FIELDDELIMITER
public static final java.lang.String PROP_QUALIFIER
public DelimitedFlatfileTable(java.lang.String name,
Database db)
throws AxionException
AxionExceptionprotected java.lang.String getDefaultDataFileExtension()
getDefaultDataFileExtension in class BaseFlatfileTableprotected java.lang.String getQualifier()
protected int getQualifierLength()
protected Row getRowByOffset(int idToAssign, long ptr) throws AxionException
getRowByOffset in class BaseDiskTableAxionExceptionprotected boolean isQuoted()
protected boolean isEndOfRecord(int recLength,
int nextChar,
BufferedDataInputStream data)
throws java.io.IOException
isEndOfRecord in class BaseFlatfileTablejava.io.IOExceptionpublic boolean loadExternalTable(java.util.Properties props)
throws AxionException
BaseFlatfileTableloadExternalTable in interface ExternalTableloadExternalTable in class BaseFlatfileTableprops - Properties for TableAxionException - thrown while setting Propertiespublic java.util.Properties getTableProperties()
ExternalTableprotected void parseTableProperties(java.io.ObjectInputStream in)
throws AxionException
parseTableProperties in class BaseDiskTableAxionExceptionprotected void writeHeader(BufferedDataOutputStream dataFile) throws AxionException
writeHeader in class BaseFlatfileTableAxionExceptionprotected void writeRow(BufferedDataOutputStream buffer, Row row) throws AxionException
writeRow in class BaseDiskTableAxionExceptionprotected void writeTableProperties(java.io.ObjectOutputStream out)
throws AxionException
writeTableProperties in class BaseDiskTableAxionExceptionprotected boolean isNewLine(int nextChar)