public SequenceBatchCSVRecord transformSequenceIncremental(BatchCSVRecord transform) {
        /**
         * Sequence schema?
         */
        List<List<List<Writable>>> converted = executeToSequence(
                toArrowWritables(toArrowColumnsStringTimeSeries(
                        bufferAllocator, transformProcess.getInitialSchema(),
                        Arrays.asList(transform.getRecordsAsString())),
                        transformProcess.getInitialSchema()), transformProcess);

        SequenceBatchCSVRecord batchCSVRecord = new SequenceBatchCSVRecord();
        for (int i = 0; i < converted.size(); i++) {
            BatchCSVRecord batchCSVRecord1 = BatchCSVRecord.fromWritables(converted.get(i));
            batchCSVRecord.add(Arrays.asList(batchCSVRecord1));
        }

        return batchCSVRecord;
    }
public SequenceBatchCSVRecord transformSequenceIncremental ( BatchCSVRecord transform ) { List < List < List < Writable > > > converted = executeToSequence ( toArrowWritables ( toArrowColumnsStringTimeSeries ( bufferAllocator , transformProcess . getInitialSchema ( ) , Arrays . asList ( transform . getRecordsAsString ( ) ) ) , transformProcess . getInitialSchema ( ) ) , transformProcess ) ; SequenceBatchCSVRecord batchCSVRecord = new SequenceBatchCSVRecord ( ) ; for ( int i = 0 ; i < converted . size ( ) ; i ++ ) { BatchCSVRecord batchCSVRecord1 = BatchCSVRecord . fromWritables ( converted . get ( i ) ) ; batchCSVRecord . add ( Arrays . asList ( batchCSVRecord1 ) ) ; } return batchCSVRecord ; }
@param transform
@return