Kafka.DotNet.ksqlDB v0.9.0

Create or replace stream/table as select:

• IKSqlDBStatementsContext - CreateStreamStatement, CreateOrReplaceStreamStatement, CreateTableStatement, CreateOrReplaceTableStatement
• CreateStatementExtensions - PartitionBy, ToStatementString
• WithOrAsClause, CreationMetadata
• ICreateStatement, CreateStatementExtensions

Kafka.DotNet.ksqlDB v0.8.0

• scalar collection functions: ArrayMax, ArrayMin, ArrayRemove

Extensions:

• HttpResponseMessageExtensions - ToStatementResponse

KSqlDbRestApiClient:

• ExecuteStatementAsync - The /ksql resource runs a sequence of SQL statements. All statements, except those starting with SELECT, can be run on this endpoint. To run SELECT statements use the /query endpoint.

KSqlDbStatement

• KSqlDbStatement allows you to set the statement, content encoding and the CommandSequenceNumber.

Kafka.DotNet.ksqlDB v0.7.0

• operator precedence
• raw string KSQL query execution
• scalar collection functions: ArrayIntersect, ArrayJoin

Fixes:

• fixed VisitNew with several binary expressions, all except the first were skipped

Kafka.DotNet.ksqlDB v0.6.0

• netstandard 2.0 (.Net Framework etc)
• CASE - Select a condition from one or more expressions.
• /Query endpoint (http 1.1)
• Collection functions: None

Added implementations:

• QueryParameters, KSqlDbContextOptionsBuilder
• KSqlDBContext.CreateQuery

Fixes:

• column alias in projections was not generated

Kafka.DotNet.ksqlDB v0.5.0

• Struct type
• Full Outer Join
• Numeric scalar functions - Entries Exp, GenerateSeries, GeoDistance, Ln, Sqrt
• Collection functions: ArrayContains, ArrayDistinct, ArrayExcept

Kafka.DotNet.ksqlDB v0.4.0

• Maps
• Deeply nested types (Maps, Arrays)
• logical operator NOT on columns
• aggregation function - Histogram

Date and time functions

• DATETOSTRING, TIMESTAMPTOSTRING etc.