1- // Licensed to the Apache Software Foundation (ASF) under one or more
1+ // Licensed to the Apache Software Foundation (ASF) under one or more
22// contributor license agreements. See the NOTICE file distributed with
33// this work for additional information regarding copyright ownership.
44// The ASF licenses this file to You under the Apache License, Version 2.0
@@ -38,15 +38,19 @@ internal FlightInfo(Protocol.FlightInfo flightInfo)
3838
3939 TotalBytes = flightInfo . TotalBytes ;
4040 TotalRecords = flightInfo . TotalRecords ;
41+ Ordered = flightInfo . Ordered ;
42+ AppMetadata = flightInfo . AppMetadata ;
4143 }
4244
43- public FlightInfo ( Schema schema , FlightDescriptor descriptor , IReadOnlyList < FlightEndpoint > endpoints , long totalRecords = - 1 , long totalBytes = - 1 )
45+ public FlightInfo ( Schema schema , FlightDescriptor descriptor , IReadOnlyList < FlightEndpoint > endpoints , long totalRecords = - 1 , long totalBytes = - 1 , bool ordered = false , ByteString appMetadata = null )
4446 {
4547 Schema = schema ;
4648 Descriptor = descriptor ;
4749 Endpoints = endpoints ;
4850 TotalBytes = totalBytes ;
4951 TotalRecords = totalRecords ;
52+ Ordered = ordered ;
53+ AppMetadata = appMetadata ;
5054 }
5155
5256 public FlightDescriptor Descriptor { get ; }
@@ -57,6 +61,10 @@ public FlightInfo(Schema schema, FlightDescriptor descriptor, IReadOnlyList<Flig
5761
5862 public long TotalRecords { get ; }
5963
64+ public bool Ordered { get ; }
65+
66+ public ByteString AppMetadata { get ; }
67+
6068 public IReadOnlyList < FlightEndpoint > Endpoints { get ; }
6169
6270 internal Protocol . FlightInfo ToProtocol ( )
@@ -67,7 +75,9 @@ internal Protocol.FlightInfo ToProtocol()
6775 Schema = serializedSchema ,
6876 FlightDescriptor = Descriptor . ToProtocol ( ) ,
6977 TotalBytes = TotalBytes ,
70- TotalRecords = TotalRecords
78+ TotalRecords = TotalRecords ,
79+ Ordered = Ordered ,
80+ AppMetadata = AppMetadata
7181 } ;
7282
7383 foreach ( var endpoint in Endpoints )
0 commit comments