Kafka.DotNet.ksqlDB v0.3.0

• functions member access (variables for method arguments)
• Where is null, is not null
• dynamic function call (support not supported functions)
• destructure arrays (indexer), arrays length, new array

ExtensionsMethods:

• LeftJoin
• Having - aggregations with column

Numeric functions

• Abs, Ceil, Floor, Random, Sign, Round

Aggregation functions

• EarliestByOffset, LatestByOffset, EarliestByOffsetAllowNulls, LatestByOffsetAllowNull
• TopK, TopKDistinct, LongCount, Count(col)
• EarliestByOffset - earliestN overload
• LatestByOffset - latestN overload
• CollectSet, CollectList, CountDistinct

SqlTableDependency.Extensions 3.0.0

• updated external packages System.Configuration.ConfigurationManager 5.0, System.Reactive 5.0 and System.ComponentModel.Annotations 5.0

Kafka.DotNet.ksqlDB v0.2.0

ExtensionsMethods and implementations:

• Having
• Window Session
• arithmetic operators
• KSqlFunctions - LIKE
• String functions - LPad, RPad, Trim, Len, Substring
• Aggregation functions - Min and Max
• Avg - Return the average value for a given column
• Inner Join
• TimeUnit milliseconds
• Source.of for inner join helper

Fixes:

• parse single value for anonymous type - KSqlDbQueryStreamProvider bug fix

Kafka.DotNet.ksqlDB v0.1.0

Kafka.DotNet.ksqlDB is a LINQ-enabled client API for issuing ksqlDB push queries and consuming JSON payloads.
Targets .NET 5 and .NET Core 3.1.

For more info see Wiki

ExtensionsMethods:

• AsAsyncEnumerable

• Sum Aggregation

• Tumbling window, Hopping window

• KSqlDBContext async disposition AsyncDisposableObject

• IKSqlGrouping

• Queries UCASE and LCASE

v0.1.0-preview3

Implementations:

• convert query visitor
• Record base type with RowTime property
• KSqlDBContext, KSqlDBContextOptions, QueryContext
• ServiceProvider

ExtensionsMethods:

• GroupBy
• Count Aggregation

v0.1.0-preview2

• KQuerySet was set to internal for maintanance reasons. Is KQueryStreamSet good enough for all push queries?

ToObservable:

• ToObservable
• Subscribe overloads

v0.1.0-preview1

ksql provider:

• SELECT projections
• FROM entity type (KStream name)
• WHERE conditions (AND, OR)
• EMIT CHANGES
• LIMIT take linq extension method

ExtensionsMethods:

• Subscribe

Interfaces:

• IQbservableProvider
• IQbservable<TEntity>

Implementations:

• KSqlVisitor
• KSqlQueryGenerator - compiler
• KStreamSet, KQuerySet, KQueryStreamSet
• QbservableProvider
• KSqldbProvider<T> - ksqldb REST api provider for push queries (KSqlDbQueryProvider<T>, KSqlDbQueryStreamProvider<T>)

Joker.OData v2.1.0

• ODataStartupBase.OnRegisterEdmModel - registration of IEdmModel to IServicesCollection. Default is singleton

• StartupBase UseCors

• StartupBase AddDefaultCorsPolicy

SqlTableDependency.Extensions 2.3.4

• SqlTableDependencyWithReconnection.Dispose finalizer fix (#11 )
• removed duplicated code from overridden Stop

v2.0.0

• Autofac.Extensions.DependencyInjection 5.0.1 updated to 7.0.2. See https://github.com/autofac/Autofac/releases/tag/v6.0.0 and bellow
• OnHostBuilt added to ApiHost

Please download it from https://www.nuget.org/packages/Joker.OData/ and try it. Thanks.

v1.6.0

• extracted StartupBase from ODataStartupBase for AspNetCore applications
• added UseAuthentication (StartupSettings.UseAuthentication)
• added OnAddExtensions - StartupBase calls UseAuthentication, UseAuthorization and UseRouting based on settings
• ApiStartup base class for non OData AspNetCore apis
• ApiHost - host for non OData AspNetCore apis (MVC, WebApi)

Please download it from https://www.nuget.org/packages/Joker.OData/ and try it. Thanks.

Joker.OData v1.4.1

Issues

• #8 fixed UseAuthorization, called between UseRouting and UseEndpoints for endpoint routing