public interface EcdaReaderContext extends EcdaContext
EcdaContext.Phase
Modifier and Type | Method and Description |
---|---|
void |
discardRow(java.util.logging.Logger discardTracer,
java.lang.String rowPosition,
java.lang.String sqlState,
java.lang.String message,
byte[] payload,
java.lang.Throwable thrown)
Discard a newly ingested row and log this action to the global error stream.
|
java.util.Set<java.lang.String> |
getAllSpecialColumns()
Returns all special columns for this source
|
RowFilter |
getFilter()
Gets the filter in use.
|
BuffersInputStream |
getInputStream()
Get inputStream associated with this context
|
long |
getLineOffset() |
java.util.Set<java.lang.String> |
getMappedSpecialColumns()
Gets list of columns that have already been mapped.
|
ExtendedParameterMetaData |
getMetaData()
Gets ParameterMetaData for output of parser.
|
DataInputParser |
getParser()
Gets the parser associated with this context
|
DataInputSource |
getSource()
Gets the source associated with this context
|
FennelTupleDescriptor |
getTupleDescriptor()
Gets the FennelTupleDecriptor that describes the metadata for this
context
|
int |
mapSpecialColumn(java.lang.String name)
Maps column name to output row.
|
void |
setFilter(RowFilter filter)
Sets the filter to use
|
void |
setLineOffset(long lineOffset) |
void |
setParserThread(java.lang.Thread parserThread)
Call to allow monitoring parsing thread.
|
void |
setSourceStatisticsReporter(java.lang.Runnable reporter)
Allows statistics logging of source along with parser statistics logging
|
addTracePropertyListener, close, getBooleanSessionVariable, getCompilingStatementId, getPhase, getQueryConnection, getSessionName, getSessionVariables, isClosed, isRowtimePresent, notifyOnCancel, removeTracePropertyListener, setUdxExitWithoutWait, validating
long getLineOffset()
void setLineOffset(long lineOffset)
ExtendedParameterMetaData getMetaData()
FennelTupleDescriptor getTupleDescriptor() throws java.sql.SQLException
java.sql.SQLException
int mapSpecialColumn(java.lang.String name) throws java.sql.SQLException
name
- name of columnjava.sql.SQLException
- if an error occurs accessing the columnjava.util.Set<java.lang.String> getMappedSpecialColumns()
java.util.Set<java.lang.String> getAllSpecialColumns()
BuffersInputStream getInputStream()
void setFilter(RowFilter filter)
filter
- RowFilter to use as filterRowFilter getFilter()
void discardRow(java.util.logging.Logger discardTracer, java.lang.String rowPosition, java.lang.String sqlState, java.lang.String message, byte[] payload, java.lang.Throwable thrown)
discardTracer
- The caller's trace Logger.rowPosition
- Position of the discarded row, coming from the source.sqlState
- Enum explaining why the row is being discarded.message
- Detailed error message corresponding to the sqlstate.payload
- A string of input near or containing the discarded row.thrown
- A throwable which may accompany the errorvoid setParserThread(java.lang.Thread parserThread)
or start
of parser thread
parserThread
- Parser thread to monitor.void setSourceStatisticsReporter(java.lang.Runnable reporter)
reporter
- lamda to be run when reporting parser statisticsDataInputSource getSource()
DataInputParser getParser()
Copyright (C) 2003-2021 SQLstream, Inc.