MCPcopy Create free account
hub / github.com/apache/iotdb-client-go / InsertTablet

Method InsertTablet

client/session.go:1223–1247  ·  view source on GitHub ↗
(tablet *Tablet, sorted bool)

Source from the content-addressed store, hash-verified

1221}
1222
1223func (s *Session) InsertTablet(tablet *Tablet, sorted bool) error {
1224 if !sorted {
1225 if err := tablet.Sort(); err != nil {
1226 return err
1227 }
1228 }
1229 request, err := s.genTSInsertTabletReq(tablet, false, false)
1230 if err != nil {
1231 return err
1232 }
1233
1234 r, err := s.client.InsertTablet(context.Background(), request)
1235
1236 if err != nil && r == nil {
1237 if s.reconnect() {
1238 request.SessionId = s.sessionId
1239 r, err = s.client.InsertTablet(context.Background(), request)
1240 }
1241 }
1242
1243 if err != nil {
1244 return err
1245 }
1246 return VerifySuccess(r)
1247}
1248
1249func (s *Session) InsertAlignedTablet(tablet *Tablet, sorted bool) error {
1250 if !sorted {

Callers

nothing calls this directly

Calls 5

genTSInsertTabletReqMethod · 0.95
reconnectMethod · 0.95
VerifySuccessFunction · 0.85
SortMethod · 0.80
InsertTabletMethod · 0.65

Tested by

no test coverage detected