Skip to content

Commit 3da550c

Browse files
general-kroll-4-lifegeneral-kroll-4-life
committed
- Stream processing moved to any-sdk.
1 parent d50f08b commit 3da550c

26 files changed

+27
-321
lines changed

‎go.mod‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ require (
1919
github.com/spf13/cobra v1.4.0
2020
github.com/spf13/pflag v1.0.5
2121
github.com/spf13/viper v1.10.1
22-
github.com/stackql/any-sdk v0.0.6-alpha05
22+
github.com/stackql/any-sdk v0.0.6-alpha08
2323
github.com/stackql/go-suffix-map v0.0.1-alpha01
2424
github.com/stackql/psql-wire v0.1.1-alpha07
2525
github.com/stackql/stackql-parser v0.0.14-alpha05

‎go.sum‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -482,8 +482,8 @@ github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
482482
github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
483483
github.com/spf13/viper v1.10.1 h1:nuJZuYpG7gTj/XqiUwg8bA0cp1+M2mC3J4g5luUYBKk=
484484
github.com/spf13/viper v1.10.1/go.mod h1:IGlFPqhNAPKRxohIzWpI5QEy4kuI7tcl5WvR+8qy1rU=
485-
github.com/stackql/any-sdk v0.0.6-alpha05 h1:B1Y0+YoGjhTdGfRkWcYKELd9vM8j2LspHrVNhRBrjKk=
486-
github.com/stackql/any-sdk v0.0.6-alpha05/go.mod h1:4jYKpPoX2GWEK+qBnlGLvr8SUfndiYwHMIkg1dn9tFM=
485+
github.com/stackql/any-sdk v0.0.6-alpha08 h1:TS8/oihI78HQBI+6SfrZdlH9STjA8BG8HkQnbOS5XE4=
486+
github.com/stackql/any-sdk v0.0.6-alpha08/go.mod h1:4jYKpPoX2GWEK+qBnlGLvr8SUfndiYwHMIkg1dn9tFM=
487487
github.com/stackql/go-suffix-map v0.0.1-alpha01 h1:TDUDS8bySu41Oo9p0eniUeCm43mnRM6zFEd6j6VUaz8=
488488
github.com/stackql/go-suffix-map v0.0.1-alpha01/go.mod h1:QAi+SKukOyf4dBtWy8UMy+hsXXV+yyEE4vmBkji2V7g=
489489
github.com/stackql/psql-wire v0.1.1-alpha07 h1:LQWVUlx4Bougk6dztDNG5tmXxpIVeeTSsInTj801xCs=

‎internal/stackql/data_staging/output_data_staging/packet_preparator.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@ import (
66
"github.com/lib/pq/oid"
77
"github.com/stackql/any-sdk/pkg/dto"
88
"github.com/stackql/any-sdk/pkg/logging"
9+
"github.com/stackql/any-sdk/pkg/streaming"
910
"github.com/stackql/stackql/internal/stackql/drm"
10-
"github.com/stackql/stackql/internal/stackql/streaming"
1111
"github.com/stackql/stackql/internal/stackql/typing"
1212
)
1313

‎internal/stackql/dependencyplanner/dependencyplanner.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ import (
88
"github.com/stackql/any-sdk/pkg/constants"
99
"github.com/stackql/any-sdk/pkg/logging"
1010
"github.com/stackql/any-sdk/pkg/media"
11+
"github.com/stackql/any-sdk/pkg/streaming"
1112
"github.com/stackql/stackql-parser/go/vt/sqlparser"
1213
"github.com/stackql/stackql/internal/stackql/astanalysis/annotatedast"
1314
"github.com/stackql/stackql/internal/stackql/astindirect"
@@ -22,7 +23,6 @@ import (
2223
"github.com/stackql/stackql/internal/stackql/primitivecomposer"
2324
"github.com/stackql/stackql/internal/stackql/sqlrewrite"
2425
"github.com/stackql/stackql/internal/stackql/sqlstream"
25-
"github.com/stackql/stackql/internal/stackql/streaming"
2626
"github.com/stackql/stackql/internal/stackql/tableinsertioncontainer"
2727
"github.com/stackql/stackql/internal/stackql/taxonomy"
2828
"github.com/stackql/stackql/internal/stackql/util"

‎internal/stackql/dependencyplanner/stream_collection.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package dependencyplanner
22

33
import (
4-
"github.com/stackql/stackql/internal/stackql/streaming"
4+
"github.com/stackql/any-sdk/pkg/streaming"
55
)
66

77
type StreamDependecyCollection interface {

‎internal/stackql/drm/drm_cfg.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,13 +11,13 @@ import (
1111
"github.com/stackql/any-sdk/anysdk"
1212
"github.com/stackql/any-sdk/pkg/constants"
1313
"github.com/stackql/any-sdk/pkg/logging"
14+
"github.com/stackql/any-sdk/pkg/streaming"
1415
"github.com/stackql/stackql/internal/stackql/internal_data_transfer/internaldto"
1516
"github.com/stackql/stackql/internal/stackql/internal_data_transfer/relationaldto"
1617
"github.com/stackql/stackql/internal/stackql/sql_system"
1718
"github.com/stackql/stackql/internal/stackql/sqlcontrol"
1819
"github.com/stackql/stackql/internal/stackql/sqlengine"
1920
"github.com/stackql/stackql/internal/stackql/sqlmachinery"
20-
"github.com/stackql/stackql/internal/stackql/streaming"
2121
"github.com/stackql/stackql/internal/stackql/tablenamespace"
2222
"github.com/stackql/stackql/internal/stackql/typing"
2323
"github.com/stackql/stackql/internal/stackql/util"

‎internal/stackql/internal_data_transfer/builder_input/builder_input.go‎

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,13 @@ package builder_input //nolint:revive,stylecheck // permissable deviation from n
22

33
import (
44
"github.com/stackql/any-sdk/anysdk"
5+
"github.com/stackql/any-sdk/pkg/streaming"
56
"github.com/stackql/stackql-parser/go/vt/sqlparser"
67
"github.com/stackql/stackql/internal/stackql/astanalysis/annotatedast"
78
"github.com/stackql/stackql/internal/stackql/handler"
89
"github.com/stackql/stackql/internal/stackql/internal_data_transfer/internaldto"
910
"github.com/stackql/stackql/internal/stackql/primitivegraph"
1011
"github.com/stackql/stackql/internal/stackql/provider"
11-
"github.com/stackql/stackql/internal/stackql/streaming"
12-
"github.com/stackql/stackql/internal/stackql/streaming/http_preparator_stream.go"
1312
"github.com/stackql/stackql/internal/stackql/tablemetadata"
1413
)
1514

@@ -46,8 +45,8 @@ type BuilderInput interface {
4645
SetParamMapStream(streaming.MapStream)
4746
SetVerb(verb string)
4847
Clone() BuilderInput
49-
GetHTTPPreparatorStream() (http_preparator_stream.HttpPreparatorStream, bool)
50-
SetHTTPPreparatorStream(prepStream http_preparator_stream.HttpPreparatorStream)
48+
GetHTTPPreparatorStream() (anysdk.HttpPreparatorStream, bool)
49+
SetHTTPPreparatorStream(prepStream anysdk.HttpPreparatorStream)
5150
IsTargetPhysicalTable() bool
5251
SetIsTargetPhysicalTable(isPhysical bool)
5352
SetTxnCtrlCtrs(internaldto.TxnControlCounters)
@@ -67,7 +66,7 @@ type builderInput struct {
6766
isUndo bool
6867
node sqlparser.SQLNode
6968
paramMapStream streaming.MapStream
70-
httpPrepStream http_preparator_stream.HttpPreparatorStream
69+
httpPrepStream anysdk.HttpPreparatorStream
7170
op anysdk.OperationStore
7271
prov provider.IProvider
7372
annotatedAst annotatedast.AnnotatedAst
@@ -133,11 +132,11 @@ func (bi *builderInput) GetParamMapStream() (streaming.MapStream, bool) {
133132
return bi.paramMapStream, bi.paramMapStream != nil
134133
}
135134

136-
func (bi *builderInput) GetHTTPPreparatorStream() (http_preparator_stream.HttpPreparatorStream, bool) {
135+
func (bi *builderInput) GetHTTPPreparatorStream() (anysdk.HttpPreparatorStream, bool) {
137136
return bi.httpPrepStream, bi.httpPrepStream != nil
138137
}
139138

140-
func (bi *builderInput) SetHTTPPreparatorStream(prepStream http_preparator_stream.HttpPreparatorStream) {
139+
func (bi *builderInput) SetHTTPPreparatorStream(prepStream anysdk.HttpPreparatorStream) {
141140
bi.httpPrepStream = prepStream
142141
}
143142

‎internal/stackql/internal_data_transfer/internaldto/executor_output.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
package internaldto
22

33
import (
4+
"github.com/stackql/any-sdk/pkg/streaming"
45
"github.com/stackql/psql-wire/pkg/sqldata"
56
"github.com/stackql/stackql/internal/stackql/acid/binlog"
6-
"github.com/stackql/stackql/internal/stackql/streaming"
77
)
88

99
var (

‎internal/stackql/nativedb/select.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package nativedb
22

3-
import "github.com/stackql/stackql/internal/stackql/streaming"
3+
import "github.com/stackql/any-sdk/pkg/streaming"
44

55
type Select interface {
66
GetColumns() []Column

‎internal/stackql/primitivebuilder/generic_http_reversal.go‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ import (
1818
"github.com/stackql/stackql/internal/stackql/primitive"
1919
"github.com/stackql/stackql/internal/stackql/primitivegraph"
2020
"github.com/stackql/stackql/internal/stackql/provider"
21-
"github.com/stackql/stackql/internal/stackql/streaming/http_preparator_stream.go"
2221
"github.com/stackql/stackql/internal/stackql/tablemetadata"
2322
)
2423

@@ -33,7 +32,7 @@ type genericHTTPReversal struct {
3332
verb string // may be "insert" or "update"
3433
inputAlias string
3534
isUndo bool
36-
reversalStream http_preparator_stream.HttpPreparatorStream
35+
reversalStream anysdk.HttpPreparatorStream
3736
prov provider.IProvider
3837
}
3938

0 commit comments

Comments
 (0)