Home
last modified time | relevance | path

Searched defs:RecordBatch (Results 1 – 25 of 261) sorted by relevance

1234567891011

/dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow/Flatbuf/
H A DRecordBatch.cs14 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 Drecord_batch.go32 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 Drecord_batch.go32 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 Drecord_batch.go32 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 DRecordBatch.cs14 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 DRecordBatch.cs14 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 Drecord_batch.go38 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 Drecord_batch.go38 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 DRecordBatch.go28 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 DRecordBatch.go28 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 DRecordBatch.go28 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 DRecordBatch.go28 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 Drecord_batch.rs40 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 Drecord_batch.rs40 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 DRecordBatch.cs24 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 DRecordBatch.cs24 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 DRecordBatch.cs24 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 Dcoalesce_batches.rs210 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 DArrowStreamReaderTests.cs108 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 DArrowStreamReaderTests.cs108 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 Dmemory.rs63 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 Dintegration_test.rs71 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 DArrowStreamReaderTests.cs110 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 Drecordbatch.ts35 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 Drecordbatch.ts35 export interface RecordBatch<T extends { [key: string]: DataType } = any> { interface
41 export class RecordBatch<T extends { [key: string]: DataType } = any> class

1234567891011