- Gbfhd_tuple() - Constructor for class com.sqlstream.aspen.namespace.common.HexToBinaryConverter.Gbfhd_tuple
-
- getAllSpecialColumns() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Returns all special columns for this source
- getAspenControlNodeProxyTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.rmp.AspenControlNodeProxy" tracer records
control protocol messages received and sent by
AspenControlNodeProxy
.
- getAspenControlNodeTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.control.AspenControlNode"
logger traces AspenControlNode
.
- getAspenJdbcTracer() - Static method in class com.sqlstream.aspen.trace.AspenClientTrace
-
The "com.sqlstream.aspen.vjdbc.AspenDriver" tracer records
trace messages generated by the ASPEN JDBC tracer
Driver
.
- getAspenJdbcTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.vjdbc.AspenDriver" tracer records
trace messages generated by the ASPEN JDBC tracer
com.sqlstream.aspen.vjdbc.AspenDriver
.
- getAspenPlannerTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.farrago.AspenPlanner"
logger traces AspenControlNode
.
- getAspenRmpTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.rmp.AspenRmp"
logger traces AspenRmp
.
- getAspenServerTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.server.AspenVJdbcServer" tracer records
trace messages generated by the Aspen*Server classes,
AspenVJdbcServer
.
- getAspenSessionFactoryTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.farrago.AspenSessionFactory" tracer
records each operation performed on a AspenSessionFactory
as distinct from the Farrago implementations of that class.
- getBooleanSessionVariable(String, boolean) - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
Get the value of a boolean session variable.
- getBoolPropertyValue(String, boolean) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getBucketFile(PartitionName, int) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink
-
- getBuffer() - Method in class com.sqlstream.aspen.namespace.common.SourceData
-
Get the buffer associated with this SourceData.
- getBytesFromHexDigits(byte[]) - Method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
Read the sequence of 1-byte hex chars which are inside this converter.
- getBytesFromHexDigits(byte[], HexToBinaryConverter.Gbfhd_tuple) - Method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
Read the sequence of 1-byte hex chars which are inside this converter.
- getCharset() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getCharset() - Method in interface com.sqlstream.aspen.namespace.common.DataInputParser
-
Get the type of character encoding assumed by this parser.
- getCharset(int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- getClassLoaderFor(String) - Static method in class com.sqlstream.aspen.core.RuntimeObjectFactory
-
- getClusterKey() - Static method in class com.sqlstream.aspen.core.AspenProperties
-
- getCompilingStatementId() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
Get the id of the statement being compiled (only valid during statement preparation)
- getConnection() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
- getControlProtocolDistributedRequestTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.control.ControlProtocolDistributedRequest"
tracer records operations performed by
ControlProtocolDistributedRequest
.
- getCurrent() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
-
Wait if needed and obtain a free SourceData for writing.
- getCurrentPayload(int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Return the byte contents of the last (consumed) buffer, up to a max number of bytes.
- getCurrentWithSize(int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
-
Wait if needed and obtain a free SourceData for writing.
- getDiscardPluginTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.plugin.discard" tracer watches the
discard plugin
.
- getDoubleValue() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
-
- getErrorMessage() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
-
Get the detailed error message to be reported
- getFactory() - Method in class com.sqlstream.aspen.namespace.common.SourceData
-
Get the factory that created this.
- getFileWriterPluginTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.plugin.filewriter" tracer watches the
plugin
.
- getFilter() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Gets the filter in use.
- getHdapProtocolTracer() - Static method in class com.sqlstream.aspen.trace.AspenClientTrace
-
The "com.sqlstream.aspen.distrib" tracer records
trace messages generated by the HDAP tracer.
- getHdapProtocolTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.sdp2.StreamingDataProtocol" tracer records
trace messages generated by the Streaming Data Protocol stack.
- getInitProperties() - Method in interface com.sqlstream.aspen.core.RuntimeObject
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BinaryParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DoubleParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.FloatParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IsoTimestampParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.LongParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ScientificNotationLongParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringMatchingCharsetParser
-
- getInitProperties() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringParser
-
- getInputStream() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Get inputStream associated with this context
- getIntPropertyValue(String, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getLine(BuffersInputStream.Line, byte[]) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Get the next input line, by scanning up to but not including the next
unquoted DELIMITER or end of message.
- getLineOffset() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
- getLogFilePluginTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.plugin.logfile" tracer watches the
logfile plugin
.
- getMajorVersion() - Method in class com.sqlstream.jdbc.Driver
-
- getMappedSpecialColumns() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Gets list of columns that have already been mapped.
- getMetaData() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Gets ParameterMetaData for output of parser.
- getMetaData() - Method in interface com.sqlstream.aspen.namespace.common.EcdaWriterContext
-
- getMinorVersion() - Method in class com.sqlstream.jdbc.Driver
-
- getMyProperties(RuntimeObject<T>) - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
-
- getNextRequestId() - Method in class com.sqlstream.jdbc.Driver
-
- getNodeManagerTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.control.NodeManager" tracer records operations
performed by NodeManager
.
- getOutput() - Method in class com.sqlstream.plugin.PairedUdxWriter.OutputHolder
-
- getOutputNamed(String) - Static method in class com.sqlstream.plugin.PairedUdxWriter
-
- getParentLogger() - Method in class com.sqlstream.jdbc.Driver
-
- getParser() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Gets the parser associated with this context
- getParserLineNumber() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getPayloadCount() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Get the number of SourceDatas we have seen so far.
- getPhase() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
Return the phase that this reader or writer is being initialized.
- getPluginActivationTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.plugin.activation" tracer watches plugin activation.
- getPluginClassLoader(EcdaPluginFactory.PluginType, String) - Method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
-
Get the classloader for a plugin by type name.
- getPosition() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Gives the offset in bytes of the next read from the start of the stream.
- getPositionKey() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Get the position key of the current input row.
- getPositionKey(String, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Get the position key of the current input row
- getPositionKeyFields(String) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Split a position key into an array of fields.
- getPropertyInfo(String, Properties) - Method in class com.sqlstream.jdbc.Driver
-
- getPulsePluginTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.plugin.pulse" tracer watches the
pulse plugin
.
- getPumpTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.pump" tracer records trace messages generated
by the Aspen PumpManager and its associated classes.
- getQueryConnection() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
Get the connection to use for querying dynamic options.
- getQueryTimeoutMillis() - Method in interface com.sqlstream.jdbc.StreamingStatement
-
- getQuoteCharacters() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Gets the quoteCharacter used for searching.
- getQuoteCount() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Gets the count of quote characters seen in the most recent
unquoted search.
- getRawBytes(String, Charset) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.CachedLocationDescription
-
Get (or compute) the byte representation of the
cached location description.
- getRegisteredTypes() - Static method in class com.sqlstream.aspen.core.RuntimeObjectFactory
-
Get a list of registered types.
- getResultSet() - Method in interface com.sqlstream.aspen.namespace.common.EcdaWriterContext
-
- getRmpTempDir() - Method in class com.sqlstream.aspen.core.AspenProperties
-
- getRowNumberInPayload() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Get the number of the row within the payload.
- getRowtimeBound() - Method in interface com.sqlstream.jdbc.StreamingResultSet
-
Returns the latest rowtime bound from the target stream.
- getRowtimeBound() - Method in interface com.sqlstream.jdbc.StreamingStatement
-
Returns the latest rowtime bound from the target stream.
- getRowtimeBounds() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getSdpState() - Method in class com.sqlstream.jdbc.Driver
-
- getSemicolonEncoding(Charset) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.CachedLocationDescription
-
Return the bytes encoding a semi-colon in the given character set
- getSessionName() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
Get the session name.
- getSessionVariables() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
Get session variables associated with session.
- getSinkHandleTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.farrago.AspenSinkHandle" tracer records each
operation performed on a AspenSinkHandle
, at level
Level.FINE
or higher.
- getSource() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Gets the source associated with this context
- getSourceDataFactory() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Get the data factory.
- getSourceDataFactory() - Method in interface com.sqlstream.aspen.namespace.common.DataInputSource
-
Get's the singleton SourceDataFactory for this DataInputSource.
- getSourceDataHandler() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Get the sourceDataHandler.
- getSQLState() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
-
Get the SQLState to be reported
- getSqlType() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
-
- getSqlType() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.TimeParser
-
- getSqlType() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.TimestampParser
-
- getStartupPositionKey() - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Retrieve the startup position key.
- getStatementId() - Method in interface com.sqlstream.jdbc.StreamingStatement
-
Returns the unique identifier of this statement.
- getStreamingDataProtocolClientsTracer() - Static method in class com.sqlstream.aspen.trace.AspenClientTrace
-
The "com.sqlstream.aspen.sdp2.clients" tracer records
trace messages generated by client interaction with the
Streaming Data Protocol stack.
- getStreamingDataProtocolClientsTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.sdp2.clients" tracer records
trace messages generated by client interaction with the
Streaming Data Protocol stack.
- getStreamingDataProtocolTracer() - Static method in class com.sqlstream.aspen.trace.AspenClientTrace
-
The "com.sqlstream.aspen.sdp.StreamingDataProtocol" tracer records
trace messages generated by the Streaming Data Protocol stack.
- getStreamingDataProtocolTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.sdp2.StreamingDataProtocol" tracer records
trace messages generated by the Streaming Data Protocol stack.
- getSubMap(Map<String, String>, String) - Static method in class com.sqlstream.aspen.namespace.common.OptionsUtils
-
- getTableMetadata(String, String) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink
-
- getTempDir() - Method in class com.sqlstream.aspen.core.AspenProperties
-
- getTestTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.aspen.test" tracer records trace messages generated
by Aspen unit tests.
- getThrowable() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
-
Get the cause of the error
- getTraceSinkPluginTracer() - Static method in class com.sqlstream.aspen.trace.AspenTrace
-
The "com.sqlstream.plugin.tracesink" tracer watches the
trace-sink plugin
.
- getTupleDescriptor() - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Gets the FennelTupleDecriptor that describes the metadata for this
context
- getTypeFormatter(int, boolean) - Method in interface com.sqlstream.aspen.namespace.common.TypeFormatterFactory
-
- getTypeParser(int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- getTypeParser(int) - Method in interface com.sqlstream.aspen.namespace.common.TypeParserFactory
-
- getUserbinDir() - Method in class com.sqlstream.aspen.core.AspenProperties
-
- getValidValues() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
-
- getWorkUnit() - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Get a SourceWorkUnit from free queue.
- getWorkUnit(long) - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Deprecated.
- scale - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
-
- sched_memoryChecker_memory_shutdownlimitRatio - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Max ratio for determining the
low memory condition.
- sched_memoryChecker_memory_type - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Memory type for the checking, either "ram" or "total" (ie.
- sched_memoryChecker_memory_warninglimitRatio - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Max ratio for determining the
low memory condition.
- sched_memoryChecker_shutdown_enabled - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Enable/disable memory checker
- sched_memoryChecker_warning_enabled - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Enable/disable memory checker
- schedAddSlowCalcs - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Slow Calcs are a trick for testing the scheduler.
- schedAddSlowCalcsNCalcs - Variable in class com.sqlstream.aspen.core.AspenProperties
-
How many Slow Calcs to add after each real Calc
- schedAddSlowCalcsNPasses - Variable in class com.sqlstream.aspen.core.AspenProperties
-
How many times each Slow Calc loops over a block of busywork;
0 means no busywork at all.
- schedCheckerPeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The scheduler periodically checks for a valid license, and whether to
throttle execution.
- schedCheckerSavePeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
While checking usage, the scheduler keeps a recent history,
and periodically saves it to a file so it can persist past server runs.
- schedCheckerThrottle - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Target throughput level for throttling, in bytes per day.
- schedCheckerThrottleAfter - Variable in class com.sqlstream.aspen.core.AspenProperties
-
When throttling is enabled, it occurs when daily input has exceeded this level, in bytes.
- schedCheckerThrottleWhen - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Circumstance when throttling is possible: never, always, [when usage is]
unreported.
- schedCheckerTimezone - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Timezone used by usage checker.
- schedDebugAsserts - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Whether to pause on an assert from C code, waiting for gdb to attach.
- schedDebugBacktrace - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Whether to print a backtrace on a debug condition.
- schedDebugBreak - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler only, whether to pause on a
debug condition, waiting for gdb to attach.
- schedDebugDetail - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler only, level of detil when printing scheduler
state.
- schedDebugOnStop - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Whether to have a debug event when the scheduler is about to stop.
- schedDebugPrint - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler only, where to print scheduler status on a
debug condition.
- schedDiamondDetectionPeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The parallel scheduler has a periodic task that checks for blockages
in stream graph due to diamond patterns.
- schedHistory - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler only, each task executor remembers this many
recently completed tasks.
- schedHistoryDetail - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler, level of detail in the task history.
- schedLicenseCheckPeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
License recheck period (secs).
- schedLicensePath - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Path used by the server to find license files.
- schedLicenseUseTrustedStorage - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Should the server look in local trusted storage for an installed license
file? False means look only in the schedLicensePath;
Ideal default is true, but local trusted storage disabled per dtbug 2768.
- schedNthreads - Variable in class com.sqlstream.aspen.core.AspenProperties
-
How many threads dedicated to execution objects.
- schedOverlookPeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The parallel scheduler has a periodic task that checks for overlooked
runnable ExecStreams.
- schedParallel - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sched.parallel" controls which scheduler version to
use.
- schedReporterPeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The scheduler periodically send usage reports to a web-service.
- schedReporterURL - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The scheduler periodically send usage reports to a web-service.
- schedStatsDiscardAfter - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Scheduler keeps entries in graph and stream tables for defunct (removed) graphs
for at least this amount of time [secs].
- schedStatsMayCountRows - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Allows the scheduler to count rows in input/output buffers.
- schedStatsPeriod - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The scheduler traces statistics of open stream graphs, with this period in secs.
- schedStatsSnapshot - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Tells the scheduler to call getSnapshot() when tracing statistics
- schedTaskTimeout - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler only, initial value of scheduler's
taskTimeout, in msecs.
- schedThrottle - Variable in class com.sqlstream.aspen.core.AspenProperties
-
For the parallel scheduler, an upper limit to the input and output rate
of every ExecStream and hence of every running statement.
- schedValidateGraphs - Variable in class com.sqlstream.aspen.core.AspenProperties
-
Tells the scheduler to verify the integrity of its stream-graph and stream-node tables
after adding or removing a stream-graph.
- schedVerbose - Variable in class com.sqlstream.aspen.core.AspenProperties
-
When true, the scheduler prints messages to stderr, notably at startup.
- ScientificNotationLongParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.ScientificNotationLongParser
-
- scottJdbcUrl - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.scott.jdbc.url" property holds
the URL of the JDBC database which contains the Scott schema (the
old Oracle favorite containing the EMP and DEPT tables),
default "jdbc:hsqldb:/saffron/demo/hsqldb/scott".
- scratchDecimal - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.AbstractFieldParser
-
- sdpBlockSize - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.blocksize" allows the configuration of the
SDP block size, in bytes.
- sdpCompressionEnable - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.tcpListenEnableCompression" Enables Zlib
compression on SDP connections
- sdpHost - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.host" sets an optional
hostname (or IP) for SDP.
- sdpLinkTimeoutMs - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.linkTimeoutMs" sets
Minimum number of milliseconds of idle time on a given Link
before timing out the link on the assumption that the connection is
broken or that the peer has crashed
- sdpMTU - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.mtu" sets maximum transmission unit(MTU)
, in bytes, for frames within SDP.
- sdpNumberIoThreads - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.numberIoThreads" sets maximum number of
IO threads used by the SDP network stack
- sdpNumberProcessingThreads - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.numberProcessingThreads" sets maximum number of
IO threads used by the SDP network stack (only for CPP stack)
- sdpPort - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.port" sets an optional
port for SDP.
- sdpPunctPingInterval - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.punctPingInterval" sets the interval in msecs
between "punctuation pings", that is periodic output rowtime bounds
emitted automatically by the XO that implements an INSERT EXPEDITED
statement that has an implicit rowtime.
- sdpReceiveBlockCount - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.rxblockcount" allows the configuration of the
SDP receive block count.
- sdpSocketRecvBufferSize - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.socketSendBufferSize" sets maximum number of
bytes in the OSes receiving TCP buffer
- sdpSocketSendBufferSize - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.socketSendBufferSize" sets maximum number of
bytes in the OSes sending TCP buffer
- sdpSslEnable - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.tcpListenEnableSSL" Enables SSL/TLSv1.2
encryption on SDP connections
- sdpStreamWindowHighWaterMarkRatio - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.streamWindowHighWaterMarkRatio"
Defines the ratio of the current window to the maximum window at which
point the window is published.
- sdpTcpConnectFailSleepMsMax - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.tcpConnectFailSleepMsMax" sets minimum
amount of time to sleep between connection retrys
- sdpTcpConnectFailSleepMsMin - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.tcpConnectFailSleepMsMin" sets minimum
amount of time to sleep between connection retrys
- sdpTcpListenFailSleepMs - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.tcpListenFailSleepMs" sets minimum
amount of time to sleep between connection retrys
- sendEndOfMessage() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
-
- sendEndOfMessage() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Send message to indicate end of multi-part message.
- sendEOS() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Send final eos to stream.
- SEPARATOR_CHAR_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- SERVER_HOST_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- SERVER_PORT_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- SERVER_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- serverMode - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.server.jvm" property controls where the aspen server is
executed.
- setAscii(int, byte[], int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setBoolean(int, boolean) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setBucketFileCallbacks(DataOutputColumnSink.BucketFileCallbacks) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink
-
- setBuffer(ByteBuffer) - Method in class com.sqlstream.aspen.namespace.common.SourceData
-
Sets the buffer associated with this SourceData.
- setBufferHook(LongConsumer) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
- setByte(int, byte) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setBytes(byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
Initialize with an array of source digits which are bytes.
- setBytes(int, byte[], int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setBytes(int, byte[]) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setChars(char[], int, int) - Method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
Initialize with an array of source digits which are chars.
- setChars(int, char[], int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setContext(T) - Method in interface com.sqlstream.aspen.core.RuntimeObject
-
- setContext(EcdaReaderContext) - Method in class com.sqlstream.aspen.namespace.common.AbstractDataInputSource
-
- setContext(RuntimeObjectContext) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.AbstractFieldParser
-
- setContext(EcdaReaderContext) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setContext(EcdaReaderContext) - Method in interface com.sqlstream.aspen.namespace.common.DataInputParser
-
Set the context for this parser.
- setContext(EcdaReaderContext) - Method in interface com.sqlstream.aspen.namespace.common.DataInputSource
-
Set the context for this data source.
- setContext(EcdaWriterContext) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputFormatter
-
- setContext(EcdaWriterContext) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
-
- setCustomParser(String, TypeParser) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setDataSourceHandler(SourceData.Handler) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Sets the sourceDataHandler
- setDataSourceHandler(RowInserter) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
- setDate(int, Date) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setDecimal(int, long, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setDisallowRowSeparatorwithinQuotes(boolean) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
- setDouble(int, double) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setError(String, String, Throwable) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
-
Set an error for this row.
- setExecutorService(ExecutorService) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setExecutorService(ExecutorService) - Method in interface com.sqlstream.aspen.namespace.common.DataInputParser
-
If this parser uses a threadpool, sets the threadpool to use, otherwise
this method should have no effect.
- setFactory(DataFactory) - Method in interface com.sqlstream.aspen.namespace.common.DataFactoryPlugin
-
Sets the DataFactory to use for requesting new a new DataInputSource.
- setFilter(RowFilter) - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Sets the filter to use
- setFloat(int, float) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setFormatter(DataOutputFormatter) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
-
- setInserter(RowInserter) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setInserter(RowInserter) - Method in interface com.sqlstream.aspen.namespace.common.DataInputParser
-
Set the inserter for parser.
- setInt(int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setLatin1(int, byte[], int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setLineOffset(long) - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
- setLong(int, long) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setMyProperties(RuntimeObject<T>, Properties) - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
-
- setNull(int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setParam(PreparedStatement, String, int, int, Object) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
-
Sets value for parameter colNum
in output ("results") row.
- setParserError(String) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setParserLineNumber(long) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setParserPosition(long) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- setParserThread(Thread) - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Call to allow monitoring parsing thread.
- setQueryConnection(Connection) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
-
Set the connection to use for querying dynamic options.
- setQueryTimeoutMillis(long) - Method in interface com.sqlstream.jdbc.StreamingStatement
-
Sets the query timeout of this StreamingStatement
.
- setQuoteCharacters(byte[]) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Sets the quote character for quote sensitive searches.
- setRange(double, double) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
-
- setRange(int, int) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
-
- setRowtimeBound(Timestamp) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setRowtimeBound(Timestamp) - Method in interface com.sqlstream.jdbc.StreamingPreparedStatement
-
Sets the rowtime bound for the current stream.
- setRowtimeBound(Timestamp, Calendar) - Method in interface com.sqlstream.jdbc.StreamingPreparedStatement
-
Sets the rowtime bound for the current stream.
- setRowtimeBoundIfNoActivity(long, long) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setShort(int, short) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setSink(DataOutputSink) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputFormatter
-
- setSourceStatisticsReporter(Runnable) - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
-
Allows statistics logging of source along with parser statistics logging
- setsRowtime - Variable in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
- setStartupPositionKey(Object[]) - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Initialize the startup position key.
- setString(String, int, int) - Method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
Initialize with a string of source digits.
- setString(int, CharSequence) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setStringColumn(byte[], int, int, RowInserter, int, Charset, boolean) - Static method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Stuff a byte array into a string column in the target stream.
- setTime(int, Time) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setTimestamp(int, long) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- setTreatEmptyStringAsNull(boolean) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.AbstractFieldParser
-
- setTreatEmptyStringAsNull(boolean) - Method in interface com.sqlstream.aspen.namespace.common.TypeParser
-
Change whether empty strings should be treated as null.
- setUdxExitWithoutWait(boolean) - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
-
- setUdxExitWithoutWait(boolean) - Method in interface com.sqlstream.jdbc.StreamingPreparedStatement
-
- setUtf8(int, byte[], int, int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
Returns true if the data was truncated into to fit a datum
- ShortParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
-
- shouldDiscardBadRows() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Return true if errors cause us to discard rows and log them
to the global error stream.
- SimpleSourceDataHandler(RowInserter) - Constructor for class com.sqlstream.aspen.namespace.common.BuffersInputStream.SimpleSourceDataHandler
-
- SINGLE_QUOTE - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
- singleDatumPerWorkUnit - Variable in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
- SINK_SUFFIX - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
-
- size() - Method in class com.sqlstream.aspen.namespace.common.FreeQueue
-
- size - Variable in class com.sqlstream.aspen.namespace.common.SourceData
-
- skip(int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
- SKIP_ROW_PAYLOAD - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- skipCurrentMessage() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Skip to the start of a message.
- SORT_BY_TIMESTAMP - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- SOURCE_SUFFIX - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
-
- sourceColumn - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx.ColumnTransferInfo
-
- SourceData - Class in com.sqlstream.aspen.namespace.common
-
- SourceData(SourceDataFactory<?>, int[]) - Constructor for class com.sqlstream.aspen.namespace.common.SourceData
-
Construct a SourceData.
- SourceData() - Constructor for class com.sqlstream.aspen.namespace.common.SourceData
-
Construct an unmanaged SourceData.
- SourceData.Handler - Interface in com.sqlstream.aspen.namespace.common
-
Handler for SourceDatas.
- SourceDataFactory<T extends SourceData> - Class in com.sqlstream.aspen.namespace.common
-
Factory for subclasses of SourceData.
- SourceDataFactory(String[], EcdaReaderContext, int, int, boolean) - Constructor for class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Create new Factory.
- SourceDataFactory(String[], EcdaReaderContext, int) - Constructor for class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Create new Factory.
- SourceDataFactory(String[], EcdaReaderContext, int, int, int, boolean, boolean) - Constructor for class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Create new Factory.
- SourceWorkUnit<T extends SourceData> - Class in com.sqlstream.aspen.namespace.common
-
- SPECIAL_COLUMNS - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- specialFormatterFor(String, int, int) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
-
- SQL_LITERAL_OVERHEAD - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
-
- SQLSTREAM_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- start - Variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
-
- start(boolean) - Method in interface com.sqlstream.aspen.namespace.common.DataInputParser
-
Start the parser
- start() - Method in interface com.sqlstream.aspen.namespace.common.DataInputSource
-
Starts the source.
- STARTING_OUTPUT_ROWTIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- STARTING_POSITION - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- STARTING_TIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- startRecording(ByteRecorder) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
Start recording bytes into the indicated byte recorder.
- startupPositionKey - Variable in class com.sqlstream.aspen.namespace.common.SourceDataFactory
-
Position at which to start reading the source data
- STATIC_FILES - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- stop() - Method in interface com.sqlstream.aspen.namespace.common.DataFactory
-
- StreamingPreparedStatement - Interface in com.sqlstream.jdbc
-
Aspen streaming prepared statement interface.
- StreamingResultSet - Interface in com.sqlstream.jdbc
-
- StreamingResultSet.RowEvent - Enum in com.sqlstream.jdbc
-
- StreamingStatement - Interface in com.sqlstream.jdbc
-
SQLstream streaming statement interface.
- String8859ToUtf8Parser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
-
- STRING_PROVENANCE_COLUMNS - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Provenance columns shared by all SQLstream-supplied string parsers
- StringAsciiToUtf8Parser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
-
- stringDataRightTruncation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Create a "string data, right truncation" SQLException
- StringMatchingCharsetParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.StringMatchingCharsetParser
-
- StringOptionParameter() - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.StringOptionParameter
-
- StringOptionParameter(String) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.StringOptionParameter
-
- StringParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.StringParser
-
- submit() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
-
Submit the buffer returned by getCurrent.
- submit(RowInserter) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- submit() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- submit() - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
-
- submitRow(Logger) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- take() - Method in class com.sqlstream.aspen.namespace.common.FreeQueue
-
Takes the from queue.
- tcpListenEnableSSL - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.sdp.tcpListenEnableSSL" optionally enables SSL
- tcpTrustAllSSL - Variable in class com.sqlstream.aspen.core.AspenProperties
-
- tempDir - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.tmp.dir" property holds the name of the directory
under the server home that contains temporary files.
- tempTraceDir - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.tmp.trace.dir" property holds the name of the directory
under the general temp directory specifically meant to hold slices of
trace logs intended to be shipped across the network.
- testAll - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.all" property controls
whether to run all regression tests, ignoring any other filters.
- testingPort - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.test.port" sets the base port for network TCP/SDP
tests.
- testName - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.test.Name" is a pattern for
which regression tests to run.
- testNoisy - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.noisy" property controls
whether to run "noisy" tests, where timestamped entries identifying
each test method are written to the trace log before and after each
individual method is executed.
- testNoisyStdEcho - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.noisy.stdecho" property controls
whether to echo "noisy" test annotations to stdout and stderr.
- testNoisyTimeout - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.noisy.timeout" property controls how many minutes
NoisySuite's watchdog timer waits before deciding the tests have hung.
- testNumRows - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.test.numrows" controls some unit tests: it sets the
scale of the test, by setting the number or rows read or written.
- testReferenceDir - Variable in class com.sqlstream.aspen.core.AspenProperties
-
- testScriptsOnly - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.scripts.only" property controls
whether to run all the unit test or only UnitSql scripts
The default is "false", run all unit tests.
- testStress - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The "aspen.test.stress" property controls
whether to run stress tests (while still honoring other filters).
- TIMEOUT_NO_WAIT - Static variable in interface com.sqlstream.jdbc.StreamingStatement
-
Timeout interval for no-wait polling.
- TimeoutException - Exception in com.sqlstream.jdbc
-
TimeoutException is thrown when a JDBC operation
has exceeded a timeout limit.
- TimeoutException() - Constructor for exception com.sqlstream.jdbc.TimeoutException
-
Creates default timeout exception.
- TimeoutException(long) - Constructor for exception com.sqlstream.jdbc.TimeoutException
-
Creates timeout exception with reason string that includes
the timeout interval that caused the timeout condition.
- TimeParser(String) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.TimeParser
-
- TimestampParser(String) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.TimestampParser
-
- toString() - Method in exception com.sqlstream.jdbc.TimeoutException
-
- toURL(String) - Static method in class com.sqlstream.aspen.core.AspenUtil
-
Converts a valid URL string to a URL.
- TOY_HASH_BUCKETS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TOY_HASH_COLUMNS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TOY_PARTITION_COLUMNS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TOY_VERBOSE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- traceFine - Variable in class com.sqlstream.aspen.namespace.common.LogLevel
-
- traceFiner - Variable in class com.sqlstream.aspen.namespace.common.LogLevel
-
- traceFinest - Variable in class com.sqlstream.aspen.namespace.common.LogLevel
-
- tracePropertyListener() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
Get the trace configuration.
- tracer - Static variable in class com.sqlstream.aspen.core.AspenUtil
-
- tracer - Static variable in class com.sqlstream.aspen.core.RuntimeObjectFactory
-
- tracer - Static variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream
-
- tracer - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
-
- tracer - Variable in class com.sqlstream.aspen.namespace.common.LogLevel
-
Tracing / logging facility.
- tracer - Static variable in class com.sqlstream.aspen.namespace.common.OptionsUtils
-
Tracing / logging facility.
- tracer - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
-
Tracing / logging facility.
- traceSampleFailedRows - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.trace.sampleFailedRows" tells fennel how to report
input rows that cause a Calculator errow.
- traceSampleLateRows - Variable in class com.sqlstream.aspen.core.AspenProperties
-
The property "aspen.trace.sampleLateRows" tells fennel how to report late
input rows.
- transferColumns(ResultSet, Object[], PreparedStatement, Map<String, int[]>) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
-
Deprecated.
- transferColumns(ResultSet, Object[], PreparedStatement, AbstractBaseUdx.ColumnTransferInfo[]) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
-
Transfers column data from input ResultSet
to output ("results") PreparedStatement
using specified column transfer map.
- transferColumns(ResultSet, PreparedStatement, AbstractBaseUdx.ColumnTransferInfo[]) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
-
- treatingEmptyStringsAsNull() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.AbstractFieldParser
-
- treatingEmptyStringsAsNull() - Method in interface com.sqlstream.aspen.namespace.common.TypeParser
-
Return true if empty strings should be treated as nulls
- trueBytes - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
-
- type - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx.ColumnTransferInfo
-
- TYPE_AVRO - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_CSV - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_DISCOVERY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_FAST_REGEX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_FCLP - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_JSON - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_KEY_VALUE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_MULTIROW - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_NONE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_ORC - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_PROTOBUF - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_TOY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_VCLP - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_W3C - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TYPE_XML - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
-
- TypeFormatter - Interface in com.sqlstream.aspen.namespace.common
-
- TypeFormatterFactory - Interface in com.sqlstream.aspen.namespace.common
-
- TypeParser - Interface in com.sqlstream.aspen.namespace.common
-
A generic typesafe parser for individual columns
- TypeParserFactory - Interface in com.sqlstream.aspen.namespace.common
-
- typeParsers - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
-