You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@parquet.apache.org by ju...@apache.org on 2014/10/29 19:10:29 UTC
git commit: PARQUET-106: Relax InputSplit Protections
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 <dw...@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 <dw...@netflix.com>
Authored: Wed Oct 29 11:10:16 2014 -0700
Committer: julien <ju...@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);