@Before
    public void setUp() {
        MockitoAnnotations.initMocks(this);
        customerSinkFunc = new CustomerSinkFunc(index, type, fieldNames, fieldTypes, idFieldIndexes, true);
        customerSinkFunc.setOutRecords(outRecords);
        tuple2.setField(true, 0);
        Row row = new Row(1);
        row.setField(0, 1);
        tuple2.setField(row, 1);
    }
Company: www.dtstack.com

@author zhufeng
@date 2020-06-23
elasticsearch6/elasticsearch6-sink/src/test/java/com/dtstack/flink/sql/sink/elasticsearch/CustomerSinkFuncTest.java