parquet-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jul...@apache.org
Subject git commit: PARQUET-106: Relax InputSplit Protections
Date Wed, 29 Oct 2014 18:10:29 GMT
Repository: incubator-parquet-mr
Updated Branches:
  refs/heads/master 31fb4dfef -> ccfca8f71


PARQUET-106: Relax InputSplit Protections

https://issues.apache.org/jira/browse/PARQUET-106

Author: Daniel Weeks <dweeks@netflix.com>

Closes #67 from dcw-netflix/input-split2 and squashes the following commits:

2f2c0c7 [Daniel Weeks] Update ParquetInputSplit.java
12bd3c1 [Daniel Weeks] Update ParquetInputSplit.java
6c662ee [Daniel Weeks] Update ParquetInputSplit.java
5f9f02e [Daniel Weeks] Update ParquetInputSplit.java
d19e1ac [Daniel Weeks] Merge branch 'master' into input-split2
c4172bb [Daniel Weeks] Merge remote-tracking branch 'upstream/master'
01a5e8f [Daniel Weeks] Relaxed protections on input split class
d37a6de [Daniel Weeks] Resetting pom to main
0c1572e [Daniel Weeks] Merge remote-tracking branch 'upstream/master'
98c6607 [Daniel Weeks] Merge remote-tracking branch 'upstream/master'
96ba602 [Daniel Weeks] Disabled projects that don't compile


Project: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/commit/ccfca8f7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/tree/ccfca8f7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/diff/ccfca8f7

Branch: refs/heads/master
Commit: ccfca8f714055cd9fbd00cf7e847b880132cae69
Parents: 31fb4df
Author: Daniel Weeks <dweeks@netflix.com>
Authored: Wed Oct 29 11:10:16 2014 -0700
Committer: julien <julien@twitter.com>
Committed: Wed Oct 29 11:10:16 2014 -0700

----------------------------------------------------------------------
 .../src/main/java/parquet/hadoop/ParquetInputSplit.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-parquet-mr/blob/ccfca8f7/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputSplit.java
----------------------------------------------------------------------
diff --git a/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputSplit.java b/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputSplit.java
index 399be64..133d5be 100644
--- a/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputSplit.java
+++ b/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputSplit.java
@@ -132,28 +132,28 @@ public class ParquetInputSplit extends FileSplit implements Writable
{
   /**
    * @return the requested schema
    */
-  String getRequestedSchema() {
+  public String getRequestedSchema() {
     return requestedSchema;
   }
 
   /**
    * @return the end offset of that split
    */
-  long getEnd() {
+  public long getEnd() {
     return end;
   }
 
   /**
    * @return app specific metadata provided by the read support in the init phase
    */
-  Map<String, String> getReadSupportMetadata() {
+  public Map<String, String> getReadSupportMetadata() {
     return readSupportMetadata;
   }
 
   /**
    * @return the offsets of the row group selected if this has been determined on the client
side
    */
-  long[] getRowGroupOffsets() {
+  public long[] getRowGroupOffsets() {
     return rowGroupOffsets;
   }
 
@@ -183,7 +183,7 @@ public class ParquetInputSplit extends FileSplit implements Writable {
    * {@inheritDoc}
    */
   @Override
-  final public void readFields(DataInput hin) throws IOException {
+  public void readFields(DataInput hin) throws IOException {
     byte[] bytes = readArray(hin);
     DataInputStream in = new DataInputStream(new GZIPInputStream(new ByteArrayInputStream(bytes)));
     super.readFields(in);
@@ -203,7 +203,7 @@ public class ParquetInputSplit extends FileSplit implements Writable {
    * {@inheritDoc}
    */
   @Override
-  final public void write(DataOutput hout) throws IOException {
+  public void write(DataOutput hout) throws IOException {
     ByteArrayOutputStream baos = new ByteArrayOutputStream();
     DataOutputStream out = new DataOutputStream(new GZIPOutputStream(baos));
     super.write(out);


Mime
View raw message