krati.core.segment
Class SegmentManager

java.lang.Object
  extended by krati.core.segment.SegmentManager

public final class SegmentManager
extends Object

SegmentManager

    SegmentManager manager = new SegmentManager(...);
    Segment segment = manager.nextSegment();
    
    while(...)
    {
        try
        {
            segment.append(...);
        }
        catch(SegmentOverflowException e)
        {
           segment.force();
           manager.updateMeta();
           segment = manger.nextSegment();
        }
    }
    
 

Author:
jwu

Method Summary
 void clear()
           
 boolean freeSegment(Segment seg)
          Frees a segment.
 Segment getCurrentSegment()
           
static SegmentManager getInstance(String segmentHomePath, SegmentFactory segmentFactory, int segmentFileSizeMB)
           
 int getLiveSegmentCount()
           
 SegmentMeta getMeta()
           
 Segment getSegment(int index)
           
 int getSegmentCount()
           
 SegmentFactory getSegmentFactory()
           
 int getSegmentFileSizeMB()
           
 String getSegmentHomePath()
           
protected  void init()
           
protected  File[] listSegmentFiles()
           
 Segment nextSegment()
          Gets the next segment available for read and write.
 void updateMeta()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getSegmentFileSizeMB

public int getSegmentFileSizeMB()

getSegmentHomePath

public String getSegmentHomePath()

getSegmentFactory

public SegmentFactory getSegmentFactory()

getCurrentSegment

public Segment getCurrentSegment()

getSegment

public Segment getSegment(int index)

getSegmentCount

public int getSegmentCount()

getLiveSegmentCount

public int getLiveSegmentCount()

clear

public void clear()

freeSegment

public boolean freeSegment(Segment seg)
                    throws IOException
Frees a segment.

Throws:
IOException

nextSegment

public Segment nextSegment()
                    throws IOException
Gets the next segment available for read and write.

Throws:
IOException

init

protected void init()
             throws IOException
Throws:
IOException

listSegmentFiles

protected File[] listSegmentFiles()

getMeta

public SegmentMeta getMeta()

updateMeta

public void updateMeta()
                throws IOException
Throws:
IOException

getInstance

public static SegmentManager getInstance(String segmentHomePath,
                                         SegmentFactory segmentFactory,
                                         int segmentFileSizeMB)
                                  throws IOException
Throws:
IOException


Copyright © 2011. All Rights Reserved.