public BBContainer pollSchema() {
        BBContainer schemaCont = null;
        long segmentIndex = -1;
        if (m_memoryDeque.peek() != null) {
            StreamBlock sb = m_memoryDeque.peek();
            BBContainer cont = sb.getSchemaContainer();
            if (cont != null) {
                return cont;
            }
            segmentIndex = sb.getSegmentIndex();
        }
        try {
            schemaCont = m_reader.getExtraHeader(segmentIndex);
        } catch (IOException e) {
            exportLog.error("Failed to poll schema: " + e);
        }
        return schemaCont;

    }
public BBContainer pollSchema ( ) { BBContainer schemaCont = null ; long segmentIndex = - 1 ; if ( m_memoryDeque . peek ( ) != null ) { StreamBlock sb = m_memoryDeque . peek ( ) ; BBContainer cont = sb . getSchemaContainer ( ) ; if ( cont != null ) { return cont ; } segmentIndex = sb . getSegmentIndex ( ) ; } try { schemaCont = m_reader . getExtraHeader ( segmentIndex ) ; } catch ( IOException e ) { exportLog . error ( "Failed to poll schema: " + e ) ; } return schemaCont ; }
/*
Poll stream table schema that either represents the first object in the memory dequeue, or
from the segment that the cursor is currently reading on.