flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/RecordIterator.java [98:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private T buildReturnType(Record record) {
        // TODO:record may be null in cluster mode
        switch (recordType) {
            case FLINK_ROW_DATA:
                return (T) buildFlinkRowData(record, fullColumns, typeConverters);
            case FLINK_TUPLE:
                return (T) buildFlinkTuple(reuse, record, fullColumns, typeConverters);
            case FLINK_ROW:
                return (T) buildFlinkRow(reuse, record, fullColumns, typeConverters);
            default:
                return (T) buildFlinkPojo(reuse, record, fullColumns);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-odps/src/main/java/org/apache/flink/odps/input/reader/CupidBatchIterator.java [102:114]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private T buildReturnType(Record record) {
        // TODO: record may be null
        switch (recordType) {
            case FLINK_ROW_DATA:
                return (T) buildFlinkRowData(record, fullColumns, typeConverters);
            case FLINK_TUPLE:
                return (T) buildFlinkTuple(reuse, record, fullColumns, typeConverters);
            case FLINK_ROW:
                return (T) buildFlinkRow(reuse, record, fullColumns, typeConverters);
            default:
                return (T) buildFlinkPojo(reuse, record, fullColumns);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -