com.nhncorp.neptune.client
Class DirectUploader

java.lang.Object
  com.nhncorp.neptune.client.DirectUploader

public class DirectUploader
extends java.lang.Object

트렌젝션 처리를 이용하면 change log에 작업된 모든 내역이 기록되기 때문에 용량이 큰 데이터를 업로드하는 경우에는 비효율적이다. DirectUploader는 용량이 큰 데이터를 업로드 하는 경우 사용한다. DirectUploader를 사용할 때에는 가능한 Scanner의 open, Split, Compaction 작업이 수행되지 않는 시간을 선택한다. 이 작업들이 수행중인 경우에는 DirectUploader는 Open되지 않고, DirectUploader가 수행중인 경우에는 이런 작업들 역시 수행되지 않는다.

Author:

김형준

Method Summary

void	close() 데이터 전송이 완료되면 반드시 close 처리를 해야 한다.
static void	main(java.lang.String[] args)
void	put(Row row) 테이블로 데이터를 upload한다.
void	rollback() open 된 이후 uploadData() 호출에 의해 전송된 모든 데이터를 삭제한다.

Methods inherited from class java.lang.Object

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

Method Detail

put

public void put(Row row)
         throws java.io.IOException

테이블로 데이터를 upload한다. put 호출에 의해 전달된 데이터는 바로 table로 저장되지 않고 로컬의 임시 데이터 파일로 저장된 다음 close()의 호출에 의해 테이블에 로딩된다.

Parameters:

rowKey -

columnValues -

Throws:

java.io.IOException

rollback

public void rollback()
              throws java.io.IOException

open 된 이후 uploadData() 호출에 의해 전송된 모든 데이터를 삭제한다.

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

데이터 전송이 완료되면 반드시 close 처리를 해야 한다. close 처리를 하지 않는 경우 데이터 누락이 발생할 수 있다.

Throws:

java.io.IOException

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException

Throws:

java.io.IOException