GH-38938: [FlightRPC] Fix spelling

cpp/src/arrow/flight/ArrowFlightTestingConfig.cmake.in

@@ -32,7 +32,7 @@ find_dependency(ArrowTesting)
 
 include("${CMAKE_CURRENT_LIST_DIR}/ArrowFlightTestingTargets.cmake")
 
-arrow_keep_backward_compatibility(ArrowFlightTetsing arrow_flight_testing)
+arrow_keep_backward_compatibility(ArrowFlightTesting arrow_flight_testing)
 
 check_required_components(ArrowFlightTesting)
 

cpp/src/arrow/flight/client.h

@@ -299,7 +299,7 @@ class ARROW_FLIGHT_EXPORT FlightClient {
   /// \brief Request and poll a long running query
   /// \param[in] options Per-RPC options
   /// \param[in] descriptor the dataset request or a descriptor returned by a
-  /// prioir PollFlightInfo call
+  /// prior PollFlightInfo call
   /// \return Arrow result with the PollInfo describing the status of
   /// the requested query
   arrow::Result<std::unique_ptr<PollInfo>> PollFlightInfo(

cpp/src/arrow/flight/cookie_internal.h

@@ -35,14 +35,14 @@ namespace flight {
 namespace internal {
 
 /// \brief Case insensitive comparator for use by cookie caching map. Cookies are not
-/// case sensitive.
+/// case-sensitive.
 class ARROW_FLIGHT_EXPORT CaseInsensitiveComparator {
  public:
   bool operator()(const std::string& t1, const std::string& t2) const;
 };
 
 /// \brief Case insensitive hasher for use by cookie caching map. Cookies are not
-/// case sensitive.
+/// case-sensitive.
 class ARROW_FLIGHT_EXPORT CaseInsensitiveHash {
  public:
   size_t operator()(const std::string& key) const;

cpp/src/arrow/flight/flight_internals_test.cc

@@ -562,7 +562,7 @@ class TestCookieParsing : public ::testing::Test {
     EXPECT_EQ(cookie_as_string, cookie.AsCookieString());
   }
 
-  void VerifyCookieDateConverson(std::string date, const std::string& converted_date) {
+  void VerifyCookieDateConversion(std::string date, const std::string& converted_date) {
     internal::Cookie::ConvertCookieDate(&date);
     EXPECT_EQ(converted_date, date);
   }
@@ -646,21 +646,21 @@ TEST_F(TestCookieParsing, ToString) {
 }
 
 TEST_F(TestCookieParsing, DateConversion) {
-  VerifyCookieDateConverson("Mon, 01 jan 2038 22:15:36 GMT;", "01 01 2038 22:15:36");
-  VerifyCookieDateConverson("TUE, 10 Feb 2038 22:15:36 GMT", "10 02 2038 22:15:36");
-  VerifyCookieDateConverson("WED, 20 MAr 2038 22:15:36 GMT;", "20 03 2038 22:15:36");
-  VerifyCookieDateConverson("thu, 15 APR 2038 22:15:36 GMT", "15 04 2038 22:15:36");
-  VerifyCookieDateConverson("Fri, 30 mAY 2038 22:15:36 GMT;", "30 05 2038 22:15:36");
-  VerifyCookieDateConverson("Sat, 03 juN 2038 22:15:36 GMT", "03 06 2038 22:15:36");
-  VerifyCookieDateConverson("Sun, 01 JuL 2038 22:15:36 GMT;", "01 07 2038 22:15:36");
-  VerifyCookieDateConverson("Fri, 06 aUg 2038 22:15:36 GMT", "06 08 2038 22:15:36");
-  VerifyCookieDateConverson("Fri, 01 SEP 2038 22:15:36 GMT;", "01 09 2038 22:15:36");
-  VerifyCookieDateConverson("Fri, 01 OCT 2038 22:15:36 GMT", "01 10 2038 22:15:36");
-  VerifyCookieDateConverson("Fri, 01 Nov 2038 22:15:36 GMT;", "01 11 2038 22:15:36");
-  VerifyCookieDateConverson("Fri, 01 deC 2038 22:15:36 GMT", "01 12 2038 22:15:36");
-  VerifyCookieDateConverson("", "");
-  VerifyCookieDateConverson("Fri, 01 INVALID 2038 22:15:36 GMT;",
-                            "01 INVALID 2038 22:15:36");
+  VerifyCookieDateConversion("Mon, 01 jan 2038 22:15:36 GMT;", "01 01 2038 22:15:36");
+  VerifyCookieDateConversion("TUE, 10 Feb 2038 22:15:36 GMT", "10 02 2038 22:15:36");
+  VerifyCookieDateConversion("WED, 20 MAr 2038 22:15:36 GMT;", "20 03 2038 22:15:36");
+  VerifyCookieDateConversion("thu, 15 APR 2038 22:15:36 GMT", "15 04 2038 22:15:36");
+  VerifyCookieDateConversion("Fri, 30 mAY 2038 22:15:36 GMT;", "30 05 2038 22:15:36");
+  VerifyCookieDateConversion("Sat, 03 juN 2038 22:15:36 GMT", "03 06 2038 22:15:36");
+  VerifyCookieDateConversion("Sun, 01 JuL 2038 22:15:36 GMT;", "01 07 2038 22:15:36");
+  VerifyCookieDateConversion("Fri, 06 aUg 2038 22:15:36 GMT", "06 08 2038 22:15:36");
+  VerifyCookieDateConversion("Fri, 01 SEP 2038 22:15:36 GMT;", "01 09 2038 22:15:36");
+  VerifyCookieDateConversion("Fri, 01 OCT 2038 22:15:36 GMT", "01 10 2038 22:15:36");
+  VerifyCookieDateConversion("Fri, 01 Nov 2038 22:15:36 GMT;", "01 11 2038 22:15:36");
+  VerifyCookieDateConversion("Fri, 01 deC 2038 22:15:36 GMT", "01 12 2038 22:15:36");
+  VerifyCookieDateConversion("", "");
+  VerifyCookieDateConversion("Fri, 01 INVALID 2038 22:15:36 GMT;",
+                             "01 INVALID 2038 22:15:36");
 }
 
 TEST_F(TestCookieParsing, ParseCookieAttribute) {

cpp/src/arrow/flight/flight_test.cc

@@ -453,7 +453,7 @@ class TestTls : public ::testing::Test {
     // get initialized.
     // https://github.com/grpc/grpc/issues/13856
     // https://github.com/grpc/grpc/issues/20311
-    // In general, gRPC on MacOS struggles with TLS (both in the sense
+    // In general, gRPC on macOS struggles with TLS (both in the sense
     // of thread-locals and encryption)
     grpc_init();
 

cpp/src/arrow/flight/integration_tests/test_integration_server.cc

@@ -40,7 +40,7 @@
 #include "arrow/flight/test_util.h"
 
 DEFINE_int32(port, 31337, "Server port to listen on");
-DEFINE_string(scenario, "", "Integration test senario to run");
+DEFINE_string(scenario, "", "Integration test scenario to run");
 
 namespace arrow {
 namespace flight {

cpp/src/arrow/flight/server.h

@@ -226,7 +226,7 @@ class ARROW_FLIGHT_EXPORT FlightServerBase {
   /// \brief Shut down the server, blocking until current requests finish.
   ///
   /// Can be called from a signal handler or another thread while Serve()
-  /// blocks. Optionally a deadline can be set. Once the the deadline expires
+  /// blocks. Optionally a deadline can be set. Once the deadline expires
   /// server will wait until remaining running calls complete.
   ///
   /// Should only be called once.
@@ -262,7 +262,7 @@ class ARROW_FLIGHT_EXPORT FlightServerBase {
   /// \brief Retrieve the current status of the target query
   /// \param[in] context The call context.
   /// \param[in] request the dataset request or a descriptor returned by a
-  /// prioir PollFlightInfo call
+  /// prior PollFlightInfo call
   /// \param[out] info the returned retry info provider
   /// \return Status
   virtual Status PollFlightInfo(const ServerCallContext& context,

cpp/src/arrow/flight/sql/example/sqlite_server.cc

@@ -598,7 +598,7 @@ class SQLiteFlightSqlServer::Impl {
       const ServerCallContext& context, const GetPrimaryKeys& command) {
     std::stringstream table_query;
 
-    // The field key_name can not be recovered by the sqlite, so it is being set
+    // The field key_name cannot be recovered by the sqlite, so it is being set
     // to null following the same pattern for catalog_name and schema_name.
     table_query << "SELECT null as catalog_name, null as schema_name, table_name, "
                    "name as column_name,  pk as key_sequence, null as key_name\n"

cpp/src/arrow/flight/sql/example/sqlite_statement.cc

@@ -130,7 +130,7 @@ arrow::Result<std::shared_ptr<Schema>> SqliteStatement::GetSchema() const {
       if (column_decltype != NULLPTR) {
         ARROW_ASSIGN_OR_RAISE(data_type, GetArrowType(column_decltype));
       } else {
-        // If it can not determine the actual column type, return a dense_union type
+        // If it cannot determine the actual column type, return a dense_union type
         // covering any type SQLite supports.
         data_type = GetUnknownColumnDataType();
       }

cpp/src/arrow/flight/sql/example/sqlite_type_info.h

@@ -24,11 +24,11 @@ namespace flight {
 namespace sql {
 namespace example {
 
-/// \brief Gets the harded-coded type info from Sqlite for all data types.
+/// \brief Gets the hard-coded type info from Sqlite for all data types.
 /// \return A record batch.
 arrow::Result<std::shared_ptr<RecordBatch>> DoGetTypeInfoResult();
 
-/// \brief Gets the harded-coded type info from Sqlite filtering
+/// \brief Gets the hard-coded type info from Sqlite filtering
 ///        for a specific data type.
 /// \return A record batch.
 arrow::Result<std::shared_ptr<RecordBatch>> DoGetTypeInfoResult(int data_type_filter);

cpp/src/arrow/flight/sql/server.h

@@ -590,7 +590,7 @@ class ARROW_FLIGHT_SQL_EXPORT FlightSqlServerBase : public FlightServerBase {
 
   /// \brief Commit/rollback a transaction.
   /// \param[in] context  The call context.
-  /// \param[in] request  The tranaction.
+  /// \param[in] request  The transaction.
   virtual Status EndTransaction(const ServerCallContext& context,
                                 const ActionEndTransactionRequest& request);
 

cpp/src/arrow/flight/sql/types.h

@@ -535,7 +535,7 @@ struct ARROW_FLIGHT_SQL_EXPORT SqlInfoOptions {
     /// allowed for a column name.
     SQL_MAX_COLUMN_NAME_LENGTH = 543,
 
-    /// Retrieves a int64 value representing the the maximum number of columns
+    /// Retrieves a int64 value representing the maximum number of columns
     /// allowed in a GROUP BY clause.
     SQL_MAX_COLUMNS_IN_GROUP_BY = 544,
 
@@ -846,7 +846,7 @@ struct ARROW_FLIGHT_SQL_EXPORT SqlInfoOptions {
 
   /// The level of support for Flight SQL transaction RPCs.
   enum SqlSupportedTransaction {
-    /// Unknown/not indicated/no supoprt
+    /// Unknown/not indicated/no support
     SQL_SUPPORTED_TRANSACTION_NONE = 0,
     /// Transactions, but not savepoints.
     SQL_SUPPORTED_TRANSACTION_TRANSACTION = 1,

cpp/src/arrow/flight/types.h

@@ -575,7 +575,7 @@ struct ARROW_FLIGHT_EXPORT SchemaResult {
   std::string raw_schema_;
 };
 
-/// \brief The access coordinates for retireval of a dataset, returned by
+/// \brief The access coordinates for retrieval of a dataset, returned by
 /// GetFlightInfo
 class ARROW_FLIGHT_EXPORT FlightInfo {
  public:
@@ -604,7 +604,7 @@ class ARROW_FLIGHT_EXPORT FlightInfo {
   ///   bookkeeping
   /// \param[in,out] dictionary_memo for dictionary bookkeeping, will
   /// be modified
-  /// \return Arrrow result with the reconstructed Schema
+  /// \return Arrow result with the reconstructed Schema
   arrow::Result<std::shared_ptr<Schema>> GetSchema(
       ipc::DictionaryMemo* dictionary_memo) const;
 

csharp/examples/FlightClientExample/Program.cs

@@ -81,7 +81,7 @@ public static async Task Main(string[] args)
                 Console.WriteLine($"Read batch from flight server: \n {batch}")  ;
             }
 
-            // See available comands on this server
+            // See available commands on this server
             var action_stream = client.ListActions();
             Console.WriteLine("Actions:");
             while (await action_stream.ResponseStream.MoveNext())

csharp/src/Apache.Arrow.Flight/FlightRecordBatchStreamReader.cs

@@ -38,11 +38,11 @@ public abstract class FlightRecordBatchStreamReader : IAsyncStreamReader<RecordB
         //Temporary until .NET 5.0 upgrade
         private static ValueTask CompletedValueTask = new ValueTask();
 
-        private readonly RecordBatcReaderImplementation _arrowReaderImplementation;
+        private readonly RecordBatchReaderImplementation _arrowReaderImplementation;
 
         private protected FlightRecordBatchStreamReader(IAsyncStreamReader<Protocol.FlightData> flightDataStream)
         {
-            _arrowReaderImplementation = new RecordBatcReaderImplementation(flightDataStream);
+            _arrowReaderImplementation = new RecordBatchReaderImplementation(flightDataStream);
         }
 
         public ValueTask<Schema> Schema => _arrowReaderImplementation.ReadSchema();
@@ -53,7 +53,7 @@ internal ValueTask<FlightDescriptor> GetFlightDescriptor()
         }        
 
         /// <summary>
-        /// Get the application metadata from the latest recieved record batch
+        /// Get the application metadata from the latest received record batch
         /// </summary>
         public IReadOnlyList<ByteString> ApplicationMetadata => _arrowReaderImplementation.ApplicationMetadata;
 

csharp/src/Apache.Arrow.Flight/Internal/RecordBatcReaderImplementation.cs → csharp/src/Apache.Arrow.Flight/Internal/RecordBatchReaderImplementation.cs

@@ -25,13 +25,13 @@
 
 namespace Apache.Arrow.Flight.Internal
 {
-    internal class RecordBatcReaderImplementation : ArrowReaderImplementation
+    internal class RecordBatchReaderImplementation : ArrowReaderImplementation
     {
         private readonly IAsyncStreamReader<Protocol.FlightData> _flightDataStream;
         private FlightDescriptor _flightDescriptor;
         private readonly List<ByteString> _applicationMetadatas;
 
-        public RecordBatcReaderImplementation(IAsyncStreamReader<Protocol.FlightData> streamReader)
+        public RecordBatchReaderImplementation(IAsyncStreamReader<Protocol.FlightData> streamReader)
         {
             _flightDataStream = streamReader;
             _applicationMetadatas = new List<ByteString>();

csharp/src/Apache.Arrow.Flight/Internal/StreamReader.cs

@@ -27,7 +27,7 @@ namespace Apache.Arrow.Flight.Internal
     /// This is a helper class that allows conversions from gRPC types to the Arrow types.
     /// It maintains the stream so data can be read as soon as possible.
     /// </summary>
-    /// <typeparam name="TIn">In paramter from gRPC</typeparam>
+    /// <typeparam name="TIn">In parameter from gRPC</typeparam>
     /// <typeparam name="TOut">The arrow type returned</typeparam>
     internal class StreamReader<TIn, TOut> : IAsyncStreamReader<TOut>
     {

dev/tasks/linux-packages/apache-arrow/debian/libarrow-flight-sql-glib-doc.doc-base

@@ -1,7 +1,7 @@
 Document: arrow-flight-sql-glib
 Title: Apache Arrow Flight SQL GLib Reference Manual
 Author: The Apache Software Foundation
-Abstract: Apache Arrow Flight SQL GLib provides a client-server framework to intract with SQL databases using Apache Arrow in-memory format and Apache Arrow Flight.
+Abstract: Apache Arrow Flight SQL GLib provides a client-server framework to interact with SQL databases using Apache Arrow in-memory format and Apache Arrow Flight.
 Section: Programming
 
 Format: HTML

docs/source/format/Flight.rst

@@ -103,7 +103,7 @@ A client that wishes to download the data would:
    different endpoints may be interleaved to allow parallel fetches.
 
    Note that since some clients may ignore ``FlightInfo.ordered``, if
-   ordering is important and client support can not be ensured,
+   ordering is important and client support cannot be ensured,
    servers should return a single endpoint.
 
    The response also contains other metadata, like the schema, and

format/FlightSql.proto

@@ -551,7 +551,7 @@ enum SqlInfo {
   // Retrieves a int64 value representing the maximum number of characters allowed for a column name.
   SQL_MAX_COLUMN_NAME_LENGTH = 543;
 
-  // Retrieves a int64 value representing the the maximum number of columns allowed in a GROUP BY clause.
+  // Retrieves a int64 value representing the maximum number of columns allowed in a GROUP BY clause.
   SQL_MAX_COLUMNS_IN_GROUP_BY = 544;
 
   // Retrieves a int64 value representing the maximum number of columns allowed in an index.
@@ -943,7 +943,7 @@ enum SqlSupportsConvert {
 
 /**
  * The JDBC/ODBC-defined type of any object.
- * All the values here are the sames as in the JDBC and ODBC specs.
+ * All the values here are the same as in the JDBC and ODBC specs.
  */
 enum XdbcDataType {
   XDBC_UNKNOWN_TYPE = 0;
@@ -1023,14 +1023,14 @@ enum Nullable {
   NULLABILITY_NULLABLE = 1;
 
   /**
-   * Indicates that nullability of the fields can not be determined.
+   * Indicates that nullability of the fields cannot be determined.
    */
   NULLABILITY_UNKNOWN = 2;
 }
 
 enum Searchable {
   /**
-   * Indicates that column can not be used in a WHERE clause.
+   * Indicates that column cannot be used in a WHERE clause.
    */
   SEARCHABLE_NONE = 0;
 
@@ -1196,7 +1196,7 @@ message CommandGetDbSchemas {
  *  - ARROW:FLIGHT:SQL:PRECISION         - Column precision/size
  *  - ARROW:FLIGHT:SQL:SCALE             - Column scale/decimal digits if applicable
  *  - ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
- *  - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case sensitive, "0" otherwise.
+ *  - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  *  - ARROW:FLIGHT:SQL:IS_READ_ONLY      - "1" indicates if the column is read only, "0" otherwise.
  *  - ARROW:FLIGHT:SQL:IS_SEARCHABLE     - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  * The returned data should be ordered by catalog_name, db_schema_name, table_name, then table_type, followed by table_schema if requested.
@@ -1676,7 +1676,7 @@ message ActionEndSavepointRequest {
  *    - ARROW:FLIGHT:SQL:PRECISION         - Column precision/size
  *    - ARROW:FLIGHT:SQL:SCALE             - Column scale/decimal digits if applicable
  *    - ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
- *    - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case sensitive, "0" otherwise.
+ *    - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  *    - ARROW:FLIGHT:SQL:IS_READ_ONLY      - "1" indicates if the column is read only, "0" otherwise.
  *    - ARROW:FLIGHT:SQL:IS_SEARCHABLE     - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  *  - GetFlightInfo: execute the query.
@@ -1702,7 +1702,7 @@ message CommandStatementQuery {
  *    - ARROW:FLIGHT:SQL:PRECISION         - Column precision/size
  *    - ARROW:FLIGHT:SQL:SCALE             - Column scale/decimal digits if applicable
  *    - ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
- *    - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case sensitive, "0" otherwise.
+ *    - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  *    - ARROW:FLIGHT:SQL:IS_READ_ONLY      - "1" indicates if the column is read only, "0" otherwise.
  *    - ARROW:FLIGHT:SQL:IS_SEARCHABLE     - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  *  - GetFlightInfo: execute the query.
@@ -1740,7 +1740,7 @@ message TicketStatementQuery {
  *    - ARROW:FLIGHT:SQL:PRECISION         - Column precision/size
  *    - ARROW:FLIGHT:SQL:SCALE             - Column scale/decimal digits if applicable
  *    - ARROW:FLIGHT:SQL:IS_AUTO_INCREMENT - "1" indicates if the column is auto incremented, "0" otherwise.
- *    - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case sensitive, "0" otherwise.
+ *    - ARROW:FLIGHT:SQL:IS_CASE_SENSITIVE - "1" indicates if the column is case-sensitive, "0" otherwise.
  *    - ARROW:FLIGHT:SQL:IS_READ_ONLY      - "1" indicates if the column is read only, "0" otherwise.
  *    - ARROW:FLIGHT:SQL:IS_SEARCHABLE     - "1" indicates if the column is searchable via WHERE clause, "0" otherwise.
  *  - DoPut: bind parameter values. All of the bound parameter sets will be executed as a single atomic execution.
@@ -1755,7 +1755,7 @@ message CommandPreparedStatementQuery {
 
 /*
  * Represents a SQL update query. Used in the command member of FlightDescriptor
- * for the the RPC call DoPut to cause the server to execute the included SQL update.
+ * for the RPC call DoPut to cause the server to execute the included SQL update.
  */
 message CommandStatementUpdate {
   option (experimental) = true;
@@ -1768,7 +1768,7 @@ message CommandStatementUpdate {
 
 /*
  * Represents a SQL update query. Used in the command member of FlightDescriptor
- * for the the RPC call DoPut to cause the server to execute the included
+ * for the RPC call DoPut to cause the server to execute the included
  * prepared statement handle as an update.
  */
 message CommandPreparedStatementUpdate {

python/pyarrow/_flight.pyx

@@ -2664,7 +2664,7 @@ cdef class TracingServerMiddlewareFactory(ServerMiddlewareFactory):
 cdef class ServerMiddleware(_Weakrefable):
     """Server-side middleware for a call, instantiated per RPC.
 
-    Methods here should be fast and must be infalliable: they should
+    Methods here should be fast and must be infallible: they should
     not raise exceptions or stall indefinitely.
 
     """

python/pyarrow/tests/test_flight.py

@@ -577,7 +577,7 @@ def is_valid(self, token):
 
 def case_insensitive_header_lookup(headers, lookup_key):
     """Lookup the value of given key in the given headers.
-       The key lookup is case insensitive.
+       The key lookup is case-insensitive.
     """
     for key in headers:
         if key.lower() == lookup_key.lower():