Method Test_InsertAlignedTablets

test/e2e/e2e_test.go:386–412

()

}

func (s *e2eTestSuite) Test_InsertAlignedTablets() {
	var timeseries = []string{"root.ln.device1.**"}
	s.session.DeleteTimeseries(timeseries)
	tablet1, err := createTablet(8)
	if err != nil {
		log.Fatal(err)
	}
	tablet2, err := createTablet(4)
	if err != nil {
		log.Fatal(err)
	}

	tablets := []*client.Tablet{tablet1, tablet2}
	s.checkError(s.session.InsertAlignedTablets(tablets, false))
	tablet1.Reset()
	tablet2.Reset()

	ds, err := s.session.ExecuteQueryStatement("select count(status) from root.ln.device1", nil)
	assert := s.Require()
	assert.NoError(err)
	defer ds.Close()
	assert.True(ds.Next())
	status, err := ds.GetStringByIndex(1)
	assert.NoError(err)
	assert.Equal(status, "8")
	s.session.DeleteStorageGroup("root.ln.**")
}

func (s *e2eTestSuite) Test_FetchMoreData() {
	var timeseries = []string{"root.ln.device1.**"}