49957,3
|
MB-14637 Add datastream pipeline library implementation
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49958,3
|
MB-14637 Implement error handling for pipeline library
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49959,3
|
MB-14637 pipeline: Add error handling and graceful shutdown tests
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49960,3
|
MB-14637 pipeline: Add PeekBlock() and FlushBlock() APIs
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49961,3
|
MB-14637 queryport: Use io.Writer instead of response channel
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49962,3
|
MB-14637 pipeline: Fix a bug in handling 0 items send through pipeline
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49964,3
|
MB-14637 scanner: Rewrite to use pipeline library
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49965,3
|
MB-14637 transport: Make payload framing methods reusable
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49966,3
|
MB-14637 Remove protobuf.StreamEndResponse from wire format
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49967,3
|
MB-14637 protobuf: Use a reusable encode buffer and avoid temp allocs
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49968,3
|
MB-14637 scanner: Use pipeline block buffer for building row batch
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49972,3
|
MB-14637 scanner: Avoid heap allocation in decode phase
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
49973,4
|
MB-14637 scanner: Export data members from package to facilitate testing
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
50150,3
|
MB-14637 scanner: Send error occured during scan to the client
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|
50154,5
|
MB-14637 scanner: Use new byte streaming row results protocol
|
unstable
|
indexing
|
Status:
ABANDONED
|
0
|
0
|
50537,3
|
MB-14637 scanner: Use lazy debug logger for logging timestamps
|
unstable
|
indexing
|
Status:
MERGED
|
+2
|
+1
|