DorisFlightSqlProducer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total436 of 1,31066%16 of 3655%35801133232362
lambda$acceptPutPreparedStatementUpdate$7(FlightStream, FlightProducer.StreamListener)600%40%33181811
createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest, String, ConnectContext, FlightProducer.StreamListener)355862%n/a01102501
executeQueryStatement(String, ConnectContext, String, FlightDescriptor)3023488%71365%61175901
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
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
close()90%n/a112211
lambda$createPreparedStatement$6(FlightProducer.CallContext, FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.StreamListener)81869%n/a013701
serializeMetadata(Schema)71669%n/a012501
getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightProducer.ServerStreamListener)70%n/a112211
getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo, 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
lambda$closePreparedStatement$2(FlightSql.ActionClosePreparedStatementRequest, FlightProducer.StreamListener)53085%n/a0131101
getSchemaStatement(FlightSql.CommandStatementQuery, FlightProducer.CallContext, FlightDescriptor)50%n/a111111
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
DorisFlightSqlProducer(Location, FlightSessionsManager)46100%n/a0101201
lambda$getStreamTables$10(FlightSql.CommandGetTables, FlightProducer.ServerStreamListener, ConnectContext)33100%2100%0201101
getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery, FlightProducer.CallContext, FlightDescriptor)31100%n/a010501
getFlightInfoForSchema(Message, FlightDescriptor, Schema)29100%n/a010301
lambda$getStreamSchemas$9(FlightSql.CommandGetDbSchemas, FlightProducer.ServerStreamListener, ConnectContext)28100%n/a0101001
getStreamStatementResult(String, FlightProducer.ServerStreamListener)26100%n/a010601
lambda$getStreamCatalogs$8(FlightProducer.ServerStreamListener, ConnectContext)25100%n/a010901
getFlightInfoTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightDescriptor)13100%2100%020401
static {...}11100%n/a010201
createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.CallContext, FlightProducer.StreamListener)10100%n/a010201
closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest, FlightProducer.CallContext, FlightProducer.StreamListener)9100%n/a010201
getStreamSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightProducer.ServerStreamListener)9100%n/a010201
getStreamTables(FlightSql.CommandGetTables, FlightProducer.CallContext, FlightProducer.ServerStreamListener)9100%n/a010201
lambda$getFlightInfoPreparedStatement$4(String, ConnectContext, String, FlightDescriptor)9100%n/a010201
lambda$getFlightInfoStatement$3(FlightProducer.CallContext, ConnectContext, FlightSql.CommandStatementQuery, FlightDescriptor)9100%n/a010101
getStreamCatalogs(FlightProducer.CallContext, FlightProducer.ServerStreamListener)8100%n/a010201
lambda$createPreparedStatement$5(FlightSql.ActionCreatePreparedStatementRequest, FlightProducer.CallContext, ConnectContext, FlightProducer.StreamListener)8100%n/a010201
getStreamStatement(FlightSql.TicketStatementQuery, FlightProducer.CallContext, FlightProducer.ServerStreamListener)7100%n/a010201
getStreamSqlInfo(FlightSql.CommandGetSqlInfo, FlightProducer.CallContext, FlightProducer.ServerStreamListener)7100%n/a010201
getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo, FlightProducer.CallContext, FlightDescriptor)6100%n/a010101
getFlightInfoCatalogs(FlightSql.CommandGetCatalogs, FlightProducer.CallContext, FlightDescriptor)6100%n/a010101
getFlightInfoSchemas(FlightSql.CommandGetDbSchemas, FlightProducer.CallContext, FlightDescriptor)6100%n/a010101
lambda$setSessionOptions$11(ConnectContext, SetSessionOptionsRequest)5100%n/a010101
lambda$streamMetadata$13(DorisFlightSqlProducer.MetadataStream, ConnectContext)4100%n/a010101
lambda$closePreparedStatement$1(ConnectContext, String)4100%n/a010101
lambda$getSessionOptions$12(ConnectContext)3100%n/a010101