Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions parquet-column/src/main/java/org/apache/parquet/column/page/DataPageV1.java
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -41,10 +41,10 @@ public class DataPageV1 extends DataPage {
* @param valuesEncoding the values encoding for this page
* @param dlEncoding
*/
public DataPageV1(BytesInput bytes, int valueCount, int uncompressedSize, Statistics<?> stats, Encoding rlEncoding, Encoding dlEncoding, Encoding valuesEncoding) {
public DataPageV1(BytesInput bytes, int valueCount, int uncompressedSize, Statistics<?> statistics, Encoding rlEncoding, Encoding dlEncoding, Encoding valuesEncoding) {
super(Ints.checkedCast(bytes.size()), uncompressedSize, valueCount);
this.bytes = bytes;
this.statistics = stats;
this.statistics = statistics;
this.rlEncoding = rlEncoding;
this.dlEncoding = dlEncoding;
this.valuesEncoding = valuesEncoding;
Expand Down
14 changes: 7 additions & 7 deletions parquet-column/src/main/java/org/apache/parquet/column/values/ValuesWriter.java
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ public void resetDictionary() {
}

/**
* ( > {@link #getBufferedMemorySize} )
* ( > {@link #getBufferedSize} )
* @return the allocated size of the buffer
*/
abstract public long getAllocatedSize();
Expand All @@ -93,42 +93,42 @@ public void writeByte(int value) {
}

/**
* @param value the value to encode
* @param v the value to encode
*/
public void writeBoolean(boolean v) {
throw new UnsupportedOperationException(getClass().getName());
}

/**
* @param value the value to encode
* @param v the value to encode
*/
public void writeBytes(Binary v) {
throw new UnsupportedOperationException(getClass().getName());
}

/**
* @param value the value to encode
* @param v the value to encode
*/
public void writeInteger(int v) {
throw new UnsupportedOperationException(getClass().getName());
}

/**
* @param value the value to encode
* @param v the value to encode
*/
public void writeLong(long v) {
throw new UnsupportedOperationException(getClass().getName());
}

/**
* @param value the value to encode
* @param v the value to encode
*/
public void writeDouble(double v) {
throw new UnsupportedOperationException(getClass().getName());
}

/**
* @param value the value to encode
* @param v the value to encode
*/
public void writeFloat(float v) {
throw new UnsupportedOperationException(getClass().getName());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public boolean readBoolean() {

/**
* {@inheritDoc}
* @see org.apache.parquet.column.values.ValuesReader#skipBoolean()
* @see org.apache.parquet.column.values.ValuesReader#skip()
*/
@Override
public void skip() {
Expand All @@ -60,7 +60,7 @@ public void skip() {

/**
* {@inheritDoc}
* @see org.apache.parquet.column.values.ValuesReader#initFromPage(byte[], int)
* @see org.apache.parquet.column.values.ValuesReader#initFromPage(int valueCount, ByteBuffer page, int offset)
*/
@Override
public void initFromPage(int valueCount, ByteBuffer in, int offset) throws IOException {
Expand Down
2 changes: 1 addition & 1 deletion parquet-column/src/main/java/org/apache/parquet/schema/TypeConverter.java
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@

/**
* to convert a MessageType tree
* @see Type#convert(TypeConverter)
* @see Type#convert(List, TypeConverter)
*
* @author Julien Le Dem
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ public static BitPackingWriter getBitPackingWriter(int bitLength, OutputStream o
/**
*
* @param bitLength the width in bits of the integers to read
* @param inthe stream to read the bytes from
* @param in the stream to read the bytes from
* @return the correct implementation for the width
*/
public static BitPackingReader createBitPackingReader(int bitLength, InputStream in, long valueCount) {
Expand Down
6 changes: 3 additions & 3 deletions parquet-hadoop/src/main/java/org/apache/parquet/hadoop/example/ExampleOutputFormat.java
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
* An example output format
*
* must be provided the schema up front
* @see ExampleOutputFormat#setSchema(Configuration, MessageType)
* @see ExampleOutputFormat#setSchema(Job, MessageType)
* @see GroupWriteSupport#PARQUET_EXAMPLE_SCHEMA
*
* @author Julien Le Dem
Expand All @@ -40,16 +40,16 @@ public class ExampleOutputFormat extends ParquetOutputFormat<Group> {

/**
* set the schema being written to the job conf
* @param job
* @param schema the schema of the data
* @param configuration the job configuration
*/
public static void setSchema(Job job, MessageType schema) {
GroupWriteSupport.setSchema(schema, ContextUtil.getConfiguration(job));
}

/**
* retrieve the schema from the conf
* @param configuration the job conf
* @param job
* @return the schema
*/
public static MessageType getSchema(Job job) {
Expand Down
1 change: 0 additions & 1 deletion parquet-hadoop/src/main/java/org/apache/parquet/hadoop/metadata/ParquetMetadata.java
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,6 @@ public static ParquetMetadata fromJSON(String json) {
*
* @param fileMetaData file level metadata
* @param blocks block level metadata
* @param keyValueMetaData
*/
public ParquetMetadata(FileMetaData fileMetaData, List<BlockMetaData> blocks) {
this.fileMetaData = fileMetaData;
Expand Down