DorisFlightSqlProducer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total626 of 1,56960%21 of 6065%521001663843770
executeQueryStatement(String, ConnectContext, String, FlightDescriptor)9618665%101050%811216101
lambda$acceptPutPreparedStatementUpdate$9(FlightStream, FlightProducer.StreamListener)600%40%33181811
lambda$getStreamStatementResult$0(ConnectContext, String, FlightProducer.ServerStreamListener)390%n/a11131311
lambda$getStreamTables$12(FlightSql.CommandGetTables, FlightProducer.ServerStreamListener, ConnectContext)330%20%22111111
streamMetadata(FlightProducer.CallContext, FlightProducer.ServerStreamListener, DorisFlightSqlProducer.MetadataStream)300%n/a11101011
lambda$getStreamSchemas$11(FlightSql.CommandGetDbSchemas, FlightProducer.ServerStreamListener, ConnectContext)280%n/a11101011
getStreamStatementResult(String, FlightProducer.ServerStreamListener)260%n/a116611
lambda$getStreamCatalogs$10(FlightProducer.ServerStreamListener, ConnectContext)250%n/a119911
lambda$closePreparedStatement$2(FlightProducer.CallContext, FlightSql.ActionClosePreparedStatementRequest, FlightProducer.StreamListener)22518%n/a016901
handleStreamException(Throwable, String, FlightProducer.ServerStreamListener)190%n/a113311
setSessionOptions(SetSessionOptionsRequest, FlightProducer.CallContext, FlightProducer.StreamListener)173466%n/a0141401
getSessionOptions(GetSessionOptionsRequest, FlightProducer.CallContext, FlightProducer.StreamListener)173366%n/a0141401
getFlightInfoTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightDescriptor)130%20%224411
createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest, String, ConnectContext, FlightProducer.StreamListener)118388%1375%1342801
getStreamSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightProducer.ServerStreamListener)90%n/a112211
getStreamTables(FlightSql.CommandGetTables, 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
getStreamStatement(FlightSql.TicketStatementQuery, 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
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
lambda$streamMetadata$15(DorisFlightSqlProducer.MetadataStream, ConnectContext)40%n/a111111
lambda$closePreparedStatement$1(ConnectContext, String)40%n/a111111
buildCreatePreparedStatementResult(ByteString, Schema, Schema)32488%2250%230601
discoverSchema(ConnectContext, String)32388%n/a012801
DorisFlightSqlProducer(Location, FlightSessionsManager)46100%n/a0101201
queryFailure(QueryState, String, Throwable)37100%2100%020701
getFlightInfoStatement(FlightSql.CommandStatementQuery, FlightProducer.CallContext, FlightDescriptor)37100%n/a010801
preparedQuery(ConnectContext, String)31100%6100%0401101
closeSession(CloseSessionRequest, FlightProducer.CallContext, FlightProducer.StreamListener)29100%n/a0101001
getFlightInfoForSchema(Message, FlightDescriptor, Schema)29100%n/a010301
preparedStatementId(FlightProducer.CallContext, ByteString)26100%4100%030501
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
listActions(FlightProducer.CallContext, FlightProducer.StreamListener)17100%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
close()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
lambda$setSessionOptions$13(ConnectContext, SetSessionOptionsRequest)5100%n/a010101
lambda$getSessionOptions$14(ConnectContext)3100%n/a010101