File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -284,19 +284,29 @@ func ReleaseCArrowArray(arr *CArrowArray) { releaseArr(arr) }
284
284
// ReleaseCArrowSchema calls ArrowSchemaRelease on the passed in cdata schema
285
285
func ReleaseCArrowSchema (schema * CArrowSchema ) { releaseSchema (schema ) }
286
286
287
+ // RecordMessage is a simple container for a record batch channel to stream for
288
+ // using the Async C Data Interface via ExportAsyncRecordBatchStream.
287
289
type RecordMessage struct {
288
290
Record arrow.Record
289
291
AdditionalMetadata arrow.Metadata
290
292
Err error
291
293
}
292
294
295
+ // AsyncRecordBatchStream represents a stream of record batches being read in
296
+ // from an ArrowAsyncDeviceStreamHandler's callbacks. If an error was encountered
297
+ // before the call to on_schema, then this will contain the error as Err. Otherwise
298
+ // the Schema will be valid and the Stream is a channel of RecordMessages being
299
+ // propagated via on_next_task and extract_data.
293
300
type AsyncRecordBatchStream struct {
294
301
Schema * arrow.Schema
295
302
AdditionalMetadata arrow.Metadata
296
303
Err error
297
304
Stream <- chan RecordMessage
298
305
}
299
306
307
+ // AsyncStreamError represents an error encountered via a call to the on_error
308
+ // callback of an ArrowAsyncDeviceStreamHandler. The Code is the error code that
309
+ // should be errno compatible.
300
310
type AsyncStreamError struct {
301
311
Code int
302
312
Msg string
You can’t perform that action at this time.
0 commit comments