DorisFlightSqlProducer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total518 of 1,56966%21 of 6065%471001403843070
lambda$acceptPutPreparedStatementUpdate$9(FlightStream, FlightProducer.StreamListener)600%40%33181811
executeQueryStatement(String, ConnectContext, String, FlightDescriptor)3025289%71365%61176101
lambda$getStreamSchemas$11(FlightSql.CommandGetDbSchemas, FlightProducer.ServerStreamListener, ConnectContext)280%n/a11101011
setSessionOptions(SetSessionOptionsRequest, FlightProducer.CallContext, FlightProducer.StreamListener)262549%n/a0171401
getSessionOptions(GetSessionOptionsRequest, FlightProducer.CallContext, FlightProducer.StreamListener)262448%n/a0171401
queryFailure(QueryState, String, Throwable)261129%1150%125701
lambda$getStreamCatalogs$10(FlightProducer.ServerStreamListener, ConnectContext)250%n/a119911
handleStreamException(Throwable, String, FlightProducer.ServerStreamListener)190%n/a113311
lambda$getStreamStatementResult$0(ConnectContext, String, FlightProducer.ServerStreamListener)172256%n/a0151301
listActions(FlightProducer.CallContext, FlightProducer.StreamListener)170%20%225511
getFlightInfoStatement(FlightSql.CommandStatementQuery, FlightProducer.CallContext, FlightDescriptor)162156%n/a014801
streamMetadata(FlightProducer.CallContext, FlightProducer.ServerStreamListener, DorisFlightSqlProducer.MetadataStream)151550%n/a0161001
closeSession(CloseSessionRequest, FlightProducer.CallContext, FlightProducer.StreamListener)141551%n/a0151001
createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest, String, ConnectContext, FlightProducer.StreamListener)118388%1375%1342801
close()90%n/a112211
getStreamSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightProducer.ServerStreamListener)90%n/a112211
lambda$createPreparedStatement$8(FlightProducer.CallContext, FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.StreamListener)81869%n/a013701
getStreamCatalogs(FlightProducer.CallContext, FlightProducer.ServerStreamListener)80%n/a112211
serializeMetadata(Schema)71669%n/a012501
getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightProducer.ServerStreamListener)70%n/a112211
getStreamSqlInfo(FlightSql.CommandGetSqlInfo, FlightProducer.CallContext, FlightProducer.ServerStreamListener)70%n/a112211
getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoCatalogs(FlightSql.CommandGetCatalogs, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoTableTypes(FlightSql.CommandGetTableTypes, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
getFlightInfoCrossReference(FlightSql.CommandGetCrossReference, FlightProducer.CallContext, FlightDescriptor)60%n/a111111
executePreparedStatement(String, ConnectContext, String, FlightDescriptor)57994%6100%0421901
lambda$closePreparedStatement$2(FlightProducer.CallContext, FlightSql.ActionClosePreparedStatementRequest, FlightProducer.StreamListener)52281%n/a013901
preparedStatementId(FlightProducer.CallContext, ByteString)52180%2250%231501
listFlights(FlightProducer.CallContext, Criteria, FlightProducer.StreamListener)50%n/a111111
doExchange(FlightProducer.CallContext, FlightStream, FlightProducer.ServerStreamListener)50%n/a111111
acceptPutStatement(FlightSql.CommandStatementUpdate, FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener)50%n/a111111
acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate, FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener)50%n/a111111
acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener)50%n/a112211
getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamTableTypes(FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamExportedKeys(FlightSql.CommandGetExportedKeys, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamImportedKeys(FlightSql.CommandGetImportedKeys, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
getStreamCrossReference(FlightSql.CommandGetCrossReference, FlightProducer.CallContext, FlightProducer.ServerStreamListener)50%n/a111111
buildCreatePreparedStatementResult(ByteString, Schema, Schema)32488%2250%230601
discoverSchema(ConnectContext, String)32388%n/a012801
getFlightInfoTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightDescriptor)1184%1150%121401
lambda$getStreamTables$12(FlightSql.CommandGetTables, FlightProducer.ServerStreamListener, ConnectContext)3296%1150%1201101
DorisFlightSqlProducer(Location, FlightSessionsManager)46100%n/a0101201
preparedQuery(ConnectContext, String)31100%6100%0401101
getFlightInfoForSchema(Message, FlightDescriptor, Schema)29100%n/a010301
getStreamStatementResult(String, FlightProducer.ServerStreamListener)26100%n/a010601
getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightDescriptor)23100%n/a010301
static {...}21100%n/a010401
getSchemaPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightDescriptor)20100%n/a010301
checkPreparedSchema(ConnectContext, String, FlightProtocolAdapter.PreparedQuery)20100%2100%020601
lambda$getSchemaPreparedStatement$6(ConnectContext, String)20100%2100%020501
getSchemaStatement(FlightSql.CommandStatementQuery, FlightProducer.CallContext, FlightDescriptor)15100%n/a010201
closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest, FlightProducer.CallContext, FlightProducer.StreamListener)10100%n/a010201
createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.CallContext, FlightProducer.StreamListener)10100%n/a010201
lambda$getFlightInfoStatement$3(FlightProducer.CallContext, ConnectContext, FlightSql.CommandStatementQuery, FlightDescriptor)10100%n/a010101
getStreamTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightProducer.ServerStreamListener)9100%n/a010201
lambda$createPreparedStatement$7(FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.CallContext, ConnectContext, FlightProducer.StreamListener)8100%n/a010201
lambda$getSchemaStatement$5(ConnectContext, FlightSql.CommandStatementQuery)8100%n/a010101
lambda$getFlightInfoPreparedStatement$4(FlightProducer.CallContext, ConnectContext, String, FlightDescriptor)8100%n/a010101
getStreamStatement(FlightSql.TicketStatementQuery, FlightProducer.CallContext, FlightProducer.ServerStreamListener)7100%n/a010201
lambda$setSessionOptions$13(ConnectContext, SetSessionOptionsRequest)5100%n/a010101
lambda$streamMetadata$15(DorisFlightSqlProducer.MetadataStream, ConnectContext)4100%n/a010101
lambda$closePreparedStatement$1(ConnectContext, String)4100%n/a010101
lambda$getSessionOptions$14(ConnectContext)3100%n/a010101