Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W Z _ 

A

AbstractBaseUdx - Class in com.sqlstream.plugin.impl
Abstract base class for UDX.
AbstractBaseUdx(Logger, ResultSet, PreparedStatement) - Constructor for class com.sqlstream.plugin.impl.AbstractBaseUdx
Creates a new AbstractBaseUdx.
AbstractBaseUdx.ColumnTransferInfo - Class in com.sqlstream.plugin.impl
 
AbstractDataInputSource - Class in com.sqlstream.aspen.namespace.common
 
AbstractDataInputSource() - Constructor for class com.sqlstream.aspen.namespace.common.AbstractDataInputSource
 
AbstractFieldParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.AbstractFieldParser
 
acceptFPs - Variable in class com.sqlstream.aspen.core.AspenProperties
With SSL, accept the client certificates with matching fingerprint, reject connection otherwise Comma separated list of SHA1 fingerprints
acceptsURL(String) - Method in class com.sqlstream.jdbc.Driver
Indicate whether the specified URL is understood by this driver.
addBuffer(SourceWorkUnit<SourceData>) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Add a SourceData to queue for reading.
addDynamicOptions(Properties, Connection) - Static method in class com.sqlstream.aspen.namespace.common.OptionsUtils
Adds options from a query to list of options.
addFooter(DataOutputSink) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputFormatter
Called when a sink needs special formatting at the end of a batch or rows,
addHeader(DataOutputSink) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputFormatter
Called when a sink needs special formatting at the beginning of a batch or rows,
addParserInfoHandlers(ArrayList<CommonRowParser.ColumnUpdater>) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
addRowtimeBound(Timestamp) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Add a rowtime bound to stream.
addTracePropertyListener(FarragoTrace.PropertyListener) - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
Add an object which listens for changes to the file of trace properties.
aggregateMaximumDeadBucketRatio - Variable in class com.sqlstream.aspen.core.AspenProperties
The property aspen.aggregate.maximumDeadBucketRatio controls when the streaming aggregate xo will clear its hashmap instead of marking aggrtegate buckets dead.
aggregateUseResultBuffering - Variable in class com.sqlstream.aspen.core.AspenProperties
The property aspen.aggregate.useResultBuffering controls when when the streaming aggregate xos will buffer their results so that they can start processing input before downstream xos have processed it's output.
AspenClientTrace - Class in com.sqlstream.aspen.trace
Contains all of the tracers used within Aspen's client-side components, e.g.
AspenClientTrace() - Constructor for class com.sqlstream.aspen.trace.AspenClientTrace
 
AspenProperties - Class in com.sqlstream.aspen.core
Provides the properties which determine the behavior of an Aspen instance.
AspenTrace - Class in com.sqlstream.aspen.trace
Contains all of the tracers used within Aspen's server side components.
AspenTrace() - Constructor for class com.sqlstream.aspen.trace.AspenTrace
 
AspenTraceTail - Class in com.sqlstream.aspen.trace
AspenTraceTail provides a fixed-maximum-length "tail" of the main trace log.
AspenTraceTail() - Constructor for class com.sqlstream.aspen.trace.AspenTraceTail
 
AspenUtil - Class in com.sqlstream.aspen.core
Collection of utility functions.
AspenUtil.StringHandler - Interface in com.sqlstream.aspen.core
 
asString() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
 
asString(int, int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
Returns a part of the line as a string for debugging.
AUTH_KEYTAB - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
AUTH_METASTORE_PRINCIPAL - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
AUTH_METHOD - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
AUTH_USERNAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
available() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Guaranteed to not return more bytes than that left in the current message - or the next on-empty message if the current one is already exhausted.
available() - Method in class com.sqlstream.aspen.namespace.common.FreeQueue
 

B

badCastFromChar(String) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Wrap an error in a "bad cast" SQLException.
BINARY_PROVENANCE_COLUMNS - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
Provenance columns shared by all SQLstream-supplied binary parsers
BinaryParser(int, int) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.BinaryParser
 
blessedPluginNames - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.test.plugin.names" property specifies a comma-separated list of case-sensitive plugin names that are "blessed" to be preserved across AspenTestCase setup and teardown.
blessedSchemaNames - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.test.schema.names" property specifies a comma-separated list of case-sensitive schema names that are "blessed" to be preserved across AspenTestCase setup and teardown.
BooleanParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
 
BooleanParser(String) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
 
buffer - Variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
 
buffer - Variable in class com.sqlstream.aspen.namespace.common.SourceData
 
buffersAvailable() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Get number of buffers available for reading
BuffersInputStream - Class in com.sqlstream.aspen.namespace.common
A queue of ByteBuffers, with interfaces to read as a stream of bytes or as a stream of lines.
BuffersInputStream() - Constructor for class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
BuffersInputStream(SourceDataFactory<?>) - Constructor for class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
BuffersInputStream.Connection<T extends SourceData> - Class in com.sqlstream.aspen.namespace.common
Maintains state for writers to this BuffersInputStream.
BuffersInputStream.Line - Class in com.sqlstream.aspen.namespace.common
To avoid making objects, represent an input line as a range in a byte array, and not as a String or a byte[].
BuffersInputStream.SimpleSourceDataHandler - Class in com.sqlstream.aspen.namespace.common
Simple handler for SourceDatas.
BYTE_MASK - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
byte_to_hexits(byte, CharBuffer) - Static method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
Convert a byte into two hex digits
ByteParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
 

C

CACHE_IDX - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
cacheColumn - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx.ColumnTransferInfo
 
CachedLocationDescription() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.CachedLocationDescription
 
CApath - Variable in class com.sqlstream.aspen.core.AspenProperties
With SSL, Certificate verification path, usually /etc/ssl/certs/
CaseInsensitiveEnumOptionParameter() - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.CaseInsensitiveEnumOptionParameter
 
CaseInsensitiveEnumOptionParameter(List<String>) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.CaseInsensitiveEnumOptionParameter
 
CaseInsensitiveEnumOptionParameter(List<String>, String) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.CaseInsensitiveEnumOptionParameter
 
catalogDir - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.catalog.directory" property holds the name of the directory which contains the Aspen repository file.
catalogFile - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.catalog.file" property holds the basename of the Aspen repository file.
char_to_hexits(char, CharBuffer) - Static method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
Convert a character into four hex digits
charset - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
charset() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
Return the character encoding of the watermark column
charset() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
 
charset() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
 
checkAndEnrichOptionsList(Map<String, String>, Map<String, OptionsUtils.OptionParameter>, boolean) - Static method in class com.sqlstream.aspen.namespace.common.OptionsUtils
 
checkDbConnectMap(Map<String, String>) - Static method in class com.sqlstream.aspen.namespace.common.OptionsUtils
 
checkValue(String) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.CaseInsensitiveEnumOptionParameter
 
checkValue(String) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
checkValue(String) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
checkValue(String) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
checkValue(String) - Method in interface com.sqlstream.aspen.namespace.common.OptionsUtils.OptionParameter
 
checkValue(String) - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.StringOptionParameter
 
clearParameter(int) - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
 
close() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
close() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
 
close() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputFormatter
Close the formatter, printing any footer information to the buffer and freeing all resources.
close() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Closes the sinks resources and frees memory.
close() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
Close context.
close() - Method in class com.sqlstream.aspen.namespace.common.FreeQueue
Close queue and cause any takers to wake up and return null.
close() - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
 
close() - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
 
close() - Method in class com.sqlstream.plugin.PairedUdxWriter.OutputHolder
 
closeAllocation() - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
Closes this object.
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BinaryParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DoubleParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.FloatParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IsoTimestampParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.LongParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ScientificNotationLongParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringMatchingCharsetParser
 
closeAllocation() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringParser
 
clusterAutojoin - Variable in class com.sqlstream.aspen.core.AspenProperties
Determines if RMPs automagically join the cluster upon startup or if they must be added via DDL after startup.
clusterIdentifier - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.cluster.uuid" is the cluster's unique identifier.
COL_IDX - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
COL_INFO_ENTRY_LEN - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
COL_MAP_ENTRY_LEN - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
COL_TYPE - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
colMap - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
UDX output column info.
COLUMN_MAPPING_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
COLUMN_QUOTE_CHARACTER - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
columnMapFor(Map<String, int[]>) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
columnMaps - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
columnName - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx.ColumnTransferInfo
 
columnNumbers - Variable in class com.sqlstream.aspen.namespace.common.SourceData
 
columnNumbers - Variable in class com.sqlstream.aspen.namespace.common.SourceDataFactory
Column numbers to pass when creating new SourceDatas.
columnsToReset - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
columnsToReset - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.CommonSourceDataHandler
 
com.sqlstream.aspen.core - package com.sqlstream.aspen.core
 
com.sqlstream.aspen.namespace.common - package com.sqlstream.aspen.namespace.common
 
com.sqlstream.aspen.trace - package com.sqlstream.aspen.trace
Defines Aspen trace loggers and levels.
com.sqlstream.jdbc - package com.sqlstream.jdbc
Provides SQLstream JDBC driver and public SQLstream extensions to the standard JDBC interface.
com.sqlstream.plugin - package com.sqlstream.plugin
 
com.sqlstream.plugin.impl - package com.sqlstream.plugin.impl
 
CommonDataConstants - Interface in com.sqlstream.aspen.namespace.common
 
CommonRowParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser
 
CommonRowParser.AbstractFieldParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.BinaryParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.BooleanParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.ByteParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.CachedLocationDescription - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.ColumnUpdater - Interface in com.sqlstream.aspen.namespace.common
 
CommonRowParser.CommonSourceDataHandler - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.DateParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.DecimalNumber - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.DecimalParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.DiscardInfo - Class in com.sqlstream.aspen.namespace.common
Holds error information for rows which are to be discarded and logged to the global error stream.
CommonRowParser.DoubleParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.FloatParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.IntParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.IsoTimestampParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.LongParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.PositionParser - Class in com.sqlstream.aspen.namespace.common
Special type parser for creating strings which encode the position of the source stream.
CommonRowParser.QuotedParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.ScientificNotationLongParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.ShortParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.String8859ToUtf8Parser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.StringAsciiToUtf8Parser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.StringMatchingCharsetParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.StringParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.TimeParser - Class in com.sqlstream.aspen.namespace.common
 
CommonRowParser.TimestampParser - Class in com.sqlstream.aspen.namespace.common
 
CommonSourceDataHandler(RowInserter, int[]) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.CommonSourceDataHandler
 
compareBytes(byte[], int, byte[], int, int) - Static method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
CONFIG_PATH - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
configUrl - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.config.url" property holds the URL of a properties file loaded at boot time.
connect(String, Properties) - Method in class com.sqlstream.jdbc.Driver
 
Connection() - Constructor for class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
 
connectionClosed(Object) - Method in class com.sqlstream.jdbc.Driver
 
context - Variable in class com.sqlstream.aspen.namespace.common.AbstractDataInputSource
 
context - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
countFileCloses() - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
countFileOpens() - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
createAndSetLogFileDirectory(String, String) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
Create a directory to hold log files generated by 3rd party software bundled inside a plugin.
createColumnTransferMap(ResultSetMetaData, String) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
Creates a column transfer map which identifies like-named columns in the specified input ResultSet and the UDX output PreparedStatement whose data is to be copied from input to output.
createColumnTransferMap(Map<String, int[]>, ResultSetMetaData, String) - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
Creates a column transfer map which identifies like-named columns in the specified input ResultSet and the specified output column map whose data is to be copied from input to output.
createDataSource() - Method in interface com.sqlstream.aspen.namespace.common.DataFactory
Request a new DataInputSource
createPassMap() - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
Creates pass-through column map.
customParsers - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
customPropertiesUrl - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.custom.properties.url" property holds the URL of a custom properties file also loaded at boot time.

D

DataFactory - Interface in com.sqlstream.aspen.namespace.common
Used by plugins that need lifecycle support.
DataFactoryPlugin - Interface in com.sqlstream.aspen.namespace.common
Interface for plugins that need lifecycle support.
DataInputParser - Interface in com.sqlstream.aspen.namespace.common
Parser interface.
DataInputSource - Interface in com.sqlstream.aspen.namespace.common
I/O Source interface for common data adapters.
DataOutputBatchSink - Interface in com.sqlstream.aspen.namespace.common
Extends DataOutputSink for delayed writes of batches of rows.
DataOutputBatchSink.FreeBufferCallback - Interface in com.sqlstream.aspen.namespace.common
 
DataOutputBinaryFormatter - Interface in com.sqlstream.aspen.namespace.common
The interface for binary data formatters.
DataOutputCharFormatter - Interface in com.sqlstream.aspen.namespace.common
The interface for binary data formatters.
DataOutputColumnFormatter - Interface in com.sqlstream.aspen.namespace.common
The interface for column-store data formatters.
DataOutputColumnSink - Interface in com.sqlstream.aspen.namespace.common
Extends DataOutputSink for writing to a partitioned columnar store.
DataOutputColumnSink.BucketFileCallbacks - Interface in com.sqlstream.aspen.namespace.common
A trio of callbacks for the start and finish of bucket files.
DataOutputFormatter - Interface in com.sqlstream.aspen.namespace.common
The interface for generic data formatters.
DataOutputRowSink - Interface in com.sqlstream.aspen.namespace.common
Extends DataOutputSink for writing one row at a time.
DataOutputSink - Interface in com.sqlstream.aspen.namespace.common
Base interface for ECDA output sinks, which write formatted data to various I/O mechanisms (files, network sockets, etc).
DateParser(String) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
DecimalNumber() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
 
DecimalParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
 
DEFAULT_HOST - Static variable in class com.sqlstream.jdbc.Driver
 
DEFAULT_PARSER_QUEUE_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
defaultValue - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
defaultValue() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
defaultValue - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
defaultValue() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
defaultValue - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
defaultValue() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
defaultValue() - Method in interface com.sqlstream.aspen.namespace.common.OptionsUtils.OptionParameter
 
defaultValue - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.StringOptionParameter
 
defaultValue() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.StringOptionParameter
 
definePartitions(String[], int) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink
Sets the partition scheme used by subsequent writes.
destColumn - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx.ColumnTransferInfo
 
devMode - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.dev.mode" allows the control node to either behave normally or in development mode.
DISALLOW_QUOTED_ROW_SEPARATOR - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
DISCARD_ROW_ON_PARSE_ERROR_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
discardCurrentRow(Logger) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Discard the current row, writing error information to the trace log and the global error stream.
DiscardInfo() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
 
discardRow(Logger, String, String, String, byte[], Throwable) - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
Discard a newly ingested row and log this action to the global error stream.
doubleBase - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
 
DoubleOptionParameter() - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
DoubleOptionParameter(double) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
DoubleOptionParameter(double, double) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
DoubleOptionParameter(double, double, double) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
DoubleParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.DoubleParser
 
Driver - Class in com.sqlstream.jdbc
Implements the SQLstream client side of the Driver interface.
Driver() - Constructor for class com.sqlstream.jdbc.Driver
Creates a new Client Driver object.

E

ECDA_SESSION_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
EcdaContext - Interface in com.sqlstream.aspen.namespace.common
 
EcdaContext.Phase - Enum in com.sqlstream.aspen.namespace.common
 
EcdaPluginFactory - Class in com.sqlstream.aspen.namespace.common
 
EcdaPluginFactory() - Constructor for class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
EcdaPluginFactory.PluginType - Enum in com.sqlstream.aspen.namespace.common
 
EcdaReaderContext - Interface in com.sqlstream.aspen.namespace.common
 
EcdaWriterContext - Interface in com.sqlstream.aspen.namespace.common
 
enableEosAtMessageEnd() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Request eos at end of every message.
enableImplicitRowtime() - Method in interface com.sqlstream.jdbc.StreamingPreparedStatement
Causes rowtime to be set automatically.
encodeHexits(byte[], byte[], int, int, int) - Static method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
Convert a byte array to hex digits.
end - Variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
 
ENGINE_URL_PREFIX - Static variable in class com.sqlstream.jdbc.Driver
 
EnumOptionParameter() - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
EnumOptionParameter(List<String>) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
EnumOptionParameter(List<String>, String) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
ERRMSG_CONTROL_NODE_SDP - Static variable in class com.sqlstream.jdbc.Driver
 
ERRMSG_INVALID_URI - Static variable in class com.sqlstream.jdbc.Driver
 
ERRMSG_REASON_NOHOST_FOUND - Static variable in class com.sqlstream.jdbc.Driver
 
expandProperties(String) - Method in class com.sqlstream.aspen.core.AspenProperties
Expands property tokens in a string, replacing them with property values, if defined.
exponent - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
 
exportScopeAsString() - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 

F

FACTORY_PLUGIN_SUFFIX - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
failOnTooFewRmps - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.node.redundancy.fail" tells Aspen if to fail to plan queries when there are not enough RMPs to meet redundancy requirements
FAST_COPY_IDX - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
FILE_COMPRESSION - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_COMPRESSION_BUFFER - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_ROTATION_RESPECT_ROWTIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_ROTATION_ROWCOUNT - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_ROTATION_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_ROTATION_TIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_ROTATION_WATERMARK_COLUMN - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILE_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
fileCloses - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
FILENAME_DATE_FORMAT - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILENAME_PATTERN - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILENAME_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FILENAME_SUFFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
fileOpens - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
filterInitProperties(Properties, String[], String[], Properties) - Static method in class com.sqlstream.aspen.namespace.common.OptionsUtils
Filter a list of properties.
filterInitProperties(Properties, String[], String[]) - Static method in class com.sqlstream.aspen.namespace.common.OptionsUtils
filterRow(Object[]) - Method in interface com.sqlstream.aspen.namespace.common.RowFilter
Check whether to send this row to the server.
findBytes(int, byte[]) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
Find the next occurrence of s in the line.
findBytes(int, int, byte[]) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
Find the next occurrence of s in the line.
FloatParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.FloatParser
 
flush() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
Flush any submitted data for this work unit.
flush() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Flushes out data to its source, preparing for a close or just freeing up some buffers.
flush() - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
 
flush() - Method in interface com.sqlstream.jdbc.StreamingPreparedStatement
Flushes all rows to stream.
flush() - Method in interface com.sqlstream.jdbc.StreamingStatement
Flushes any rows in current buffers on a best effort basis.
format - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
format(ResultSet) - Method in interface com.sqlstream.aspen.namespace.common.TypeFormatter
Formats a piece of data to the provided byte array at the specific location.
FORMAT_CHARSET_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FORMAT_TYPE_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FORMAT_WRITE_HEADER_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
formatRow(ResultSet, ByteBuffer) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputBinaryFormatter
Formats one row from a result set to a byte buffer, if it fits.
formatRow(ResultSet) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputCharFormatter
Formats one row from a result set that has already confirmed the presence of a row using rs.next() to byte buffer
formatRow(ResultSet, DataOutputColumnSink) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnFormatter
Reads the current row from a result set, and formats it to a columnar store.
FORMATTER_CLASSNAME_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FORMATTER_INCLUDE_ROWTIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FORMATTER_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
FORMATTER_SUFFIX - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
FORMATTER_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
freeBuffer() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputBatchSink.FreeBufferCallback
 
freeBuffer(SourceWorkUnit<?>) - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
Return a SourceData to free queue.
FreeQueue<T> - Class in com.sqlstream.aspen.namespace.common
Implements a fair free list that's much faster than a BlockingArrayQueue when there are many takers.
FreeQueue(int) - Constructor for class com.sqlstream.aspen.namespace.common.FreeQueue
 
freeWorkUnits - Variable in class com.sqlstream.aspen.namespace.common.SourceDataFactory
 

G

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
Returns the query timeout value of this statement, in milliseconds, as set by StreamingStatement.setQueryTimeoutMillis(long).
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.

H

hasAvailable(int) - Method in class com.sqlstream.aspen.namespace.common.SourceWorkUnit
 
hasAvailableBuffer() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
Check if there is a SourceData available without waiting.
hasAvailableBuffer() - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
Check if there is a SourceData available without waiting.
hasError() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
Return true if an error has already been set for this row
hasUnflushedData() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
Is there any data to flush?
HDFS_LOG_DIRECTORY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HDFS_OUTPUT_DIR - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HDFS_POLLING_INTERVAL - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HDFS_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HexToBinaryConverter - Class in com.sqlstream.aspen.namespace.common
Machine to convert hex digits (either char or byte) to byte arrays.
HexToBinaryConverter() - Constructor for class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
HexToBinaryConverter.Gbfhd_tuple - Class in com.sqlstream.aspen.namespace.common
For return results from getBytesFromHexDigits()
HIGH_BYTE - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
HIGH_BYTE_MASK - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
highwaterMark - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
HIVE_METASTORE_URIS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_PARTITION_NAME_FORMAT_SUFFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_SCHEMA_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_SKIP_MSCK - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_TABLE_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_TABLE_OPTIONS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_TEMPLATE_SCHEMA_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_TEMPLATE_TABLE_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
HIVE_URI - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 

I

importScopeFromString(String, Function<Properties, Properties>) - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 
IN_IDX - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
incParserLineNumber() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
init(Properties) - Method in interface com.sqlstream.aspen.core.RuntimeObject
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BinaryParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DoubleParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.FloatParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Initializes this formatter and throws an exception if something is underspecified
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IsoTimestampParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.LongParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ScientificNotationLongParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringMatchingCharsetParser
 
init(Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringParser
 
init(Properties) - Method in interface com.sqlstream.aspen.namespace.common.RowFilter
Initialize this filter.
initDefaultTypeParsers(Properties, Properties) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
initProps - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
inputRows - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
inputStmt - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
inputStream - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
insertDate(RowInserter, int, long) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
insertDate(RowInserter, int, long) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.TimeParser
 
insertDate(RowInserter, int, long) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.TimestampParser
 
inserter - Variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream.SimpleSourceDataHandler
 
inserter - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.CommonSourceDataHandler
 
installAwsaccount_id - Variable in class com.sqlstream.aspen.core.AspenProperties
The AWS installer/setup prompts and fills field.
installCompany - Variable in class com.sqlstream.aspen.core.AspenProperties
The installer prompts and fills this field.
installEmail - Variable in class com.sqlstream.aspen.core.AspenProperties
The installer prompts and fills field.
installFactoryPlugin(String, Class<? extends DataFactoryPlugin>) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
installFormatter(String, Class<? extends DataOutputFormatter>) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
installParser(String, Class<? extends DataInputParser>) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
installPlugin(EcdaPluginFactory.PluginType, String, Class<? extends RuntimeObject<?>>) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
installPlugins() - Method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
installSink(String, Class<? extends DataOutputSink>) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
installSource(String, Class<? extends DataInputSource>) - Static method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
instance() - Static method in class com.sqlstream.aspen.core.AspenProperties
Returns the singleton instance.
INTERNAL_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
interpolate(String) - Method in class com.sqlstream.aspen.core.AspenProperties
 
inToolContext - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.tool" indicates to aspen components that they are running as part of a tool, not as part of an aspen server.
IntOptionParameter() - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
IntOptionParameter(int) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
IntOptionParameter(int, int) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
IntOptionParameter(int, int, int) - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
IntParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
 
invalidCharacterInNumber(char, byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Wrap an error in a "invalid character in number" SQLException.
invalidCharacterInTimestamp() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Generate a SQLException for invalid character in timestamp.
invalidDateTime(Throwable) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Generate a SQLException for an invalid date/time/timestamp.
invalidDateTime(String, Throwable) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Generate a SQLException for an invalid date/time/timestamp.
IS_IPV6_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
IS_TCP_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
isAtEos() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Is this stream at eos (but perhaps resettable)
isBlocked() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Is a read blocked waiting for buffer.
isClosed() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Is this stream closed.
isClosed() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
Has context been closed.
isClosed() - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
 
isDisallowRowSeparatorwithinQuotes() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
isEmpty() - Method in class com.sqlstream.aspen.namespace.common.FreeQueue
 
isEndOfMessage() - Method in class com.sqlstream.aspen.namespace.common.SourceData
Is this the known end of a message? Override for sources that return messages using more than one buffer.
isLittleEndian(ExtendedParameterMetaData, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Return true if the parameter's charset is little endian.
isOpen() - Method in class com.sqlstream.plugin.PairedUdxWriter.OutputHolder
 
IsoTimestampParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.IsoTimestampParser
 
isProjected - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
isRegistered(String, Class<? extends RuntimeObject<?>>) - Static method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 
isRequired() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
isRequired() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
isRequired() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
isRequired() - Method in interface com.sqlstream.aspen.namespace.common.OptionsUtils.OptionParameter
 
isRequired() - Method in class com.sqlstream.aspen.namespace.common.OptionsUtils.StringOptionParameter
 
isRowtimePresent() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
Is ROWTIME present.
isStartOfMessage() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Return true if the current payload is the start of a message.
isStartOfMessage() - Method in class com.sqlstream.aspen.namespace.common.SourceData
Is this the start of a new message? Override for sources that return messages using more than one buffer.
isTraceFine() - Method in class com.sqlstream.aspen.namespace.common.LogLevel
 
isTraceFiner() - Method in class com.sqlstream.aspen.namespace.common.LogLevel
 
isTraceFinest() - Method in class com.sqlstream.aspen.namespace.common.LogLevel
 
isValidIpAddress(String) - Static method in class com.sqlstream.aspen.core.AspenUtil
Returns whether a string is of the right format for an IPv4 or IPv6 address.

J

JDBC_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
jdbcCompliant() - Method in class com.sqlstream.jdbc.Driver
 
jdbcDriverName - Variable in class com.sqlstream.aspen.core.AspenProperties
Name of JDBC driver as reported by java.sql.DatabaseMetaData.
jdbcDrivers - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.test.jdbc.drivers" property holds a comma-separated list of class names to be used as JDBC drivers.
jdbcDriverVersionMajor - Variable in class com.sqlstream.aspen.core.AspenProperties
Major version of driver as reported by java.sql.DatabaseMetaData.
jdbcDriverVersionMinor - Variable in class com.sqlstream.aspen.core.AspenProperties
Minor version of driver as reported by java.sql.DatabaseMetaData.
jdbcStressColsPerQuery - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.test.jdbc.stress.colsPerQuery" property specifies the maximum number of columns per query during JDBC driver stress tests.
jdbcStressStmtsPerConn - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.test.jdbc.stress.stmtsPerConn" property specifies the maximum number of simultaneously open statements per connection during JDBC driver stress tests.

K

KERBEROS_OPTIONS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
KERBEROS_SECURITY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
keyPassword - Variable in class com.sqlstream.aspen.core.AspenProperties
With SSL on, use this password to open up the key file.

L

length() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Line
Length of line in bytes
lineNo - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
locationDescription() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Get locationDescription of current SourceData.
locationDescription() - Method in class com.sqlstream.aspen.namespace.common.SourceData
Should give a description of the source that this buffer comes from.
logLevel - Static variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
logLevel - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
LogLevel - Class in com.sqlstream.aspen.namespace.common
 
LogLevel() - Constructor for class com.sqlstream.aspen.namespace.common.LogLevel
 
LogLevel(String) - Constructor for class com.sqlstream.aspen.namespace.common.LogLevel
 
logStringTruncation(int, byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Log a string truncation warning.
logThrowable(Logger, String, Throwable, SqlStateCodes, Level, boolean) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Log an error.
logUnparsableBytes() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Return true if we should log an error for gibberish columns, but still fill in a row.
logUnparsableBytes(Logger, String, Throwable, int, byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Log an ingestion error, including the gibberish bytes which could not be parsed.
LongParser() - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.LongParser
 
LOW_BYTE - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
LOW_BYTE_MASK - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
LOWER_A - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
LOWER_BYTE_MASK - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
LOWER_F - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
LOWER_X - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 

M

makeFieldDescriptor(String, int, int, int, boolean) - Static method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Make a field descriptor from the passed-in fields
mapSpecialColumn(String) - Method in interface com.sqlstream.aspen.namespace.common.EcdaReaderContext
Maps column name to output row.
mark(int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
markForDiscarding(String, String, Throwable) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Mark this row to be discarded, setting the SQLState and error message which will be logged along with the current payload.
markSupported() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
max - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
max - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
MAX_LOGGED_PAYLOAD - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
MAX_PUNCT_TIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
maximumStreamSize - Variable in class com.sqlstream.aspen.core.AspenProperties
The long property aspen.ddl.maximumRowSize is the maximum width that aspen streams can be declared as.
mdrImplementationType - Variable in class com.sqlstream.aspen.core.AspenProperties
The "org.eigenbase.enki.implementationType" property describes the engine used to hold metadata.
mdrModelExt - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.catalog.modelextname" property holds the model extension name of the Aspen model in the repository.
mdrPersistenceDir - Variable in class com.sqlstream.aspen.core.AspenProperties
The "org.netbeans.mdr.persistence.Dir" property holds the name of the directory where the Netbeans repository looks for a repository file.
MESSAGE_STREAM - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
messageStartPosition - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
metaData - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
min - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.DoubleOptionParameter
 
min - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.IntOptionParameter
 
MIN_PUNCT_TIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
mustDiscardThisRow() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Return true if we must discard the current row and log it to the global error stream.

N

namedOutput(String, PreparedStatement) - Static method in class com.sqlstream.plugin.PairedUdxWriter
 
needsFlushOnExit() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Tells if this sink needs to be flushed before a close or risk invalid data being written out.
needsOneRowPerWrite() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputBatchSink
 
needsOneRowPerWrite() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Tells if this sink needs to be passed one row for each write, or if rows can be buffered up.
nestedParser - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
newBufferInfo() - Method in class com.sqlstream.aspen.namespace.common.SourceDataFactory
Override to create the appropriate SourceData.
newInstance(String) - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 
newLine() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
newObject(String, Properties) - Method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 
newSimpleExtension() - Method in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
nextRowOrRowtime() - Method in interface com.sqlstream.jdbc.StreamingResultSet
Extension to ResultSet.next that returns when the next row or new rowtime bound arrives.
nextRowOrRowtime(long) - Method in interface com.sqlstream.jdbc.StreamingResultSet
Extension to ResultSet.next that returns when the next row or new rowtime bound arrives.
nexusDeadlockDetection - Variable in class com.sqlstream.aspen.core.AspenProperties
The property aspen.nexus.deadlockDetection controls whether runtime diamond detection is performed.
nexusMaximumBufferExpansion - Variable in class com.sqlstream.aspen.core.AspenProperties
The property aspen.nexus.maximumBufferExpansion controls how many buffers can be allocated when a nexus has one output in overflow and one in underflow.
NIBBLE_MASK - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
NINE - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
NO_COLUMN - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
nodeIdentifier - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.sdp.node.identifier" allows Aspen nodes to determine and persist their unique node identifier.
nodeRedundancy - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.node.redundancy" tells Aspen control nodes how many RMPs must crash before a distributed Aspen loses tuples.
notifyOnCancel(Runnable) - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
 
notifyUdxOnCancel(Runnable) - Method in interface com.sqlstream.jdbc.StreamingPreparedStatement
 
numColumns - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 

O

offer(T) - Method in class com.sqlstream.aspen.namespace.common.FreeQueue
 
onActivate() - Method in class com.sqlstream.aspen.namespace.common.AbstractDataInputSource
 
onActivate() - Method in interface com.sqlstream.aspen.namespace.common.DataInputSource
Called when the associated nexus is created.
onActivate() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Called when the associated nexus is created.
onCloseBucket(DataOutputColumnSink, File, PartitionName, int) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink.BucketFileCallbacks
 
onCloseTree(DataOutputColumnSink) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink.BucketFileCallbacks
 
onOpenBucket(DataOutputColumnSink, File, PartitionName, int) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputColumnSink.BucketFileCallbacks
 
onProtocolErrorThrowException - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.sdp.throwOnProtocolError" If true and protocol decoding becomes mis-synchronized, throw an exception.
open() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputFormatter
Called at run-time before sending any input rows to the formatter
open() - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Opens the new I/O mechanism.
OPTIONAL_PROPERTIES - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
OPTIONS_QUERY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
OptionsUtils - Class in com.sqlstream.aspen.namespace.common
 
OptionsUtils() - Constructor for class com.sqlstream.aspen.namespace.common.OptionsUtils
 
OptionsUtils.CaseInsensitiveEnumOptionParameter - Class in com.sqlstream.aspen.namespace.common
 
OptionsUtils.DoubleOptionParameter - Class in com.sqlstream.aspen.namespace.common
 
OptionsUtils.EnumOptionParameter - Class in com.sqlstream.aspen.namespace.common
 
OptionsUtils.IntOptionParameter - Class in com.sqlstream.aspen.namespace.common
 
OptionsUtils.OptionParameter - Interface in com.sqlstream.aspen.namespace.common
 
OptionsUtils.StringOptionParameter - Class in com.sqlstream.aspen.namespace.common
 
ORC_BATCH_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_BLOCK_PADDING - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_BLOCK_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_BLOOM_FILTER_COLUMNS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_BLOOM_FILTER_FPP - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_COMPRESS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_COMPRESS_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_DIRECT_ENCODING_COLUMNS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_OPTION_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_ROW_INDEX_STRIDE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_SORT_ORDER - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_STRIPE_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_USER_METADATA_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORC_VERSION - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ORIGINAL_FILENAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
OUT_IDX - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
OUT_TYPE - Static variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
overflowed - Variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter.Gbfhd_tuple
 

P

PairedUdxWriter - Class in com.sqlstream.plugin
 
PairedUdxWriter() - Constructor for class com.sqlstream.plugin.PairedUdxWriter
 
PairedUdxWriter.OutputHolder - Class in com.sqlstream.plugin
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BinaryParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BinaryParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.BooleanParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DoubleParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DoubleParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.FloatParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.FloatParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IsoTimestampParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.IsoTimestampParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.LongParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.LongParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ScientificNotationLongParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.String8859ToUtf8Parser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringAsciiToUtf8Parser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringMatchingCharsetParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringMatchingCharsetParser
 
parse(byte[], int, int, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringParser
 
parse(String, RowInserter, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.StringParser
 
parse(String, RowInserter, int) - Method in interface com.sqlstream.aspen.namespace.common.TypeParser
Parses a value directly from a string and puts it into the row inserter
parse(byte[], int, int, RowInserter, int) - Method in interface com.sqlstream.aspen.namespace.common.TypeParser
Parses a value from a range of a byte array, and applies it to the row inserer.
parseDateTime(byte[], int, int, int[]) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
parseDecimal(CommonRowParser.DecimalNumber, byte[], int, int, boolean) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
parseDouble(byte[], int, int, CommonRowParser.DecimalNumber) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
parseError - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
parseIsoValue(byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
Parse a date/time value.
parseIsoValue(byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.TimeParser
 
parseLong(byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
PARSER_CHARSET_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PARSER_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PARSER_QUEUE_SIZE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PARSER_SKIP_HEADER_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PARSER_SUFFIX - Static variable in class com.sqlstream.aspen.namespace.common.EcdaPluginFactory
 
PARSER_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
parserInfoHandlers - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
parserPosition - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
passList - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
passMap - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
Deprecated.
passThruColumns() - Method in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
PATH_SUFFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
pattern - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
peek() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
peek(int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
peekBuffer() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
performFastCopy - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx.ColumnTransferInfo
 
PLUGIN_LEVEL - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
pluginPollPunct - Variable in class com.sqlstream.aspen.core.AspenProperties
 
populate() - Method in class com.sqlstream.aspen.core.AspenProperties
Loads this property set from its source files.
position - Variable in class com.sqlstream.aspen.namespace.common.SourceData
 
POSITION_KEY_COL - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
POSITION_KEY_SEPARATOR - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
PositionParser(int) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.PositionParser
 
POSTPROCESS_COMMAND - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
process(String) - Method in interface com.sqlstream.aspen.core.AspenUtil.StringHandler
 
process(SourceData) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.SimpleSourceDataHandler
 
process(SourceData) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.CommonSourceDataHandler
 
process(SourceData) - Method in interface com.sqlstream.aspen.namespace.common.SourceData.Handler
Invoked when buffer is read from BuffersInputStream buffer queue.
productName - Variable in class com.sqlstream.aspen.core.AspenProperties
Name of the product as reported by java.sql.DatabaseMetaData.
PROJECTED_COLUMN_MAPPING_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
propertiesUrl - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.properties.url" property holds the URL of the properties file loaded at boot time.
props - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
PROV_AMQP_CREATION_TIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_AMQP_PARTITION - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_FILE_SOURCE_FILE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_APPLICATION_ID_DATA - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_APPLICATION_ORIGIN_DATA - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_GROUP_ID - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_MESSAGE_SEQUENCE_NUMBER - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_PUT_APPLICATION_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_PUT_APPLICATION_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_PUT_DATA_TIME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_IBMMQ_USER_ID - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_HEADERS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_OFFSET - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_PARTITION - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_PAYLOAD_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_TIMESTAMP - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KAFKA_TOPIC - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KINESIS_PARTITION_ID - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KINESIS_SEQUENCE_NUMBER - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_KINESIS_SHARD_ID - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_MQTT_MESSAGE_ID - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_MQTT_TOPIC - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_PARSE_ERROR - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_PARSE_LINE_NUMBER - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_PARSE_POSITION - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_ROW_PAYLOAD - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_SOCKET_SOURCE_HOST - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROV_SOCKET_SOURCE_PORT - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
PROVENANCE_PREFIX - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
pumpManagerStartPumpsAtBoot - Variable in class com.sqlstream.aspen.core.AspenProperties
At s-Server startup, pumpManager starts all enabled pumps in the catalog Regardless of this propery, Pump Manager will always start error stream at s-server startup time.

Q

quoteBytes - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
QUOTED_COLUMNS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
QuotedParser(TypeParser) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 
QuotedParser(TypeParser, byte[]) - Constructor for class com.sqlstream.aspen.namespace.common.CommonRowParser.QuotedParser
 

R

radix - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.ByteParser
 
radix - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalParser
 
radix - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.IntParser
 
radix - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.ScientificNotationLongParser
 
radix - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.ShortParser
 
read() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
read(byte[]) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
read(byte[], int, int) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
REASON - Static variable in exception com.sqlstream.jdbc.TimeoutException
 
registerClass(String, Class<? extends RuntimeObject<?>>) - Static method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 
registerClassIfNew(String, Class<? extends RuntimeObject<?>>) - Static method in class com.sqlstream.aspen.core.RuntimeObjectFactory
 
reject() - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
 
RELATION_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
REMOTE_HOST_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
REMOTE_PORT_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
removeTracePropertyListener(FarragoTrace.PropertyListener) - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
Remove an object which was listening for changes to the file of trace properties.
REPEAT - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
reposUrl - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.test.repos.url" property holds the URL of the XML repository file used for testing, default value "file:demo/repository.xml".
requestWrite(int, int, String) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Ask the sink for permission to write some row data.
REQUIRED_PROPERTIES - Static variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
reset() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream.Connection
Release any SourceData obtained by getCurrent if submit is not called.
reset() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
reset() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DiscardInfo
Reset for next row
reset(int, boolean) - Method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter.Gbfhd_tuple
 
reset() - Method in class com.sqlstream.aspen.namespace.common.LogLevel
 
resetBeforeFree() - Method in class com.sqlstream.aspen.namespace.common.SourceData
Clear any resources associated with this SourceData.
resetEos() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Reset eos if possible (because at record end).
resultLength - Variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter.Gbfhd_tuple
 
results - Variable in class com.sqlstream.plugin.impl.AbstractBaseUdx
 
rmpTempDir - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.rmp.temp" property holds the name of a temporary directory for Aspen RMPs.
ROOT_DIRECTORY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
ROW_SEPARATOR_CHAR_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
RowFilter - Interface in com.sqlstream.aspen.namespace.common
Filters rows for the agent.
RowInserter - Interface in com.sqlstream.aspen.namespace.common
This interface is a thin wrapper around PreparedStatement for use in the ECDA API.
rowIsNotFiltered() - Method in interface com.sqlstream.aspen.namespace.common.RowInserter
Indicate whether row is filtered.
rowPayloadColumn() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Get the 1-based index of the row payload column, if any.
ROWTIME_COLUMN_NAME - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
run() - Method in interface com.sqlstream.aspen.namespace.common.DataFactoryPlugin
Start listening for new requests.
runApplication(String[], Logger, AspenUtil.StringHandler) - Static method in class com.sqlstream.aspen.core.AspenUtil
 
RuntimeObject<T extends RuntimeObjectContext> - Interface in com.sqlstream.aspen.core
A lightweight interface for runtime object lifetime events
RuntimeObjectContext - Interface in com.sqlstream.aspen.core
 
RuntimeObjectFactory<T extends RuntimeObjectContext> - Class in com.sqlstream.aspen.core
A lightweight factory for runtime objects needed by Java UDXes and adapters
RuntimeObjectFactory() - Constructor for class com.sqlstream.aspen.core.RuntimeObjectFactory
 
RuntimeObjectFactory(T) - Constructor for class com.sqlstream.aspen.core.RuntimeObjectFactory
 

S

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
Creates a SourceDataHandler that just calls SourceData.updateLocation(RowInserter).
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
Used for writing data to a BuffersInputStream.
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
 

T

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
 

U

udpAddress - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.udp.address" allows nodes to determine which address they should listen on for UDP connections.
udpPort - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.udp.port" allows nodes to determine which port they should listen on for UDP connections.
udxCheckMonotonicRowtimes - Variable in class com.sqlstream.aspen.core.AspenProperties
The property "aspen.udx.checkMonotonicRowtimes" causes the query planner to add an EnforceRowtimeRel after each UDX call, in order to check that the output stream of the UDX has non-decreasing (monotonic) rowtimes.
unblockedTime() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 
UNKNOWN_TYPE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
UNPARSED_TEXT_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
UNPARSED_TEXT_LAST_COLUMN - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
UNPARSED_TEXT_NEW_ROW - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
UNPARSED_TEXT_TRUNCATE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
UNPROJECTED_COLUMNS_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
UNPROJECTED_NUM_COLUMNS_KEY - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
update(RowInserter) - Method in interface com.sqlstream.aspen.namespace.common.CommonRowParser.ColumnUpdater
 
updateLocation(RowInserter) - Method in class com.sqlstream.aspen.namespace.common.SourceData
Update any requested metadata into RowInserter.
UPPER_A - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
UPPER_F - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
UPPER_X - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 
URL_PREFIX - Static variable in class com.sqlstream.jdbc.Driver
 
useBuiltin - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
useDoubleBase - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
 
useDoubleBuffering - Variable in class com.sqlstream.aspen.core.AspenProperties
The property aspen.aggregate.useResultBuffering controls whether or not to use double buffering between xo's that that don't allocate their own buffers.
useIsoConverter() - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
userbinDir - Variable in class com.sqlstream.aspen.core.AspenProperties
The "aspen.userbin.dir" property holds the name of the directory under the server home that contains user binary files, such as scripts for post-process cleanup.
utf8 - Static variable in class com.sqlstream.aspen.namespace.common.BuffersInputStream
 

V

validating() - Method in interface com.sqlstream.aspen.namespace.common.EcdaContext
Return true if we are validating a statement.
validValues - Variable in class com.sqlstream.aspen.namespace.common.OptionsUtils.EnumOptionParameter
 
value - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DecimalNumber
 
valueOf(String) - Static method in enum com.sqlstream.aspen.namespace.common.EcdaContext.Phase
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.sqlstream.aspen.namespace.common.EcdaPluginFactory.PluginType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.sqlstream.jdbc.StreamingResultSet.RowEvent
Returns the enum constant of this type with the specified name.
valueOutOfRange(String) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Wrap an error in an overflow/underflow SQLException
values() - Static method in enum com.sqlstream.aspen.namespace.common.EcdaContext.Phase
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.sqlstream.aspen.namespace.common.EcdaPluginFactory.PluginType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.sqlstream.jdbc.StreamingResultSet.RowEvent
Returns an array containing the constants of this enum type, in the order they are declared.
varbinary_to_string(byte[], String) - Static method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
System function varbinary_to_string() to convert a varbinary value into a varchar using the indicated character encoding.
varbinary_to_varchar(byte[]) - Static method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
System function varbinary_to_varchar() to convert a varbinary value into a varchar.
varchar_to_varbinary(String) - Static method in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
System function varchar_to_varbinary() to convert a char/varchar value into a varbinary, two hex digits per byte.
verify_fail_if_no_peer_cert - Variable in class com.sqlstream.aspen.core.AspenProperties
With SSL, require the client certificate , reject connection if verification fails
verifyNotEmpty(String) - Method in class com.sqlstream.aspen.namespace.common.CommonRowParser.AbstractFieldParser
Raise an error if the text is an empty string.
vetProvenanceColumnTypes(String, ExtendedParameterMetaData, FarragoParamFieldMetaData[]) - Static method in class com.sqlstream.aspen.namespace.common.CommonRowParser
Raise a validation error if a provenance column does not have the correct datatype.

W

waitABitTillBlockedOrClosed(long) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Wait for blocked read or close.
waitForBuffer() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Wait for buffer to be available for reading.
waitForBuffer(long) - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Wait for buffer to be available for reading.
waitUntilAllConsumed() - Method in class com.sqlstream.aspen.namespace.common.BuffersInputStream
Wait for all buffers to be consumed.
WATERMARK_STORE - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
WATERMARKED_SINK - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
WATERMARKS - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
wrap(SourceData) - Static method in class com.sqlstream.aspen.namespace.common.SourceWorkUnit
 
write(int, byte[], int, int, DataOutputBatchSink.FreeBufferCallback) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputBatchSink
Writes bytes to the output running.
write(byte[], int, int) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputRowSink
Write one row.
writeBounds(long) - Method in interface com.sqlstream.aspen.namespace.common.DataOutputSink
Writes a rowtime bounds if this sink supports such a thing, usually this does nothing.
WS_POSITION_KEY_COL - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 
WS_SINK_NAME_COL - Static variable in interface com.sqlstream.aspen.namespace.common.CommonDataConstants
 

Z

ZERO - Static variable in class com.sqlstream.aspen.namespace.common.HexToBinaryConverter
 

_

_hexConverter - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
_isoConverter - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser.DateParser
 
_positionKeyByteLength - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
_positionKeyBytes - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
_relationName - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
_rowPayloadColumn - Variable in class com.sqlstream.aspen.namespace.common.CommonRowParser
 
A B C D E F G H I J K L M N O P Q R S T U V W Z _ 
Skip navigation links

Copyright (C) 2003-2021 SQLstream, Inc.