Return-Path: X-Original-To: apmail-tajo-commits-archive@minotaur.apache.org Delivered-To: apmail-tajo-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 26EF3D1F6 for ; Mon, 20 May 2013 05:34:05 +0000 (UTC) Received: (qmail 51146 invoked by uid 500); 20 May 2013 05:34:06 -0000 Delivered-To: apmail-tajo-commits-archive@tajo.apache.org Received: (qmail 51079 invoked by uid 500); 20 May 2013 05:34:04 -0000 Mailing-List: contact commits-help@tajo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@tajo.apache.org Delivered-To: mailing list commits@tajo.apache.org Received: (qmail 51023 invoked by uid 99); 20 May 2013 05:34:02 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 May 2013 05:34:02 +0000 X-ASF-Spam-Status: No, hits=-2001.1 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 20 May 2013 05:33:59 +0000 Received: (qmail 50485 invoked by uid 99); 20 May 2013 05:33:37 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 May 2013 05:33:37 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 63209319EDB; Mon, 20 May 2013 05:33:37 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: hsaputra@apache.org To: commits@tajo.incubator.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: git commit: TAJO-41 Storage handler name row in storage-default.xml must be rowfile. Date: Mon, 20 May 2013 05:33:37 +0000 (UTC) X-Virus-Checked: Checked by ClamAV on apache.org Updated Branches: refs/heads/master adb6b3e17 -> c9a0bafa0 TAJO-41 Storage handler name row in storage-default.xml must be rowfile. Project: http://git-wip-us.apache.org/repos/asf/incubator-tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-tajo/commit/c9a0bafa Tree: http://git-wip-us.apache.org/repos/asf/incubator-tajo/tree/c9a0bafa Diff: http://git-wip-us.apache.org/repos/asf/incubator-tajo/diff/c9a0bafa Branch: refs/heads/master Commit: c9a0bafa0f34aa5583ad974559faf2a54caa4752 Parents: adb6b3e Author: Henry Saputra Authored: Sun May 19 22:23:39 2013 -0700 Committer: Henry Saputra Committed: Sun May 19 22:29:38 2013 -0700 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../src/test/java/tajo/storage/TestRowFile.java | 4 ++-- .../src/main/resources/storage-default.xml | 4 ++-- .../src/test/resources/storage-default.xml | 4 ++-- 4 files changed, 8 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/c9a0bafa/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 2599759..9a81c02 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -45,6 +45,8 @@ Release 0.2.0 - unreleased TAJO-54: SubQuery::allocateContainers() may ask 0 containers. (hyunsik) + TAJO-41: Storage handler name row in storage-default.xml must be rowfile. (hsaputra) + TAJO-47: RowFile has the duplicated initialization problem and unflipped ByteBuffer problem. (jihoon) http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/c9a0bafa/tajo-core/tajo-core-backend/src/test/java/tajo/storage/TestRowFile.java ---------------------------------------------------------------------- diff --git a/tajo-core/tajo-core-backend/src/test/java/tajo/storage/TestRowFile.java b/tajo-core/tajo-core-backend/src/test/java/tajo/storage/TestRowFile.java index b7b5b0a..d9275f4 100644 --- a/tajo-core/tajo-core-backend/src/test/java/tajo/storage/TestRowFile.java +++ b/tajo-core/tajo-core-backend/src/test/java/tajo/storage/TestRowFile.java @@ -81,7 +81,7 @@ public class TestRowFile { FileUtil.writeProto(util.getDefaultFileSystem(), metaPath, meta.getProto()); - Appender appender = new RowFile.RowFileAppender(conf, meta, dataPath); + Appender appender = StorageManager.getAppender(conf, meta, dataPath); appender.enableStats(); appender.init(); @@ -117,7 +117,7 @@ public class TestRowFile { int tupleCnt = 0; start = System.currentTimeMillis(); - Scanner scanner = new RowFile.RowFileScanner(conf, meta, fragment); + Scanner scanner = StorageManager.getScanner(conf, meta, fragment); scanner.init(); while ((tuple=scanner.next()) != null) { tupleCnt++; http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/c9a0bafa/tajo-core/tajo-core-storage/src/main/resources/storage-default.xml ---------------------------------------------------------------------- diff --git a/tajo-core/tajo-core-storage/src/main/resources/storage-default.xml b/tajo-core/tajo-core-storage/src/main/resources/storage-default.xml index 8f78e3e..afdc604 100644 --- a/tajo-core/tajo-core-storage/src/main/resources/storage-default.xml +++ b/tajo-core/tajo-core-storage/src/main/resources/storage-default.xml @@ -42,7 +42,7 @@ - tajo.storage.scanner-handler.row.class + tajo.storage.scanner-handler.rowfile.class tajo.storage.RowFile$RowFileScanner @@ -73,7 +73,7 @@ - tajo.storage.appender-handler.row.class + tajo.storage.appender-handler.rowfile.class tajo.storage.RowFile$RowFileAppender http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/c9a0bafa/tajo-core/tajo-core-storage/src/test/resources/storage-default.xml ---------------------------------------------------------------------- diff --git a/tajo-core/tajo-core-storage/src/test/resources/storage-default.xml b/tajo-core/tajo-core-storage/src/test/resources/storage-default.xml index 8f78e3e..afdc604 100644 --- a/tajo-core/tajo-core-storage/src/test/resources/storage-default.xml +++ b/tajo-core/tajo-core-storage/src/test/resources/storage-default.xml @@ -42,7 +42,7 @@ - tajo.storage.scanner-handler.row.class + tajo.storage.scanner-handler.rowfile.class tajo.storage.RowFile$RowFileScanner @@ -73,7 +73,7 @@ - tajo.storage.appender-handler.row.class + tajo.storage.appender-handler.rowfile.class tajo.storage.RowFile$RowFileAppender