/dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow/Flatbuf/ |
H A D | RecordBatch.cs | 14 internal struct RecordBatch : IFlatbufferObject struct 16 private Table __p; 17 public ByteBuffer ByteBuffer { get { return __p.bb; } } 20 public void __init(int _i, ByteBuffer _bb) { __p.bb_pos = _i; __p.bb = _bb; } in __init() 21 public RecordBatch __assign(int _i, ByteBuffer _bb) { __init(_i, _bb); return this; } in __assign() 28 …ublic int NodesLength { get { int o = __p.__offset(6); return o != 0 ? __p.__vector_len(o) : 0; } } 36 …lic int BuffersLength { get { int o = __p.__offset(8); return o != 0 ? __p.__vector_len(o) : 0; } } 40 public static Offset<RecordBatch> CreateRecordBatch(FlatBufferBuilder builder, in CreateRecordBatch() 53 public static void StartRecordBatch(FlatBufferBuilder builder) { builder.StartObject(4); } in StartRecordBatch() 54 …ic static void AddLength(FlatBufferBuilder builder, long length) { builder.AddLong(0, length, 0); } in AddLength() [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
H A D | record_batch.go | 32 type RecordBatch struct { struct 33 FirstOffset int64 34 PartitionLeaderEpoch int32 35 Version int8 37 CompressionLevel int 38 Control bool 39 LogAppendTime bool 40 LastOffsetDelta int32 47 PartialTrailingRecord bool 48 IsTransactional bool [all …]
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
H A D | record_batch.go | 32 type RecordBatch struct { struct 33 FirstOffset int64 34 PartitionLeaderEpoch int32 35 Version int8 37 CompressionLevel int 38 Control bool 39 LogAppendTime bool 40 LastOffsetDelta int32 47 PartialTrailingRecord bool 48 IsTransactional bool [all …]
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
H A D | record_batch.go | 32 type RecordBatch struct { struct 33 FirstOffset int64 34 PartitionLeaderEpoch int32 35 Version int8 37 CompressionLevel int 38 Control bool 39 LogAppendTime bool 40 LastOffsetDelta int32 47 PartialTrailingRecord bool 48 IsTransactional bool [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/Flatbuf/ |
H A D | RecordBatch.cs | 14 internal struct RecordBatch : IFlatbufferObject struct 16 private Table __p; 17 public ByteBuffer ByteBuffer { get { return __p.bb; } } 20 public void __init(int _i, ByteBuffer _bb) { __p.bb_pos = _i; __p.bb = _bb; } in __init() 21 public RecordBatch __assign(int _i, ByteBuffer _bb) { __init(_i, _bb); return this; } in __assign() 28 …ublic int NodesLength { get { int o = __p.__offset(6); return o != 0 ? __p.__vector_len(o) : 0; } } 36 …lic int BuffersLength { get { int o = __p.__offset(8); return o != 0 ? __p.__vector_len(o) : 0; } } 38 public static Offset<RecordBatch> CreateRecordBatch(FlatBufferBuilder builder, in CreateRecordBatch() 49 public static void StartRecordBatch(FlatBufferBuilder builder) { builder.StartObject(3); } in StartRecordBatch() 50 …ic static void AddLength(FlatBufferBuilder builder, long length) { builder.AddLong(0, length, 0); } in AddLength() [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/Flatbuf/ |
H A D | RecordBatch.cs | 14 internal struct RecordBatch : IFlatbufferObject struct 16 private Table __p; 17 public ByteBuffer ByteBuffer { get { return __p.bb; } } 20 public void __init(int _i, ByteBuffer _bb) { __p.bb_pos = _i; __p.bb = _bb; } in __init() 21 public RecordBatch __assign(int _i, ByteBuffer _bb) { __init(_i, _bb); return this; } in __assign() 28 …ublic int NodesLength { get { int o = __p.__offset(6); return o != 0 ? __p.__vector_len(o) : 0; } } 36 …lic int BuffersLength { get { int o = __p.__offset(8); return o != 0 ? __p.__vector_len(o) : 0; } } 38 public static Offset<RecordBatch> CreateRecordBatch(FlatBufferBuilder builder, in CreateRecordBatch() 49 public static void StartRecordBatch(FlatBufferBuilder builder) { builder.StartObject(3); } in StartRecordBatch() 50 …ic static void AddLength(FlatBufferBuilder builder, long length) { builder.AddLong(0, length, 0); } in AddLength() [all …]
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
H A D | record_batch.go | 38 type RecordBatch struct { struct 39 FirstOffset int64 40 PartitionLeaderEpoch int32 41 Version int8 43 CompressionLevel int 44 Control bool 45 LastOffsetDelta int32 48 ProducerID int64 49 ProducerEpoch int16 52 PartialTrailingRecord bool [all …]
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
H A D | record_batch.go | 38 type RecordBatch struct { struct 39 FirstOffset int64 40 PartitionLeaderEpoch int32 41 Version int8 43 CompressionLevel int 44 Control bool 45 LastOffsetDelta int32 48 ProducerID int64 49 ProducerEpoch int16 52 PartialTrailingRecord bool [all …]
|
/dports/databases/arrow/apache-arrow-6.0.1/go/arrow/internal/flatbuf/ |
H A D | RecordBatch.go | 28 type RecordBatch struct { struct 29 _tab flatbuffers.Table 39 func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT) { 44 func (rcv *RecordBatch) Table() flatbuffers.Table { 50 func (rcv *RecordBatch) Length() int64 { 60 func (rcv *RecordBatch) MutateLength(n int64) bool { 65 func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool { 76 func (rcv *RecordBatch) NodesLength() int { 91 func (rcv *RecordBatch) Buffers(obj *Buffer, j int) bool { 102 func (rcv *RecordBatch) BuffersLength() int { [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/snowflakedb/gosnowflake/vendor/github.com/apache/arrow/go/arrow/internal/flatbuf/ |
H A D | RecordBatch.go | 28 type RecordBatch struct { struct 29 _tab flatbuffers.Table 39 func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT) { 44 func (rcv *RecordBatch) Table() flatbuffers.Table { 50 func (rcv *RecordBatch) Length() int64 { 60 func (rcv *RecordBatch) MutateLength(n int64) bool { 65 func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool { 76 func (rcv *RecordBatch) NodesLength() int { 91 func (rcv *RecordBatch) Buffers(obj *Buffer, j int) bool { 102 func (rcv *RecordBatch) BuffersLength() int {
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/go/arrow/internal/flatbuf/ |
H A D | RecordBatch.go | 28 type RecordBatch struct { struct 29 _tab flatbuffers.Table 39 func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT) { 44 func (rcv *RecordBatch) Table() flatbuffers.Table { 50 func (rcv *RecordBatch) Length() int64 { 60 func (rcv *RecordBatch) MutateLength(n int64) bool { 65 func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool { 76 func (rcv *RecordBatch) NodesLength() int { 91 func (rcv *RecordBatch) Buffers(obj *Buffer, j int) bool { 102 func (rcv *RecordBatch) BuffersLength() int {
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/go/arrow/internal/flatbuf/ |
H A D | RecordBatch.go | 28 type RecordBatch struct { struct 29 _tab flatbuffers.Table 39 func (rcv *RecordBatch) Init(buf []byte, i flatbuffers.UOffsetT) { 44 func (rcv *RecordBatch) Table() flatbuffers.Table { 50 func (rcv *RecordBatch) Length() int64 { 60 func (rcv *RecordBatch) MutateLength(n int64) bool { 65 func (rcv *RecordBatch) Nodes(obj *FieldNode, j int) bool { 76 func (rcv *RecordBatch) NodesLength() int { 91 func (rcv *RecordBatch) Buffers(obj *Buffer, j int) bool { 102 func (rcv *RecordBatch) BuffersLength() int {
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/arrow/src/ |
H A D | record_batch.rs | 40 pub struct RecordBatch { struct 45 impl RecordBatch { implementation 187 impl From<&StructArray> for RecordBatch { implementation 205 impl Into<StructArray> for RecordBatch { implementation 225 fn next_batch(&mut self) -> Result<Option<RecordBatch>>; in next_batch()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/arrow/src/ |
H A D | record_batch.rs | 40 pub struct RecordBatch { struct 45 impl RecordBatch { argument 263 impl From<&StructArray> for RecordBatch { implementation 307 fn next_batch(&mut self) -> Result<Option<RecordBatch>> { in next_batch()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/ |
H A D | RecordBatch.cs | 24 public partial class RecordBatch : IDisposable class 63 public RecordBatch(Schema schema, IEnumerable<IArrowArray> data, int length) in RecordBatch() method in Apache.Arrow.RecordBatch 76 …internal RecordBatch(Schema schema, IMemoryOwner<byte> memoryOwner, List<IArrowArray> arrays, int … in RecordBatch() method in Apache.Arrow.RecordBatch
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/ |
H A D | RecordBatch.cs | 24 public partial class RecordBatch : IDisposable class 63 public RecordBatch(Schema schema, IEnumerable<IArrowArray> data, int length) in RecordBatch() method in Apache.Arrow.RecordBatch 76 …internal RecordBatch(Schema schema, IMemoryOwner<byte> memoryOwner, List<IArrowArray> arrays, int … in RecordBatch() method in Apache.Arrow.RecordBatch
|
/dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow/ |
H A D | RecordBatch.cs | 24 public partial class RecordBatch : IDisposable class 65 public RecordBatch(Schema schema, IEnumerable<IArrowArray> data, int length) in RecordBatch() method in Apache.Arrow.RecordBatch 78 …internal RecordBatch(Schema schema, IMemoryOwner<byte> memoryOwner, List<IArrowArray> arrays, int … in RecordBatch() method in Apache.Arrow.RecordBatch
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/datafusion/src/physical_plan/ |
H A D | coalesce_batches.rs | 210 batches: &[RecordBatch], in concat_batches() 212 ) -> ArrowResult<RecordBatch> { in concat_batches() 266 fn create_vec_batches(schema: &Arc<Schema>, num_batches: usize) -> Vec<RecordBatch> { in create_vec_batches() 275 fn create_batch(schema: &Arc<Schema>) -> RecordBatch { in create_batch() 285 input_partitions: Vec<Vec<RecordBatch>>, in coalesce_batches() 287 ) -> Result<Vec<Vec<RecordBatch>>> { in coalesce_batches()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/test/Apache.Arrow.Tests/ |
H A D | ArrowStreamReaderTests.cs | 108 Func<ArrowStreamReader, RecordBatch, Task> verificationFunc, in TestReaderFromMemory() argument 150 Func<ArrowStreamReader, RecordBatch, Task> verificationFunc, in TestReaderFromStream() argument 191 …tic async Task TestReaderFromPartialReadStream(Func<ArrowStreamReader, RecordBatch, Task> verifica… in TestReaderFromPartialReadStream() argument
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/csharp/test/Apache.Arrow.Tests/ |
H A D | ArrowStreamReaderTests.cs | 108 Func<ArrowStreamReader, RecordBatch, Task> verificationFunc, in TestReaderFromMemory() argument 150 Func<ArrowStreamReader, RecordBatch, Task> verificationFunc, in TestReaderFromStream() argument 191 …tic async Task TestReaderFromPartialReadStream(Func<ArrowStreamReader, RecordBatch, Task> verifica… in TestReaderFromPartialReadStream() argument
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/datafusion/src/execution/physical_plan/ |
H A D | memory.rs | 63 partitions: &Vec<Vec<RecordBatch>>, in try_new() 88 data: Vec<RecordBatch>, in new() 126 data: Vec<RecordBatch>, in try_new() 146 fn next(&mut self) -> Result<Option<RecordBatch>> { in next()
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/integration-testing/src/flight_client_scenarios/ |
H A D | integration_test.rs | 71 original_data: Vec<RecordBatch>, in upload_data() 126 batch: &RecordBatch, in send_batch() 146 expected_data: &[RecordBatch], in verify_data() 181 expected_data: &[RecordBatch], in consume_flight_location()
|
/dports/databases/arrow/apache-arrow-6.0.1/csharp/test/Apache.Arrow.Tests/ |
H A D | ArrowStreamReaderTests.cs | 110 Func<ArrowStreamReader, RecordBatch, Task> verificationFunc, in TestReaderFromMemory() argument 156 Func<ArrowStreamReader, RecordBatch, Task> verificationFunc, in TestReaderFromStream() argument 201 …tic async Task TestReaderFromPartialReadStream(Func<ArrowStreamReader, RecordBatch, Task> verifica… in TestReaderFromPartialReadStream() argument
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/js/src/ |
H A D | recordbatch.ts | 35 export interface RecordBatch<T extends { [key: string]: DataType } = any> { interface 41 export class RecordBatch<T extends { [key: string]: DataType } = any> class
|
/dports/databases/arrow/apache-arrow-6.0.1/js/src/ |
H A D | recordbatch.ts | 35 export interface RecordBatch<T extends { [key: string]: DataType } = any> { interface 41 export class RecordBatch<T extends { [key: string]: DataType } = any> class
|