PDF Documentation
SQLstream Concepts
s-Server Overview
Stream and View
Differences from RDBMS tables
Plugins
Pump
ROWTIME
s-Server and the Linear Road Benchmark
High Availability through Parallel Redundancy and Checkpointing
Time and Streaming Data
Complex Event Processing
Rowtime Bounds
Application Design Considerations
Transforming and Analyzing Data in s-Server
Application Model
General Concepts
Correctness Mode
Advanced Stream Resequencing with Guavus SQLstream
Aggregation Windows
Pumps, Streams, and Processing Pipelines
SQLstream Objects
Troubleshooting Processing Delays
Installing Guavus SQLstream
Guavus SQLstream Components Overview
SQLstream s-Server Licensing
Installing s-Server on Linux
Using the Guavus SQLstream Cover Page
Installing SQLstream on Parallels
Using the AWS Marketplace Guavus SQLstream AMI
Installing the SQLstream AMI
Installing the Guavus SQLstream Azure MI
Installing the Guavus SQLstream Virtual Hard Disk
Installing the Guavus SQLstream Trial VM Appliance
Installing the Guavus SQLstream Trial Docker Container
Installing SQLstream StreamLab on Linux
Starting and Stopping s-Server Manually
Installing s-Studio and Client Tools as Standalone Packages
Troubleshooting Installation
Installation Guide Appendix
Appendix: Installing the MySQL Driver
Appendix: Managing s-Server as a Service
Appendix: Network Configuration Issues for s-Server
Appendix: Running Multiple Instances of s-Server
Appendix: SQLstream s-Server Installation Directories
Appendix: Upgrading SQLstream s-Server
Command-line Installation
Setting Up Environment Variables & Path
What's Next?
Building Streaming Applications
Tutorial 1: Introduction to StreamLab
Tutorial 2: Introduction to Coding with Streaming SQL
Tutorial 3: Using a Pump
Tutorial 4: Creating a View
Introduction to Pipelines
Best Practices
Using Trace Files to Troubleshoot Streams
Integrating Guavus SQLstream with Other Systems
s-Server Integrations
Full List of Plugins and Agents
Embedding Guavus SQLstream
SQLstream JDBC Driver
Using the Extensible Common Data Framework
Reading Data into s-Server
Writing Data Out of s-Server
Integrating AMQP
Integrating MQTT
Using the ECD Agent
Integrating DataRobot
Integrating Cassandra
Integrating the File System
Integrating HTTP
Integrating Kafka
Using Exactly Once Semantics
Integrating Kinesis
Integrating RDBMS Systems
Integrating Sockets
Integrating WebSockets
Integrating Hadoop
Integrating Mail Servers
Integrating MongoDB
Integrating Snowflake
Output Formats for Writing
Formatting Data as Avro
Formatting Data as BSON
Formatting Data as CSV
Formatting Data as JSON
Formatting Data as ORC
Formatting Data as XML
Parser Types for Reading
Parsing Using the Discovery Parser
Parsing CSV
Parsing JSON
Parsing XML
Parsing ProtoBuf
Parsing Avro
Using the None Parser
Parsing Key Pair Values
Using s-Server over the Internet
Guavus SQLstream Software Development Kit
Writing a UDX
Writing a UDF
Writing an Extensible Common Data Framework Plugin
StreamingPreparedStatement
Sample Code for Parser
Sample Code for Source Plugin
Streaming ResultSet
Streaming Statement
Using s-Server for Machine Learning with SystemML
Writing to Hive Tables
Analyzing Data in s-Server
Writing Streaming SQL Queries
More Complex SQL Examples
Windowed Aggregation on Streams
Using Pumps to Create Processing Pipelines
Creating Streaming JOINs
Query Patterns
Running Demo Applications and Data
Using UDXs and UDFs for Analysis
Transforming Data
AesEncryptDecrypt UDX
Avro Formatter UDX
GeoIPFunctions UDX
GoogleGeoCode UDF
Group Rank UDX
Kalman Filter UDX
Linear Interpolation UDX
Matched Filter UDX
Parser UDX
Quadratic Interpolation UDX
Table Lookup UDX
URI Parse UDX
XML Parse UDX
The Mochi Demo
The Hamachi Demo
Generating Test Data with DataGen
Using MTSQL
Using StreamLab
Installing and Running Streamlab on Linux
Working with Projects
Using StreamLab Sources
Adding an External Stream Source
Configuring Streaming Data Sources
Adding an External Table Source
Adding an s-Server Stream Source
Verifying a Source by Sampling Rows
Throttling a Source
Working with Partitioned Sources
StreamLab External Connections Overview
StreamLab Pipeline Guides Overview
Advanced Commands
Analytics
Basic Commands
Custom View
Customizing the Scrutinizer
Duplicate
Filter
GroupRank
Managing the Scrutinizer
New Column
Parsers
Partition Window
Pivot
Timestamp
Turning off the Scrutinizer
Window
StreamLab Galleries
StreamLab Sinks Overview
Sink Output Types
Adding an External Stream Sink
Adding an External Table Sink
Adding an Internal Stream Sink
Configuring External Stream Sinks
Creating a New s-Server Stream as a Sink
Routing Data to a Sink
StreamLab Dashboards
Modifying Dashboard Layouts
Creating Collections
Creating Custom Dashboards
Bar Graph
Bars Over Time
Bars and Lines
Bollinger Bands
Creating a Line Plot Panel
Map and Table Dashboard
Parallel Coordinates
Scatter Matrix
Time Series
Customizing the SELECT Template
Locking Dashboards
Using Preferences to Change Panel Appearance and Input
Troubleshooting StreamLab
Running webAgent
Using the Rose API
Using s-Dashboard
Running s-Dashboard
Integrating Panels
View Stream as a Table
View Latest Row Panels
View Rows Over Time Panels
View Rows Over a Key Column Panels
Geographical and 3D Stream Panels
Creating a Custom Panel in s-Dashboard Using Chart_js
Creating a Custom Panel in s-Dashboard Using SVG
Using the Inter Panel Blackboard
Creating a Custom Panel in s-Dashboard Using Vega
Panel Development Process
Using Panel Preferences
Using the Mochi Demo
Integrating Dashboard Layouts
s-Dashboard Input Overview
Running webAgent
Troubleshooting s-Dashboard
Appendix A: Map IDs for Cloropleth
Using SQLLine
Using sqlLineRemote to Connect to a Database
Using s-Studio
Connecting to s-Server
Inspecting s-Server Objects in s-Studio
Creating Objects in s-Studio
Integrating SQL in s-Studio
Managing s-Server through s-Studio
Administering s-Server
Starting and Stopping s-Server
Configuring Networking for s-Server
Configuring s-Server Parameters
Using and Managing Trace Files
Session Management
Implementing Federation for s-Server
Monitoring s-Server and Components
Using Telemetry to Monitor Performance
Running Multiple Instances of s-Server
Autoprovisioning s-Server
Maintaining s-Server
Hardening s-Server
Sandboxing in s-Server
Guavus s-Server Streaming SQL Reference Manual
Extensions to the SQL standard
Temporal Predicates
Error Handling
Basic Building Blocks
Catalog Objects
Common Clauses
Condition Clause
Expressions and Literals
Identifiers
Monotonic Expressions and Operators
Objects within a Schema
Run-Time Context
SQLstream Data Types
Built-in Functions
Aggregate Functions
Analytic Functions
Conversion Functions
Statistical Variance and Deviation Functions
Time Functions
Scalar Functions
LISTAGG function
ABS
ANY and EVERY
AVG
CAST
CEIL / CEILING
CHAR_LENGTH / CHARACTER_LENGTH
CHAR_TO_DATE
CHAR_TO_TIME
COALESCE
COUNT
CURRENT_DATE
CURRENT_PATH
CURRENT_ROW_TIMESTAMP
CURRENT_TIME
CURRENT_TIMESTAMP
Char To Timestamp(Sys)
DATEDIFF
DATE_TO_CHAR
Date and Time Patterns
EXP
EXP_AVG
EXTRACT
FAST_REGEX_LOG_PARSER
FIRST_VALUE
FIXED_COLUMN_LOG_PARSE
FLOOR
INITCAP
LAG
LAST_VALUE
LN
LOCALTIME
LOCALTIMESTAMP
LOG10
LOWER
MAX
MIN
MOD
Monotonic Function
NTH_VALUE
NULLIF
OVERLAY
POSITION
POWER
REGEX_LOG_PARSE
REGEX_REPLACE
SESSION_USER
STEP
SUBSTRING
SUM
SYS_LOG_PARSE
TIMESTAMP_TO_CHAR
TIME_TO_CHAR
TO_TIMESTAMP
TRIM
TSDIFF
UNIX_TIMESTAMP
UPPER
VARBINARY_TO_VARCHAR
VARCHAR_TO_VARBINARY
VARIABLE_COLUMN_LOG_PARSE
W3C_LOG_PARSE
General Management Functions
BROWSE_CONNECT_FOREIGN_SERVER
BROWSE_TABLE
COMPLETE_SQL
FORMAT_SQL
GENERATE DDL FOR SERVER
GENERATE_DDL_FOR_CATALOG
GENERATE_DDL_FOR_JAR
GENERATE_DDL_FOR_SCHEMA
GENERATE_DDL_FOR_TABLE
GENERATE_DDL_FOR_USER
GENERATE_DDL_FOR_WRAPPER
GET_KEYWORDS
GET_OBJECT_DDL
GET_PLUGIN_PROPERTY_INFO
GET_TABLE_TYPE_BY_MOF_CLASS_NAME
GETÂ SERVER_PROPERTY_INFO
IS_VALID_SQL
OBJECTS_IN_USE
PERFORMANCE_COUNTERS
REPOSITORY_INTEGRITY_VIOLATIONS
REPOSITORY_PROPERTIES
SESSIONS
SESSION_PARAMETERS
STATEMENTS
STAT_GET_CARDINALITY
STAT_GET_ROW_COUNT
STAT_GET_SELECTIVITY
SYSTEM_Info
SYSTEM_USER
THREADS
THREAD_STACK_ENTRIES
VALIDATE_SQL
Operators
Date, Timestamp, and Interval Operators
Logical Operators
String Operators
ALTER statements
ALTER PUMP
ALTER SESSION
ALTER STREAM
ALTER SYSTEM
ALTER USER
CALL
CREATE statements
CREATE FOREIGN DATA WRAPPER
CREATE FOREIGN STREAM
CREATE FOREIGN TABLE
CREATE FUNCTION
CREATE JAR
CREATE LOCAL DATA WRAPPER
CREATE PROCEDURE
CREATE PUMP
CREATE SCHEMA
CREATE SERVER
CREATE STREAM
CREATE USER
CREATE VIEW
DELETE
DROP statements
DROP FOREIGN DATA WRAPPER
DROP FOREIGN STREAM
DROP FOREIGN TABLE
DROP FUNCTION
DROP JAR
DROP LOCAL DATA WRAPPER
DROP PROCEDURE
DROP PUMP
DROP SCHEMA
DROP SERVER
DROP STREAM
DROP VIEW
EXPLAIN PLAN
IMPORT FOREIGN SCHEMA
INSERT
MERGE
Query
SELECT statement
FROM clause
GROUP BY clause
HAVING clause
JOIN clause
OFFSET/FETCH Clause
ORDER BY clause
ROWTIME
SELECT ALL and SELECT DISTINCT
WHERE clause
WINDOW clause
SET statements
TRUNCATE TABLE
Appendix A - List of Error Messages
Appendix B - SQL Limitations
Appendix C - Reserved Words and Key Words
Glossary
ALTER
ANALYZE
Adapter
Aggregate Function
ApplicationIntegration
Attribute
CREATE
Cartesian Join
Catalog
Checkpoint
Column
CrossJoin
Current Row
Cursor
DROP
Data Definition Language
Data Manipulation Language
Data Wrapper
Datagen
Driver
EXCEPT
Extensible Common Data Adapter
Finite Relation
Foreign Data Wrapper
Foreign Server
Foreign Stream
ForeignTable
Function
GroupAggregateFunction
Highwater Mark
Hopping Window
INSERTEXPEDITED
INTERSECT
InnerJoin
Interval
JDBC
JDBCDriver
JavaMetadataInterface
Join
JoinCondition
KeyWord
LOCALDB
Local Data Wrapper
Log File
Loopback Table
Meta Data Repository
Metadata
Monotonically Increasing
Monotonicity
Native Stream
Natural Join
Node
Offset Window
Option
OuterJoin
Path
Pipeline
Procedure
Project Schema
Projection
Pump
Punctuation
Query Plan
ROWTIME
Relation
RelationalOperator
Repository
RepositoryObject
Routine
Row
Row-based Window
RowtimeBound
SELECT
SQL
SQL/MED
SQLLineRemote
SQLline
SQLstream Server
SQLstream Studio
SYSFTRS
Sandboxed Mode
Schema
Schema Object
Server
Server Properties
Sink
Sliding Window
SoftwareDevelopmentKit
Source
Statistical Variance and Deviation Functions
StorageEngine
Stream
Stream Graph
StreamLab
StreamView
StreamingAggregation
StreamingDataProtocol
StreamingQuery
StreamingRelation
Subquery
Table
Time-based Window
Timestamp
Tumbling Window
Tuple
UNION
UNION ALL
UPDATE
User
User Defined Function
User Defined Procedure
User Defined Routine
User Defined Transform
VALUES
View
Window
Window Aggregate Function
Windowed Aggregation
XML Metadata Interchange
s-Dashboard
sysjdbc
webAgent
More
SQLstream
Download
PDF
Last update: Friday, Jul 10, 2020
SQLstream Documentation
>
Glossary
> CrossJoin
CrossJoin
The implementation of a cartesian join.