com.nhncorp.neptune.client.scanner
Class ScannerFactory

java.lang.Object
  com.nhncorp.neptune.client.scanner.ScannerFactory

public class ScannerFactory
extends java.lang.Object

TableScanner를 오픈하는데 사용하는 클래스 Tablet에 TableScanner가 오픈되어 있으면 Split Action은 수행되지 않는다.

Author:

nhn

Constructor Summary

ScannerFactory()

Method Summary

static TableScanner	openScanner(NConfiguration conf, TabletInfo tabletInfo, RowFilter rowFilter) 특정 Tablet을 Scan하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NConfiguration conf, TabletInfo tabletInfo, java.lang.String columnName) 특정 Tablet을 Scan하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NConfiguration conf, TabletInfo tabletInfo, java.lang.String[] columnNames) 특정 Tablet을 Scan하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, Row.Key startRowKey, Row.Key endRowKey, java.lang.String columnName) 주어진 범위내에서 테이블을 Scan하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, Row.Key startRowKey, Row.Key endRowKey, java.lang.String[] columns) 여러 컬럼, Row의 범위를 지정할 수 있는 TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, Row.Key startRowKey, Row.Key endRowKey, java.lang.String columnName, int timeout) 주어진 범위내에서 테이블을 Scan하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, RowFilter rowFilter) 다양한 조건(RowFilter)를 이용하여 Scan를 수행하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, RowFilter rowFilter, int timeout) 다양한 조건(RowFilter)를 이용하여 Scan를 수행하는 TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, java.lang.String columnName) TableScanner를 오픈한다.
static TableScanner	openScanner(NTable ntable, java.lang.String[] columns) 여러개의 컬럼을 동시에 Scan 하는 TableScanner를 오픈한다.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScannerFactory

public ScannerFactory()

Method Detail

openScanner

public static TableScanner openScanner(NTable ntable,
                                       java.lang.String columnName)
                                throws java.io.IOException

TableScanner를 오픈한다. Scan 범위는 전체 테이블을 대상으로 한다.

Parameters:

ntable -

columnName -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NTable ntable,
                                       java.lang.String[] columns)
                                throws java.io.IOException

여러개의 컬럼을 동시에 Scan 하는 TableScanner를 오픈한다. Scan 범위는 전체 테이블을 대상으로 한다.

Parameters:

ntable -

columns -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NTable ntable,
                                       Row.Key startRowKey,
                                       Row.Key endRowKey,
                                       java.lang.String columnName)
                                throws java.io.IOException

주어진 범위내에서 테이블을 Scan하는 TableScanner를 오픈한다. 처음부터 Scanner의 위치를 이동하면서 startRowKey로 이동하는 것이 아니라 한번에 startRowKey로 이동한 다음 scan을 시작한다.

Parameters:

ntable -

startRowKey -

endRowKey -

columnName -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NTable ntable,
                                       Row.Key startRowKey,
                                       Row.Key endRowKey,
                                       java.lang.String columnName,
                                       int timeout)
                                throws java.io.IOException

주어진 범위내에서 테이블을 Scan하는 TableScanner를 오픈한다. 처음부터 Scanner의 위치를 이동하면서 startRowKey로 이동하는 것이 아니라 한번에 startRowKey로 이동한 다음 scan을 시작한다.

Parameters:

ntable -

startRowKey -

endRowKey -

columnName -

timeout -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NTable ntable,
                                       Row.Key startRowKey,
                                       Row.Key endRowKey,
                                       java.lang.String[] columns)
                                throws java.io.IOException

여러 컬럼, Row의 범위를 지정할 수 있는 TableScanner를 오픈한다.

Parameters:

ntable -

startRowKey -

endRowKey -

columns -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NTable ntable,
                                       RowFilter rowFilter)
                                throws java.io.IOException

다양한 조건(RowFilter)를 이용하여 Scan를 수행하는 TableScanner를 오픈한다. 동일한 Cell.Key에 버전이 여러개 있는 경우 모든 버전을 scan할 경우 rowFilter의 cellFilter에 옵션 값을 지정하여 Scan 조건을 설정한다.

Parameters:

ntable -

rowFilter -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NTable ntable,
                                       RowFilter rowFilter,
                                       int timeout)
                                throws java.io.IOException

다양한 조건(RowFilter)를 이용하여 Scan를 수행하는 TableScanner를 오픈한다. 동일한 Cell.Key에 버전이 여러개 있는 경우 모든 버전을 scan할 경우 rowFilter의 cellFilter에 옵션 값을 지정하여 Scan 조건을 설정한다.

Parameters:

ntable -

rowFilter -

timeout -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NConfiguration conf,
                                       TabletInfo tabletInfo,
                                       java.lang.String[] columnNames)
                                throws java.io.IOException

특정 Tablet을 Scan하는 TableScanner를 오픈한다. Scan 도중에는 Tablet은 split 되지 않는다.

Parameters:

conf -

tabletInfo -

columnNames -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NConfiguration conf,
                                       TabletInfo tabletInfo,
                                       java.lang.String columnName)
                                throws java.io.IOException

특정 Tablet을 Scan하는 TableScanner를 오픈한다. Scan 도중에는 Tablet은 split 되지 않는다.

Parameters:

conf -

tabletInfo -

columnName -

Returns:

Throws:

java.io.IOException

openScanner

public static TableScanner openScanner(NConfiguration conf,
                                       TabletInfo tabletInfo,
                                       RowFilter rowFilter)
                                throws java.io.IOException

특정 Tablet을 Scan하는 TableScanner를 오픈한다. Scan 도중에는 Tablet은 split 되지 않는다.

Parameters:

conf -

tabletInfo -

rowFilter -

Returns:

Throws:

java.io.IOException